Add implementation. Closes #1

lib/spark.js

@@ -42,11 +42,11 @@ export default class Spark {
   async fetchCAR (url) {
     // TODO: Ensure these fields are persisted by `spark-api`
     const stats = {
-      start: new Date(),
-      firstByte: null,
-      end: null,
+      startAt: new Date(),
+      firstByteAt: null,
+      endAt: null,
       byteLength: 0,
-      status: null
+      statusCode: null
     }
     console.log('Fetching CAR...')
 
@@ -64,13 +64,13 @@ export default class Spark {
     try {
       startTimeout()
       const res = await this.#fetch(url, { signal })
-      stats.status = res.status
+      stats.statusCode = res.status
 
       if (res.ok) {
         startTimeout()
         for await (const value of res.body) {
-          if (stats.firstByte === null) {
-            stats.firstByte = new Date()
+          if (stats.firstByteAt === null) {
+            stats.firstByteAt = new Date()
           }
           stats.byteLength += value.byteLength
           startTimeout()
@@ -80,7 +80,7 @@ export default class Spark {
       clearTimeout(timeout)
     }
 
-    stats.end = new Date()
+    stats.endAt = new Date()
     console.log(stats)
     return stats
   }
@@ -125,6 +125,7 @@ export default class Spark {
 
     await this.submitRetrieval(retrieval.id, { success, ...stats })
     Zinnia.jobCompleted()
+    return retrieval.id
   }
 
   async run () {

test/integration.js

@@ -1,7 +1,13 @@
 import Spark from '../lib/spark.js'
 import { test } from 'zinnia:test'
+import { assert, assertEquals } from 'zinnia:assert'
 
 test('integration', async () => {
   const spark = new Spark()
-  await spark.nextRetrieval()
+  const id = await spark.nextRetrieval()
+  const res = await fetch(`https://spark.fly.dev/retrievals/${id}`)
+  const retrieval = await res.json()
+  assert(retrieval.startAt)
+  assert(retrieval.finishedAt)
+
 })