fs/event: consolidate fs.written to fs.write

stash changes

Author: XiaochenCui

src/backend/src/modules/puterfs/lib/PuterFSProvider.js

@@ -20,6 +20,7 @@
 const putility = require('@heyputer/putility');
 const { MultiDetachable } = putility.libs.listener;
 const { TDetachable } = putility.traits;
+const { TeePromise } = putility.libs.promise;
 
 const { NodeInternalIDSelector, NodeChildSelector, NodeUIDSelector, RootNodeSelector, NodePathSelector } = require("../../../filesystem/node/selectors");
 const { Context } = require("../../../util/context");
@@ -719,21 +720,21 @@ class PuterFSProvider extends putility.AdvancedBase {
         const entryOp = await svc_fsEntry.update(uid, raw_fsentry_delta);
 
         // depends on fsentry, does not depend on S3
-        (async () => {
+        const entryOpPromise = (async () => {
             await entryOp.awaitDone();
             resourceService.free(uid);
-            svc_event.emit('fs.written.file', {
-                node,
-                context: this.context,
-            });
         })();
 
-        state_upload.post_insert({
+        const postInsertPromise = state_upload.post_insert({
             db, user: actor.type.user, node, uid, message, ts,
         });
 
-        const svc_fileCache = context.get('services').get('file-cache');
-        await svc_fileCache.invalidate(node);
+        const cachePromise = (async () => {
+            const svc_fileCache = context.get('services').get('file-cache');
+            await svc_fileCache.invalidate(node);
+        })();
+
+        await Promise.all([entryOpPromise, postInsertPromise, cachePromise]);
 
         svc_event.emit('fs.write.file', {
             node,

src/backend/src/services/worker/WorkerService.js

@@ -91,7 +91,7 @@ class WorkerService extends BaseService {
         const svc_auth = this.services.get("auth");
         const svc_notification = this.services.get('notification');
 
-        svc_event.on('fs.written.file', async (_key, data, meta) => {
+        svc_event.on('fs.write.file', async (_key, data, meta) => {
             // Code should only run on the same server as the write
             if (meta.from_outside) return;