@signalwire/compatibility-api - npm Package Compare versions

Comparing version 3.0.3 to 3.0.4-dev.202301191718.e2c475a.0

dist/compatibility-api/src/index.d.ts

@@ -7,5 +7,5 @@ import type { Twilio, TwimlInterface, JwtInterface } from 'twilio';
  */
-declare const RestClient: (username: string, token: string, opts?: CompatibilityAPIRestClientOptions | undefined) => Twilio;
+declare const RestClient: (username: string, token: string, opts?: CompatibilityAPIRestClientOptions) => Twilio;
 export { RestClient };
 export type { CompatibilityAPIRestClientOptions, Twilio, TwimlInterface, JwtInterface, };
 //# sourceMappingURL=index.d.ts.map

dist/core/src/BaseComponent.d.ts

@@ -15,3 +15,2 @@ import type { Task } from '@redux-saga/types';
     /** @internal */
-    private _proxyFactoryCache;
     /** @internal */
@@ -80,3 +79,3 @@ get __uuid(): string;
             runSaga: any;
-        }) => Task;
+        }) => Task<any>;
         dispatch: import("redux").Dispatch<import("redux").AnyAction>;
@@ -83,0 +82,0 @@ getState(): any;

dist/core/src/BaseConsumer.d.ts

@@ -13,3 +13,3 @@ import { BaseComponent, EventEmitter, BaseComponentOptions, JSONRPCSubscribeMethod } from '.';
     protected subscribeParams?: Record<string, any>;
-    private _latestExecuteParams;
+    private _latestExecuteParams?;
     constructor(options: BaseComponentOptions<EventTypes>);
@@ -16,0 +16,0 @@ private shouldExecuteSubscribe;

dist/core/src/BaseSession.d.ts

 import { PayloadAction } from './redux';
-import { SessionOptions, RPCConnectResult, JSONRPCRequest, JSONRPCResponse, WebSocketAdapter, NodeSocketAdapter, WebSocketClient, SessionStatus } from './utils/interfaces';
+import { SessionOptions, RPCConnectResult, JSONRPCRequest, JSONRPCResponse, WebSocketAdapter, NodeSocketAdapter, WebSocketClient, SessionStatus, SessionAuthError } from './utils/interfaces';
+import { SwAuthorizationState } from '.';
 export declare const SW_SYMBOL: unique symbol;
