chore: appease linter

storacha · Sep 14, 2023 · 630172b · 630172b
1 parent 462c8a4
commit 630172b
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 12 deletions.
diff --git a/packages/upload-client/src/index.js b/packages/upload-client/src/index.js
@@ -119,15 +119,17 @@ async function uploadBlockStream(conf, blocks, options = {}) {
   const concurrency = options.concurrentRequests ?? CONCURRENT_REQUESTS
   await blocks
     .pipeThrough(new ShardingStream(options))
-    .pipeThrough(new Parallel(concurrency, async car => {
-      const bytes = new Uint8Array(await car.arrayBuffer())
-      const [cid, piece] = await Promise.all([
-        Store.add(conf, bytes, options),
-        Piece.fromPayload(bytes)
-      ])
-      const { version, roots, size } = car
-      return { version, roots, size, cid, piece: piece.link }
-    }))
+    .pipeThrough(
+      new Parallel(concurrency, async (car) => {
+        const bytes = new Uint8Array(await car.arrayBuffer())
+        const [cid, piece] = await Promise.all([
+          Store.add(conf, bytes, options),
+          Piece.fromPayload(bytes),
+        ])
+        const { version, roots, size } = car
+        return { version, roots, size, cid, piece: piece.link }
+      })
+    )
     .pipeTo(
       new WritableStream({
         write(meta) {

diff --git a/packages/upload-client/src/store.js b/packages/upload-client/src/store.js
@@ -51,7 +51,8 @@ export async function add(
   options = {}
 ) {
   // TODO: validate blob contains CAR data
-  const bytes = car instanceof Uint8Array ? car : new Uint8Array(await car.arrayBuffer())
+  const bytes =
+    car instanceof Uint8Array ? car : new Uint8Array(await car.arrayBuffer())
   const link = await CAR.codec.link(bytes)
   /* c8 ignore next */
   const conn = options.connection ?? connection

diff --git a/packages/upload-client/test/index.test.js b/packages/upload-client/test/index.test.js
@@ -559,7 +559,7 @@ describe('uploadCAR', () => {
       car,
       {
         connection,
-        onShardStored: (meta) => pieceCIDs.push(meta.piece)
+        onShardStored: (meta) => pieceCIDs.push(meta.piece),
       }
     )
 
@@ -568,6 +568,9 @@ describe('uploadCAR', () => {
     assert(service.upload.add.called)
     assert.equal(service.upload.add.callCount, 1)
     assert.equal(pieceCIDs.length, 1)
-    assert.equal(pieceCIDs[0].toString(), 'bafkzcibbammseumg3mjlev5odi5bpcsrp4gg62d7xnx44zkxzvgedq7nxldbc')
+    assert.equal(
+      pieceCIDs[0].toString(),
+      'bafkzcibbammseumg3mjlev5odi5bpcsrp4gg62d7xnx44zkxzvgedq7nxldbc'
+    )
   })
 })