From 85a0f71bfd66c884c8f603cc1f274d5a465a2933 Mon Sep 17 00:00:00 2001 From: XiaochenCui Date: Wed, 30 Jul 2025 10:21:01 -0700 Subject: [PATCH] hotfix: emit the missing event, fix check condition --- src/backend/src/modules/puterfs/lib/PuterFSProvider.js | 4 ++++ src/backend/src/services/worker/WorkerService.js | 2 +- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/src/backend/src/modules/puterfs/lib/PuterFSProvider.js b/src/backend/src/modules/puterfs/lib/PuterFSProvider.js index f71283531..3504e942e 100644 --- a/src/backend/src/modules/puterfs/lib/PuterFSProvider.js +++ b/src/backend/src/modules/puterfs/lib/PuterFSProvider.js @@ -722,6 +722,10 @@ class PuterFSProvider extends putility.AdvancedBase { (async () => { await entryOp.awaitDone(); resourceService.free(uid); + svc_event.emit('fs.written.file', { + node, + context: this.context, + }); })(); state_upload.post_insert({ diff --git a/src/backend/src/services/worker/WorkerService.js b/src/backend/src/services/worker/WorkerService.js index 92310f227..b7cfc9fdb 100644 --- a/src/backend/src/services/worker/WorkerService.js +++ b/src/backend/src/services/worker/WorkerService.js @@ -98,7 +98,7 @@ class WorkerService extends BaseService { const result = await svc_su.sudo(async ()=> { return await es_subdomain.select({ predicate: new Eq({ key: "root_dir", value: data.node }) }); }); - if (!result) + if (!result || result.length === 0) return; // Person who just wrote file (not necessarily file owner)