@@ -21,7 +22,13 @@ export declare class BaseSession {
     private _host;
+    protected _swConnectError: symbol;
     private _executeTimeoutMs;
     private _executeTimeoutError;
+    private _executeQueue;
     private _checkPingDelay;
     private _checkPingTimer;
+    private _reconnectTimer;
     private _status;
+    private wsOpenHandler;
+    private wsCloseHandler;
+    private wsErrorHandler;
     constructor(options: SessionOptions);
@@ -32,3 +39,3 @@ get host(): string;
     get signature(): string;
-    protected get logger(): import("./utils/interfaces").InternalSDKLogger;
+    protected get logger(): import(".").InternalSDKLogger;
     get connecting(): boolean;
@@ -39,2 +46,4 @@ get connected(): boolean;
     get status(): SessionStatus;
+    get idle(): boolean;
+    get ready(): boolean;
     set token(token: string);
@@ -51,3 +60,7 @@ /**
      */
-    protected _createSocket(): WebSocketClient;
+    protected _createSocket(): WebSocketClient | import(".").NodeSocketClient;
+    /** Allow children classes to override it. */
+    protected destroySocket(): void;
+    protected _addSocketListeners(): void;
+    protected _removeSocketListeners(): void;
     /**
@@ -68,7 +81,8 @@ * Clear the Session and close the WS connection.
     authenticate(): Promise<void>;
+    authError(error: SessionAuthError): void;
     protected _onSocketOpen(event: Event): Promise<void>;
     protected _onSocketError(event: Event): void;
     protected _onSocketClose(event: CloseEvent): void;
+    private _clearTimers;
     protected _onSocketMessage(event: MessageEvent): void | Promise<void>;
-    protected _handleWebSocketMessage(_payload: JSONRPCRequest | JSONRPCResponse): void;
     dispatch(_payload: PayloadAction<any>): void;
@@ -83,2 +97,9 @@ /**
     protected decode<T>(input: any): T;
+    onSwAuthorizationState(state: SwAuthorizationState): Promise<void>;
+    protected retrieveSwAuthorizationState(): Promise<string>;
+    protected persistSwAuthorizationState(_: SwAuthorizationState): Promise<void>;
+    private _send;
+    private _addToExecuteQueue;
+    private _flushExecuteQueue;
+    private _clearCheckPingTimer;
     private _pingHandler;
@@ -85,0 +106,0 @@ private _closeConnection;

dist/core/src/index.d.ts

@@ -1,2 +0,2 @@
-import { uuid, setLogger, getLogger, isGlobalEvent, toExternalJSON, toSnakeCaseKeys, toLocalEvent, toSyntheticEvent, extendComponent, validateEventsToSubscribe, toInternalEventName, toInternalAction, serializeableProxy, timeoutPromise } from './utils';
+import { uuid, setLogger, getLogger, isGlobalEvent, toExternalJSON, toSnakeCaseKeys, toLocalEvent, toSyntheticEvent, extendComponent, validateEventsToSubscribe, toInternalEventName, toInternalAction, serializeableProxy, timeoutPromise, debounce } from './utils';
 import { BaseSession } from './BaseSession';
@@ -12,3 +12,3 @@ import { BaseJWTSession } from './BaseJWTSession';
 import { MEMBER_UPDATED_EVENTS, INTERNAL_MEMBER_UPDATED_EVENTS } from './types/videoMember';
-export { uuid, setLogger, getLogger, BaseSession, BaseJWTSession, BaseComponent, BaseConsumer, BaseClient, connect, configureStore, EventEmitter, extendComponent, validateEventsToSubscribe, getEventEmitter, isGlobalEvent, toExternalJSON, toSnakeCaseKeys, toLocalEvent, toInternalEventName, toInternalAction, serializeableProxy, toSyntheticEvent, GLOBAL_VIDEO_EVENTS, MEMBER_UPDATED_EVENTS, INTERNAL_MEMBER_UPDATED_EVENTS, findNamespaceInPayload, timeoutPromise, };
+export { uuid, setLogger, getLogger, BaseSession, BaseJWTSession, BaseComponent, BaseConsumer, BaseClient, connect, configureStore, EventEmitter, extendComponent, validateEventsToSubscribe, getEventEmitter, isGlobalEvent, toExternalJSON, toSnakeCaseKeys, toLocalEvent, toInternalEventName, toInternalAction, serializeableProxy, toSyntheticEvent, GLOBAL_VIDEO_EVENTS, MEMBER_UPDATED_EVENTS, INTERNAL_MEMBER_UPDATED_EVENTS, findNamespaceInPayload, timeoutPromise, debounce, };
 export * from './redux/features/component/componentSlice';
@@ -21,3 +21,3 @@ export * from './redux/features/session/sessionSlice';
 export * from './CustomErrors';
-export type { SessionState, CustomSagaParams, CustomSaga, PubSubChannel, PubSubAction, MapToPubSubShape, SDKActions, } from './redux/interfaces';
+export type { SessionState, CustomSagaParams, CustomSaga, PubSubChannel, PubSubAction, MapToPubSubShape, SDKActions, ReduxComponent, } from './redux/interfaces';
 export type { ToExternalJSONResult } from './utils';
@@ -32,3 +32,3 @@ export * as actions from './redux/actions';
 export * as MemberPosition from './memberPosition';
-export type { RoomSessionRecording, RoomSessionPlayback } from './rooms';
+export type { RoomSessionRecording, RoomSessionPlayback, RoomSessionStream, } from './rooms';
 export declare const selectors: {
@@ -35,0 +35,0 @@ getIceServers: ({ session }: import("./redux/interfaces").SDKState) => RTCIceServer[];

dist/core/src/memberPosition/workers.d.ts

@@ -5,6 +5,6 @@ import { sagaEffects, SDKWorker, SDKWorkerParams, VideoMemberUpdatedEventParams } from '..';
     action: any;
-}): Generator<sagaEffects.ChannelPutEffect<import("..").MapToPubSubShape<import("..").InternalVideoRoomJoinedEvent> | import("..").MapToPubSubShape<import("..").InternalVideoRoomAudienceCountEvent> | import("..").MapToPubSubShape<import("..").InternalVideoMemberUpdatedEvent> | import("..").MapToPubSubShape<import("..").InternalVideoMemberTalkingEvent> | import("..").MapToPubSubShape<import("..").VideoRoomStartedEvent> | import("..").MapToPubSubShape<import("..").VideoRoomSubscribedEvent> | import("..").MapToPubSubShape<import("..").VideoRoomUpdatedEvent> | import("..").MapToPubSubShape<import("..").VideoRoomEndedEvent> | import("..").MapToPubSubShape<import("..").VideoMemberJoinedEvent> | import("..").MapToPubSubShape<import("..").VideoMemberLeftEvent> | import("..").MapToPubSubShape<import("..").VideoMemberUpdatedEvent> | import("..").MapToPubSubShape<import("..").VideoMemberTalkingEvent> | import("..").MapToPubSubShape<import("..").VideoMemberPromotedEvent> | import("..").MapToPubSubShape<import("..").VideoMemberDemotedEvent> | import("..").MapToPubSubShape<import("..").VideoLayoutChangedEvent> | import("..").MapToPubSubShape<import("..").VideoRecordingStartedEvent> | import("..").MapToPubSubShape<import("..").VideoRecordingUpdatedEvent> | import("..").MapToPubSubShape<import("..").VideoRecordingEndedEvent> | import("..").MapToPubSubShape<import("..").VideoPlaybackStartedEvent> | import("..").MapToPubSubShape<import("..").VideoPlaybackUpdatedEvent> | import("..").MapToPubSubShape<import("..").VideoPlaybackEndedEvent> | import("..").MapToPubSubShape<import("..").VideoRoomAudienceCountEvent> | {
+}): Generator<sagaEffects.ChannelPutEffect<import("..").MapToPubSubShape<import("..").InternalVideoRoomJoinedEvent> | import("..").MapToPubSubShape<import("..").InternalVideoRoomAudienceCountEvent> | import("..").MapToPubSubShape<import("..").InternalVideoMemberUpdatedEvent> | import("..").MapToPubSubShape<import("..").InternalVideoMemberTalkingEvent> | import("..").MapToPubSubShape<import("..").VideoRoomStartedEvent> | import("..").MapToPubSubShape<import("..").VideoRoomSubscribedEvent> | import("..").MapToPubSubShape<import("..").VideoRoomUpdatedEvent> | import("..").MapToPubSubShape<import("..").VideoRoomEndedEvent> | import("..").MapToPubSubShape<import("..").VideoMemberJoinedEvent> | import("..").MapToPubSubShape<import("..").VideoMemberLeftEvent> | import("..").MapToPubSubShape<import("..").VideoMemberUpdatedEvent> | import("..").MapToPubSubShape<import("..").VideoMemberTalkingEvent> | import("..").MapToPubSubShape<import("..").VideoMemberPromotedEvent> | import("..").MapToPubSubShape<import("..").VideoMemberDemotedEvent> | import("..").MapToPubSubShape<import("..").VideoLayoutChangedEvent> | import("..").MapToPubSubShape<import("..").VideoRecordingStartedEvent> | import("..").MapToPubSubShape<import("..").VideoRecordingUpdatedEvent> | import("..").MapToPubSubShape<import("..").VideoRecordingEndedEvent> | import("..").MapToPubSubShape<import("..").VideoPlaybackStartedEvent> | import("..").MapToPubSubShape<import("..").VideoPlaybackUpdatedEvent> | import("..").MapToPubSubShape<import("..").VideoPlaybackEndedEvent> | import("..").MapToPubSubShape<import("..").VideoStreamStartedEvent> | import("..").MapToPubSubShape<import("..").VideoStreamEndedEvent> | import("..").MapToPubSubShape<import("..").VideoRoomAudienceCountEvent> | {
     type: "session.unknown" | "session.idle" | "session.reconnecting" | "session.connected" | "session.disconnected" | "session.auth_error" | "session.expiring";
     payload: Error | undefined;
-} | import("..").MapToPubSubShape<import("..").VideoManagerRoomsSubscribedEvent> | import("..").MapToPubSubShape<import("..").VideoManagerRoomEvent> | import("..").MapToPubSubShape<import("..").ChatChannelMessageEvent> | import("..").MapToPubSubShape<import("..").ChatMemberJoinedEvent> | import("..").MapToPubSubShape<import("..").ChatMemberUpdatedEvent> | import("..").MapToPubSubShape<import("..").ChatMemberLeftEvent> | import("..").MapToPubSubShape<import("..").PubSubChannelMessageEvent> | import("..").TaskAction | import("..").MapToPubSubShape<import("..").MessagingStateEvent> | import("..").MapToPubSubShape<import("..").MessageUpdatedEvent> | import("..").MapToPubSubShape<import("..").MessagingReceiveEvent> | import("..").MapToPubSubShape<import("..").MessageReceivedEvent> | import("..").MapToPubSubShape<import("..").CallingCallDialEvent> | import("..").MapToPubSubShape<import("..").CallingCallStateEvent> | import("..").MapToPubSubShape<import("..").CallingCallReceiveEvent> | import("..").MapToPubSubShape<import("..").CallingCallPlayEvent> | import("..").MapToPubSubShape<import("..").CallingCallRecordEvent> | import("..").MapToPubSubShape<import("..").CallingCallCollectEvent> | import("..").MapToPubSubShape<import("..").CallingCallTapEvent> | import("..").MapToPubSubShape<import("..").CallingCallConnectEvent> | import("..").MapToPubSubShape<import("..").CallingCallSendDigitsEvent> | import("..").MapToPubSubShape<import("..").CallingCallDetectEvent> | import("..").MapToPubSubShape<import("..").CallReceivedEvent> | import("..").MapToPubSubShape<import("..").CallPlaybackStartedEvent> | import("..").MapToPubSubShape<import("..").CallPlaybackUpdatedEvent> | import("..").MapToPubSubShape<import("..").CallPlaybackEndedEvent> | import("..").MapToPubSubShape<import("..").CallRecordingStartedEvent> | import("..").MapToPubSubShape<import("..").CallRecordingUpdatedEvent> | import("..").MapToPubSubShape<import("..").CallRecordingEndedEvent> | import("..").MapToPubSubShape<import("..").CallRecordingFailedEvent> | import("..").MapToPubSubShape<import("..").CallPromptStartedEvent> | import("..").MapToPubSubShape<import("..").CallPromptUpdatedEvent> | import("..").MapToPubSubShape<import("..").CallPromptEndedEvent> | import("..").MapToPubSubShape<import("..").CallPromptFailedEvent> | import("..").MapToPubSubShape<import("..").CallTapStartedEvent> | import("..").MapToPubSubShape<import("..").CallTapEndedEvent> | import("..").MapToPubSubShape<import("..").CallConnectConnectingEvent> | import("..").MapToPubSubShape<import("..").CallConnectConnectedEvent> | import("..").MapToPubSubShape<import("..").CallConnectDisconnectedEvent> | import("..").MapToPubSubShape<import("..").CallConnectFailedEvent> | import("..").MapToPubSubShape<import("..").CallDetectStartedEvent> | import("..").MapToPubSubShape<import("..").CallDetectUpdatedEvent> | import("..").MapToPubSubShape<import("..").CallDetectEndedEvent>>, void, unknown>;
+} | import("..").MapToPubSubShape<import("..").VideoManagerRoomsSubscribedEvent> | import("..").MapToPubSubShape<import("..").VideoManagerRoomEvent> | import("..").MapToPubSubShape<import("..").ChatChannelMessageEvent> | import("..").MapToPubSubShape<import("..").ChatMemberJoinedEvent> | import("..").MapToPubSubShape<import("..").ChatMemberUpdatedEvent> | import("..").MapToPubSubShape<import("..").ChatMemberLeftEvent> | import("..").MapToPubSubShape<import("..").PubSubChannelMessageEvent> | import("..").TaskAction | import("..").MapToPubSubShape<import("..").MessagingStateEvent> | import("..").MapToPubSubShape<import("..").MessageUpdatedEvent> | import("..").MapToPubSubShape<import("..").MessagingReceiveEvent> | import("..").MapToPubSubShape<import("..").MessageReceivedEvent> | import("..").MapToPubSubShape<import("..").CallingCallDialEvent> | import("..").MapToPubSubShape<import("..").CallingCallStateEvent> | import("..").MapToPubSubShape<import("..").CallingCallReceiveEvent> | import("..").MapToPubSubShape<import("..").CallingCallPlayEvent> | import("..").MapToPubSubShape<import("..").CallingCallRecordEvent> | import("..").MapToPubSubShape<import("..").CallingCallCollectEvent> | import("..").MapToPubSubShape<import("..").CallingCallTapEvent> | import("..").MapToPubSubShape<import("..").CallingCallConnectEvent> | import("..").MapToPubSubShape<import("..").CallingCallSendDigitsEvent> | import("..").MapToPubSubShape<import("..").CallingCallDetectEvent> | import("..").MapToPubSubShape<import("..").CallReceivedEvent> | import("..").MapToPubSubShape<import("..").CallPlaybackStartedEvent> | import("..").MapToPubSubShape<import("..").CallPlaybackUpdatedEvent> | import("..").MapToPubSubShape<import("..").CallPlaybackEndedEvent> | import("..").MapToPubSubShape<import("..").CallRecordingStartedEvent> | import("..").MapToPubSubShape<import("..").CallRecordingUpdatedEvent> | import("..").MapToPubSubShape<import("..").CallRecordingEndedEvent> | import("..").MapToPubSubShape<import("..").CallRecordingFailedEvent> | import("..").MapToPubSubShape<import("..").CallPromptStartedEvent> | import("..").MapToPubSubShape<import("..").CallPromptStartOfInputEvent> | import("..").MapToPubSubShape<import("..").CallPromptUpdatedEvent> | import("..").MapToPubSubShape<import("..").CallPromptEndedEvent> | import("..").MapToPubSubShape<import("..").CallPromptFailedEvent> | import("..").MapToPubSubShape<import("..").CallTapStartedEvent> | import("..").MapToPubSubShape<import("..").CallTapEndedEvent> | import("..").MapToPubSubShape<import("..").CallConnectConnectingEvent> | import("..").MapToPubSubShape<import("..").CallConnectConnectedEvent> | import("..").MapToPubSubShape<import("..").CallConnectDisconnectedEvent> | import("..").MapToPubSubShape<import("..").CallConnectFailedEvent> | import("..").MapToPubSubShape<import("..").CallDetectStartedEvent> | import("..").MapToPubSubShape<import("..").CallDetectUpdatedEvent> | import("..").MapToPubSubShape<import("..").CallDetectEndedEvent> | import("..").MapToPubSubShape<import("..").CallCollectStartedEvent> | import("..").MapToPubSubShape<import("..").CallCollectStartOfInputEvent> | import("..").MapToPubSubShape<import("..").CallCollectUpdatedEvent> | import("..").MapToPubSubShape<import("..").CallCollectEndedEvent> | import("..").MapToPubSubShape<import("..").CallCollectFailedEvent>>, void, unknown>;
 export declare const MEMBER_POSITION_COMPOUND_EVENTS: Map<any, any>;
@@ -11,0 +11,0 @@ export declare const memberPositionWorker: SDKWorker<any>;

dist/core/src/redux/actions.d.ts

@@ -7,3 +7,2 @@ import { createAction, Action } from './toolkit';
 export declare const destroyAction: import("./toolkit").ActionCreatorWithoutPayload<"swSdk/destroy">;
-export declare const closeConnectionAction: import("./toolkit").ActionCreatorWithoutPayload<"swSdk/closeConnection">;
 /**
@@ -24,4 +23,2 @@ * Used to trigger a `signalwire.reauthenticate`
 export declare const authExpiringAction: import("./toolkit").ActionCreatorWithoutPayload<"auth/expiring">;
-export declare const socketClosedAction: import("./toolkit").ActionCreatorWithoutPayload<"socket/closed">;
-export declare const socketErrorAction: import("./toolkit").ActionCreatorWithoutPayload<"socket/error">;
 export declare const socketMessageAction: import("./toolkit").ActionCreatorWithPayload<JSONRPCRequest, string>;
@@ -28,0 +25,0 @@ export declare const sessionConnectedAction: import("./toolkit").ActionCreatorWithoutPayload<"session.unknown" | "session.idle" | "session.reconnecting" | "session.connected" | "session.disconnected" | "session.auth_error" | "session.expiring">;

dist/core/src/redux/features/session/sessionSaga.d.ts

@@ -5,3 +5,4 @@ import { SagaIterator, EventChannel } from '@redux-saga/core';
 declare type SessionSagaParams = {
-    sessionChannel: EventChannel<unknown>;
+    session: BaseSession;
+    sessionChannel: EventChannel<any>;
     pubSubChannel: PubSubChannel;
@@ -17,5 +18,5 @@ swEventChannel: SwEventChannel;
 export declare function executeActionWatcher(session: BaseSession): SagaIterator;
-export declare function sessionChannelWatcher({ sessionChannel, pubSubChannel, swEventChannel, }: SessionSagaParams): SagaIterator;
-export declare function createSessionChannel(session: BaseSession): EventChannel<unknown>;
+export declare function sessionChannelWatcher({ sessionChannel, pubSubChannel, swEventChannel, session, }: SessionSagaParams): SagaIterator;
+export declare function createSessionChannel(session: BaseSession): EventChannel<import("@redux-saga/types").NotUndefined>;
 export {};
 //# sourceMappingURL=sessionSaga.d.ts.map

dist/core/src/redux/features/session/sessionSlice.d.ts

@@ -1,2 +0,2 @@
-import type { PayloadAction } from '../../toolkit';
+import type { PayloadAction, AnyAction } from '../../toolkit';
 import type { SessionState } from '../../interfaces';
@@ -22,12 +22,20 @@ import type { Authorization, RPCConnectResult, SessionAuthStatus } from '../../../utils/interfaces';
             readonly resource: string;
+            readonly join_as: "member" | "audience";
             readonly user_name: string;
             readonly room?: {
                 readonly name: string;
+                readonly display_name: string;
                 readonly scopes: readonly string[];
+                readonly meta: {
+                    readonly [x: string]: any;
+                };
             } | undefined;
             readonly signature: string;
             readonly expires_at?: number | undefined;
-            readonly media_allowed: import("../../../utils/interfaces").MediaAllowed;
-            readonly audio_allowed: import("../../../utils/interfaces").MediaDirectionAllowed;
-            readonly video_allowed: import("../../../utils/interfaces").MediaDirectionAllowed;
+            readonly media_allowed?: import("../../../utils/interfaces").MediaAllowed | undefined;
+            readonly audio_allowed: "none" | "receive" | "both";
+            readonly video_allowed: "none" | "receive" | "both";
+            readonly meta: {
+                readonly [x: string]: any;
+            };
         } | {
@@ -83,12 +91,20 @@ readonly type: "chat";
             readonly resource: string;
+            readonly join_as: "member" | "audience";
             readonly user_name: string;
             readonly room?: {
                 readonly name: string;
+                readonly display_name: string;
                 readonly scopes: readonly string[];
+                readonly meta: {
+                    readonly [x: string]: any;
+                };
             } | undefined;
             readonly signature: string;
             readonly expires_at?: number | undefined;
-            readonly media_allowed: import("../../../utils/interfaces").MediaAllowed;
-            readonly audio_allowed: import("../../../utils/interfaces").MediaDirectionAllowed;
-            readonly video_allowed: import("../../../utils/interfaces").MediaDirectionAllowed;
+            readonly media_allowed?: import("../../../utils/interfaces").MediaAllowed | undefined;
+            readonly audio_allowed: "none" | "receive" | "both";
+            readonly video_allowed: "none" | "receive" | "both";
+            readonly meta: {
+                readonly [x: string]: any;
+            };
         } | {
@@ -133,12 +149,20 @@ readonly type: "chat";
             readonly resource: string;
+            readonly join_as: "member" | "audience";
             readonly user_name: string;
             readonly room?: {
                 readonly name: string;
+                readonly display_name: string;
                 readonly scopes: readonly string[];
+                readonly meta: {
+                    readonly [x: string]: any;
+                };
             } | undefined;
             readonly signature: string;
             readonly expires_at?: number | undefined;
-            readonly media_allowed: import("../../../utils/interfaces").MediaAllowed;
-            readonly audio_allowed: import("../../../utils/interfaces").MediaDirectionAllowed;
-            readonly video_allowed: import("../../../utils/interfaces").MediaDirectionAllowed;
+            readonly media_allowed?: import("../../../utils/interfaces").MediaAllowed | undefined;
+            readonly audio_allowed: "none" | "receive" | "both";
+            readonly video_allowed: "none" | "receive" | "both";
+            readonly meta: {
+                readonly [x: string]: any;
+            };
         } | {
@@ -184,12 +208,20 @@ readonly type: "chat";
             readonly resource: string;
+            readonly join_as: "member" | "audience";
             readonly user_name: string;
             readonly room?: {
                 readonly name: string;
+                readonly display_name: string;
                 readonly scopes: readonly string[];
+                readonly meta: {
+                    readonly [x: string]: any;
+                };
             } | undefined;
             readonly signature: string;
             readonly expires_at?: number | undefined;
-            readonly media_allowed: import("../../../utils/interfaces").MediaAllowed;
-            readonly audio_allowed: import("../../../utils/interfaces").MediaDirectionAllowed;
-            readonly video_allowed: import("../../../utils/interfaces").MediaDirectionAllowed;
+            readonly media_allowed?: import("../../../utils/interfaces").MediaAllowed | undefined;
+            readonly audio_allowed: "none" | "receive" | "both";
+            readonly video_allowed: "none" | "receive" | "both";
+            readonly meta: {
+                readonly [x: string]: any;
+            };
         } | {
@@ -236,2 +268,3 @@ readonly type: "chat";
 }>, sessionReducer: import("redux").Reducer<{
+    readonly authStatus: SessionAuthStatus;
     readonly protocol: string;
@@ -244,3 +277,2 @@ readonly iceServers?: readonly {
     }[] | undefined;
-    readonly authStatus: SessionAuthStatus;
     readonly authState?: {
@@ -252,12 +284,20 @@ readonly type: "video";
         readonly resource: string;
+        readonly join_as: "member" | "audience";
         readonly user_name: string;
         readonly room?: {
             readonly name: string;
+            readonly display_name: string;
             readonly scopes: readonly string[];
+            readonly meta: {
+                readonly [x: string]: any;
+            };
         } | undefined;
         readonly signature: string;
         readonly expires_at?: number | undefined;
-        readonly media_allowed: import("../../../utils/interfaces").MediaAllowed;
-        readonly audio_allowed: import("../../../utils/interfaces").MediaDirectionAllowed;
-        readonly video_allowed: import("../../../utils/interfaces").MediaDirectionAllowed;
+        readonly media_allowed?: import("../../../utils/interfaces").MediaAllowed | undefined;
+        readonly audio_allowed: "none" | "receive" | "both";
+        readonly video_allowed: "none" | "receive" | "both";
+        readonly meta: {
+            readonly [x: string]: any;
+        };
     } | {
@@ -287,3 +327,3 @@ readonly type: "chat";
     readonly authCount: number;
-}, import("redux").AnyAction>;
+}, AnyAction>;
 //# sourceMappingURL=sessionSlice.d.ts.map

dist/core/src/redux/index.d.ts

@@ -17,3 +17,3 @@ import { Saga, Task } from '@redux-saga/core';
         runSaga: any;
-    }) => Task;
+    }) => Task<any>;
     dispatch: import("redux").Dispatch<import("redux").AnyAction>;
@@ -20,0 +20,0 @@ getState(): any;

dist/core/src/redux/rootReducer.d.ts

@@ -395,2 +395,3 @@ export declare const rootReducer: import("redux").Reducer<import("redux").CombinedState<{
     session: {
+        readonly authStatus: import("..").SessionAuthStatus;
         readonly protocol: string;
@@ -403,3 +404,2 @@ readonly iceServers?: readonly {
         }[] | undefined;
-        readonly authStatus: import("..").SessionAuthStatus;
         readonly authState?: {
@@ -411,12 +411,20 @@ readonly type: "video";
             readonly resource: string;
+            readonly join_as: "member" | "audience";
             readonly user_name: string;
             readonly room?: {
                 readonly name: string;
+                readonly display_name: string;
                 readonly scopes: readonly string[];
+                readonly meta: {
+                    readonly [x: string]: any;
+                };
             } | undefined;
             readonly signature: string;
             readonly expires_at?: number | undefined;
-            readonly media_allowed: import("..").MediaAllowed;
-            readonly audio_allowed: import("..").MediaDirectionAllowed;
-            readonly video_allowed: import("..").MediaDirectionAllowed;
+            readonly media_allowed?: import("..").MediaAllowed | undefined;
+            readonly audio_allowed: "none" | "receive" | "both";
+            readonly video_allowed: "none" | "receive" | "both";
+            readonly meta: {
+                readonly [x: string]: any;
+            };
         } | {
@@ -423,0 +431,0 @@ readonly type: "chat";

dist/core/src/redux/rootSaga.d.ts

@@ -8,3 +8,3 @@ import type { SagaIterator } from '@redux-saga/types';
     session: BaseSession;
-    sessionChannel: EventChannel<unknown>;
+    sessionChannel: EventChannel<any>;
     pubSubChannel: PubSubChannel;
@@ -18,10 +18,2 @@ userOptions: InternalUserOptions;
 }): SagaIterator;
-export declare function socketClosedWorker({ session, sessionChannel, pubSubChannel, }: {
-    session: BaseSession;
-    sessionChannel: EventChannel<unknown>;
-    pubSubChannel: PubSubChannel;
-}): Generator<import("@redux-saga/core/effects").ChannelPutEffect<import("./interfaces").MapToPubSubShape<import("..").InternalVideoRoomJoinedEvent> | import("./interfaces").MapToPubSubShape<import("..").InternalVideoRoomAudienceCountEvent> | import("./interfaces").MapToPubSubShape<import("..").InternalVideoMemberUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").InternalVideoMemberTalkingEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRoomStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRoomSubscribedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRoomUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRoomEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberJoinedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberLeftEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberTalkingEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberPromotedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberDemotedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoLayoutChangedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRecordingStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRecordingUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRecordingEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoPlaybackStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoPlaybackUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoPlaybackEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRoomAudienceCountEvent> | {
-    type: "session.unknown" | "session.idle" | "session.reconnecting" | "session.connected" | "session.disconnected" | "session.auth_error" | "session.expiring";
-    payload: Error | undefined;
-} | import("./interfaces").MapToPubSubShape<import("..").VideoManagerRoomsSubscribedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoManagerRoomEvent> | import("./interfaces").MapToPubSubShape<import("..").ChatChannelMessageEvent> | import("./interfaces").MapToPubSubShape<import("..").ChatMemberJoinedEvent> | import("./interfaces").MapToPubSubShape<import("..").ChatMemberUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").ChatMemberLeftEvent> | import("./interfaces").MapToPubSubShape<import("..").PubSubChannelMessageEvent> | import("..").TaskAction | import("./interfaces").MapToPubSubShape<import("..").MessagingStateEvent> | import("./interfaces").MapToPubSubShape<import("..").MessageUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").MessagingReceiveEvent> | import("./interfaces").MapToPubSubShape<import("..").MessageReceivedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallDialEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallStateEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallReceiveEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallPlayEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallRecordEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallCollectEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallTapEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallConnectEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallSendDigitsEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallDetectEvent> | import("./interfaces").MapToPubSubShape<import("..").CallReceivedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPlaybackStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPlaybackUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPlaybackEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallRecordingStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallRecordingUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallRecordingEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallRecordingFailedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPromptStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPromptUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPromptEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPromptFailedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallTapStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallTapEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallConnectConnectingEvent> | import("./interfaces").MapToPubSubShape<import("..").CallConnectConnectedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallConnectDisconnectedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallConnectFailedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallDetectStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallDetectUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallDetectEndedEvent>> | import("@redux-saga/core/effects").CallEffect<void> | import("@redux-saga/core/effects").CallEffect<true>, void, unknown>;
 export declare function reauthenticateWorker({ session, token, pubSubChannel, }: {
@@ -31,13 +23,10 @@ session: BaseSession;
     pubSubChannel: PubSubChannel;
-}): Generator<import("@redux-saga/core/effects").ChannelPutEffect<import("./interfaces").MapToPubSubShape<import("..").InternalVideoRoomJoinedEvent> | import("./interfaces").MapToPubSubShape<import("..").InternalVideoRoomAudienceCountEvent> | import("./interfaces").MapToPubSubShape<import("..").InternalVideoMemberUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").InternalVideoMemberTalkingEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRoomStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRoomSubscribedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRoomUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRoomEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberJoinedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberLeftEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberTalkingEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberPromotedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberDemotedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoLayoutChangedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRecordingStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRecordingUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRecordingEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoPlaybackStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoPlaybackUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoPlaybackEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRoomAudienceCountEvent> | {
+}): Generator<import("@redux-saga/core/effects").ChannelPutEffect<import("./interfaces").MapToPubSubShape<import("..").InternalVideoRoomJoinedEvent> | import("./interfaces").MapToPubSubShape<import("..").InternalVideoRoomAudienceCountEvent> | import("./interfaces").MapToPubSubShape<import("..").InternalVideoMemberUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").InternalVideoMemberTalkingEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRoomStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRoomSubscribedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRoomUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRoomEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberJoinedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberLeftEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberTalkingEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberPromotedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoMemberDemotedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoLayoutChangedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRecordingStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRecordingUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRecordingEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoPlaybackStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoPlaybackUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoPlaybackEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoStreamStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoStreamEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoRoomAudienceCountEvent> | {
     type: "session.unknown" | "session.idle" | "session.reconnecting" | "session.connected" | "session.disconnected" | "session.auth_error" | "session.expiring";
     payload: Error | undefined;
-} | import("./interfaces").MapToPubSubShape<import("..").VideoManagerRoomsSubscribedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoManagerRoomEvent> | import("./interfaces").MapToPubSubShape<import("..").ChatChannelMessageEvent> | import("./interfaces").MapToPubSubShape<import("..").ChatMemberJoinedEvent> | import("./interfaces").MapToPubSubShape<import("..").ChatMemberUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").ChatMemberLeftEvent> | import("./interfaces").MapToPubSubShape<import("..").PubSubChannelMessageEvent> | import("..").TaskAction | import("./interfaces").MapToPubSubShape<import("..").MessagingStateEvent> | import("./interfaces").MapToPubSubShape<import("..").MessageUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").MessagingReceiveEvent> | import("./interfaces").MapToPubSubShape<import("..").MessageReceivedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallDialEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallStateEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallReceiveEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallPlayEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallRecordEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallCollectEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallTapEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallConnectEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallSendDigitsEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallDetectEvent> | import("./interfaces").MapToPubSubShape<import("..").CallReceivedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPlaybackStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPlaybackUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPlaybackEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallRecordingStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallRecordingUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallRecordingEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallRecordingFailedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPromptStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPromptUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPromptEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPromptFailedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallTapStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallTapEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallConnectConnectingEvent> | import("./interfaces").MapToPubSubShape<import("..").CallConnectConnectedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallConnectDisconnectedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallConnectFailedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallDetectStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallDetectUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallDetectEndedEvent>> | import("@redux-saga/core/effects").CallEffect<void> | import("@redux-saga/core/effects").PutEffect<{
-    payload: {
-        error: import("../utils/interfaces").SessionAuthError;
-    };
+} | import("./interfaces").MapToPubSubShape<import("..").VideoManagerRoomsSubscribedEvent> | import("./interfaces").MapToPubSubShape<import("..").VideoManagerRoomEvent> | import("./interfaces").MapToPubSubShape<import("..").ChatChannelMessageEvent> | import("./interfaces").MapToPubSubShape<import("..").ChatMemberJoinedEvent> | import("./interfaces").MapToPubSubShape<import("..").ChatMemberUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").ChatMemberLeftEvent> | import("./interfaces").MapToPubSubShape<import("..").PubSubChannelMessageEvent> | import("..").TaskAction | import("./interfaces").MapToPubSubShape<import("..").MessagingStateEvent> | import("./interfaces").MapToPubSubShape<import("..").MessageUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").MessagingReceiveEvent> | import("./interfaces").MapToPubSubShape<import("..").MessageReceivedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallDialEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallStateEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallReceiveEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallPlayEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallRecordEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallCollectEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallTapEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallConnectEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallSendDigitsEvent> | import("./interfaces").MapToPubSubShape<import("..").CallingCallDetectEvent> | import("./interfaces").MapToPubSubShape<import("..").CallReceivedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPlaybackStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPlaybackUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPlaybackEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallRecordingStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallRecordingUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallRecordingEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallRecordingFailedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPromptStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPromptStartOfInputEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPromptUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPromptEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallPromptFailedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallTapStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallTapEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallConnectConnectingEvent> | import("./interfaces").MapToPubSubShape<import("..").CallConnectConnectedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallConnectDisconnectedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallConnectFailedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallDetectStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallDetectUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallDetectEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallCollectStartedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallCollectStartOfInputEvent> | import("./interfaces").MapToPubSubShape<import("..").CallCollectUpdatedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallCollectEndedEvent> | import("./interfaces").MapToPubSubShape<import("..").CallCollectFailedEvent>> | import("@redux-saga/core/effects").CallEffect<void> | import("@redux-saga/core/effects").PutEffect<{
+    payload: import("../utils/interfaces").RPCConnectResult;
     type: string;
 }>, void, unknown>;
 export declare function sessionStatusWatcher(options: StartSagaOptions): SagaIterator;
-export declare function startSaga(options: StartSagaOptions): SagaIterator;
 interface SessionAuthErrorOptions extends StartSagaOptions {
@@ -44,0 +33,0 @@ action: any;

dist/core/src/rooms/index.d.ts

@@ -10,2 +10,3 @@ import { BaseComponent, EventEmitter } from '..';
 export * from './RoomSessionPlayback';
+export * from './RoomSessionStream';
 //# sourceMappingURL=index.d.ts.map

dist/core/src/rooms/methods.d.ts

@@ -1,4 +0,4 @@
-import type { BaseRoomInterface, RoomSessionRecording, RoomSessionPlayback } from '.';
+import type { BaseRoomInterface, RoomSessionRecording, RoomSessionPlayback, RoomSessionStream } from '.';
 import type { VideoMemberEntity, MemberCommandParams, VideoPosition } from '../types';
-import type { MediaAllowed } from '../utils/interfaces';
+import type { MediaAllowed, VideoMeta } from '../utils/interfaces';
 declare type RoomMethodParams = Record<string, unknown>;
@@ -55,2 +55,6 @@ interface RoomMethodPropertyDescriptor<OutputType, ParamsType> extends PropertyDescriptor {
 export declare const play: RoomMethodDescriptor<any, PlayParams>;
+interface GetMetaOutput {
+    meta: VideoMeta;
+}
+export declare const getMeta: RoomMethodDescriptor<GetMetaOutput, RoomMethodParams>;
 export interface SetMetaParams extends Record<string, unknown> {
@@ -64,2 +68,10 @@ }
 export declare const deleteMeta: RoomMethodDescriptor<any, DeleteMetaParams>;
+export interface GetStreamsOutput {
+    streams: RoomSessionStream[];
+}
+export declare const getStreams: RoomMethodDescriptor<GetStreamsOutput>;
+export interface StartStreamParams {
+    url: string;
+}
+export declare const startStream: RoomMethodDescriptor<any, StartStreamParams>;
 export declare type GetLayouts = ReturnType<typeof getLayouts.value>;
@@ -74,5 +86,8 @@ export declare type GetMembers = ReturnType<typeof getMembers.value>;
 export declare type Play = ReturnType<typeof play.value>;
+export declare type GetMeta = ReturnType<typeof getMeta.value>;
 export declare type SetMeta = ReturnType<typeof setMeta.value>;
 export declare type UpdateMeta = ReturnType<typeof updateMeta.value>;
 export declare type DeleteMeta = ReturnType<typeof deleteMeta.value>;
+export declare type GetStreams = ReturnType<typeof getStreams.value>;
+export declare type StartStream = ReturnType<typeof startStream.value>;
 /**
@@ -93,5 +108,8 @@ * Room Member Methods
     mediaAllowed?: MediaAllowed;
-    permissions?: string[];
 }
 export interface PromoteMemberParams extends PromoteDemoteMemberParams {
+    permissions?: string[];
+    meta?: VideoMeta;
+    joinAudioMuted?: boolean;
+    joinVideoMuted?: boolean;
 }
@@ -101,3 +119,3 @@ export declare const promote: RoomMethodDescriptor<void, PromoteMemberParams>;
 }
-export declare const demote: RoomMethodDescriptor<unknown, PromoteDemoteMemberParams>;
+export declare const demote: RoomMethodDescriptor<void, DemoteMemberParams>;
 export interface SetMemberPositionParams extends MemberCommandParams {
@@ -109,8 +127,12 @@ position: VideoPosition;
 export declare const removeAllMembers: RoomMethodDescriptor<void, void>;
+interface GetMemberMetaOutput {
+    meta: VideoMeta;
+}
+export declare const getMemberMeta: RoomMethodDescriptor<GetMemberMetaOutput, RoomMemberMethodParams>;
 export interface SetMemberMetaParams extends MemberCommandParams {
-    meta: Record<string, unknown>;
+    meta: VideoMeta;
 }
 export declare const setMemberMeta: RoomMethodDescriptor<void, RoomMemberMethodParams>;
 export interface UpdateMemberMetaParams extends MemberCommandParams {
-    meta: Record<string, unknown>;
+    meta: VideoMeta;
 }
@@ -137,2 +159,3 @@ export declare const updateMemberMeta: RoomMethodDescriptor<void, RoomMemberMethodParams>;
 export declare type RemoveAllMembers = ReturnType<typeof removeAllMembers.value>;
+export declare type GetMemberMeta = ReturnType<typeof getMemberMeta.value>;
 export declare type SetMemberMeta = ReturnType<typeof setMemberMeta.value>;
@@ -139,0 +162,0 @@ export declare type UpdateMemberMeta = ReturnType<typeof updateMemberMeta.value>;

dist/core/src/RPCMessages/RPCConnect.d.ts

@@ -17,2 +17,3 @@ declare type WithToken = {
     protocol?: string;
+    authorization_state?: string;
     contexts?: string[];
@@ -19,0 +20,0 @@ };

dist/core/src/RPCMessages/RPCPing.d.ts

@@ -9,3 +9,3 @@ export declare const RPCPing: () => {
 };
-export declare const RPCPingResponse: (id: string, timestamp?: number | undefined) => {
+export declare const RPCPingResponse: (id: string, timestamp?: number) => {
     id: string;
@@ -12,0 +12,0 @@ result: {

dist/core/src/testUtils.d.ts

@@ -13,7 +13,7 @@ /// <reference types="jest" />
  */
-export declare const configureJestStore: (options?: Partial<ConfigureStoreOptions> | undefined) => {
+export declare const configureJestStore: (options?: Partial<ConfigureStoreOptions>) => {
     runSaga: <T>(saga: import("@redux-saga/types").Saga<any[]>, args: {
         instance: T;
         runSaga: any;
-    }) => import("@redux-saga/types").Task;
+    }) => import("@redux-saga/types").Task<any>;
     dispatch: import("redux").Dispatch<import("redux").AnyAction>;
@@ -37,3 +37,3 @@ getState(): any;
             runSaga: any;
-        }) => import("@redux-saga/types").Task;
+        }) => import("@redux-saga/types").Task<any>;
         dispatch: import("redux").Dispatch<import("redux").AnyAction>;
