debug commit

Author: mustard-mh

components/dashboard/src/service/public-api.ts

@@ -46,6 +46,27 @@ export const organizationClient = createServiceClient(
     "organization",
 );
 
+// @ts-ignore
+window.$testWorkspaceClient = workspaceClient;
+
+// @ts-ignore
+window.$testWatch = (workspaceId: string) => {
+    const abortController = new AbortController();
+    const it = workspaceClient.watchWorkspaceStatus(
+        { workspaceId },
+        {
+            signal: abortController.signal,
+        },
+    );
+    const startWatchWorkspace = async () => {
+        for await (const workspace of it) {
+            console.log("rcv", workspaceId, JSON.stringify(workspace));
+        }
+    };
+    startWatchWorkspace().then().catch(console.error);
+    return abortController.abort.bind(abortController);
+};
+
 export async function listAllProjects(opts: { orgId: string }): Promise<ProtocolProject[]> {
     let pagination = {
         page: 1,

components/server/src/workspace/workspace-service.ts

@@ -739,7 +739,10 @@ export class WorkspaceService {
             const dispose = this.subscriber.listenForWorkspaceInstanceUpdates(userId, (_ctx, instance) => {
                 sink.next(instance);
             });
-            return dispose.dispose;
+            return () => {
+                console.log("=============dispose");
+                dispose.dispose();
+            };
         }, opts);
     }