core: release camera and microphone when the local client is kicked

Author: thyal

.changeset/fast-drinks-end.md

@@ -0,0 +1,5 @@
+---
+"@whereby.com/core": patch
+---
+
+core: release camera and microphone when the local client is kicked, eg when the meeting is ended by the host

packages/core/src/redux/slices/roomConnection/index.ts

@@ -304,6 +304,13 @@ startAppListening({
     },
 });
 
+startAppListening({
+    actionCreator: signalEvents.clientKicked,
+    effect: (_, { dispatch }) => {
+        dispatch(doAppStop());
+    },
+});
+
 startAppListening({
     actionCreator: doAppStop,
     effect: (_, { dispatch, getState }) => {

packages/core/src/redux/tests/store/localMedia.spec.ts

@@ -1,4 +1,6 @@
 import * as localMediaSlice from "../../slices/localMedia";
+import { initialState as appInitialState } from "../../slices/app";
+import { signalEvents } from "../../slices/signalConnection/actions";
 import { createStore } from "../store.setup";
 import { diff } from "deep-object-diff";
 import * as MediaDevices from "@whereby.com/media";
@@ -158,6 +160,27 @@ describe("actions", () => {
                     stream: undefined,
                 });
             });
+
+            it("should stop all tracks when the local client is kicked", () => {
+                const store = createStore({
+                    withSignalConnection: true,
+                    connectToRoom: true,
+                    initialState: {
+                        ...initialState,
+                        localMedia: {
+                            ...initialState.localMedia!,
+                            options: { audio: true, video: true },
+                        },
+                        app: { ...appInitialState, isActive: true },
+                    },
+                });
+
+                store.dispatch(signalEvents.clientKicked({ clientId: "self-client-id" }));
+
+                expect(audioTrack.stop).toHaveBeenCalled();
+                expect(videoTrack.stop).toHaveBeenCalled();
+                expect(store.getState().localMedia.status).toEqual("stopped");
+            });
         });
     });
 

packages/core/src/redux/tests/store/roomConnection.spec.ts

@@ -1,5 +1,7 @@
 import { createStore, mockSignalEmit } from "../store.setup";
 import { doKnockRoom, doConnectRoom } from "../../slices/roomConnection";
+import { initialState as appInitialState } from "../../slices/app";
+import { signalEvents } from "../../slices/signalConnection/actions";
 import { diff } from "deep-object-diff";
 
 describe("actions", () => {
@@ -30,6 +32,23 @@ describe("actions", () => {
         });
     });
 
+    describe("signalEvents.clientKicked", () => {
+        it("should stop the app so local media and connections are cleaned up", () => {
+            const store = createStore({
+                withSignalConnection: true,
+                connectToRoom: true,
+                initialState: {
+                    app: { ...appInitialState, isActive: true },
+                },
+            });
+
+            store.dispatch(signalEvents.clientKicked({ clientId: "self-client-id" }));
+
+            expect(store.getState().roomConnection.status).toEqual("kicked");
+            expect(store.getState().app.isActive).toEqual(false);
+        });
+    });
+
     it("doConnectRoom", async () => {
         const store = createStore({ withSignalConnection: true });