fix: force prepend piece

storacha · Feb 6, 2024 · a904867 · a904867
1 parent 4204cb1
commit a904867
Show file tree

Hide file tree

Showing 4 changed files with 32 additions and 12 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/packages/core/package.json b/packages/core/package.json
@@ -23,7 +23,7 @@
     "@ucanto/transport": "^9.0.0",
     "@web3-storage/capabilities": "^12.0.3",
     "@web3-storage/data-segment": "^5.0.0",
-    "@web3-storage/filecoin-api": "^4.3.1",
+    "@web3-storage/filecoin-api": "^4.4.0",
     "@web3-storage/filecoin-client": "^3.1.3",
     "fzstd": "^0.1.0",
     "multiformats": "12.0.1",

diff --git a/packages/functions/package.json b/packages/functions/package.json
@@ -11,7 +11,8 @@
     "@ucanto/core": "^9.0.0",
     "@ucanto/server": "^9.0.1",
     "@ucanto/transport": "^9.0.0",
-    "@web3-storage/filecoin-api": "^4.3.1",
+    "@web3-storage/data-segment": "5.0.0",
+    "@web3-storage/filecoin-api": "^4.4.0",
     "@web3-storage/filecoin-client": "3.0.1",
     "@w3filecoin/core": "*"
   },

diff --git a/packages/functions/src/aggregator/handle-buffer-queue-message.js b/packages/functions/src/aggregator/handle-buffer-queue-message.js
@@ -4,6 +4,7 @@ import { createClient as createBufferStoreClient } from '@w3filecoin/core/src/st
 import { createClient as createBufferQueueClient, decodeMessage } from '@w3filecoin/core/src/queue/buffer-queue.js'
 import { createClient as createAggregateOfferQueueClient } from '@w3filecoin/core/src/queue/aggregate-offer-queue.js'
 import * as aggregatorEvents from '@web3-storage/filecoin-api/aggregator/events'
+import { Piece } from '@web3-storage/data-segment'
 
 import { mustGetEnv } from '../utils.js'
 
@@ -93,7 +94,14 @@ function getContext () {
     config: {
       maxAggregateSize,
       minAggregateSize,
-      minUtilizationFactor
+      minUtilizationFactor,
+      prependBufferedPieces: [{
+        // Small piece to prepend that is encoded as a CAR file
+        piece: Piece.fromString('bafkzcibciab3bwd67rgcoiejigar34jguwfasa5327hq3sjdcma3zz2ccupy4oi').link,
+        // will be prepended, so policy is irrelevant
+        policy: /** @type {import('@web3-storage/filecoin-api/src/aggregator/api').PiecePolicy} */ (0),
+        insertedAt: (new Date()).toISOString()
+      }]
     }
   }
 }