fix: lint

packages/eslint-config-w3up/index.js

@@ -1,61 +1,60 @@
 'use strict'
 
 module.exports = {
-  "extends": [
-    "eslint:recommended",
-    "plugin:@typescript-eslint/recommended",
-    "plugin:jsdoc/recommended",
+  extends: [
+    'eslint:recommended',
+    'plugin:@typescript-eslint/recommended',
+    'plugin:jsdoc/recommended',
   ],
   rules: {
-    "@typescript-eslint/no-unused-vars": "off",
-    "@typescript-eslint/ban-ts-comment": "off",
-  
+    '@typescript-eslint/no-unused-vars': 'off',
+    '@typescript-eslint/ban-ts-comment': 'off',
+
     /**
      * many of these rules are inherited from hd-scripts.
      * It may be useful over time to remove these rules
      * and juse use plugin:jsdoc/recommended defaults.
      * But that might require updating src.
      */
-    "jsdoc/check-values": "off",
-    "jsdoc/check-tag-names": "off",
-    "jsdoc/require-jsdoc": [
-      "warn",
+    'jsdoc/check-values': 'off',
+    'jsdoc/check-tag-names': 'off',
+    'jsdoc/require-jsdoc': [
+      'warn',
       {
-        "publicOnly": true
-      }
+        publicOnly: true,
+      },
     ],
-    "jsdoc/require-returns": "off",
-    "jsdoc/require-returns-type": "off",
-    "jsdoc/require-throws": "off",
-    "jsdoc/require-yields": "off",
-    "jsdoc/require-param-description": "off",
-    "jsdoc/require-property-description": "off",
-    "jsdoc/require-returns-description": "off",
-    "jsdoc/valid-types": "off",
-    "jsdoc/tag-lines": [
-      "error",
-      "any",
+    'jsdoc/require-returns': 'off',
+    'jsdoc/require-returns-type': 'off',
+    'jsdoc/require-throws': 'off',
+    'jsdoc/require-yields': 'off',
+    'jsdoc/require-param-description': 'off',
+    'jsdoc/require-property-description': 'off',
+    'jsdoc/require-returns-description': 'off',
+    'jsdoc/valid-types': 'off',
+    'jsdoc/tag-lines': [
+      'error',
+      'any',
       {
-        "startLines": 1
-      }
+        startLines: 1,
+      },
     ],
-    "jsdoc/no-undefined-types": [
-      "error",
+    'jsdoc/no-undefined-types': [
+      'error',
       {
-        "definedTypes": [
-          "ArrayLike",
-          "AsyncIterable",
-          "AsyncIterableIterator",
-          "Iterable",
-          "IterableIterator",
-          "Generator",
-          "CryptoKeyPair",
-          "NodeJS",
-          "ErrorOptions",
-          "IDBTransactionMode"
-        ]
-      }
-    ]
-
-  }
+        definedTypes: [
+          'ArrayLike',
+          'AsyncIterable',
+          'AsyncIterableIterator',
+          'Iterable',
+          'IterableIterator',
+          'Generator',
+          'CryptoKeyPair',
+          'NodeJS',
+          'ErrorOptions',
+          'IDBTransactionMode',
+        ],
+      },
+    ],
+  },
 }

packages/filecoin-api/src/aggregator/api.ts

@@ -19,7 +19,11 @@ export type BufferQueue = Queue<BufferMessage>
 export type BufferStore = Store<Link, BufferRecord>
 export type AggregateStore = Store<AggregateRecordKey, AggregateRecord>
 export type PieceAcceptQueue = Queue<PieceAcceptMessage>
