fix: add ts and proof array

storacha · Dec 13, 2022 · 31a4aed · 31a4aed
1 parent 51bf234
commit 31a4aed
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/upload-api/functions/ucan-invocation-router.js b/upload-api/functions/ucan-invocation-router.js
@@ -95,7 +95,8 @@ async function ucanInvocationRouter (request) {
   await kinesisClient.putRecord({
     Data: uint8arrayFromString(JSON.stringify({
       carCid: ucanInvocation.carCid,
-      value: ucanInvocation.value
+      value: ucanInvocation.value,
+      ts: Date.now()
     })),
     // https://docs.aws.amazon.com/streams/latest/dev/key-concepts.html
     // A partition key is used to group data by shard within a stream.

diff --git a/upload-api/test/service/ucan-invocation.test.js b/upload-api/test/service/ucan-invocation.test.js
@@ -143,7 +143,7 @@ test('replace all link values as object and array', async t => {
         size: car.size
       },
       can: 'store/add',
-      with: 'did:key:z6MkfTDbhRZz26kcDNmmehPxeujSkbXe8jqv5fLpKvtc3Wcv'
+      with: 'did:key:z6MkfTDbhRZz26kcDNmmehPxeujSkbXe8jqv5fLpKvtc3Wcv',
     },
     {
       nb: {

diff --git a/upload-api/ucan-invocation.js b/upload-api/ucan-invocation.js
@@ -50,7 +50,8 @@ export async function parseUcanInvocationRequest (request) {
       // @ts-ignore missing types
       att: dagUcan.att.map(replaceAllLinkValues),
       aud: dagUcan.aud.did(),
-      iss: dagUcan.iss.did()
+      iss: dagUcan.iss.did(),
+      prf: replaceAllLinkValues(dagUcan.prf)
     }
   }
 }