feat: trigger content claims equals on piece cid computed

filecoin/functions/piece-cid-report.js

@@ -2,6 +2,7 @@ import * as Sentry from '@sentry/serverless'
 import { Config } from '@serverless-stack/node/config/index.js'
 import { unmarshall } from '@aws-sdk/util-dynamodb'
 import { Piece } from '@web3-storage/data-segment'
+import { CID } from 'multiformats/cid'
 
 import { reportPieceCid } from '../index.js'
 import { getServiceConnection, getServiceSigner } from '../service.js'
@@ -28,27 +29,36 @@ async function pieceCidReport (event) {
   // @ts-expect-error can't figure out type of new
   const pieceRecord = unmarshall(records[0].new)
   const piece = Piece.fromString(pieceRecord.piece).link
+  const content = CID.parse(pieceRecord.link)
 
   const aggregateServiceConnection = getServiceConnection({
     did: aggregatorDid,
     url: aggregatorUrl
   })
+  const claimsServiceConnection = getServiceConnection({
+    did: aggregatorDid,
+    url: aggregatorUrl
+  })
   const issuer = getServiceSigner({
     privateKey
   })
-  const audience = aggregateServiceConnection.id
-  /** @type {import('@web3-storage/filecoin-client/types').InvocationConfig} */
-  const invocationConfig = {
-    issuer,
-    audience,
-    with: issuer.did(),
-  }
 
   const { ok, error } = await reportPieceCid({
     piece,
+    content,
     group: issuer.did(),
     aggregateServiceConnection,
-    invocationConfig
+    aggregateInvocationConfig: /** @type {import('@web3-storage/filecoin-client/types').InvocationConfig} */ ({
+      issuer,
+      audience: aggregateServiceConnection.id,
+      with: issuer.did(),
+    }),
+    claimsServiceConnection,
+    claimsInvocationConfig: /** @type {import('@web3-storage/filecoin-client/types').InvocationConfig} */ ({
+      issuer,
+      audience: claimsServiceConnection.id,
+      with: issuer.did(),
+    })
   })
 
   if (error) {
@@ -73,6 +83,8 @@ function getEnv() {
   return {
     aggregatorDid: mustGetEnv('AGGREGATOR_DID'),
     aggregatorUrl: mustGetEnv('AGGREGATOR_URL'),
+    contentClaimsDid: mustGetEnv('CONTENT_CLAIMS_DID'),
+    contentClaimsUrl: mustGetEnv('CONTENT_CLAIMS_URL'),
   }
 }
 

filecoin/index.js

@@ -4,6 +4,7 @@ import * as Hasher from 'fr32-sha2-256-trunc254-padded-binary-tree-multihash'
 import * as Digest from 'multiformats/hashes/digest'
 import { Piece } from '@web3-storage/data-segment'
 import { CID } from 'multiformats/cid'
+import { Assert } from '@web3-storage/content-claims/capability'
 import { Aggregator } from '@web3-storage/filecoin-client'
 
 import { GetCarFailed, ComputePieceFailed } from './errors.js'
@@ -83,19 +84,25 @@ export async function computePieceCid({
 /**
  * @param {object} props
  * @param {import('@web3-storage/data-segment').PieceLink} props.piece
+ * @param {import('multiformats').CID} props.content
  * @param {string} props.group
- * @param {import('@web3-storage/filecoin-client/types').InvocationConfig} props.invocationConfig
  * @param {import('@ucanto/principal/ed25519').ConnectionView<any>} props.aggregateServiceConnection
+ * @param {import('@web3-storage/filecoin-client/types').InvocationConfig} props.aggregateInvocationConfig
+ * @param {import('@ucanto/principal/ed25519').ConnectionView<any>} props.claimsServiceConnection
+ * @param {import('@web3-storage/filecoin-client/types').InvocationConfig} props.claimsInvocationConfig
  */
 export async function reportPieceCid ({
   piece,
+  content,
   group,
-  invocationConfig,
-  aggregateServiceConnection
+  aggregateServiceConnection,
+  aggregateInvocationConfig,
+  claimsServiceConnection,
+  claimsInvocationConfig
 }) {
   // Add piece for aggregation
   const aggregateQueue = await Aggregator.aggregateQueue(
-    invocationConfig,
+    aggregateInvocationConfig,
     piece,
     group,
     { connection: aggregateServiceConnection }
@@ -106,6 +113,26 @@ export async function reportPieceCid ({
       error: aggregateQueue.out.error
     }
   }
+
+  // Add claim for reading
+  const claimResult = await Assert.equals
+    .invoke({
+      issuer: claimsInvocationConfig.issuer,
+      audience: claimsInvocationConfig.audience,
+      with: claimsInvocationConfig.with,
+      nb: {
+        content,
+        equals: piece
+      }
+    })
+    .execute(claimsServiceConnection)
+
+  if (claimResult.out.error) {
+    return {
+      error: claimResult.out.error
+    }
+  }
+
   return {
     ok: {},
   }

filecoin/package.json

@@ -13,6 +13,7 @@
     "@ucanto/client": "^8.0.1",
     "@ucanto/principal": "^8.1.0",
     "@ucanto/transport": "^8.0.0",
+    "@web3-storage/content-claims": "^3.0.1",
     "@web3-storage/data-segment": "^3.0.1",
     "@web3-storage/filecoin-client": "^1.3.0",
     "fr32-sha2-256-trunc254-padded-binary-tree-multihash": "github:web3-storage/fr32-sha2-256-trunc254-padded-binary-tree-multihash",

stacks/config.js

@@ -128,6 +128,8 @@ export function getEnv() {
     UPLOAD_API_DID: mustGetEnv('UPLOAD_API_DID'),
     AGGREGATOR_DID: mustGetEnv('AGGREGATOR_DID'),
     AGGREGATOR_URL: mustGetEnv('AGGREGATOR_URL'),
+    CONTENT_CLAIMS_DID: mustGetEnv('CONTENT_CLAIMS_DID'),
+    CONTENT_CLAIMS_URL: mustGetEnv('CONTENT_CLAIMS_URL'),
   }
 }
 

stacks/filecoin-stack.js

@@ -20,7 +20,7 @@ export function FilecoinStack({ stack, app }) {
     srcPath: 'filecoin'
   })
 
-  const { AGGREGATOR_DID, AGGREGATOR_URL } = getEnv()
+  const { AGGREGATOR_DID, AGGREGATOR_URL, CONTENT_CLAIMS_DID, CONTENT_CLAIMS_URL } = getEnv()
 
   // Setup app monitoring with Sentry
   setupSentry(app, stack)
@@ -40,6 +40,8 @@ export function FilecoinStack({ stack, app }) {
         environment: {
           AGGREGATOR_DID,
           AGGREGATOR_URL,
+          CONTENT_CLAIMS_DID,
+          CONTENT_CLAIMS_URL,
         },
         timeout: 3 * 60,
         bind: [