fix: remove prefixes from listStream method parameters (#6480)

Signed-off-by: Alexander Onnikov <Alexander.Onnikov@xored.com>

models/core/src/migration.ts

@@ -337,7 +337,7 @@ async function migrateBlobData (exAdapter: StorageAdapterEx, client: MigrationCl
     if (!(await adapter.exists(ctx, client.workspaceId))) {
       continue
     }
-    const blobs = await adapter.listStream(ctx, client.workspaceId, '')
+    const blobs = await adapter.listStream(ctx, client.workspaceId)
     const bulk = new Map<Ref<Blob>, Blob>()
     try {
       const push = async (force: boolean): Promise<void> => {

packages/storage/src/index.ts

@@ -45,7 +45,7 @@ export interface StorageAdapter {
 
   listBuckets: (ctx: MeasureContext) => Promise<BucketInfo[]>
   remove: (ctx: MeasureContext, workspaceId: WorkspaceId, objectNames: string[]) => Promise<void>
-  listStream: (ctx: MeasureContext, workspaceId: WorkspaceId, prefix?: string) => Promise<BlobStorageIterator>
+  listStream: (ctx: MeasureContext, workspaceId: WorkspaceId) => Promise<BlobStorageIterator>
   stat: (ctx: MeasureContext, workspaceId: WorkspaceId, objectName: string) => Promise<Blob | undefined>
   get: (ctx: MeasureContext, workspaceId: WorkspaceId, objectName: string) => Promise<Readable>
   put: (
@@ -114,15 +114,11 @@ export class DummyStorageAdapter implements StorageAdapter, StorageAdapterEx {
 
   async remove (ctx: MeasureContext, workspaceId: WorkspaceId, objectNames: string[]): Promise<void> {}
 
-  async list (ctx: MeasureContext, workspaceId: WorkspaceId, prefix?: string | undefined): Promise<ListBlobResult[]> {
+  async list (ctx: MeasureContext, workspaceId: WorkspaceId): Promise<ListBlobResult[]> {
     return []
   }
 
-  async listStream (
+  async listStream (ctx: MeasureContext, workspaceId: WorkspaceId): Promise<BlobStorageIterator> {
-    ctx: MeasureContext,
-    workspaceId: WorkspaceId,
-    prefix?: string | undefined
-  ): Promise<BlobStorageIterator> {
     return {
       next: async (): Promise<ListBlobResult | undefined> => {
         return undefined
@@ -203,11 +199,10 @@ export async function removeAllObjects (
 export async function objectsToArray (
   ctx: MeasureContext,
   storage: StorageAdapter,
-  workspaceId: WorkspaceId,
+  workspaceId: WorkspaceId
-  prefix?: string
 ): Promise<ListBlobResult[]> {
   // We need to list all files and delete them
-  const iterator = await storage.listStream(ctx, workspaceId, prefix)
+  const iterator = await storage.listStream(ctx, workspaceId)
   const bulk: ListBlobResult[] = []
   while (true) {
     const obj = await iterator.next()

server/core/src/__tests__/memAdapters.ts

@@ -52,11 +52,7 @@ export class MemStorageAdapter implements StorageAdapter {
     }
   }
 
-  async listStream (
+  async listStream (ctx: MeasureContext, workspaceId: WorkspaceId): Promise<BlobStorageIterator> {
-    ctx: MeasureContext,
-    workspaceId: WorkspaceId,
-    prefix?: string | undefined
-  ): Promise<BlobStorageIterator> {
     const files = Array.from(this.files.values()).filter((it) => it.workspace === workspaceId.name)
     return {
       next: async () => {

server/core/src/server/aggregator.ts

@@ -224,14 +224,8 @@ export class AggregatorStorageAdapter implements StorageAdapter, StorageAdapterE
     await this.dbAdapter.clean(ctx, workspaceId, DOMAIN_BLOB, objectNames as Ref<Blob>[])
   }
 
-  async listStream (
+  async listStream (ctx: MeasureContext, workspaceId: WorkspaceId): Promise<BlobStorageIterator> {
-    ctx: MeasureContext,
+    const data = await this.dbAdapter.findStream<Blob>(ctx, workspaceId, DOMAIN_BLOB, {})
-    workspaceId: WorkspaceId,
-    prefix?: string | undefined
-  ): Promise<BlobStorageIterator> {
-    const data = await this.dbAdapter.findStream<Blob>(ctx, workspaceId, DOMAIN_BLOB, {
-      _id: { $regex: `${prefix ?? ''}.*` }
-    })
     return {
       next: async (): Promise<ListBlobResult | undefined> => {
         return await data.next()

server/datalake/src/index.ts

@@ -73,11 +73,7 @@ export class DatalakeService implements StorageAdapter {
   }
 
   @withContext('listStream')
-  async listStream (
+  async listStream (ctx: MeasureContext, workspaceId: WorkspaceId): Promise<BlobStorageIterator> {
-    ctx: MeasureContext,
-    workspaceId: WorkspaceId,
-    prefix?: string | undefined
-  ): Promise<BlobStorageIterator> {
     throw new Error('not supported')
   }
 

server/minio/src/index.ts

@@ -182,11 +182,7 @@ export class MinioService implements StorageAdapter {
   }
 
   @withContext('listStream')
-  async listStream (
+  async listStream (ctx: MeasureContext, workspaceId: WorkspaceId): Promise<BlobStorageIterator> {
-    ctx: MeasureContext,
-    workspaceId: WorkspaceId,
-    prefix?: string | undefined
-  ): Promise<BlobStorageIterator> {
     let hasMore = true
     let stream: BucketStream<BucketItem> | undefined
     let done = false
@@ -199,7 +195,7 @@ export class MinioService implements StorageAdapter {
       next: async (): Promise<ListBlobResult | undefined> => {
         try {
           if (stream === undefined && !done) {
-            const rprefix = rootPrefix !== undefined ? rootPrefix + (prefix ?? '') : prefix ?? ''
+            const rprefix = rootPrefix ?? ''
             stream = this.client.listObjects(this.getBucketId(workspaceId), rprefix, true)
             stream.on('end', () => {
               stream?.destroy()

server/s3/src/index.ts

@@ -232,11 +232,7 @@ export class S3Service implements StorageAdapter {
   }
 
   @withContext('listStream')
-  async listStream (
+  async listStream (ctx: MeasureContext, workspaceId: WorkspaceId): Promise<BlobStorageIterator> {
-    ctx: MeasureContext,
-    workspaceId: WorkspaceId,
-    prefix?: string | undefined
-  ): Promise<BlobStorageIterator> {
     let hasMore = true
     const buffer: ListBlobResult[] = []
     let token: string | undefined
@@ -248,7 +244,7 @@ export class S3Service implements StorageAdapter {
           if (hasMore && buffer.length === 0) {
             const res = await this.client.listObjectsV2({
               Bucket: this.getBucketId(workspaceId),
-              Prefix: rootPrefix !== undefined ? rootPrefix + (prefix ?? '') : prefix ?? '',
+              Prefix: rootPrefix ?? '',
               ContinuationToken: token
             })
             if (res.IsTruncated === true) {
@@ -273,7 +269,7 @@ export class S3Service implements StorageAdapter {
             }
           }
         } catch (err: any) {
-          ctx.error('Failed to get list', { error: err, workspaceId: workspaceId.name, prefix })
+          ctx.error('Failed to get list', { error: err, workspaceId: workspaceId.name })
         }
         if (buffer.length > 0) {
           return buffer.shift()