@@ -40,0 +40,0 @@ getState(): any;

dist/core/src/types/index.d.ts

@@ -27,2 +27,4 @@ import type { EventEmitter } from '../utils/EventEmitter';
 export interface BaseConnectionContract<EventTypes extends EventEmitter.ValidEventTypes> extends EmitterContract<EventTypes> {
+    /** @internal The BaseConnection options  */
+    readonly options: Record<any, any>;
     /** The id of the video device, or null if not available */
@@ -54,2 +56,4 @@ readonly cameraId: string | null;
     readonly roomId: string;
+    /** @internal The underlying connection id - callId  */
+    readonly callId: string;
     /** The unique identifier for the room session */
@@ -135,3 +139,10 @@ readonly roomSessionId: string;
 }
-export declare type SwEventParams = VideoAPIEventParams | WebRTCMessageParams | VideoManagerEvent | ChatEvent | TaskEvent | MessagingEvent | VoiceCallEvent;
+export declare type SwAuthorizationState = string;
+export interface SwAuthorizationStateParams {
+    event_type: 'signalwire.authorization.state';
+    params: {
+        authorization_state: SwAuthorizationState;
+    };
+}
+export declare type SwEventParams = VideoAPIEventParams | WebRTCMessageParams | VideoManagerEvent | ChatEvent | TaskEvent | MessagingEvent | VoiceCallEvent | SwAuthorizationStateParams;
 export declare type PubSubChannelEvents = InternalVideoEventNames | SessionEvents;