-export type InclusionStore = QueryableStore<InclusionRecordKey, InclusionRecord, InclusionRecordQueryByGroup>
+export type InclusionStore = QueryableStore<
+  InclusionRecordKey,
+  InclusionRecord,
+  InclusionRecordQueryByGroup
+>
 export type AggregateOfferQueue = Queue<AggregateOfferMessage>
 
 export interface ServiceContext {

packages/filecoin-api/src/aggregator/buffer-reducing.js

@@ -45,7 +45,9 @@ export async function handleBufferReducingWithAggregate({
     pieces: aggregateInfo.addedBufferedPieces,
     group,
   }
-  const piecesBlock = await CBOR.write(aggregateInfo.addedBufferedPieces.map(bf => bf.piece))
+  const piecesBlock = await CBOR.write(
+    aggregateInfo.addedBufferedPieces.map((bf) => bf.piece)
+  )
   const aggregateBlock = await CBOR.write(aggregateReducedBuffer)
 
   // Store buffered pieces for aggregate

packages/filecoin-api/src/aggregator/service.js

@@ -77,7 +77,7 @@ export const pieceAccept = async ({ capability }, context) => {
     }
   }
 
-  // Get buffered pieces 
+  // Get buffered pieces
   const [{ aggregate, inclusion }] = getInclusionRes.ok
   const getAggregateRes = await context.aggregateStore.get({ aggregate })
   if (getAggregateRes.error) {

packages/filecoin-api/src/deal-tracker/api.ts

@@ -2,7 +2,11 @@ import type { Signer } from '@ucanto/interface'
 import { PieceLink } from '@web3-storage/data-segment'
 import { QueryableStore } from '../types.js'
 
-export type DealStore = QueryableStore<DealRecordKey, DealRecord, DealRecordQueryByPiece>
+export type DealStore = QueryableStore<
+  DealRecordKey,
+  DealRecord,
+  DealRecordQueryByPiece
+>
 
 export interface ServiceContext {
   /**

packages/filecoin-api/src/dealer/api.ts

@@ -44,7 +44,8 @@ export interface AggregateUpdatedStatusEventContext {
   dealerService: ServiceConfig<DealerService>
 }
 
-export interface CronContext extends Pick<ServiceContext, 'aggregateStore' | 'dealTrackerService'> {}
+export interface CronContext
+  extends Pick<ServiceContext, 'aggregateStore' | 'dealTrackerService'> {}
 
 export interface AggregateRecord {
   /**

packages/filecoin-api/src/dealer/events.js

@@ -141,7 +141,7 @@ async function updateApprovedDeals({
     { aggregate: deal.aggregate },
     {
       status: 'accepted',
-      updatedAt: new Date().toISOString()
+      updatedAt: new Date().toISOString(),
     }
   )
 

packages/filecoin-api/src/dealer/service.js

@@ -8,10 +8,7 @@ import * as DealerCaps from '@web3-storage/capabilities/filecoin/dealer'
 import { DealTracker } from '@web3-storage/filecoin-client'
 // eslint-disable-next-line no-unused-vars
 import * as API from '../types.js'
-import {
-  StoreOperationFailed,
-  DecodeBlockOperationFailed,
-} from '../errors.js'
+import { StoreOperationFailed, DecodeBlockOperationFailed } from '../errors.js'
 
 /**
  * @param {API.Input<DealerCaps.aggregateOffer>} input
@@ -112,17 +109,19 @@ export const aggregateAccept = async ({ capability }, context) => {
   const deals = Object.keys(info.out.ok.deals || {})
   if (!deals.length) {
     return {
-      error: new Server.Failure('no deals were obtained for given aggregate CID')
+      error: new Server.Failure(
+        'no deals were obtained for given aggregate CID'
+      ),
     }
   }
-  
+
   // For receipts, we only care about first deal
   // TODO: We need to revisit this with renewals
   const deal = {
     dataType: 0n,
     dataSource: {
-      dealID: BigInt(deals[0])
-    }
+      dealID: BigInt(deals[0]),
+    },
   }
 
   return {

packages/filecoin-api/src/storefront/api.ts

@@ -18,7 +18,11 @@ import {
   ServiceConfig,
 } from '../types.js'
 
-export type PieceStore = UpdatableAndQueryableStore<PieceRecordKey, PieceRecord, Pick<PieceRecord, 'status'>>
+export type PieceStore = UpdatableAndQueryableStore<
+  PieceRecordKey,
+  PieceRecord,
+  Pick<PieceRecord, 'status'>
+>
 export type FilecoinSubmitQueue = Queue<FilecoinSubmitMessage>
 export type PieceOfferQueue = Queue<PieceOfferMessage>
 export type TaskStore = Store<UnknownLink, Invocation>

packages/filecoin-api/src/storefront/events.js

@@ -29,7 +29,7 @@ export const handleFilecoinSubmitMessage = async (context, message) => {
   }
   if (hasRes.ok) {
     return {
-      ok: {}
+      ok: {},
     }
   }
 

packages/filecoin-api/src/storefront/service.js

@@ -5,10 +5,7 @@ import * as StorefrontCaps from '@web3-storage/capabilities/filecoin/storefront'
 import * as AggregatorCaps from '@web3-storage/capabilities/filecoin/aggregator'
 // eslint-disable-next-line no-unused-vars
 import * as API from '../types.js'
-import {
-  QueueOperationFailed,
-  StoreOperationFailed,
-} from '../errors.js'
+import { QueueOperationFailed, StoreOperationFailed } from '../errors.js'
 
 /**
  * @param {API.Input<StorefrontCaps.filecoinOffer>} input

packages/filecoin-api/test/aggregator.spec.js

@@ -25,15 +25,9 @@ describe('Aggregator', () => {
         // resources
         /** @type {Map<string, unknown[]>} */
         const queuedMessages = new Map()
+        const { pieceQueue } = getQueues(queuedMessages)
         const {
-          pieceQueue,
-        } = getQueues(queuedMessages)
-        const {
-          aggregator: {
-            pieceStore,
-            aggregateStore,
-            inclusionStore,
-          },
+          aggregator: { pieceStore, aggregateStore, inclusionStore },
         } = getStoreImplementations()
 
         await test(
@@ -55,7 +49,7 @@ describe('Aggregator', () => {
             inclusionStore,
             pieceQueue,
             queuedMessages,
-            validateAuthorization
+            validateAuthorization,
           }
         )
       })
@@ -138,7 +132,7 @@ describe('Aggregator', () => {
               minAggregateSize: 2 ** 34,
               minUtilizationFactor: 4,
             },
-            validateAuthorization
+            validateAuthorization,
           }
         )
       })

