Add HEAD request. #104

Author: juliangruber

lib/spark.js

@@ -78,6 +78,9 @@ export default class Spark {
     stats.providerAddress = provider.address
 
     await this.fetchCAR(provider.protocol, provider.address, retrieval.cid, stats)
+    if (stats.protocol === 'http') {
+      await this.testHeadRequest(provider.address, retrieval.cid, stats)
+    }
   }
 
   async fetchCAR (protocol, address, cid, stats) {
@@ -160,6 +163,22 @@ export default class Spark {
     stats.endAt = new Date()
   }
 
+  async testHeadRequest (address, cid, stats) {
+    const url = getRetrievalUrl('http', address, cid)
+    console.log(`Testing HEAD request: ${url}`)
+    try {
+      const res = await this.#fetch(url, {
+        method: 'HEAD',
+        signal: AbortSignal.timeout(10_000)
+      })
+      stats.headStatusCode = res.status
+    } catch (err) {
+      console.error(`Failed to make HEAD request to ${address} for ${cid}`)
+      console.error(err)
+      stats.headStatusCode = mapErrorToStatusCode(err)
+    }
+  }
+
   async submitMeasurement (task, stats) {
     console.log('Submitting measurement...')
     const payload = {
@@ -211,11 +230,11 @@ export default class Spark {
         this.handleRunError(err)
       }
       const duration = Date.now() - started
-      const delay = calculateDelayBeforeNextTask({
+      const delay = /* calculateDelayBeforeNextTask({
         roundLengthInMs: APPROX_ROUND_LENGTH_IN_MS,
         maxTasksPerRound: this.#tasker.maxTasksPerRound,
         lastTaskDurationInMs: duration
-      })
+      }) */ 0
 
       if (delay > 0) {
         console.log(
@@ -263,7 +282,8 @@ export function newStats () {
     carTooLarge: false,
     byteLength: 0,
     carChecksum: null,
-    statusCode: null
+    statusCode: null,
+    headStatusCode: null
   }
 }