Attempt to fix inbound calls on Windows

packages/core/src/RPCMessages/RPCConnect.ts

@@ -19,12 +19,14 @@ export const DEFAULT_CONNECT_VERSION = {
   major: 3,
   minor: 0,
   revision: 0,
+  string: 'bkw',
 }
 
 export const UNIFIED_CONNECT_VERSION = {
   major: 4,
   minor: 0,
   revision: 0,
+  string: 'bkw',
 }
 
 export const RPCConnect = (params: RPCConnectParams) => {

packages/js/package.json

@@ -3,7 +3,7 @@
   "description": "SignalWire JS SDK",
   "author": "SignalWire Team <[email protected]>",
   "license": "MIT",
-  "version": "3.29.1",
+  "version": "3.29.1-bkw",
   "main": "dist/index.js",
   "module": "dist/index.esm.js",
   "unpkg": "dist/index.umd.js",

packages/js/src/fabric/WSClient.ts

@@ -32,6 +32,7 @@ import { PREVIOUS_CALLID_STORAGE_KEY } from './utils/constants'
 export class WSClient extends BaseClient<{}> implements WSClientContract {
   private _incomingCallManager: IncomingCallManager
   private _disconnected: boolean = false
+  private _eventCleanup: Array<() => void> = []
 
   constructor(private wsClientOptions: WSClientOptions) {
     const client = createWSClient(wsClientOptions)
@@ -305,10 +306,24 @@ export class WSClient extends BaseClient<{}> implements WSClientContract {
         this._disconnected = true
       })
 
+      // Clean up all event listeners
+      this._cleanupEventListeners()
+
       super.disconnect()
     })
   }
 
+  private _cleanupEventListeners() {
+    this._eventCleanup.forEach(cleanup => {
+      try {
+        cleanup()
+      } catch (error) {
+        this.logger.error('Error cleaning up event listener:', error)
+      }
+    })
+    this._eventCleanup = []
+  }
+
   public async dial(params: DialParams) {
     return new Promise<FabricRoomSession>(async (resolve, reject) => {
       try {

packages/js/src/fabric/workers/callSegmentWorker.ts

@@ -64,6 +64,9 @@ export const callSegmentWorker = function* (
       case 'call.room':
         cfRoomSession.emit(type, payload)
         break
+      case 'call.state':
+        cfRoomSession.emit(type, payload)
+        break
 
       /**
        * The Core module includes a generic worker, {@link memberPositionWorker},
@@ -120,17 +123,23 @@ export const callSegmentWorker = function* (
   }
 
   const isSegmentEvent = (action: SDKActions) => {
-    const { type, payload } = action as FabricAction
-    const shouldWatch =
-      type.startsWith('call.') ||
-      type.startsWith('member.') ||
-      type.startsWith('layout.')
+    const { payload } = action as FabricAction
+
+    // Check both direct payload fields and nested params (for call.state events)
     const hasSegmentCallId =
-      'call_id' in payload && segmentCallId === payload.call_id
+      ('call_id' in payload && segmentCallId === payload.call_id) ||
+      ('params' in payload &&
+        'call_id' in (payload as any).params &&
+        (payload as any).params.call_id === segmentCallId)
+
     const hasSegmentRoomSessionId =
-      segmentRooSessionId === payload.room_session_id
+      (segmentRooSessionId === payload.room_session_id) ||
+      ('params' in payload &&
+        'room_session_id' in (payload as any).params &&
+        (payload as any).params.room_session_id === segmentRooSessionId)
 
-    if (shouldWatch && (hasSegmentCallId || hasSegmentRoomSessionId)) {
+    // Allow ALL events that belong to this segment (no type filtering)
+    if (hasSegmentCallId || hasSegmentRoomSessionId) {
       return true
     }