@@ -138,0 +149,0 @@ export * from './video';

dist/core/src/types/video.d.ts

@@ -6,2 +6,3 @@ import { VideoRoomEvent, InternalVideoRoomSessionEventNames, InternalVideoRoomEvent } from './videoRoomSession';
 import { VideoPlaybackEvent, InternalVideoPlaybackEventNames } from './videoPlayback';
+import { VideoStreamEvent, InternalVideoStreamEventNames } from './videoStream';
 import { VideoRoomAudienceCountEvent } from '.';
@@ -14,2 +15,3 @@ import { MapToPubSubShape } from '..';
 export * from './videoPlayback';
+export * from './videoStream';
 export declare type RTCTrackEventName = 'track';
@@ -56,6 +58,6 @@ /**
  */
-export declare type InternalVideoEventNames = InternalVideoRoomSessionEventNames | InternalVideoMemberEventNames | InternalVideoLayoutEventNames | InternalVideoRecordingEventNames | InternalVideoPlaybackEventNames | RTCTrackEventName;
+export declare type InternalVideoEventNames = InternalVideoRoomSessionEventNames | InternalVideoMemberEventNames | InternalVideoLayoutEventNames | InternalVideoRecordingEventNames | InternalVideoPlaybackEventNames | InternalVideoStreamEventNames | RTCTrackEventName;
 export declare type InternalVideoAPIEvent = InternalVideoRoomEvent | InternalVideoMemberEvent;
