fix: issues with thread subscriptions

I really screwed that up on my first attempt. Puter apps don't trigger
the user-connected websocket event, which rendered thread subscriptions
in apps useless. Furthermore, the uuid of the thread that was subscribed
too wasn't present in the event, which is also pretty useless.

Author: KernelDeimos

src/backend/src/modules/web/WebServerService.js

@@ -259,8 +259,12 @@ class WebServerService extends BaseService {
             socket.on('trash.is_empty', (msg) => {
                 socket.broadcast.to(socket.user.id).emit('trash.is_empty', msg);
             });
+            const svc_event = this.services.get('event');
+            svc_event.emit('web.socket.connected', {
+                socket,
+                user: socket.user
+            });
             socket.on('puter_is_actually_open', async (msg) => {
-                const svc_event = this.services.get('event');
                 await context.sub({
                     actor: socket.actor,
                 }).arun(async () => {

src/backend/src/services/ThreadService.js

@@ -126,7 +126,7 @@ class ThreadService extends BaseService {
         this.socket_subs_ = {};
 
         const svc_event = this.services.get('event');
-        svc_event.on('web.socket.user-connected', async (_, { socket }) => {
+        svc_event.on('web.socket.connected', async (_, { socket }) => {
             socket.on('disconnect', () => {
                 for ( const uid in this.socket_subs_ ) {
                     this.socket_subs_[uid].delete(socket.id);
@@ -156,7 +156,7 @@ class ThreadService extends BaseService {
         await svc_socketio.send(
             Array.from(this.socket_subs_[uid]).map(socket => ({ socket })),
             'thread.' + action,
-            data,
+            { ...data, subscription: uid },
         );
     }
 

src/puter-js/src/modules/Threads.js

@@ -25,7 +25,7 @@ export default class Threads {
 
     async create (spec, parent) {
         if ( typeof spec === 'string' ) spec = { text: spec };
-        await this.req_('POST', '/threads/create', {
+        return await this.req_('POST', '/threads/create', {
             ...spec,
             ...(parent ? { parent } : {}),
         });
@@ -49,7 +49,19 @@ export default class Threads {
         );
     }
 
-    async subscribe (uid) {
+    async subscribe (uid, callback) {
         puter.fs.socket.emit('thread.sub-request', { uid });
+
+        // socket.io, which we use unfortunatelly, doesn't handle
+        // wildcard events, so we have to just put them all here.
+        const events = [
+            'post', 'edit', 'delete', 'child-edit', 'child-delete',
+        ];
+
+        for ( const event of events ) {
+            puter.fs.socket.on(`thread.${event}`, (data) => {
+                if ( data.subscription === uid ) callback(event, data);
+            });
+        }
     }
 }