feat: support transfer (#1995)

Author: nshestakov

package-lock.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": {

package.json

@@ -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/DiagnosticsPages.ts

@@ -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/Overview.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/Credentials.tsx

@@ -0,0 +1,99 @@
+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 {YqlHighlighter} from '../../../../../components/YqlHighlighter/YqlHighlighter';
+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>,
+    });
+
+    info.push({
+        name: i18n('transformLambda.label'),
+        copyText: transformLambda,
+        content: transformLambda ? <YqlHighlighter>{transformLambda}</YqlHighlighter> : null,
+    });
+
+    return info;
+}

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

@@ -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/en.json

@@ -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/i18n/index.ts

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

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

@@ -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'),