-export declare type VideoAPIEventParams = VideoRoomEvent | VideoMemberEvent | VideoLayoutEvent | VideoRecordingEvent | VideoPlaybackEvent | VideoRoomAudienceCountEvent;
+export declare type VideoAPIEventParams = VideoRoomEvent | VideoMemberEvent | VideoLayoutEvent | VideoRecordingEvent | VideoPlaybackEvent | VideoStreamEvent | VideoRoomAudienceCountEvent;
 export declare type VideoAction = MapToPubSubShape<InternalVideoAPIEvent | VideoAPIEventParams | VideoRoomAudienceCountEvent>;
 //# sourceMappingURL=video.d.ts.map

dist/core/src/types/videoRoomSession.d.ts

@@ -62,2 +62,6 @@ import type { SwEvent } from '.';
     updated?: Array<Exclude<keyof VideoRoomSessionContract, 'updated'>>;
+    /** Whether the room is streaming */
+    streaming: boolean;
+    /** List of active streams in the room session. */
+    streams?: Rooms.RoomSessionStream[];
     /**
@@ -580,2 +584,11 @@ * Puts the microphone on mute. The other participants will not hear audio
     setMeta(params: Rooms.SetMetaParams): Rooms.SetMeta;
+    /**
+     * Retrieve the custom metadata for the RoomSession.
+     *
+     * @example
+     * ```js
+     * const { meta } = await roomSession.getMeta()
+     * ```
+     */
+    getMeta(): Rooms.GetMeta;
     updateMeta(params: Rooms.UpdateMetaParams): Rooms.UpdateMeta;
