WIP

Author: nshestakov

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

@@ -5,7 +5,6 @@ import {AsyncReplicationState} from '../../../../../components/AsyncReplicationS
 import {YDBDefinitionList} from '../../../../../components/YDBDefinitionList/YDBDefinitionList';
 import type {TEvDescribeSchemeResult} from '../../../../../types/api/schema';
 import {getEntityName} from '../../../utils';
-import {AsyncReplicationPaths} from '../AsyncReplicationPaths';
 
 import {Credentials} from './Credentials';
 import i18n from './i18n';
@@ -31,7 +30,6 @@ export function TransferInfo({data}: TransferProps) {
     return (
         <Flex direction="column" gap="4">
             <YDBDefinitionList title={entityName} items={transferItems} />
-            <AsyncReplicationPaths config={data.PathDescription?.ReplicationDescription?.Config} />
         </Flex>
     );
 }
@@ -41,6 +39,10 @@ function prepareTransferItems(data: TEvDescribeSchemeResult) {
     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[] = [];
 
@@ -74,5 +76,27 @@ function prepareTransferItems(data: TEvDescribeSchemeResult) {
         });
     }
 
+    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: (
+            <Text variant="code-2" whiteSpace="nowrap">
+                <pre>{transformLambda}</pre>
+            </Text>
+        ),
+    });
+
     return info;
 }

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

@@ -3,5 +3,8 @@
   "noData": "No data for entity:",
   "srcConnection.database.label": "Source Database Path",
   "srcConnection.endpoint.label": "Source Cluster Endpoint",
-  "state.label": "State"
+  "state.label": "State",
+  "srcPath.label": "Source Topic",
+  "dstPath.label": "Destination Table",
+  "transformLambda.label": "Transformation Lambda"
 }

src/types/api/schema/replication.ts

@@ -33,13 +33,24 @@ interface TTargetSpecific {
     Targets: TTarget[];
 }
 
+export interface TTransformTarget {
+    SrcPath?: string;
+    DstPath?: string;
+    TransformLambda?: string;
+}
+
+interface TTransformTargetSpecific {
+    Targets: TTransformTarget[];
+}
+
 /**
  * source: https://github.com/ydb-platform/ydb/blob/main/ydb/core/protos/replication.proto
  */
 export interface TReplicationConfig {
     SrcConnectionParams?: TConnectionParams;
     Everything?: TTargetEverything;
     Specific?: TTargetSpecific;
+    TransferSpecific?: TTransformTargetSpecific;
     InitialSync?: boolean;
 }