chore: npm run lint:fix

Signed-off-by: Miroslav Bajtoš <oss@bajtos.net>

Author: bajtos

.github/dependabot.yml

@@ -1,27 +1,27 @@
 version: 2
 updates:
-  - package-ecosystem: "npm"
-    directory: "/"
+  - package-ecosystem: 'npm'
+    directory: '/'
     versioning-strategy: increase
     schedule:
-      interval: "daily"
-      time: "09:00"
-      timezone: "Europe/Berlin"
+      interval: 'daily'
+      time: '09:00'
+      timezone: 'Europe/Berlin'
     commit-message:
-      prefix: "deps"
-      prefix-development: "deps(dev)"
-  - package-ecosystem: "github-actions"
-    directory: "/"
+      prefix: 'deps'
+      prefix-development: 'deps(dev)'
+  - package-ecosystem: 'github-actions'
+    directory: '/'
     schedule:
-      interval: "daily"
-      time: "09:00"
-      timezone: "Europe/Berlin"
+      interval: 'daily'
+      time: '09:00'
+      timezone: 'Europe/Berlin'
     commit-message:
-      prefix: "ci"
-  - package-ecosystem: "docker"
+      prefix: 'ci'
+  - package-ecosystem: 'docker'
     directories:
-      - "/"
+      - '/'
     schedule:
-      interval: "daily"
-      time: "15:00"
-      timezone: "Europe/Berlin"
+      interval: 'daily'
+      time: '15:00'
+      timezone: 'Europe/Berlin'

.github/workflows/dependabot-auto-approve-always.yml

@@ -17,7 +17,7 @@ jobs:
         id: metadata
         uses: dependabot/fetch-metadata@v2
         with:
-          github-token: "${{ secrets.GITHUB_TOKEN }}"
+          github-token: '${{ secrets.GITHUB_TOKEN }}'
       - name: Approve a PR
         if: ${{startsWith(steps.metadata.outputs.dependency-names, matrix.dependencyStartsWith)}}
         run: gh pr review --approve "$PR_URL"

.github/workflows/dependabot-auto-approve-minor.yml

@@ -26,9 +26,12 @@ jobs:
         id: metadata
         uses: dependabot/fetch-metadata@v2
         with:
-          github-token: "${{ secrets.GITHUB_TOKEN }}"
+          github-token: '${{ secrets.GITHUB_TOKEN }}'
       - name: Approve a PR
-        if: ${{startsWith(steps.metadata.outputs.dependency-names, matrix.dependencyStartsWith) && (steps.metadata.outputs.update-type == 'version-update:semver-patch' || steps.metadata.outputs.update-type == 'version-update:semver-minor')}}
+        if:
+          ${{startsWith(steps.metadata.outputs.dependency-names, matrix.dependencyStartsWith) &&
+          (steps.metadata.outputs.update-type == 'version-update:semver-patch' ||
+          steps.metadata.outputs.update-type == 'version-update:semver-minor')}}
         run: gh pr review --approve "$PR_URL"
         env:
           PR_URL: ${{github.event.pull_request.html_url}}

README.md

@@ -6,27 +6,26 @@ A lightweight IPNI node mapping Filecoin PieceCID → payload block CID.
 
 ## Basic use
 
-Note: this will change soon, see
-https://github.com/filecoin-station/piece-indexer/issues/33
+Note: this will change soon, see https://github.com/filecoin-station/piece-indexer/issues/33
 
 ## `GET /sample/{provider-id}/{piece-cid}`
 
-Sample a set of multihashes ingested by IPNI for a given ContextID, matching the
-route eventually to be exposed by an IPNI reverse index.
+Sample a set of multihashes ingested by IPNI for a given ContextID, matching the route eventually to
+be exposed by an IPNI reverse index.
 
 _This is an alternative implementation of the IPNI Reverse Index as specified in
 [xedni/openapi.yaml](https://github.com/ipni/xedni/blob/526f90f5a6001cb50b52e6376f8877163f8018af/openapi.yaml)._
 
 Parameters:
 
 - `provider-id` - the peer ID of the storage provider (index publisher)
-- `piece-cid` - the Filecoin deal's PieceCID as advertised by the provider in
-  Graphsync retrieval metadata
+- `piece-cid` - the Filecoin deal's PieceCID as advertised by the provider in Graphsync retrieval
+  metadata
 
 Response:
 
-- `samples` - a list of exactly one payload block CID contained inside the piece
-  identified by the requested PieceCID.
+- `samples` - a list of exactly one payload block CID contained inside the piece identified by the
+  requested PieceCID.
 
 Example:
 

api/bin/server.js

@@ -9,7 +9,7 @@ const {
   HOST = '127.0.0.1',
   DOMAIN: domain = 'localhost',
   REDIS_URL: redisUrl = 'redis://localhost:6379',
-  REQUEST_LOGGING: requestLogging = 'true'
+  REQUEST_LOGGING: requestLogging = 'true',
 } = process.env
 
 const redisUrlParsed = new URL(redisUrl)
@@ -19,7 +19,7 @@ const redis = new Redis({
   username: redisUrlParsed.username,
   password: redisUrlParsed.password,
   lazyConnect: true, // call connect() explicitly so that we can exit on connection error
-  family: 6 // required for upstash
+  family: 6, // required for upstash
 })
 
 await redis.connect()
@@ -29,8 +29,8 @@ const app = createApp({
   repository,
   domain,
   logger: {
-    level: ['1', 'true'].includes(requestLogging) ? 'info' : 'error'
-  }
+    level: ['1', 'true'].includes(requestLogging) ? 'info' : 'error',
+  },
 })
 console.log('Starting the http server on host %j port %s', HOST, PORT)
 const baseUrl = await app.listen({ host: HOST, port: Number(PORT) })

