[developer] Auto-commit: Implement Core Feature

Author: jonathanpeterwu

src/integrations/ralph/monitoring/swarm-registry.ts

@@ -18,7 +18,7 @@ export interface RegisteredSwarm {
 export class SwarmRegistry extends EventEmitter {
   private static instance: SwarmRegistry | null = null;
   private swarms: Map<string, RegisteredSwarm> = new Map();
-  
+
   private constructor() {
     super();
     logger.info('SwarmRegistry initialized');
@@ -36,18 +36,18 @@ export class SwarmRegistry extends EventEmitter {
    */
   registerSwarm(coordinator: SwarmCoordinator, description: string): string {
     const swarmId = this.generateSwarmId();
-    
+
     const registration: RegisteredSwarm = {
       id: swarmId,
       coordinator,
       startTime: Date.now(),
       status: 'active',
-      description
+      description,
     };
-    
+
     this.swarms.set(swarmId, registration);
     this.emit('swarmRegistered', registration);
-    
+
     logger.info(`Swarm registered: ${swarmId} - ${description}`);
     return swarmId;
   }
@@ -76,14 +76,17 @@ export class SwarmRegistry extends EventEmitter {
    */
   listActiveSwarms(): RegisteredSwarm[] {
     return Array.from(this.swarms.values()).filter(
-      swarm => swarm.status === 'active'
+      (swarm) => swarm.status === 'active'
     );
   }
 
   /**
    * Update swarm status
    */
-  updateSwarmStatus(swarmId: string, status: 'active' | 'idle' | 'completed' | 'error'): void {
+  updateSwarmStatus(
+    swarmId: string,
+    status: 'active' | 'idle' | 'completed' | 'error'
+  ): void {
     const swarm = this.swarms.get(swarmId);
     if (swarm) {
       swarm.status = status;
@@ -102,23 +105,34 @@ export class SwarmRegistry extends EventEmitter {
     averageUptime: number;
   } {
     const active = this.listActiveSwarms();
-    const completed = Array.from(this.swarms.values()).filter(s => s.status === 'completed');
-    
-    const totalUptime = active.reduce((sum, swarm) => 
-      sum + (Date.now() - swarm.startTime), 0
+    const completed = Array.from(this.swarms.values()).filter(
+      (s) => s.status === 'completed'
+    );
+
+    const totalUptime = active.reduce(
+      (sum, swarm) => sum + (Date.now() - swarm.startTime),
+      0
     );
-    
+
     return {
       totalSwarms: this.swarms.size,
       activeSwarms: active.length,
       completedSwarms: completed.length,
-      averageUptime: active.length > 0 ? totalUptime / active.length : 0
+      averageUptime: active.length > 0 ? totalUptime / active.length : 0,
     };
   }
 
+  /**
+   * Cleanup all swarms and reset registry
+   */
+  cleanup(): void {
+    this.swarms.clear();
+    logger.info('SwarmRegistry cleaned up');
+  }
+
   private generateSwarmId(): string {
     return `swarm_${Date.now()}_${Math.random().toString(36).substring(2, 8)}`;
   }
 }
 
-export default SwarmRegistry;
+export default SwarmRegistry;