draft docker compose create database job

OpenTOSCA · Sep 3, 2024 · 364e3c3 · 364e3c3
1 parent a59037b
commit 364e3c3
Showing 1 changed file with 89 additions and 2 deletions.
diff --git a/...rules/generators/mysql-database/compose/mysql-dbms/docker-engine/virtual-machine/index.ts b/...rules/generators/mysql-database/compose/mysql-dbms/docker-engine/virtual-machine/index.ts
@@ -1,7 +1,16 @@
 import {ImplementationGenerator} from '#technologies/plugins/rules/types'
-import {MetadataGenerated, MetadataUnfurl, OpenstackMachineCredentials} from '#technologies/plugins/rules/utils'
+import {
+    AnsibleHostOperation,
+    AnsibleHostOperationPlaybookArgs,
+    AnsibleWaitForSSHTask,
+    MetadataGenerated,
+    MetadataUnfurl,
+    OpenstackMachineCredentials,
+} from '#technologies/plugins/rules/utils'
 
-// TODO: next: implement this
+// TODO: next: test this
+
+// TODO: we assume that dbms is exposed
 
 const generator: ImplementationGenerator = {
     component: 'mysql.database',
@@ -20,6 +29,84 @@ const generator: ImplementationGenerator = {
             properties: {
                 ...OpenstackMachineCredentials(),
             },
+            interfaces: {
+                Standard: {
+                    operations: {
+                        create: {
+                            implementation: {
+                                ...AnsibleHostOperation(),
+                            },
+                            inputs: {
+                                playbook: {
+                                    q: [
+                                        {
+                                            ...AnsibleWaitForSSHTask(),
+                                        },
+                                        {
+                                            name: 'touch compose',
+                                            register: 'compose',
+                                            'ansible.builtin.tempfile': {
+                                                suffix: '{{ SELF.database_name }}-{{ HOST.dbms_name }}.database.compose.yaml',
+                                            },
+                                        },
+                                        {
+                                            name: 'create compose',
+                                            'ansible.builtin.copy': {
+                                                dest: '{{ compose.path }}',
+                                                content: '{{ manifest | to_yaml }}',
+                                            },
+                                            vars: {
+                                                manifest: {
+                                                    name: '{{ SELF.dbms_name }}',
+                                                    services: {
+                                                        job: {
+                                                            container_name:
+                                                                '{{ SELF.database_name }}-{{ HOST.dbms_name }}-database-job',
+                                                            image: 'mysql:{{ HOST.dbms_version }}',
+                                                            network_mode: 'host',
+                                                            command: [
+                                                                'mysql',
+                                                                '--host={{ HOST.management_address }}',
+                                                                '--port={{ HOST.management_port }}',
+                                                                '--user=root',
+                                                                '--password={{ HOST.dbms_password }}',
+                                                                '-e',
+                                                                "CREATE DATABASE IF NOT EXISTS {{ SELF.database_name }}; CREATE USER IF NOT EXISTS '{{ SELF.database_user }}'@'%' IDENTIFIED BY '{{ SELF.database_password }}'; GRANT ALL PRIVILEGES ON *.* TO '{{ SELF.database_user }}'@'%';",
+                                                            ],
+                                                        },
+                                                    },
+                                                },
+                                            },
+                                        },
+                                        {
+                                            name: 'apply compose',
+                                            'ansible.builtin.shell': 'docker compose -f {{ compose.path }} up -d',
+                                            args: {
+                                                executable: '/usr/bin/bash',
+                                            },
+                                        },
+                                        {
+                                            name: 'give job some time',
+                                            'ansible.builtin.pause': {
+                                                seconds: 10,
+                                            },
+                                        },
+                                        {
+                                            name: 'unapply compose',
+                                            'ansible.builtin.shell': 'docker compose -f {{ compose.path }} down',
+                                            args: {
+                                                executable: '/usr/bin/bash',
+                                            },
+                                        },
+                                    ],
+                                },
+                                playbookArgs: [...AnsibleHostOperationPlaybookArgs()],
+                            },
+                        },
+                        delete: 'exit 0',
+                    },
+                },
+            },
         }
     },
 }