Create a promise per rename operation

adobe · May 27, 2024 · dbdd5e3 · dbdd5e3
1 parent 647e437
commit dbdd5e3
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 14 deletions.
diff --git a/src/storage/object/copy.js b/src/storage/object/copy.js
@@ -58,15 +58,10 @@ export default async function copyObject(env, daCtx, details) {
       const resp = await client.send(command);
 
       const { Contents = [], NextContinuationToken } = resp;
+
       sourceKeys.push(...Contents.map(({ Key }) => Key));
 
-      await Promise.all(
-        new Array(1).fill(null).map(async () => {
-          while (sourceKeys.length) {
-            await copyFile(client, daCtx.org, sourceKeys.pop(), details);
-          }
-        }),
-      );
+      await Promise.all(sourceKeys.map((key) => copyFile(client, daCtx.org, key, details)));
 
       ContinuationToken = NextContinuationToken;
     } catch (e) {

diff --git a/src/storage/object/delete.js b/src/storage/object/delete.js
@@ -55,13 +55,7 @@ export default async function deleteObjects(env, daCtx) {
       const { Contents = [], NextContinuationToken } = resp;
       sourceKeys.push(...Contents.map(({ Key }) => Key));
 
-      await Promise.all(
-        new Array(1).fill(null).map(async () => {
-          while (sourceKeys.length) {
-            await deleteObject(client, daCtx.org, sourceKeys.pop());
-          }
-        }),
-      );
+      await Promise.all(sourceKeys.map((key) => deleteObject(client, daCtx.org, key)));
 
       ContinuationToken = NextContinuationToken;
     } catch (e) {