Drop mirror: Deal with peer names only in client side

ui/app/api/mirrors/drop/route.ts

@@ -1,10 +1,23 @@
 import { UDropMirrorResponse } from '@/app/dto/MirrorsDTO';
+import prisma from '@/app/utils/prisma';
 import { ShutdownRequest, ShutdownResponse } from '@/grpc_generated/route';
 import { GetFlowHttpAddressFromEnv } from '@/rpc/http';
+import { getTruePeer } from '../../peers/getTruePeer';
 
+const getPeerFromName = async (name: string) => {
+  const catalogPeer = await prisma.peers.findUnique({
+    where: {
+      name,
+    },
+  });
+  const peer = getTruePeer(catalogPeer!);
+  return peer;
+};
 export async function POST(request: Request) {
   const body = await request.json();
-  const { workflowId, flowJobName, sourcePeer, destinationPeer } = body;
+  const { workflowId, flowJobName, sourcePeerName, destinationPeerName } = body;
+  const sourcePeer = await getPeerFromName(sourcePeerName);
+  const destinationPeer = await getPeerFromName(destinationPeerName);
   const flowServiceAddr = GetFlowHttpAddressFromEnv();
   const req: ShutdownRequest = {
     workflowId,

ui/app/mirrors/tables.tsx

@@ -87,8 +87,8 @@ export function CDCFlows({ cdcFlows }: { cdcFlows: any }) {
                   dropArgs={{
                     workflowId: flow.workflow_id,
                     flowJobName: flow.name,
-                    sourcePeer: flow.sourcePeer,
-                    destinationPeer: flow.destinationPeer,
+                    sourcePeerName: flow.sourcePeer.name,
+                    destinationPeerName: flow.destinationPeer.name,
                   }}
                 />
               </TableCell>
@@ -172,8 +172,8 @@ export function QRepFlows({
                   dropArgs={{
                     workflowId: flow.workflow_id,
                     flowJobName: flow.name,
-                    sourcePeer: flow.sourcePeer,
-                    destinationPeer: flow.destinationPeer,
+                    sourcePeerName: flow.sourcePeer.name,
+                    destinationPeerName: flow.destinationPeer.name,
                   }}
                 />
               </TableCell>

ui/components/DropDialog.tsx

@@ -2,7 +2,6 @@
 import { UDropMirrorResponse } from '@/app/dto/MirrorsDTO';
 import { UDropPeerResponse } from '@/app/dto/PeersDTO';
 import { DeleteScript } from '@/app/scripts/handlers';
-import { Peer } from '@/grpc_generated/peers';
 import { Button } from '@/lib/Button';
 import { Dialog, DialogClose } from '@/lib/Dialog';
 import { Icon } from '@/lib/Icon';
@@ -14,8 +13,8 @@ import { BarLoader } from 'react-spinners';
 interface dropMirrorArgs {
   workflowId: string | null;
   flowJobName: string;
-  sourcePeer: Peer;
-  destinationPeer: Peer;
+  sourcePeerName: string;
+  destinationPeerName: string;
   forResync?: boolean;
 }
 

ui/components/ResyncDialog.tsx

@@ -25,8 +25,8 @@ export const ResyncDialog = ({
       {
         workflowId: workflowId,
         flowJobName: mirrorConfig.flowJobName,
-        sourcePeer: mirrorConfig.source!,
-        destinationPeer: mirrorConfig.destination!,
+        sourcePeerName: mirrorConfig.source!.name,
+        destinationPeerName: mirrorConfig.destination!.name,
         forResync: true,
       },
       setDropping,