packages/filecoin-api/test/context/queue-implementations.js

@@ -1,7 +1,7 @@
 import { Queue } from './queue.js'
 
 /**
- * @param {Map<string, unknown[]>} queuedMessages 
+ * @param {Map<string, unknown[]>} queuedMessages
  */
 export const getQueueImplementations = (
   queuedMessages,
@@ -26,7 +26,7 @@ export const getQueueImplementations = (
   return {
     storefront: {
       filecoinSubmitQueue,
-      pieceOfferQueue
-    }
+      pieceOfferQueue,
+    },
   }
 }

packages/filecoin-api/test/context/service.js

@@ -227,7 +227,7 @@ export function getConnection(id, service) {
     id: id,
     service,
     codec: CAR.inbound,
-    validateAuthorization
+    validateAuthorization,
   })
   const connection = Client.connect({
     id: id,

packages/filecoin-api/test/context/store-implementations.js

@@ -170,15 +170,18 @@ export const getStoreImplementations = (
         /** @type {Set<DealerAggregateRecord>} */ items,
         /** @type {Partial<DealerAggregateRecord>} */ search
       ) => {
-        return Array.from(items).filter((i) => i.status === search.status || i.aggregate.equals(search.aggregate))
+        return Array.from(items).filter(
+          (i) =>
+            i.status === search.status || i.aggregate.equals(search.aggregate)
+        )
       },
       updateFn: (
         /** @type {Set<DealerAggregateRecord>} */ items,
         /** @type {DealerAggregateRecordKey} */ key,
         /** @type {Partial<DealerAggregateRecord>} */ item
       ) => {
-        const itemToUpdate = Array.from(items).find(
-          (i) => i.aggregate.equals(key.aggregate)
+        const itemToUpdate = Array.from(items).find((i) =>
+          i.aggregate.equals(key.aggregate)
         )
         if (!itemToUpdate) {
           throw new Error('not found')

packages/filecoin-api/test/deal-tracker.spec.js

@@ -43,7 +43,7 @@ describe('deal-tracker', () => {
                 assert.fail(error)
               },
             },
-            validateAuthorization
+            validateAuthorization,
           }
         )
       })

packages/filecoin-api/test/dealer.spec.js

@@ -57,7 +57,7 @@ describe('Dealer', () => {
                 audience: dealTrackerSigner,
               },
             },
-            validateAuthorization
+            validateAuthorization,
           }
         )
       })
@@ -122,7 +122,7 @@ describe('Dealer', () => {
               },
             },
             service,
-            validateAuthorization
+            validateAuthorization,
           }
         )
       })