Phase 2.1: Integrate MetadataManager with IRealtimeService

- Add IRealtimeService import to MetadataManager
- Add setRealtimeService() method to MetadataManager
- Publish metadata.{type}.created events in register()
- Publish metadata.{type}.deleted events in unregister()
- Bridge realtime service in MetadataPlugin.start()

Agent-Logs-Url: https://github.com/objectstack-ai/framework/sessions/6a38da2b-8234-4c22-b456-ec507a8f82f2

Co-authored-by: hotlong <50353452+hotlong@users.noreply.github.com>

Author: Claude

packages/metadata/src/metadata-manager.ts

@@ -28,6 +28,8 @@ import type {
   MetadataImportOptions,
   MetadataImportResult,
   MetadataTypeInfo,
+  IRealtimeService,
+  RealtimeEventPayload,
 } from '@objectstack/spec/contracts';
 import type {
   MetadataQuery,
@@ -83,6 +85,9 @@ export class MetadataManager implements IMetadataService {
   // Dependency tracking: "type:name" -> dependencies
   private dependencies = new Map<string, MetadataDependency[]>();
 
+  // Realtime service for event publishing
+  private realtimeService?: IRealtimeService;
+
   constructor(config: MetadataManagerOptions) {
     this.config = config;
     this.logger = createLogger({ level: 'info', format: 'pretty' });
@@ -139,6 +144,17 @@ export class MetadataManager implements IMetadataService {
     this.logger.info('DatabaseLoader configured', { datasource: this.config.datasource, tableName });
   }
 
+  /**
+   * Set the realtime service for publishing metadata change events.
+   * Should be called after kernel resolves the realtime service.
+   *
+   * @param service - An IRealtimeService instance for event publishing
+   */
+  setRealtimeService(service: IRealtimeService): void {
+    this.realtimeService = service;
+    this.logger.info('RealtimeService configured for metadata events');
+  }
+
   /**
    * Register a new metadata loader (data source)
    */
@@ -171,6 +187,28 @@ export class MetadataManager implements IMetadataService {
         await loader.save(type, name, data);
       }
     }
+
+    // Publish metadata.{type}.created event to realtime service
+    if (this.realtimeService) {
+      const event: RealtimeEventPayload = {
+        type: `metadata.${type}.created`,
+        object: type,
+        payload: {
+          metadataType: type,
+          name,
+          definition: data,
+          packageId: (data as any)?.packageId,
+        },
+        timestamp: new Date().toISOString(),
+      };
+
+      try {
+        await this.realtimeService.publish(event);
+        this.logger.debug(`Published metadata.${type}.created event`, { name });
+      } catch (error) {
+        this.logger.warn(`Failed to publish metadata event`, { type, name, error });
+      }
+    }
   }
 
   /**
@@ -246,6 +284,26 @@ export class MetadataManager implements IMetadataService {
         }
       }
     }
+
+    // Publish metadata.{type}.deleted event to realtime service
+    if (this.realtimeService) {
+      const event: RealtimeEventPayload = {
+        type: `metadata.${type}.deleted`,
+        object: type,
+        payload: {
+          metadataType: type,
+          name,
+        },
+        timestamp: new Date().toISOString(),
+      };
+
+      try {
+        await this.realtimeService.publish(event);
+        this.logger.debug(`Published metadata.${type}.deleted event`, { name });
+      } catch (error) {
+        this.logger.warn(`Failed to publish metadata event`, { type, name, error });
+      }
+    }
   }
 
   /**

packages/metadata/src/plugin.ts

@@ -125,5 +125,20 @@ export class MetadataPlugin implements Plugin {
                 error: e.message,
             });
         }
+
+        // Bridge realtime service from kernel service registry to MetadataManager.
+        // RealtimeServicePlugin registers as 'realtime' service during init().
+        // This enables MetadataManager to publish metadata change events.
+        try {
+            const realtimeService = ctx.getService('realtime');
+            if (realtimeService) {
+                ctx.logger.info('[MetadataPlugin] Bridging realtime service to MetadataManager for event publishing');
+                this.manager.setRealtimeService(realtimeService);
+            }
+        } catch (e: any) {
+            ctx.logger.debug('[MetadataPlugin] No realtime service found — metadata events will not be published', {
+                error: e.message,
+            });
+        }
     }
 }