@@ -625,2 +638,13 @@ deleteMeta(params: Rooms.DeleteMetaParams): Rooms.DeleteMeta;
     setMemberMeta(params: Rooms.SetMemberMetaParams): Rooms.SetMemberMeta;
+    /**
+     * Retrieve the custom metadata for the specified RoomSession member.
+     *
+     * @param params.memberId Id of the member to retrieve the meta. If omitted, fallback to the current memberId.
+     *
+     * @example
+     * ```js
+     * const { meta } = await roomSession.getMemberMeta({ memberId: 'de550c0c-3fac-4efd-b06f-b5b8614b8966' })
+     * ```
+     */
+    getMemberMeta(params?: MemberCommandParams): Rooms.GetMemberMeta;
     updateMemberMeta(params: Rooms.UpdateMemberMetaParams): Rooms.UpdateMemberMeta;
@@ -630,2 +654,36 @@ deleteMemberMeta(params: Rooms.DeleteMemberMetaParams): Rooms.DeleteMemberMeta;
     demote(params: Rooms.DemoteMemberParams): Rooms.DemoteMember;
+    /**
+     * Obtains a list of streams for the current room session.
+     *
+     * @permissions
+     *  - `room.stream`
+     *
+     * You need to specify the permissions when [creating the Video Room
+     * Token](https://developer.signalwire.com/apis/reference/create_room_token)
+     * on the server side.
+     *
+     * @example
+     * ```typescript
+     * await room.getStreams()
+     * ```
+     */
+    getStreams(): Rooms.GetStreams;
+    /**
+     * Starts to stream the room to the provided URL. You can use the returned
+     * {@link RoomSessionStream} object to then stop the stream.
+     *
+     * @permissions
+     *  - `room.stream.start` or `room.stream`
+     *
+     * You need to specify the permissions when [creating the Video Room
+     * Token](https://developer.signalwire.com/apis/reference/create_room_token)
+     * on the server side.
+     *
+     * @example
+     * ```typescript
+     * const stream = await room.startStream({ url: 'rtmp://example.com' })
+     * await stream.stop()
+     * ```
+     */
+    startStream(params: Rooms.StartStreamParams): Promise<Rooms.RoomSessionStream>;
 }
@@ -632,0 +690,0 @@ /**

dist/core/src/types/voiceCall.d.ts

@@ -35,5 +35,11 @@ import type { SwEvent } from '.';
 export declare type CallPromptStarted = 'prompt.started';
+export declare type CallPromptStartOfInput = 'prompt.startOfInput';
 export declare type CallPromptUpdated = 'prompt.updated';
 export declare type CallPromptEnded = 'prompt.ended';
 export declare type CallPromptFailed = 'prompt.failed';
+export declare type CallCollectStarted = 'collect.started';
+export declare type CallCollectStartOfInput = 'collect.startOfInput';
+export declare type CallCollectUpdated = 'collect.updated';
+export declare type CallCollectEnded = 'collect.ended';
+export declare type CallCollectFailed = 'collect.failed';
 export declare type CallTapStarted = 'tap.started';
@@ -51,3 +57,3 @@ export declare type CallTapEnded = 'tap.ended';
  */
-export declare type VoiceCallEventNames = CallCreated | CallEnded | CallPlaybackStarted | CallPlaybackUpdated | CallPlaybackEnded | CallRecordingStarted | CallRecordingUpdated | CallRecordingEnded | CallRecordingFailed | CallPromptStarted | CallPromptUpdated | CallPromptEnded | CallPromptFailed | CallTapStarted | CallTapEnded | CallConnectConnecting | CallConnectConnected | CallConnectDisconnected | CallConnectFailed | CallDetectStarted | CallDetectUpdated | CallDetectEnded;
+export declare type VoiceCallEventNames = CallCreated | CallEnded | CallPlaybackStarted | CallPlaybackUpdated | CallPlaybackEnded | CallRecordingStarted | CallRecordingUpdated | CallRecordingEnded | CallRecordingFailed | CallPromptStarted | CallPromptUpdated | CallPromptEnded | CallPromptFailed | CallTapStarted | CallTapEnded | CallConnectConnecting | CallConnectConnected | CallConnectDisconnected | CallConnectFailed | CallDetectStarted | CallDetectUpdated | CallDetectEnded | CallCollectStarted | CallCollectUpdated | CallCollectEnded | CallCollectFailed;
 /**
@@ -77,2 +83,3 @@ * List of internal events
     webrtcMedia?: boolean;
+    sessionTimeout?: number;
 }
@@ -139,2 +146,3 @@ export interface NestedArray<T> extends Array<T | NestedArray<T>> {
         terminators?: string;
+        inputSensitivity?: number;
     };
@@ -156,3 +164,3 @@ }
     /** Language to detect. Default to `en-US`. */
-    language?: number;
+    language?: string;
     /** Array of expected phrases to detect. */
@@ -214,2 +222,9 @@ hints?: string[];
 }
+export declare type VoiceCallCollectMethodParams = SpeechOrDigits & {
+    initialTimeout?: number;
+    partialResults?: boolean;
+    continuous: boolean;
+    sendStartOfInput: boolean;
+    startInputTimers: boolean;
+};
 export declare type VoiceCallConnectMethodParams = VoiceDeviceBuilder | {
@@ -285,3 +300,7 @@ devices: VoiceDeviceBuilder;
     setVolume(volume: number): Promise<this>;
+    /**
+     * @deprecated use {@link ended} instead.
+     */
     waitForEnded(): Promise<this>;
+    ended(): Promise<this>;
 }
@@ -315,2 +334,3 @@ /**
     stop(): Promise<this>;
+    ended(): Promise<this>;
 }
@@ -338,3 +358,7 @@ /**
     stop(): Promise<this>;
+    /**
+     * @deprecated use {@link ended} instead.
+     */
     waitForResult(): Promise<this>;
+    ended(): Promise<this>;
 }
@@ -368,3 +392,7 @@ /**
     setVolume(volume: number): Promise<this>;
+    /**
+     * @deprecated use {@link ended} instead.
+     */
     waitForResult(): Promise<VoiceCallPromptContract>;
+    ended(): Promise<this>;
 }
@@ -380,2 +408,31 @@ /**
 /**
+ * Public Contract for a VoiceCallCollect
+ */
+export interface VoiceCallCollectContract {
+    /** Unique id for this recording */
+    readonly id: string;
+    /** @ignore */
+    readonly callId: string;
+    /** @ignore */
+    readonly controlId: string;
+    readonly type?: CallingCallCollectResult['type'];
+    /** Alias for type in case of errors */
+    readonly reason?: string;
+    readonly digits?: string;
+    readonly terminator?: string;
+    readonly text?: string;
+    readonly confidence?: number;
+    stop(): Promise<this>;
+    startInputTimers(): Promise<this>;
+    ended(): Promise<this>;
+}
+/**
+ * VoiceCallCollect properties
+ */
+export declare type VoiceCallCollectEntity = OnlyStateProperties<VoiceCallCollectContract>;
+/**
+ * VoiceCallCollect methods
+ */
+export declare type VoiceCallCollectMethods = OnlyFunctionProperties<VoiceCallCollectContract>;
+/**
  * Public Contract for a VoiceCallTap
@@ -393,2 +450,3 @@ */
     stop(): Promise<this>;