api/lib/app.js

@@ -7,7 +7,7 @@ import Fastify from 'fastify'
  * @param {string|boolean} args.domain
  * @param {Fastify.FastifyLoggerOptions} args.logger
  */
-export function createApp ({ repository, domain, logger }) {
+export function createApp({ repository, domain, logger }) {
   const app = Fastify({ logger })
   Sentry.setupFastifyErrorHandler(app)
 
@@ -41,7 +41,7 @@ export function createApp ({ repository, domain, logger }) {
     if (!walkerState) {
       return reply.send({
         providerId,
-        ingestionStatus: 'Unknown provider ID'
+        ingestionStatus: 'Unknown provider ID',
       })
     }
 
@@ -54,7 +54,7 @@ export function createApp ({ repository, domain, logger }) {
       lastHeadWalkedFrom: walkerState.lastHead ?? walkerState.head,
       adsMissingPieceCID: walkerState.adsMissingPieceCID ?? 0,
       entriesNotRetrievable: walkerState.entriesNotRetrievable ?? 0,
-      piecesIndexed: await repository.countPiecesIndexed(providerId)
+      piecesIndexed: await repository.countPiecesIndexed(providerId),
     })
   })
 

api/lib/instrument.js

@@ -7,14 +7,9 @@ const { SENTRY_ENVIRONMENT = 'development' } = process.env
 
 const pkg = JSON.parse(
   await fs.readFile(
-    join(
-      dirname(fileURLToPath(import.meta.url)),
-      '..',
-      '..',
-      'package.json'
-    ),
-    'utf8'
-  )
+    join(dirname(fileURLToPath(import.meta.url)), '..', '..', 'package.json'),
+    'utf8',
+  ),
 )
 
 Sentry.init({
@@ -24,13 +19,13 @@ Sentry.init({
   tracesSampleRate: 0.1,
   // Ignore Fastify 4xx errors
   // Remove once https://github.com/getsentry/sentry-javascript/pull/13198 lands
-  beforeSend (event, { originalException: err }) {
+  beforeSend(event, { originalException: err }) {
     const isBadRequest =
       typeof err === 'object' &&
       err !== null &&
       'statusCode' in err &&
       typeof err.statusCode === 'number' &&
       err.statusCode < 500
     return isBadRequest ? null : event
-  }
+  },
 })

api/test/app.test.js

@@ -24,10 +24,8 @@ describe('HTTP request handler', () => {
       repository,
       domain: false,
       logger: {
-        level: process.env.DEBUG === '*' || process.env.DEBUG?.includes('test')
-          ? 'debug'
-          : 'error'
-      }
+        level: process.env.DEBUG === '*' || process.env.DEBUG?.includes('test') ? 'debug' : 'error',
+      },
     })
     baseUrl = await app.listen()
   })
