feat: Add 'stop', 'start' events in space stream

packages/restapi/src/lib/pushstream/DataModifier.ts

@@ -392,6 +392,10 @@ export class DataModifier {
         return ProposedEventNames.JoinSpace;
       case 'remove':
         return ProposedEventNames.SpaceRemove;
+      case 'start':
+        return ProposedEventNames.StartSpace;
+      case 'stop':
+        return ProposedEventNames.StopSpace;
       default:
         throw new Error(`Unknown current event name: ${currentEventName}`);
     }
@@ -431,6 +435,10 @@ export class DataModifier {
         return this.mapToJoinSpaceEvent(data, includeRaw);
       case 'leaveSpace':
         return this.mapToLeaveSpaceEvent(data, includeRaw);
+      case 'start':
+        return this.mapToStartSpaceEvent(data, includeRaw);
+      case 'stop':
+        return this.mapToStopSpaceEvent(data, includeRaw);
       default:
         // If the eventType is unknown, check for known messageCategories
         switch (data.messageCategory) {
@@ -702,4 +710,60 @@ export class DataModifier {
     }
     return eventData;
   }
+
+  private static mapToStartSpaceEvent(data: any, includeRaw: boolean): any {
+    type BaseEventData = {
+      event: string;
+      origin: string;
+      timestamp: string;
+      spaceId: string;
+      from: string;
+      to: null;
+      raw?: {
+        verificationProof: string;
+      };
+    };
+
+    const eventData: BaseEventData = {
+      origin: data.messageOrigin,
+      timestamp: data.timestamp,
+      spaceId: data.spaceId,
+      from: data.from,
+      to: null,
+      event: data.eventType,
+    };
+
+    if (includeRaw) {
+      eventData.raw = { verificationProof: data.verificationProof };
+    }
+    return eventData;
+  }
+
+  private static mapToStopSpaceEvent(data: any, includeRaw: boolean): any {
+    type BaseEventData = {
+      event: string;
+      origin: string;
+      timestamp: string;
+      spaceId: string;
+      from: string;
+      to: null;
+      raw?: {
+        verificationProof: string;
+      };
+    };
+
+    const eventData: BaseEventData = {
+      origin: data.messageOrigin,
+      timestamp: data.timestamp,
+      spaceId: data.spaceId,
+      from: data.from,
+      to: null,
+      event: data.eventType,
+    };
+
+    if (includeRaw) {
+      eventData.raw = { verificationProof: data.verificationProof };
+    }
+    return eventData;
+  }
 }

packages/restapi/src/lib/pushstream/PushStream.ts

@@ -309,10 +309,12 @@ export class PushStream extends EventEmitter {
 
           if (this.shouldEmitSpace(data.spaceId)) {
             if (
-              data.eventType === SpaceEventType.JoinSpace ||
-              data.eventType === SpaceEventType.LeaveSpace ||
+              data.eventType === SpaceEventType.Join ||
+              data.eventType === SpaceEventType.Leave ||
               data.eventType === MessageEventType.Request ||
-              data.eventType === SpaceEventType.Remove
+              data.eventType === SpaceEventType.Remove || 
+              data.eventType === SpaceEventType.Start ||
+              data.eventType === SpaceEventType.Stop
             ) {
               if (shouldEmit(STREAM.SPACE)) {
                 this.emit(STREAM.SPACE, modifiedData);

packages/restapi/src/lib/pushstream/pushStreamTypes.ts

@@ -57,9 +57,11 @@ export enum GroupEventType {
 export enum SpaceEventType {
   CreateSpace = 'createSpace',
   UpdateSpace = 'updateSpace',
-  JoinSpace = 'joinSpace',
-  LeaveSpace = 'leaveSpace',
+  Join = 'joinSpace',
+  Leave = 'leaveSpace',
   Remove = 'remove',
+  Stop = 'stop',
+  Start = 'start' 
 }
 
 export enum ProposedEventNames {
@@ -81,6 +83,8 @@ export enum ProposedEventNames {
   LeaveSpace = 'space.participant.leave',
   JoinSpace = 'space.participant.join',
   SpaceRemove = 'space.participant.remove',
+  StartSpace = 'space.start',
+  StopSpace = 'space.stop'
 }
 
 export interface Profile {