fix: update slot on ably when it's changed on new io

src/core/launcher/index.ts

@@ -355,7 +355,7 @@ export class Launcher extends Observable implements DefaultLauncher {
   private onParticipantJoinedIOC = (presence: Socket.PresenceEvent<Participant>): void => {
     if (presence.id === this.participant.value.id) {
       // Assign a slot to the participant
-      SlotService.register(this.LauncherRealtimeRoom, this.realtime, this.participant.value);
+      SlotService.register(this.LauncherRealtimeRoom, this.participant.value);
       this.LauncherRealtimeRoom.presence.update<Participant>(this.participant.value);
     }
 
@@ -420,6 +420,13 @@ export class Launcher extends Observable implements DefaultLauncher {
       this.publish(ParticipantEvent.LOCAL_UPDATED, presence.data);
 
       this.logger.log('Publishing ParticipantEvent.UPDATED', presence.data);
+
+      if (
+        presence.data?.slot?.index !== undefined &&
+        presence.data?.slot?.index !== this.realtime.participant.data.slotIndex
+      ) {
+        this.realtime.updateMyProperties({ slotIndex: presence.data.slot.index });
+      }
     }
 
     this.participants.value.set(presence.id, presence.data);

src/services/slot/index.test.ts

@@ -16,7 +16,7 @@ describe('slot service', () => {
       id: '123',
     } as any;
 
-    const instance = new SlotService(room, { updateMyProperties: jest.fn() } as any, participant);
+    const instance = new SlotService(room, participant);
     await instance['assignSlot']();
 
     expect(instance['slotIndex']).toBeDefined();
@@ -47,7 +47,7 @@ describe('slot service', () => {
       id: '123',
     } as any;
 
-    const instance = new SlotService(room, { updateMyProperties: jest.fn() } as any, participant);
+    const instance = new SlotService(room, participant);
     await instance['assignSlot']();
 
     expect(instance['slotIndex']).toBeDefined();
@@ -80,7 +80,7 @@ describe('slot service', () => {
       id: '123',
     } as any;
 
-    const instance = new SlotService(room, { updateMyProperties: jest.fn() } as any, participant);
+    const instance = new SlotService(room, participant);
     await instance['assignSlot']();
 
     expect(instance['slotIndex']).toBeUndefined();
@@ -114,7 +114,7 @@ describe('slot service', () => {
       id: '123',
     } as any;
 
-    const instance = new SlotService(room, { updateMyProperties: jest.fn() } as any, participant);
+    const instance = new SlotService(room, participant);
     await instance['assignSlot']();
 
     expect(instance['slotIndex']).toBeDefined();

src/services/slot/index.ts

@@ -12,26 +12,20 @@ export class SlotService {
   private room: Socket.Room;
   private participant: Participant;
   private slotIndex: number;
-  private realtime: AblyRealtimeService;
   private static instance: SlotService;
 
   // @NOTE - reciving old realtime service instance until we migrate to new IO
-  constructor(room: Socket.Room, realtime: AblyRealtimeService, participant: Participant) {
+  constructor(room: Socket.Room, participant: Participant) {
     this.room = room;
     this.participant = participant;
-    this.realtime = realtime;
 
     this.assignSlot();
     this.room.presence.on(Socket.PresenceEvents.UPDATE, this.onPresenceUpdate);
   }
 
-  public static register(
-    room: Socket.Room,
-    realtime: AblyRealtimeService,
-    participant: Participant,
-  ) {
+  public static register(room: Socket.Room, participant: Participant) {
     if (!SlotService.instance) {
-      SlotService.instance = new SlotService(room, realtime, participant);
+      SlotService.instance = new SlotService(room, participant);
     }
 
     return SlotService.instance;
@@ -89,16 +83,16 @@ export class SlotService {
 
         // @NOTE - this is a temporary fix for the issue where the slot is not being updated in the presence
         // @TODO - remove this once we remove the colors from the old io
-        if (!this.realtime.isJoinedRoom) {
-          await new Promise((resolve) => {
-            setTimeout(resolve, 1500);
-          });
-        }
-
-        this.realtime.updateMyProperties({
-          slotIndex: slot,
-          slot: slotData,
-        });
+        // if (!this.realtime.isJoinedRoom) {
+        //   await new Promise((resolve) => {
+        //     setTimeout(resolve, 1500);
+        //   });
+        // }
+
+        // this.realtime.updateMyProperties({
+        //   slotIndex: slot,
+        //   slot: slotData,
+        // });
       })
       .catch((error) => {
         this.room.presence.update({