@@ -48,20 +46,35 @@ describe('HTTP request handler', () => {
 
   describe('GET /samples/{providerId}/{pieceCid}', () => {
     it('returns the first payload block from the index', async () => {
-      await repository.addPiecePayloadBlocks('provider-id', 'piece-cid', 'payload-cid-1', 'payload-cid-2')
-      await repository.addPiecePayloadBlocks('provider-id2', 'piece-cid', 'payload-cid-1', 'payload-cid-2')
-      await repository.addPiecePayloadBlocks('provider-id', 'piece-cid2', 'payload-cid-1', 'payload-cid-2')
+      await repository.addPiecePayloadBlocks(
+        'provider-id',
+        'piece-cid',
+        'payload-cid-1',
+        'payload-cid-2',
+      )
+      await repository.addPiecePayloadBlocks(
+        'provider-id2',
+        'piece-cid',
+        'payload-cid-1',
+        'payload-cid-2',
+      )
+      await repository.addPiecePayloadBlocks(
+        'provider-id',
+        'piece-cid2',
+        'payload-cid-1',
+        'payload-cid-2',
+      )
 
       const res = await fetch(new URL('/sample/provider-id/piece-cid', baseUrl))
       await assertResponseStatus(res, 200)
       const body = await res.json()
 
       assert.deepStrictEqual(body, {
-        samples: ['payload-cid-1']
+        samples: ['payload-cid-1'],
       })
       assert.strictEqual(
         res.headers.get('cache-control'),
-        `public, max-age=${24 * 3600}, immutable`
+        `public, max-age=${24 * 3600}, immutable`,
       )
     })
 
@@ -73,12 +86,9 @@ describe('HTTP request handler', () => {
       const body = await res.json()
 
       assert.deepStrictEqual(body, {
-        error: 'PROVIDER_OR_PIECE_NOT_FOUND'
+        error: 'PROVIDER_OR_PIECE_NOT_FOUND',
       })
-      assert.strictEqual(
-        res.headers.get('cache-control'),
-        `public, max-age=${60}`
-      )
+      assert.strictEqual(res.headers.get('cache-control'), `public, max-age=${60}`)
     })
 
     it('returns error when provider piece is not found', async () => {
@@ -89,12 +99,9 @@ describe('HTTP request handler', () => {
       const body = await res.json()
 
       assert.deepStrictEqual(body, {
-        error: 'PROVIDER_OR_PIECE_NOT_FOUND'
+        error: 'PROVIDER_OR_PIECE_NOT_FOUND',
       })
-      assert.strictEqual(
-        res.headers.get('cache-control'),
-        `public, max-age=${60}`
-      )
+      assert.strictEqual(res.headers.get('cache-control'), `public, max-age=${60}`)
     })
   })
 
@@ -115,20 +122,17 @@ describe('HTTP request handler', () => {
         lastHeadWalkedFrom: 'last-head',
         adsMissingPieceCID: 0,
         entriesNotRetrievable: 0,
-        piecesIndexed: 1
+        piecesIndexed: 1,
       })
 
-      assert.strictEqual(
-        res.headers.get('cache-control'),
-        `public, max-age=${60}`
-      )
+      assert.strictEqual(res.headers.get('cache-control'), `public, max-age=${60}`)
     })
 
     it('returns error for an unknown provider', async () => {
       await repository.setWalkerState('provider-id', {
         status: 'walking',
         tail: 'tail',
-        lastHead: 'last-head'
+        lastHead: 'last-head',
       })
       await repository.addPiecePayloadBlocks('provider-id', 'piece-cid', 'bafy1')
 
@@ -138,13 +142,10 @@ describe('HTTP request handler', () => {
 
       assert.deepStrictEqual(body, {
         providerId: 'unknown-provider-id',
-        ingestionStatus: 'Unknown provider ID'
+        ingestionStatus: 'Unknown provider ID',
       })
 
-      assert.strictEqual(
-        res.headers.get('cache-control'),
-        `public, max-age=${60}`
-      )
+      assert.strictEqual(res.headers.get('cache-control'), `public, max-age=${60}`)
     })
 
     it('returns "head" as "lastHead" when the initial walk has not finished yet', async () => {
@@ -161,21 +162,18 @@ describe('HTTP request handler', () => {
         lastHeadWalkedFrom: 'head',
         adsMissingPieceCID: 0,
         entriesNotRetrievable: 0,
-        piecesIndexed: 1
+        piecesIndexed: 1,
       })
 
-      assert.strictEqual(
-        res.headers.get('cache-control'),
-          `public, max-age=${60}`
-      )
+      assert.strictEqual(res.headers.get('cache-control'), `public, max-age=${60}`)
     })
 
     it('returns the number of adsMissingPieceCID and entriesNotRetrievable', async () => {
       await repository.setWalkerState('provider-id', {
         status: 'walking',
         head: 'head',
         entriesNotRetrievable: 10,
-        adsMissingPieceCID: 20
+        adsMissingPieceCID: 20,
       })
 
       const res = await fetch(new URL('/ingestion-status/provider-id', baseUrl))
@@ -188,13 +186,10 @@ describe('HTTP request handler', () => {
         lastHeadWalkedFrom: 'head',
         entriesNotRetrievable: 10,
         adsMissingPieceCID: 20,
-        piecesIndexed: 0
+        piecesIndexed: 0,
       })
 
-      assert.strictEqual(
-        res.headers.get('cache-control'),
-          `public, max-age=${60}`
-      )
+      assert.strictEqual(res.headers.get('cache-control'), `public, max-age=${60}`)
     })
   })
 })

api/test/test-helpers.js

@@ -5,7 +5,7 @@ export const assertResponseStatus = async (res, status) => {
     throw new AssertionError({
       actual: res.status,
       expected: status,
-      message: `Unexpected status code ${res.status} (expected ${status}). Response body: ${await res.text() || '(empty)'}`
+      message: `Unexpected status code ${res.status} (expected ${status}). Response body: ${(await res.text()) || '(empty)'}`,
     })
   }
 }