fix(server): avoid get object content when syncing (#9402)

packages/backend/server/src/base/event/def.ts

@@ -24,6 +24,10 @@ export interface WorkspaceEvents {
       workspaceId: Workspace['id'];
       key: string;
     }>;
+    sync: Payload<{
+      workspaceId: Workspace['id'];
+      key: string;
+    }>;
   };
 }
 

packages/backend/server/src/base/storage/providers/fs.ts

@@ -61,6 +61,15 @@ export class FsStorageProvider implements StorageProvider {
     this.logger.verbose(`Object \`${key}\` put`);
   }
 
+  async head(key: string) {
+    const metadata = this.readMetadata(key);
+    if (!metadata) {
+      this.logger.verbose(`Object \`${key}\` not found`);
+      return undefined;
+    }
+    return metadata;
+  }
+
   async get(key: string): Promise<{
     body?: Readable;
     metadata?: GetObjectMetadata;

packages/backend/server/src/base/storage/providers/provider.ts

@@ -34,6 +34,7 @@ export interface StorageProvider {
     body: BlobInputType,
     metadata?: PutObjectMetadata
   ): Promise<void>;
+  head(key: string): Promise<GetObjectMetadata | undefined>;
   get(
     key: string
   ): Promise<{ body?: BlobOutputType; metadata?: GetObjectMetadata }>;

packages/backend/server/src/core/storage/wrappers/blob.ts

@@ -32,7 +32,7 @@ export class WorkspaceBlobStorage {
     const meta: PutObjectMetadata = autoMetadata(blob);
 
     await this.provider.put(`${workspaceId}/${key}`, blob, meta);
-    this.trySyncBlobMeta(workspaceId, key, {
+    await this.upsert(workspaceId, key, {
       contentType: meta.contentType ?? 'application/octet-stream',
       contentLength: blob.length,
       lastModified: new Date(),
@@ -119,53 +119,48 @@ export class WorkspaceBlobStorage {
 
   private trySyncBlobsMeta(workspaceId: string, blobs: ListObjectsMetadata[]) {
     for (const blob of blobs) {
-      this.trySyncBlobMeta(workspaceId, blob.key);
+      this.event.emit('workspace.blob.sync', {
+        workspaceId,
+        key: blob.key,
+      });
     }
   }
 
-  private trySyncBlobMeta(
+  private async upsert(
     workspaceId: string,
     key: string,
-    meta?: GetObjectMetadata
+    meta: GetObjectMetadata
   ) {
-    setImmediate(() => {
+    await this.db.blob.upsert({
-      this.syncBlobMeta(workspaceId, key, meta).catch(() => {
+      where: {
-        /* never throw */
+        workspaceId_key: {
-      });
+          workspaceId,
+          key,
+        },
+      },
+      update: {
+        mime: meta.contentType,
+        size: meta.contentLength,
+      },
+      create: {
+        workspaceId,
+        key,
+        mime: meta.contentType,
+        size: meta.contentLength,
+      },
     });
   }
 
-  private async syncBlobMeta(
+  @OnEvent('workspace.blob.sync')
-    workspaceId: string,
+  async syncBlobMeta({
-    key: string,
+    workspaceId,
-    meta?: GetObjectMetadata
+    key,
-  ) {
+  }: EventPayload<'workspace.blob.sync'>) {
     try {
-      if (!meta) {
+      const meta = await this.provider.head(`${workspaceId}/${key}`);
-        const blob = await this.get(workspaceId, key);
-        meta = blob.metadata;
-        blob.body?.destroy();
-      }
 
       if (meta) {
-        await this.db.blob.upsert({
+        await this.upsert(workspaceId, key, meta);
-          where: {
-            workspaceId_key: {
-              workspaceId,
-              key,
-            },
-          },
-          update: {
-            mime: meta.contentType,
-            size: meta.contentLength,
-          },
-          create: {
-            workspaceId,
-            key,
-            mime: meta.contentType,
-            size: meta.contentLength,
-          },
-        });
       } else {
         await this.db.blob.deleteMany({
           where: {

packages/backend/server/src/plugins/storage/providers/s3.ts

@@ -1,9 +1,10 @@
-/* eslint-disable @typescript-eslint/no-non-null-assertion */
+/* oxlint-disable @typescript-eslint/no-non-null-assertion */
 import { Readable } from 'node:stream';
 
 import {
   DeleteObjectCommand,
   GetObjectCommand,
+  HeadObjectCommand,
   ListObjectsV2Command,
   NoSuchKey,
   PutObjectCommand,
@@ -75,6 +76,34 @@ export class S3StorageProvider implements StorageProvider {
     }
   }
 
+  async head(key: string) {
+    try {
+      const obj = await this.client.send(
+        new HeadObjectCommand({
+          Bucket: this.bucket,
+          Key: key,
+        })
+      );
+
+      return {
+        contentType: obj.ContentType!,
+        contentLength: obj.ContentLength!,
+        lastModified: obj.LastModified!,
+        checksumCRC32: obj.ChecksumCRC32,
+      };
+    } catch (e) {
+      // 404
+      if (e instanceof NoSuchKey) {
+        this.logger.verbose(`Object \`${key}\` not found`);
+        return undefined;
+      } else {
+        throw new Error(`Failed to head object \`${key}\``, {
+          cause: e,
+        });
+      }
+    }
+  }
+
   async get(key: string): Promise<{
     body?: Readable;
     metadata?: GetObjectMetadata;