From 96008233ba4935e789cd092c07aa8b351cb44d45 Mon Sep 17 00:00:00 2001 From: KernelDeimos Date: Tue, 10 Dec 2024 13:45:31 -0500 Subject: [PATCH] fix: context error in user connected event --- src/backend/src/modules/web/WebServerService.js | 4 ++-- src/backend/src/services/Container.js | 3 ++- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/src/backend/src/modules/web/WebServerService.js b/src/backend/src/modules/web/WebServerService.js index 97bb09482..b19b972d4 100644 --- a/src/backend/src/modules/web/WebServerService.js +++ b/src/backend/src/modules/web/WebServerService.js @@ -266,9 +266,9 @@ class WebServerService extends BaseService { socket.on('trash.is_empty', (msg) => { socket.broadcast.to(socket.user.id).emit('trash.is_empty', msg); }); - socket.on('puter_is_actually_open', (msg) => { + socket.on('puter_is_actually_open', async (msg) => { const svc_event = this.services.get('event'); - svc_event.emit('web.socket.user-connected', { + await svc_event.emit('web.socket.user-connected', { user: socket.user }); }); diff --git a/src/backend/src/services/Container.js b/src/backend/src/services/Container.js index ec82c72a6..c3132fa18 100644 --- a/src/backend/src/services/Container.js +++ b/src/backend/src/services/Container.js @@ -212,10 +212,11 @@ class Container { if ( this.logger ) { this.logger.noticeme(`services:event ${id}`, { args }); } + const promises = []; for ( const k in this.instances_ ) { if ( this.instances_[k].__on ) { - promises.push(this.instances_[k].__on(id, args)); + promises.push(Context.arun(() => this.instances_[k].__on(id, args))); } } await Promise.all(promises);