+    ended(): Promise<this>;
 }
@@ -426,2 +484,4 @@ /**
     headers?: SipHeader[];
+    active: boolean;
+    connected: boolean;
     dial(params: VoiceDialerParams): Promise<T>;
@@ -447,3 +507,26 @@ hangup(reason?: VoiceCallDisconnectReason): Promise<void>;
     connectSip(params: VoiceCallConnectSipMethodParams): Promise<VoiceCallContract>;
+    /**
+     * @deprecated use {@link disconnected} instead.
+     */
     waitForDisconnected(): Promise<this>;
+    /**
+     * Returns a promise that is resolved only after the current call has been
+     * disconnected. Also see {@link connect}.
+     *
+     * @example
+     *
+     * ```js
+     * const plan = new Voice.DeviceBuilder().add(
+     *   Voice.DeviceBuilder.Sip({
+     *     from: 'sip:[e-mail]',
+     *     to: 'sip:[e-mail]',
+     *     timeout: 30,
+     *   })
+     * )
+     *
+     * const peer = await call.connect(plan)
+     * await call.disconnected()
+     * ```
+     */
+    disconnected(): Promise<this>;
     waitFor(params: CallingCallWaitForState | CallingCallWaitForState[]): Promise<boolean>;
@@ -453,4 +536,6 @@ disconnect(): Promise<void>;
     amd(params?: Omit<VoiceCallDetectMachineParams, 'type'>): Promise<VoiceCallDetectContract>;
+    detectAnsweringMachine(params?: Omit<VoiceCallDetectMachineParams, 'type'>): Promise<VoiceCallDetectContract>;
     detectFax(params?: Omit<VoiceCallDetectFaxParams, 'type'>): Promise<VoiceCallDetectContract>;
     detectDigit(params?: Omit<VoiceCallDetectDigitParams, 'type'>): Promise<VoiceCallDetectContract>;
+    collect(params: VoiceCallCollectMethodParams): Promise<VoiceCallCollectContract>;
 }
@@ -609,2 +694,5 @@ /**
 }
+interface CallingCallCollectResultStartOfInput {
+    type: 'start_of_input';
+}
 interface CallingCallCollectResultDigit {
@@ -624,3 +712,3 @@ type: 'digit';
 }
-export declare type CallingCallCollectResult = CallingCallCollectResultError | CallingCallCollectResultNoInput | CallingCallCollectResultNoMatch | CallingCallCollectResultDigit | CallingCallCollectResultSpeech;
+export declare type CallingCallCollectResult = CallingCallCollectResultError | CallingCallCollectResultNoInput | CallingCallCollectResultNoMatch | CallingCallCollectResultStartOfInput | CallingCallCollectResultDigit | CallingCallCollectResultSpeech;
 export interface CallingCallCollectEventParams {
@@ -832,2 +920,12 @@ node_id: string;
 /**
+ * 'calling.prompt.startOfInput'
+ * Different from `started` because it's from the server
+ */
+export interface CallPromptStartOfInputEvent extends SwEvent {
+    event_type: ToInternalVoiceEvent<CallPromptStartOfInput>;
+    params: CallingCallCollectEventParams & {
+        tag: string;
+    };
+}
+/**
  * 'calling.prompt.updated'
@@ -932,8 +1030,54 @@ */
 }
-export declare type VoiceCallEvent = CallingCallDialEvent | CallingCallStateEvent | CallingCallReceiveEvent | CallingCallPlayEvent | CallingCallRecordEvent | CallingCallCollectEvent | CallingCallTapEvent | CallingCallConnectEvent | CallingCallSendDigitsEvent | CallingCallDetectEvent | CallReceivedEvent | CallPlaybackStartedEvent | CallPlaybackUpdatedEvent | CallPlaybackEndedEvent | CallRecordingStartedEvent | CallRecordingUpdatedEvent | CallRecordingEndedEvent | CallRecordingFailedEvent | CallPromptStartedEvent | CallPromptUpdatedEvent | CallPromptEndedEvent | CallPromptFailedEvent | CallTapStartedEvent | CallTapEndedEvent | CallConnectConnectingEvent | CallConnectConnectedEvent | CallConnectDisconnectedEvent | CallConnectFailedEvent | CallDetectStartedEvent | CallDetectUpdatedEvent | CallDetectEndedEvent;
-export declare type VoiceCallEventParams = CallingCallDialEventParams | CallingCallStateEventParams | CallingCallReceiveEventParams | CallingCallPlayEventParams | CallingCallRecordEventParams | CallingCallCollectEventParams | CallingCallTapEventParams | CallingCallConnectEventParams | CallingCallSendDigitsEventParams | CallingCallDetectEventParams | CallReceivedEvent['params'] | CallPlaybackStartedEvent['params'] | CallPlaybackUpdatedEvent['params'] | CallPlaybackEndedEvent['params'] | CallRecordingStartedEvent['params'] | CallRecordingUpdatedEvent['params'] | CallRecordingEndedEvent['params'] | CallRecordingFailedEvent['params'] | CallPromptStartedEvent['params'] | CallPromptUpdatedEvent['params'] | CallPromptEndedEvent['params'] | CallPromptFailedEvent['params'] | CallTapStartedEvent['params'] | CallTapEndedEvent['params'] | CallConnectConnectingEvent['params'] | CallConnectConnectedEvent['params'] | CallConnectDisconnectedEvent['params'] | CallConnectFailedEvent['params'] | CallDetectStartedEvent['params'] | CallDetectUpdatedEvent['params'] | CallDetectEndedEvent['params'];
+/**
+ * 'calling.collect.started'
+ */
+export interface CallCollectStartedEvent extends SwEvent {
+    event_type: ToInternalVoiceEvent<CallCollectStarted>;
+    params: CallingCallCollectEventParams & {
+        tag: string;
+    };
+}
+/**
+ * 'calling.collect.startOfInput'
+ * Different from `started` because it's from the server
+ */
+export interface CallCollectStartOfInputEvent extends SwEvent {
+    event_type: ToInternalVoiceEvent<CallCollectStartOfInput>;
+    params: CallingCallCollectEventParams & {
+        tag: string;
+    };
+}
+/**
+ * 'calling.collect.updated'
+ */
+export interface CallCollectUpdatedEvent extends SwEvent {
+    event_type: ToInternalVoiceEvent<CallCollectUpdated>;
+    params: CallingCallCollectEventParams & {
+        tag: string;
+    };
+}
+/**
+ * 'calling.collect.ended'
+ */
+export interface CallCollectEndedEvent extends SwEvent {
+    event_type: ToInternalVoiceEvent<CallCollectEnded>;
+    params: CallingCallCollectEventParams & {
+        tag: string;
+    };
+}
+/**
+ * 'calling.collect.failed'
+ */
+export interface CallCollectFailedEvent extends SwEvent {
+    event_type: ToInternalVoiceEvent<CallCollectFailed>;
+    params: CallingCallCollectEventParams & {
+        tag: string;
+    };
+}
+export declare type VoiceCallEvent = CallingCallDialEvent | CallingCallStateEvent | CallingCallReceiveEvent | CallingCallPlayEvent | CallingCallRecordEvent | CallingCallCollectEvent | CallingCallTapEvent | CallingCallConnectEvent | CallingCallSendDigitsEvent | CallingCallDetectEvent | CallReceivedEvent | CallPlaybackStartedEvent | CallPlaybackUpdatedEvent | CallPlaybackEndedEvent | CallRecordingStartedEvent | CallRecordingUpdatedEvent | CallRecordingEndedEvent | CallRecordingFailedEvent | CallPromptStartedEvent | CallPromptStartOfInputEvent | CallPromptUpdatedEvent | CallPromptEndedEvent | CallPromptFailedEvent | CallTapStartedEvent | CallTapEndedEvent | CallConnectConnectingEvent | CallConnectConnectedEvent | CallConnectDisconnectedEvent | CallConnectFailedEvent | CallDetectStartedEvent | CallDetectUpdatedEvent | CallDetectEndedEvent | CallCollectStartedEvent | CallCollectStartOfInputEvent | CallCollectUpdatedEvent | CallCollectEndedEvent | CallCollectFailedEvent;
+export declare type VoiceCallEventParams = CallingCallDialEventParams | CallingCallStateEventParams | CallingCallReceiveEventParams | CallingCallPlayEventParams | CallingCallRecordEventParams | CallingCallCollectEventParams | CallingCallTapEventParams | CallingCallConnectEventParams | CallingCallSendDigitsEventParams | CallingCallDetectEventParams | CallReceivedEvent['params'] | CallPlaybackStartedEvent['params'] | CallPlaybackUpdatedEvent['params'] | CallPlaybackEndedEvent['params'] | CallRecordingStartedEvent['params'] | CallRecordingUpdatedEvent['params'] | CallRecordingEndedEvent['params'] | CallRecordingFailedEvent['params'] | CallPromptStartedEvent['params'] | CallPromptStartOfInputEvent['params'] | CallPromptUpdatedEvent['params'] | CallPromptEndedEvent['params'] | CallPromptFailedEvent['params'] | CallTapStartedEvent['params'] | CallTapEndedEvent['params'] | CallConnectConnectingEvent['params'] | CallConnectConnectedEvent['params'] | CallConnectDisconnectedEvent['params'] | CallConnectFailedEvent['params'] | CallDetectStartedEvent['params'] | CallDetectUpdatedEvent['params'] | CallDetectEndedEvent['params'] | CallCollectStartedEvent['params'] | CallCollectStartOfInputEvent['params'] | CallCollectUpdatedEvent['params'] | CallCollectEndedEvent['params'] | CallCollectFailedEvent['params'];
 export declare type VoiceCallAction = MapToPubSubShape<VoiceCallEvent>;
