feat: add tool to query aggregates pending deal

.github/workflows/convert-piece-cid-v1-to-v2-with-height.yml

@@ -20,7 +20,7 @@ jobs:
       - uses: actions/setup-node@v3
         with:
           registry-url: 'https://registry.npmjs.org'
-          node-version: 18
+          node-version: 20
           cache: 'npm'
       - run: npm install @web3-storage/pieces
       - name: Run job

.github/workflows/convert-piece-cid-v1-to-v2-with-log2-size.yml

@@ -20,7 +20,7 @@ jobs:
       - uses: actions/setup-node@v3
         with:
           registry-url: 'https://registry.npmjs.org'
-          node-version: 18
+          node-version: 20
           cache: 'npm'
       - run: npm install @web3-storage/pieces
       - name: Run job

.github/workflows/get-aggregate-deals.yml

@@ -21,7 +21,7 @@ jobs:
       - uses: actions/setup-node@v3
         with:
           registry-url: 'https://registry.npmjs.org'
-          node-version: 18
+          node-version: 20
           cache: 'npm'
       - run: npm ci
       - name: Run job

.github/workflows/get-aggregates-pending-deals.yml

@@ -0,0 +1,23 @@
+name: Get Aggregates pending deals
+
+on:
+  workflow_dispatch:
+
+jobs:
+  getAggregatesOffered:
+    name: Get Aggregates pending deals
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        env: ['staging', 'production']
+    timeout-minutes: 20
+    steps:
+      - uses: actions/checkout@v3
+      - uses: actions/setup-node@v3
+        with:
+          registry-url: 'https://registry.npmjs.org'
+          node-version: 20
+          cache: 'npm'
+      - run: npm ci
+      - name: Run job
+        run: npm run get-aggregates-pending-deals -w packages/tools

.github/workflows/test.yaml

@@ -15,7 +15,7 @@ jobs:
       - uses: actions/setup-node@v3
         with:
           registry-url: 'https://registry.npmjs.org'
-          node-version: 18
+          node-version: 20
           cache: 'npm'
       - run: npm ci
       - run: npm run lint

packages/tools/README.md

@@ -0,0 +1,46 @@
+# w3filecoin Tools
+
+> A set of tools to facilitate diagnosing and debugging incidents.
+
+## Getting Started
+
+Run in the main folder of this repo `npm install` to guarantee all the dependencies needed are properly installed.
+
+To be able to run these tools, an AWS account with the AWS CLI MUST be configured locally and have access to the resources of w3filecoin.
+
+## Tools
+
+### Get aggregate deals
+
+Get all known deals for a given aggregate.
+
+```sh
+$ npm run get-aggregate-deals bafkz...
+> @w3filecoin/[email protected] get-aggregate-deals
+> node get-aggregate-deals.js bafkz...
+
+known information for aggregate bafkz...:
+{
+  deals: {
+    '123': { provider: '111' },
+    '124': { provider: '222' }
+  }
+}
+```
+
+### Get aggregates pending deals
+
+```sh
+$ npm run get-aggregates-pending-deals
+
+> @w3filecoin/[email protected] get-aggregates-pending-deals
+> node get-aggregates-pending-deals.js
+
+Offered aggregates page size:  4 
+
+Aggregate offer list:
+bafkzcibcaapg... at 2024-05-28T06:52:25.779Z
+bafkzcibcaapn... at 2024-05-28T07:12:45.567Z
+bafkzcibcaapb... at 2024-05-28T07:48:21.420Z
+bafkzcibcaapi... at 2024-05-28T08:23:59.203Z
+```

packages/tools/get-aggregates-pending-deals.js

@@ -0,0 +1,23 @@
+import { createClient as createAggregateStoreClient } from '@w3filecoin/core/src/store/dealer-aggregate-store.js'
+
+const AWS_REGION = 'us-west-2'
+
+const aggregateStore = createAggregateStoreClient({
+  region: AWS_REGION
+}, {
+  tableName: 'prod-w3filecoin-dealer-aggregate-store'
+})
+
+// Get offered aggregates pending approval/rejection
+const offeredAggregates = await aggregateStore.query({
+  status: 'offered',
+})
+if (offeredAggregates.error) {
+  throw offeredAggregates.error
+}
+
+console.log('Offered aggregates page size:', offeredAggregates.ok.length, '\n')
+console.log('Aggregate offer list:')
+for (const aggregate of offeredAggregates.ok) {
+  console.log(`${aggregate.aggregate.link()} at ${aggregate.insertedAt}`)
+}

packages/tools/package.json

@@ -3,7 +3,8 @@
   "version": "0.0.0",
   "type": "module",
   "scripts": {
-    "get-aggregate-deals": "node get-aggregate-deals.js"
+    "get-aggregate-deals": "node get-aggregate-deals.js",
+    "get-aggregates-pending-deals": "node get-aggregates-pending-deals.js"
   },
   "dependencies": {},
   "devDependencies": {