lint

PeerDB-io · Jan 20, 2025 · 80d31a7 · 80d31a7
1 parent 735ae63
commit 80d31a7
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 9 deletions.
diff --git a/flow/connectors/clickhouse/clickhouse.go b/flow/connectors/clickhouse/clickhouse.go
@@ -38,10 +38,10 @@ type ClickHouseConnector struct {
 
 type ClickHouseDestinationCheckInput struct {
 	TableMappings          []*protos.TableMapping
+	TableNameSchemaMapping map[string]*protos.TableSchema
 	SyncedAtColName        string
 	Resync                 bool
 	DoInitialSnapshot      bool
-	TableNameSchemaMapping map[string]*protos.TableSchema
 }
 
 func ValidateS3(ctx context.Context, creds *utils.ClickHouseS3Credentials) error {

diff --git a/ui/app/mirrors/[mirrorId]/edit/page.tsx b/ui/app/mirrors/[mirrorId]/edit/page.tsx
@@ -121,16 +121,22 @@ const EditMirror = ({ params: { mirrorId } }: EditMirrorProps) => {
         addedTables: additionalTables,
       };
 
-      const res = await fetch('/api/v1/mirrors/cdc/edit/validate', {
-        method: 'POST',
-        body: JSON.stringify(validateReq),
-        cache: 'no-store',
-      });
+      try {
+        const res = await fetch('/api/v1/mirrors/cdc/edit/validate', {
+          method: 'POST',
+          body: JSON.stringify(validateReq),
+          cache: 'no-store',
+        });
 
-      if (!res.ok) {
-        notifyErr(`Table addition invalidated: ${res.statusText}`);
+        if (!res.ok) {
+          const errRes = await res.json();
+          notifyErr('Table addition invalidated: ' + errRes.message);
+          setLoading(false);
+          return;
+        }
+      } catch (e) {
+        console.error(e);
         setLoading(false);
-        return;
       }
     }
     const req: FlowStateChangeRequest = {