debezium/dbz#1937 Update signal verify payload and use fullyQualifiedName for collections

debezium-platform-stage/src/__fixtures__/collection.json

@@ -0,0 +1,40 @@
+{
+  "catalogs": [
+    {
+      "name": null,
+      "schemas": [
+        {
+          "name": "inventory",
+          "collections": [
+            {
+              "name": "spatial_ref_sys",
+              "fullyQualifiedName": "inventory.spatial_ref_sys"
+            },
+            {
+              "name": "geom",
+              "fullyQualifiedName": "inventory.geom"
+            },
+            {
+              "name": "products_on_hand",
+              "fullyQualifiedName": "inventory.products_on_hand"
+            },
+            {
+              "name": "customers",
+              "fullyQualifiedName": "inventory.customers"
+            },
+            {
+              "name": "orders",
+              "fullyQualifiedName": "inventory.orders"
+            },
+            {
+              "name": "products",
+              "fullyQualifiedName": "inventory.products"
+            }
+          ],
+          "collectionCount": 6
+        }
+      ],
+      "totalCollections": 6
+    }
+  ]
+}

debezium-platform-stage/src/components/CreateSourceSchemaForm.tsx

@@ -446,7 +446,7 @@
     }
   );
 
   const collectionsError =
     collectionsQueryError != null
       ? typeof collectionsQueryError === "object"
         ? (collectionsQueryError as object)
@@ -657,7 +657,7 @@
     }
     const payload = {
       databaseType: getDatabaseType(sourceId),
-      connectionConfig: selectedConnection,
+      connectionId: selectedConnection.id,
       fullyQualifiedTableName: signalCollectionNameVerify,
     };
     const response = await verifySignals(`${API_URL}/api/sources/signals/verify`, payload);

debezium-platform-stage/src/components/TableViewComponent.tsx

@@ -17,6 +17,7 @@ type TableViewComponentProps = {
 type SelectedItem = {
     name: string;
     id: string;
+    fullyQualifiedName?: string;
     checkProps: { checked?: boolean | null; "aria-label"?: string };
     children?: SelectedItem[];
 };
@@ -60,9 +61,13 @@ export function extractSelections(selectedItems: SelectedItem[]): SelectionResul
             }
 
         } else if (isTable) {
-            const schemaFromId = item.id.match(/^schema-\d+-(.*?)-collection-/)?.[1];
-            const schemaName = schemaFromId ?? "unknown_schema";
-            tableSet.add(`${schemaName}.${item.name}`);
+            // Use fullyQualifiedName if available, otherwise fall back to constructing it
+            const tableName = item.fullyQualifiedName || (() => {
+                const schemaFromId = item.id.match(/^schema-\d+-(.*?)-collection-/)?.[1];
+                const schemaName = schemaFromId ?? "unknown_schema";
+                return `${schemaName}.${item.name}`;
+            })();
+            tableSet.add(tableName);
         }
     }
 
@@ -182,8 +187,12 @@ const TableViewComponent: FC<TableViewComponentProps> = ({ collections, setSelec
                         newCheckedItems.push(...item.children);
                     }
                 } else if (isTableItem) {
-                    const schemaFromId = itemId.match(/^schema-\d+-(.*?)-collection-/)?.[1];
-                    const tableName = `${schemaFromId}.${itemName}`;
+                    // Use fullyQualifiedName if available, otherwise construct it
+                    // eslint-disable-next-line @typescript-eslint/no-explicit-any
+                    const tableName = (item as any).fullyQualifiedName || (() => {
+                        const schemaFromId = itemId.match(/^schema-\d+-(.*?)-collection-/)?.[1];
+                        return `${schemaFromId}.${itemName}`;
+                    })();
                     if (tables.includes(tableName)) {
                         newCheckedItems.push(item);
                     }
@@ -223,8 +232,10 @@ const TableViewComponent: FC<TableViewComponentProps> = ({ collections, setSelec
                                         name: collection.name,
                                         id: `schema-${schemaIdx}-${schema.name}-collection-${collection.name}`,
                                         icon: <ServerGroupIcon />,
-                                        checkProps: { checked: false }
-                                    });
+                                        checkProps: { checked: false },
+                                        fullyQualifiedName: collection.fullyQualifiedName // Store fullyQualifiedName
+                                        // eslint-disable-next-line @typescript-eslint/no-explicit-any
+                                    } as any);
                                 });
                             }
                             newOptions.push({

debezium-platform-stage/src/pages/Connection/CreateConnection.tsx

@@ -17,7 +17,7 @@ import {
     type AdditionalPropertyRowErrorCode,
     type AdditionalPropertyValueKind,
 } from "@utils/additionalConfigProperties";
-import { getConnectorTypeName } from "@utils/helpers";
+import { extractConnectorType, getConnectorTypeName } from "@utils/helpers";
 import { AdditionalPropertiesRows } from "@components/AdditionalPropertiesRows";
 import { ExclamationCircleIcon, EyeIcon, EyeSlashIcon, PlusIcon } from "@patternfly/react-icons";
 import { useState } from "react";
@@ -221,12 +221,12 @@ const CreateConnection: React.FunctionComponent<ICreateConnectionProps> = ({ sel
 
         return selectedSchema
             ? ({
-                  type: selectedSchema?.type.toUpperCase() || connectionId?.toUpperCase() || "",
+                  type: selectedSchema?.type.toUpperCase() || extractConnectorType(connectionId || "").toUpperCase(),
                   config: mergedConfig,
                   name: name as string,
               } as ConnectionPayload)
             : {
-                  type: connectionId?.toUpperCase() || "",
+                  type: extractConnectorType(connectionId || "").toUpperCase(),
                   config: validation.additionalFlat,
                   name: name as string,
               };

debezium-platform-stage/src/utils/helpers.ts

@@ -57,6 +57,33 @@ export const getConnectionRole = (connectorType: string, catalog: Catalog[]): st
   return catalog.find((entry) => entry.class.toLowerCase() === lower || lower.includes(entry.class.toLowerCase()) || entry.class.toLowerCase().includes(lower))?.role;
 }
 
+export const extractConnectorType = (connectorClass: string): string => {
+  // Simple string
+  if (!connectorClass.includes('.')) {
+    return connectorClass;
+  }
+
+  // For source connectors: extract after "io.debezium.connector."
+  const sourcePrefix = "io.debezium.connector.";
+  if (connectorClass.startsWith(sourcePrefix)) {
+    const afterPrefix = connectorClass.substring(sourcePrefix.length);
+    const firstSegment = afterPrefix.split('.')[0];
+    return firstSegment;
+  }
+
+  // For destination/sink connectors: extract after "io.debezium.server."
+  const serverPrefix = "io.debezium.server.";
+  if (connectorClass.startsWith(serverPrefix)) {
+    const afterPrefix = connectorClass.substring(serverPrefix.length);
+    const firstSegment = afterPrefix.split('.')[0];
+    return firstSegment;
+  }
+
+  // Fallback
+  return connectorClass;
+};
+
+
 export const getConnectorTypeName = (connectorType: string) => {
   let name = "";