-export declare type VoiceCallJSONRPCMethod = 'calling.dial' | 'calling.end' | 'calling.answer' | 'calling.play' | 'calling.play.pause' | 'calling.play.resume' | 'calling.play.volume' | 'calling.play.stop' | 'calling.record' | 'calling.record.stop' | 'calling.play_and_collect' | 'calling.play_and_collect.stop' | 'calling.play_and_collect.volume' | 'calling.tap' | 'calling.tap.stop' | 'calling.connect' | 'calling.disconnect' | 'calling.send_digits' | 'calling.detect' | 'calling.detect.stop';
-export declare type CallingTransformType = 'voiceCallReceived' | 'voiceCallPlayback' | 'voiceCallRecord' | 'voiceCallPrompt' | 'voiceCallTap' | 'voiceCallConnect' | 'voiceCallState' | 'voiceCallDetect';
+export declare type VoiceCallJSONRPCMethod = 'calling.dial' | 'calling.end' | 'calling.answer' | 'calling.play' | 'calling.play.pause' | 'calling.play.resume' | 'calling.play.volume' | 'calling.play.stop' | 'calling.record' | 'calling.record.stop' | 'calling.play_and_collect' | 'calling.play_and_collect.stop' | 'calling.play_and_collect.volume' | 'calling.tap' | 'calling.tap.stop' | 'calling.connect' | 'calling.disconnect' | 'calling.send_digits' | 'calling.detect' | 'calling.detect.stop' | 'calling.collect' | 'calling.collect.stop' | 'calling.collect.start_input_timers';
+export declare type CallingTransformType = 'voiceCallReceived' | 'voiceCallPlayback' | 'voiceCallRecord' | 'voiceCallPrompt' | 'voiceCallTap' | 'voiceCallConnect' | 'voiceCallState' | 'voiceCallDetect' | 'voiceCallCollect';
 export {};
 //# sourceMappingURL=voiceCall.d.ts.map

dist/core/src/utils/index.d.ts

@@ -12,2 +12,3 @@ import { JSONRPCRequest, JSONRPCResponse } from '..';
 export * from './proxyUtils';
+export * from './debounce';
 export declare const mutateStorageKey: (key: string) => string;
@@ -14,0 +15,0 @@ export declare const safeParseJson: <T>(value: T) => Object | T;

dist/core/src/utils/interfaces.d.ts

@@ -89,5 +89,6 @@ /// <reference types="node" />
 export declare type MediaAllowed = 'all' | 'audio-only' | 'video-only';
-export declare type MediaDirectionAllowed = 'none' | 'receive' | 'both';
+declare type MediaDirectionAllowed = 'none' | 'receive' | 'both';
 declare type AudioAllowed = MediaDirectionAllowed;
 declare type VideoAllowed = MediaDirectionAllowed;
+export declare type VideoMeta = Record<string, any>;
 export interface VideoAuthorization {
@@ -99,12 +100,16 @@ type: 'video';
     resource: string;
+    join_as: 'member' | 'audience';
     user_name: string;
     room?: {
         name: string;
+        display_name: string;
         scopes: string[];
+        meta: VideoMeta;
     };
     signature: string;
     expires_at?: number;
-    media_allowed: MediaAllowed;
+    media_allowed?: MediaAllowed;
     audio_allowed: AudioAllowed;
     video_allowed: VideoAllowed;
+    meta: VideoMeta;
 }
@@ -154,6 +159,6 @@ export declare type ChatAuthorizationChannels = Record<string, {
  */
-export declare type RoomMethod = 'video.room.get' | 'video.rooms.get' | 'video.list_available_layouts' | 'video.hide_video_muted' | 'video.show_video_muted' | 'video.members.get' | 'video.member.audio_mute' | 'video.member.audio_unmute' | 'video.member.video_mute' | 'video.member.video_unmute' | 'video.member.deaf' | 'video.member.undeaf' | 'video.member.set_input_volume' | 'video.member.set_output_volume' | 'video.member.set_input_sensitivity' | 'video.member.set_position' | 'video.member.remove' | 'video.member.set_meta' | 'video.member.update_meta' | 'video.member.delete_meta' | 'video.set_meta' | 'video.update_meta' | 'video.delete_meta' | 'video.set_layout' | 'video.set_position' | 'video.recording.list' | 'video.recording.start' | 'video.recording.stop' | 'video.recording.pause' | 'video.recording.resume' | 'video.playback.list' | 'video.playback.start' | 'video.playback.pause' | 'video.playback.resume' | 'video.playback.stop' | 'video.playback.set_volume' | 'video.playback.seek_absolute' | 'video.playback.seek_relative' | 'video.member.demote' | 'video.member.promote';
+export declare type RoomMethod = 'video.room.get' | 'video.rooms.get' | 'video.list_available_layouts' | 'video.hide_video_muted' | 'video.show_video_muted' | 'video.members.get' | 'video.member.audio_mute' | 'video.member.audio_unmute' | 'video.member.video_mute' | 'video.member.video_unmute' | 'video.member.deaf' | 'video.member.undeaf' | 'video.member.set_input_volume' | 'video.member.set_output_volume' | 'video.member.set_input_sensitivity' | 'video.member.set_position' | 'video.member.remove' | 'video.member.get_meta' | 'video.member.set_meta' | 'video.member.update_meta' | 'video.member.delete_meta' | 'video.get_meta' | 'video.set_meta' | 'video.update_meta' | 'video.delete_meta' | 'video.set_layout' | 'video.set_position' | 'video.recording.list' | 'video.recording.start' | 'video.recording.stop' | 'video.recording.pause' | 'video.recording.resume' | 'video.playback.list' | 'video.playback.start' | 'video.playback.pause' | 'video.playback.resume' | 'video.playback.stop' | 'video.playback.set_volume' | 'video.playback.seek_absolute' | 'video.playback.seek_relative' | 'video.member.demote' | 'video.member.promote' | 'video.stream.list' | 'video.stream.start' | 'video.stream.stop';
 export interface WebSocketClient {
     addEventListener: WebSocket['addEventListener'];
-    removeEventListener: WebSocket['addEventListener'];
+    removeEventListener: WebSocket['removeEventListener'];
     send: WebSocket['send'];
@@ -163,5 +168,6 @@ close: WebSocket['close'];
 }
-interface NodeSocketClient extends WebSocketClient {
+export interface NodeSocketClient extends WebSocketClient {
     addEventListener(method: 'open' | 'close' | 'error' | 'message', cb: (event: any) => void, options?: any): void;
     removeEventListener(method: 'open' | 'close' | 'error' | 'message', cb: (event: any) => void): void;
+    send(data: any, cb?: (err?: Error) => void): void;
 }
@@ -212,3 +218,3 @@ /**
  */
-export declare type EventTransformType = 'roomSession' | 'roomSessionSubscribed' | 'roomSessionMember' | 'roomSessionLayout' | 'roomSessionRecording' | 'roomSessionRecordingList' | 'roomSessionPlaybackList' | 'roomSessionPlayback' | 'roomSessionAudienceCount' | ChatTransformType | PubSubTransformType | MessagingTransformType | CallingTransformType;
+export declare type EventTransformType = 'roomSession' | 'roomSessionSubscribed' | 'roomSessionMember' | 'roomSessionLayout' | 'roomSessionRecording' | 'roomSessionRecordingList' | 'roomSessionPlaybackList' | 'roomSessionPlayback' | 'roomSessionStream' | 'roomSessionStreamList' | 'roomSessionAudienceCount' | ChatTransformType | PubSubTransformType | MessagingTransformType | CallingTransformType;
 export interface NestedFieldToProcess {
@@ -271,2 +277,3 @@ /**
     type: EventTransformType;
+    afterCreateHook?: (instance: any) => void;
     /**
@@ -273,0 +280,0 @@ * Must return an **stateless** object. Think of it as a

package.json

@@ -6,3 +6,3 @@ {
   "license": "MIT",
-  "version": "3.0.3",
+  "version": "3.0.4-dev.202301191718.e2c475a.0",
   "main": "dist/index.node.js",
@@ -43,3 +43,6 @@ "exports": {
   },
+  "overrides": {
+    "jsonwebtoken": "9.0.0"
+  },
   "types": "compatibility-api.d.ts"
 }

New alerts

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

880232

increased by4.45%

Number of package files

288

increased by2.86%

Lines of code

11430

increased by3.42%

Worsened metrics

Number of low quality alerts

1

increased byInfinity%

No dependency changes