feat: support transfer

package.json

@@ -58,7 +58,7 @@
     "use-query-params": "^2.2.1",
     "uuid": "^10.0.0",
     "web-vitals": "^1.1.2",
-    "ydb-ui-components": "^4.5.0",
+    "ydb-ui-components": "^4.6.0",
     "zod": "^3.24.1"
   },
   "scripts": {

src/containers/Tenant/Diagnostics/DiagnosticsPages.ts

@@ -82,6 +82,8 @@ const operations = {
 
 const ASYNC_REPLICATION_PAGES = [overview, tablets, describe];
 
+const TRANSFER_PAGES = [overview, tablets, describe];
+
 const DATABASE_PAGES = [
     overview,
     topQueries,
@@ -133,6 +135,7 @@ const pathTypeToPages: Record<EPathType, Page[] | undefined> = {
     [EPathType.EPathTypeView]: VIEW_PAGES,
 
     [EPathType.EPathTypeReplication]: ASYNC_REPLICATION_PAGES,
+    [EPathType.EPathTypeTransfer]: TRANSFER_PAGES,
     [EPathType.EPathTypeResourcePool]: DIR_PAGES,
 };
 

src/containers/Tenant/Diagnostics/Overview/Overview.tsx

@@ -20,6 +20,7 @@ import {AsyncReplicationInfo} from './AsyncReplicationInfo';
 import {ChangefeedInfo} from './ChangefeedInfo';
 import {TableInfo} from './TableInfo';
 import {TopicInfo} from './TopicInfo';
+import {TransferInfo} from './TransferInfo';
 
 interface OverviewProps {
     type?: EPathType;
@@ -94,6 +95,7 @@ function Overview({type, path, database}: OverviewProps) {
             [EPathType.EPathTypeExternalDataSource]: () => <ExternalDataSourceInfo data={data} />,
             [EPathType.EPathTypeView]: () => <ViewInfo data={data} />,
             [EPathType.EPathTypeReplication]: () => <AsyncReplicationInfo data={data} />,
+            [EPathType.EPathTypeTransfer]: () => <TransferInfo data={data} />,
         };
 
         return (type && pathTypeToComponent[type]?.()) || <TableInfo data={data} type={type} />;

src/containers/Tenant/Diagnostics/Overview/TransferInfo/Credentials.tsx

@@ -0,0 +1,27 @@
+import {Label} from '@gravity-ui/uikit';
+
+import type {TConnectionParams} from '../../../../../types/api/schema/replication';
+
+interface CredentialsProps {
+    connection?: TConnectionParams;
+}
+
+export function Credentials({connection}: CredentialsProps) {
+    if (!connection) {
+        return null;
+    }
+
+    if (connection.StaticCredentials) {
+        return (
+            <Label value={connection.StaticCredentials.User} theme="normal">
+                user
+            </Label>
+        );
+    }
+
+    if ('OAuthToken' in connection) {
+        return 'OAuth';
+    }
+
+    return 'unknown';
+}

src/containers/Tenant/Diagnostics/Overview/TransferInfo/TransferInfo.tsx

@@ -0,0 +1,103 @@
+import type {DefinitionListItem} from '@gravity-ui/components';
+import {Flex, Text} from '@gravity-ui/uikit';
+
+import {AsyncReplicationState} from '../../../../../components/AsyncReplicationState';
+import {YDBDefinitionList} from '../../../../../components/YDBDefinitionList/YDBDefinitionList';
+import type {TEvDescribeSchemeResult} from '../../../../../types/api/schema';
+import {getEntityName} from '../../../utils';
+
+import {Credentials} from './Credentials';
+import i18n from './i18n';
+
+interface TransferProps {
+    data?: TEvDescribeSchemeResult;
+}
+
+/** Displays overview for Transfer EPathType */
+export function TransferInfo({data}: TransferProps) {
+    const entityName = getEntityName(data?.PathDescription);
+
+    if (!data) {
+        return (
+            <div className="error">
+                {i18n('noData')} {entityName}
+            </div>
+        );
+    }
+
+    const transferItems = prepareTransferItems(data);
+
+    return (
+        <Flex direction="column" gap="4">
+            <YDBDefinitionList title={entityName} items={transferItems} />
+        </Flex>
+    );
+}
+
+function prepareTransferItems(data: TEvDescribeSchemeResult) {
+    const transferDescription = data.PathDescription?.ReplicationDescription || {};
+    const state = transferDescription.State;
+    const srcConnectionParams = transferDescription.Config?.SrcConnectionParams || {};
+    const {Endpoint, Database} = srcConnectionParams;
+    const target = transferDescription.Config?.TransferSpecific?.Targets[0];
+    const srcPath = target?.SrcPath;
+    const dstPath = target?.DstPath;
+    const transformLambda = target?.TransformLambda;
+
+    const info: DefinitionListItem[] = [];
+
+    if (state) {
+        info.push({
+            name: i18n('state.label'),
+            content: <AsyncReplicationState state={state} />,
+        });
+    }
+
+    if (Endpoint) {
+        info.push({
+            name: i18n('srcConnection.endpoint.label'),
+            copyText: Endpoint,
+            content: <Text variant="code-inline-2">{Endpoint}</Text>,
+        });
+    }
+
+    if (Database) {
+        info.push({
+            name: i18n('srcConnection.database.label'),
+            copyText: Database,
+            content: <Text variant="code-inline-2">{Database}</Text>,
+        });
+    }
+
+    if (srcConnectionParams) {
+        info.push({
+            name: i18n('credentials.label'),
+            content: <Credentials connection={srcConnectionParams} />,
+        });
+    }
+
+    info.push({
+        name: i18n('srcPath.label'),
+        copyText: srcPath,
+        content: <Text variant="code-inline-2">{srcPath}</Text>,
+    });
+
+    info.push({
+        name: i18n('dstPath.label'),
+        copyText: dstPath,
+        content: <Text variant="code-inline-2">{dstPath}</Text>,
+    });
+
+    // TODO use true pre
+    info.push({
+        name: i18n('transformLambda.label'),
+        copyText: transformLambda,
+        content: (
+            <Text variant="code-2" whiteSpace="nowrap">
+                <pre>{transformLambda}</pre>
+            </Text>
+        ),
+    });
+
+    return info;
+}

src/containers/Tenant/Diagnostics/Overview/TransferInfo/i18n/en.json

@@ -0,0 +1,10 @@
+{
+  "credentials.label": "Credentials",
+  "noData": "No data for entity:",
+  "srcConnection.database.label": "Source Database Path",
+  "srcConnection.endpoint.label": "Source Cluster Endpoint",
+  "state.label": "State",
+  "srcPath.label": "Source Topic",
+  "dstPath.label": "Destination Table",
+  "transformLambda.label": "Transformation Lambda"
+}

src/containers/Tenant/Diagnostics/Overview/TransferInfo/i18n/index.ts

@@ -0,0 +1,7 @@
+import {registerKeysets} from '../../../../../../utils/i18n';
+
+import en from './en.json';
+
+const COMPONENT = 'ydb-diagnostics-transfer-info';
+
+export default registerKeysets(COMPONENT, {en});

src/containers/Tenant/Diagnostics/Overview/TransferInfo/index.ts

@@ -0,0 +1 @@
+export * from './TransferInfo';

src/containers/Tenant/ObjectSummary/ObjectSummary.tsx

@@ -310,6 +310,20 @@ export function ObjectSummary({
                     return [];
                 }
 
+                return [
+                    {
+                        name: i18n('field_state'),
+                        content: <AsyncReplicationState state={state} />,
+                    },
+                ];
+            },
+            [EPathType.EPathTypeTransfer]: () => {
+                const state = PathDescription?.ReplicationDescription?.State;
+
+                if (!state) {
+                    return [];
+                }
+
                 return [
                     {
                         name: i18n('field_state'),

src/containers/Tenant/Query/NewSQL/NewSQL.tsx

@@ -106,6 +106,23 @@ export function NewSQL() {
                 },
             ],
         },
+        {
+            text: i18n('menu.transfer'),
+            items: [
+                {
+                    text: i18n('action.create-transfer'),
+                    action: actions.createTransfer,
+                },
+                {
+                    text: i18n('action.alter-transfer'),
+                    action: actions.alterTransfer,
+                },
+                {
+                    text: i18n('action.drop-transfer'),
+                    action: actions.dropTransfer,
+                },
+            ],
+        },
         {
             text: i18n('menu.capture'),
             items: [

src/containers/Tenant/Query/NewSQL/i18n/en.json

@@ -16,18 +16,22 @@
   "menu.topics": "Topics",
   "menu.capture": "Change data capture",
   "menu.replication": "Async replication",
+  "menu.transfer": "Transfer",
   "menu.users": "Users",
   "action.create-topic": "Create Topic",
   "action.drop-topic": "Drop Topic",
   "action.alter-topic": "Alter Topic",
   "action.create-cdc-stream": "Create changefeed",
   "action.create-async-replication": "Create async replication",
+  "action.create-transfer": "Create transfer",
   "action.create-user": "Create user",
   "action.create-group": "Create group",
   "action.drop-user": "Drop user",
   "action.drop-group": "Drop group",
   "action.grant-privilege": "Grant privilege",
   "action.revoke-privilege": "Revoke privilege",
   "action.alter-async-replication": "Alter async replication",
-  "action.drop-async-replication": "Drop async replication"
+  "action.drop-async-replication": "Drop async replication",
+  "action.alter-transfer": "Alter transfer",
+  "action.drop-transfer": "Drop transfer"
 }

src/containers/Tenant/i18n/en.json

@@ -33,6 +33,7 @@
   "actions.createTopic": "Create topic...",
   "actions.createColumnTable": "Create column table...",
   "actions.createAsyncReplication": "Create async replication...",
+  "actions.createTransfer": "Create transfer...",
   "actions.createView": "Create view...",
   "actions.dropTable": "Drop table...",
   "actions.dropTopic": "Drop topic...",
@@ -46,7 +47,9 @@
   "actions.selectQuery": "Select query...",
   "actions.upsertQuery": "Upsert query...",
   "actions.alterReplication": "Alter async replicaton...",
+  "actions.alterTransfer": "Alter transfer...",
   "actions.dropReplication": "Drop async replicaton...",
+  "actions.dropTransfer": "Drop transfer...",
   "actions.createDirectory": "Create directory",
   "schema.tree.dialog.placeholder": "Relative path",
   "schema.tree.dialog.invalid": "Invalid path",

src/containers/Tenant/utils/controls.tsx

@@ -61,6 +61,7 @@ export const getSchemaControls =
 
         const nodeTypeToControls: Record<NavigationTreeNodeType, Controls> = {
             async_replication: undefined,
+            transfer: undefined,
 
             database: undefined,
             directory: undefined,

src/containers/Tenant/utils/newSQLQueryActions.ts

@@ -3,13 +3,15 @@ import {
     alterAsyncReplicationTemplate,
     alterTableTemplate,
     alterTopicTemplate,
+    alterTransferTemplate,
     createAsyncReplicationTemplate,
     createCdcStreamTemplate,
     createColumnTableTemplate,
     createExternalTableTemplate,
     createGroupTemplate,
     createTableTemplate,
     createTopicTemplate,
+    createTransferTemplate,
     createUserTemplate,
     createViewTemplate,
     deleteRowsTemplate,
@@ -19,6 +21,7 @@ import {
     dropTableIndex,
     dropTableTemplate,
     dropTopicTemplate,
+    dropTransferTemplate,
     dropUserTemplate,
     grantPrivilegeTemplate,
     revokePrivilegeTemplate,
@@ -38,6 +41,9 @@ export const bindActions = (changeUserInput: (input: string) => void) => {
         createAsyncReplication: inputQuery(createAsyncReplicationTemplate),
         alterAsyncReplication: inputQuery(alterAsyncReplicationTemplate),
         dropAsyncReplication: inputQuery(dropAsyncReplicationTemplate),
+        createTransfer: inputQuery(createTransferTemplate),
+        alterTransfer: inputQuery(alterTransferTemplate),
+        dropTransfer: inputQuery(dropTransferTemplate),
         alterTable: inputQuery(alterTableTemplate),
         selectQuery: inputQuery(selectQueryTemplate),
         upsertQuery: inputQuery(upsertQueryTemplate),