feat: add action "Create async replication" (#959)

Author: Raubzeug

src/containers/Tenant/i18n/en.json

@@ -29,12 +29,15 @@
   "actions.createExternalTable": "Create external table...",
   "actions.createTopic": "Create topic...",
   "actions.createColumnTable": "Create column table...",
+  "actions.createAsyncReplication": "Create async replication...",
   "actions.createView": "Create view...",
   "actions.dropTable": "Drop table...",
   "actions.dropTopic": "Drop topic...",
   "actions.dropView": "Drop view...",
   "actions.alterTable": "Alter table...",
   "actions.alterTopic": "Alter topic...",
   "actions.selectQuery": "Select query...",
-  "actions.upsertQuery": "Upsert query..."
+  "actions.upsertQuery": "Upsert query...",
+  "actions.alterReplication": "Alter async replicaton...",
+  "actions.dropReplication": "Drop async replicaton..."
 }

src/containers/Tenant/utils/queryTemplates.ts

@@ -42,6 +42,20 @@ CREATE TABLE \`${path}/ydb_column_table\` (
 PARTITION BY HASH(id)
 WITH (STORE = COLUMN)`;
 };
+export const createAsyncReplicationTemplate = () => {
+    return `CREATE OBJECT secret_name (TYPE SECRET) WITH value="secret_value";
+
+CREATE ASYNC REPLICATION my_replication
+FOR \`/remote_database/table_name\` AS "local_table_name" --[, \`/remote_database/another_table_name\` AS "another_local_table_name" ...]
+WITH (
+    CONNECTION_STRING=\`grpcs://mydb.ydb.tech:2135/?database=/remote_database\`,
+    TOKEN_SECRET_NAME = "secret_name",
+    -- ENDPOINT="mydb.ydb.tech:2135",
+    -- DATABASE=\`/remote_database\`,
+    -- USER="user",
+    -- PASSWORD_SECRET_NAME="your_password"
+);`;
+};
 export const alterTableTemplate = (path: string) => {
     return `ALTER TABLE \`${path}\`
     ADD COLUMN is_deleted Bool;`;
@@ -131,3 +145,10 @@ export const createViewTemplate = (path: string) => {
 export const dropViewTemplate = (path: string) => {
     return `DROP VIEW \`${path}\`;`;
 };
+export const dropAsyncReplicationTemplate = (path: string) => {
+    return `DROP ASYNC REPLICATION \`${path}\`;`;
+};
+
+export const alterAsyncReplicationTemplate = (path: string) => {
+    return `ALTER ASYNC REPLICATION \`${path}\` SET (STATE = "DONE", FAILOVER_MODE = "FORCE");`;
+};

src/containers/Tenant/utils/schemaActions.ts

@@ -9,13 +9,16 @@ import createToast from '../../../utils/createToast';
 import i18n from '../i18n';
 
 import {
+    alterAsyncReplicationTemplate,
     alterTableTemplate,
     alterTopicTemplate,
+    createAsyncReplicationTemplate,
     createColumnTableTemplate,
     createExternalTableTemplate,
     createTableTemplate,
     createTopicTemplate,
     createViewTemplate,
+    dropAsyncReplicationTemplate,
     dropExternalTableTemplate,
     dropTopicTemplate,
     dropViewTemplate,
@@ -49,6 +52,9 @@ const bindActions = (
     return {
         createTable: inputQuery(createTableTemplate, 'script'),
         createColumnTable: inputQuery(createColumnTableTemplate, 'script'),
+        createAsyncReplication: inputQuery(createAsyncReplicationTemplate, 'script'),
+        alterAsyncReplication: inputQuery(alterAsyncReplicationTemplate, 'script'),
+        dropAsyncReplication: inputQuery(dropAsyncReplicationTemplate, 'script'),
         alterTable: inputQuery(alterTableTemplate, 'script'),
         selectQuery: inputQuery(selectQueryTemplate),
         upsertQuery: inputQuery(upsertQueryTemplate),
@@ -92,6 +98,10 @@ export const getActions =
             [
                 {text: i18n('actions.createTable'), action: actions.createTable},
                 {text: i18n('actions.createColumnTable'), action: actions.createColumnTable},
+                {
+                    text: i18n('actions.createAsyncReplication'),
+                    action: actions.createAsyncReplication,
+                },
                 {text: i18n('actions.createTopic'), action: actions.createTopic},
                 {text: i18n('actions.createView'), action: actions.createView},
             ],
@@ -135,12 +145,20 @@ export const getActions =
             [{text: i18n('actions.dropView'), action: actions.dropView}],
         ];
 
+        const ASYNC_REPLICATION_SET: ActionsSet = [
+            [copyItem],
+            [
+                {text: i18n('actions.alterReplication'), action: actions.alterAsyncReplication},
+                {text: i18n('actions.dropReplication'), action: actions.dropAsyncReplication},
+            ],
+        ];
+
         const JUST_COPY: ActionsSet = [copyItem];
 
         // verbose mapping to guarantee a correct actions set for new node types
         // TS will error when a new type is added in the lib but is not mapped here
         const nodeTypeToActions: Record<NavigationTreeNodeType, ActionsSet> = {
-            async_replication: JUST_COPY,
+            async_replication: ASYNC_REPLICATION_SET,
 
             database: DIR_SET,
             directory: DIR_SET,