mirror of
https://github.com/HeyPuter/puter.git
synced 2026-07-08 16:21:40 +00:00
fix: context error in user connected event
This commit is contained in:
@@ -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
|
||||
});
|
||||
});
|
||||
|
||||
@@ -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);
|
||||
|
||||
Reference in New Issue
Block a user