feat(backend): add MCP Registry sync progress and management endpoints

Author: Lasim

services/backend/src/routes/admin/mcp-registry.ts

@@ -136,4 +136,337 @@ export default async function mcpRegistryRoutes(server: FastifyInstance) {
       return reply.status(500).type('application/json').send(jsonString);
     }
   });
+
+  /**
+   * Get detailed batch progress
+   * Provides real-time progress, job status, and error details for a sync batch
+   */
+  server.get('/admin/mcp-registry/progress/:batchId', {
+    preValidation: requirePermission('mcp.registry.sync'),
+    schema: {
+      tags: ['Admin - MCP Registry'],
+      summary: 'Get detailed sync progress for batch',
+      description: 'Get real-time progress, job status, and error details for MCP Registry sync batch',
+      security: [{ cookieAuth: [] }],
+      
+      params: {
+        type: 'object',
+        properties: {
+          batchId: { type: 'string', description: 'Job batch ID' }
+        },
+        required: ['batchId']
+      },
+      
+      response: {
+        200: {
+          type: 'object',
+          properties: {
+            success: { type: 'boolean' },
+            data: {
+              type: 'object',
+              properties: {
+                batch: {
+                  type: 'object',
+                  description: 'Batch information'
+                },
+                progress: {
+                  type: 'object',
+                  properties: {
+                    total: { type: 'number' },
+                    completed: { type: 'number' },
+                    failed: { type: 'number' },
+                    pending: { type: 'number' },
+                    processing: { type: 'number' },
+                    percentage: { type: 'number' }
+                  }
+                },
+                recentJobs: {
+                  type: 'array',
+                  description: 'Recent jobs in batch (last 10)'
+                },
+                errors: {
+                  type: 'array',
+                  description: 'Failed jobs with error details'
+                },
+                estimatedTimeRemaining: {
+                  type: 'number',
+                  nullable: true,
+                  description: 'Estimated milliseconds until completion'
+                }
+              }
+            }
+          }
+        },
+        500: {
+          type: 'object',
+          properties: {
+            success: { type: 'boolean' },
+            error: { type: 'string' }
+          }
+        }
+      }
+    }
+  }, async (request, reply) => {
+    const { batchId } = request.params as { batchId: string };
+    
+    try {
+      const db = getDb();
+      const jobQueueService = new JobQueueService(db, request.log);
+      
+      const batchProgress = await jobQueueService.getBatchProgress(batchId);
+      
+      const responseData = {
+        success: true,
+        data: batchProgress
+      };
+      const jsonString = JSON.stringify(responseData);
+      return reply.status(200).type('application/json').send(jsonString);
+      
+    } catch (error) {
+      request.log.error({ error, batchId }, 'Failed to get batch progress');
+      const errorResponse = {
+        success: false,
+        error: error instanceof Error ? error.message : 'Failed to get batch progress'
+      };
+      const jsonString = JSON.stringify(errorResponse);
+      return reply.status(500).type('application/json').send(jsonString);
+    }
+  });
+
+  /**
+   * Cancel active sync batch
+   * Cancels all pending jobs in a batch
+   */
+  server.post('/admin/mcp-registry/cancel/:batchId', {
+    preValidation: requirePermission('mcp.registry.sync'),
+    schema: {
+      tags: ['Admin - MCP Registry'],
+      summary: 'Cancel active sync batch',
+      description: 'Cancel an active MCP Registry sync batch and all pending jobs',
+      security: [{ cookieAuth: [] }],
+      
+      params: {
+        type: 'object',
+        properties: {
+          batchId: { type: 'string', description: 'Job batch ID to cancel' }
+        },
+        required: ['batchId']
+      },
+      
+      response: {
+        200: {
+          type: 'object',
+          properties: {
+            success: { type: 'boolean' },
+            message: { type: 'string' },
+            data: {
+              type: 'object',
+              properties: {
+                batchId: { type: 'string' },
+                cancelledJobs: { type: 'number' }
+              }
+            }
+          }
+        },
+        500: {
+          type: 'object',
+          properties: {
+            success: { type: 'boolean' },
+            error: { type: 'string' }
+          }
+        }
+      }
+    }
+  }, async (request, reply) => {
+    const { batchId } = request.params as { batchId: string };
+    
+    try {
+      const db = getDb();
+      const jobQueueService = new JobQueueService(db, request.log);
+      
+      const cancelledJobs = await jobQueueService.cancelBatchJobs(batchId);
+      
+      request.log.info({
+        batchId,
+        cancelledJobs,
+        userId: request.user!.id,
+        operation: 'mcp_sync_batch_cancelled'
+      }, 'MCP Registry sync batch cancelled');
+      
+      const responseData = {
+        success: true,
+        message: `Cancelled ${cancelledJobs} pending jobs in batch`,
+        data: { batchId, cancelledJobs }
+      };
+      const jsonString = JSON.stringify(responseData);
+      return reply.status(200).type('application/json').send(jsonString);
+      
+    } catch (error) {
+      request.log.error({ error, batchId }, 'Failed to cancel sync batch');
+      const errorResponse = {
+        success: false,
+        error: error instanceof Error ? error.message : 'Failed to cancel sync batch'
+      };
+      const jsonString = JSON.stringify(errorResponse);
+      return reply.status(500).type('application/json').send(jsonString);
+    }
+  });
+
+  /**
+   * Retry failed jobs in batch
+   * Resets and retries all failed jobs in a batch
+   */
+  server.post('/admin/mcp-registry/retry/:batchId', {
+    preValidation: requirePermission('mcp.registry.sync'),
+    schema: {
+      tags: ['Admin - MCP Registry'],
+      summary: 'Retry failed jobs in batch',
+      description: 'Retry all failed jobs in an MCP Registry sync batch',
+      security: [{ cookieAuth: [] }],
+      
+      params: {
+        type: 'object',
+        properties: {
+          batchId: { type: 'string', description: 'Job batch ID to retry failed jobs' }
+        },
+        required: ['batchId']
+      },
+      
+      response: {
+        200: {
+          type: 'object',
+          properties: {
+            success: { type: 'boolean' },
+            message: { type: 'string' },
+            data: {
+              type: 'object',
+              properties: {
+                batchId: { type: 'string' },
+                retriedJobs: { type: 'number' }
+              }
+            }
+          }
+        },
+        500: {
+          type: 'object',
+          properties: {
+            success: { type: 'boolean' },
+            error: { type: 'string' }
+          }
+        }
+      }
+    }
+  }, async (request, reply) => {
+    const { batchId } = request.params as { batchId: string };
+    
+    try {
+      const db = getDb();
+      const jobQueueService = new JobQueueService(db, request.log);
+      
+      const retriedJobs = await jobQueueService.retryFailedBatchJobs(batchId);
+      
+      request.log.info({
+        batchId,
+        retriedJobs,
+        userId: request.user!.id,
+        operation: 'mcp_sync_batch_retry'
+      }, 'Retried failed jobs in MCP Registry sync batch');
+      
+      const responseData = {
+        success: true,
+        message: `Retried ${retriedJobs} failed jobs in batch`,
+        data: { batchId, retriedJobs }
+      };
+      const jsonString = JSON.stringify(responseData);
+      return reply.status(200).type('application/json').send(jsonString);
+      
+    } catch (error) {
+      request.log.error({ error, batchId }, 'Failed to retry batch jobs');
+      const errorResponse = {
+        success: false,
+        error: error instanceof Error ? error.message : 'Failed to retry batch jobs'
+      };
+      const jsonString = JSON.stringify(errorResponse);
+      return reply.status(500).type('application/json').send(jsonString);
+    }
+  });
+
+  /**
+   * Get recent sync batches
+   * Returns recent MCP registry sync operations for monitoring
+   */
+  server.get('/admin/mcp-registry/batches', {
+    preValidation: requirePermission('mcp.registry.sync'),
+    schema: {
+      tags: ['Admin - MCP Registry'],
+      summary: 'Get recent sync batches',
+      description: 'Get recent MCP Registry sync operations with progress information',
+      security: [{ cookieAuth: [] }],
+      
+      querystring: {
+        type: 'object',
+        properties: {
+          limit: { 
+            type: 'number', 
+            minimum: 1, 
+            maximum: 50,
+            default: 10,
+            description: 'Number of batches to return'
+          }
+        }
+      },
+      
+      response: {
+        200: {
+          type: 'object',
+          properties: {
+            success: { type: 'boolean' },
+            data: {
+              type: 'array',
+              items: {
+                type: 'object',
+                description: 'Batch information with progress'
+              }
+            }
+          }
+        },
+        500: {
+          type: 'object',
+          properties: {
+            success: { type: 'boolean' },
+            error: { type: 'string' }
+          }
+        }
+      }
+    }
+  }, async (request, reply) => {
+    // eslint-disable-next-line @typescript-eslint/no-explicit-any
+    const { limit } = (request.query || {}) as any;
+    
+    try {
+      const db = getDb();
+      const jobQueueService = new JobQueueService(db, request.log);
+      
+      const recentBatches = await jobQueueService.getRecentBatches(
+        'mcp_registry_sync',
+        limit || 10
+      );
+      
+      const responseData = {
+        success: true,
+        data: recentBatches
+      };
+      const jsonString = JSON.stringify(responseData);
+      return reply.status(200).type('application/json').send(jsonString);
+      
+    } catch (error) {
+      request.log.error({ error }, 'Failed to get recent batches');
+      const errorResponse = {
+        success: false,
+        error: error instanceof Error ? error.message : 'Failed to get recent batches'
+      };
+      const jsonString = JSON.stringify(errorResponse);
+      return reply.status(500).type('application/json').send(jsonString);
+    }
+  });
 }