Implement end call endpoint

GetStream · Jun 20, 2024 · d7009da · d7009da
1 parent 25a34f6
commit d7009da
Show file tree

Hide file tree

Showing 3 changed files with 35 additions and 3 deletions.
diff --git a/__tests__/call.test.ts b/__tests__/call.test.ts
@@ -10,7 +10,7 @@ import {
 
 describe('call API', () => {
   let client: StreamClient;
-  const callId = `call${uuidv4()}`;
+  const callId = `callnodetest${uuidv4()}`;
   let call: StreamCall;
 
   beforeAll(async () => {
@@ -280,5 +280,11 @@ describe('call API', () => {
         );
       });
     });
+
+    it('delete', async () => {
+      const response = await call.delete({ hard: true });
+
+      expect(response.call.cid).toBe(call.cid);
+    });
   });
 });
diff --git a/src/StreamCall.ts b/src/StreamCall.ts
@@ -6,6 +6,7 @@ import {
   GetCallStatsRequest,
   ProductvideoApi,
   VideoBlockUserRequest,
+  VideoDeleteCallRequest,
   VideoGetOrCreateCallRequest,
   VideoGoLiveRequest,
   VideoMuteUsersRequest,
@@ -28,14 +29,18 @@ export class StreamCall {
 
   constructor(
     private readonly streamClient: StreamClient,
-    private readonly type: string,
-    private readonly id: string,
+    public readonly type: string,
+    public readonly id: string,
   ) {
     this.baseRequest = { id: this.id, type: this.type };
     const configuration = this.streamClient.getConfiguration('video');
     this.apiClient = new ProductvideoApi(configuration);
   }
 
+  get cid() {
+    return `${this.type}:${this.id}`;
+  }
+
   blockUser = (videoBlockUserRequest: VideoBlockUserRequest) => {
     return this.apiClient.blockUser({
       ...this.baseRequest,
@@ -51,6 +56,13 @@ export class StreamCall {
     return this.apiClient.getCall({ ...(request ?? {}), ...this.baseRequest });
   };
 
+  delete = (videoDeleteCallRequest?: VideoDeleteCallRequest) => {
+    return this.apiClient.deleteCall({
+      ...this.baseRequest,
+      videoDeleteCallRequest: videoDeleteCallRequest || null,
+    });
+  };
+
   getOrCreate = (videoGetOrCreateCallRequest?: VideoGetOrCreateCallRequest) => {
     return this.apiClient.getOrCreateCall({
       ...this.baseRequest,

diff --git a/test-cleanup.js b/test-cleanup.js
@@ -24,6 +24,19 @@ const cleanupBlockLists = async () => {
   );
 };
 
+const cleanupCalls = async () => {
+  const calls = (await client.video.queryCalls()).calls;
+  const testCalls = Object.keys(calls).filter((t) =>
+    t.startsWith("callnodetest"),
+  );
+
+  await Promise.all(
+    testCalls.map((t) =>
+      client.video.call(t.call.type, t.call.id).delete({ hard: true }),
+    ),
+  );
+};
+
 const cleanupCallTypes = async () => {
   const callTypes = (await client.video.listCallTypes()).call_types;
   const customCallTypes = Object.keys(callTypes).filter(
@@ -127,6 +140,7 @@ const cleanup = async () => {
   await cleanUpRoles();
   await cleanUpUsers();
   await cleanupExternalStorage();
+  await cleanupCalls();
 };
 
 cleanup().then(() => {