add .github/workflows/cron-nft-ttr

.github/workflows/cron-nft-ttr.yaml

@@ -0,0 +1,37 @@
+name: Cron Pins
+
+on:
+  schedule:
+    - cron: '30 * * * *'
+  workflow_dispatch:
+
+jobs:
+  measure:
+    name: measure nft time to retrievability
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        env: ['staging', 'production']
+    timeout-minutes: 60
+    steps:
+      - uses: actions/checkout@v2
+      - uses: actions/setup-node@v2
+        with:
+          node-version: 16
+      - uses: bahmutov/npm-install@v1
+      - name: Run job
+        env:
+          DEBUG: '*'
+          ENV: ${{ matrix.env }}
+          STAGING_DATABASE_CONNECTION: ${{ secrets.STAGING_DATABASE_CONNECTION }}
+          PROD_DATABASE_CONNECTION: ${{ secrets.PROD_DATABASE_CONNECTION }}
+          CLUSTER1_API_URL: ${{ secrets.CLUSTER1_API_URL }}
+          CLUSTER1_BASIC_AUTH_TOKEN: ${{ secrets.CLUSTER1_BASIC_AUTH_TOKEN }}
+          CLUSTER2_API_URL: ${{ secrets.CLUSTER2_API_URL }}
+          CLUSTER2_BASIC_AUTH_TOKEN: ${{ secrets.CLUSTER2_BASIC_AUTH_TOKEN }}
+          CLUSTER3_API_URL: ${{ secrets.CLUSTER3_API_URL }}
+          CLUSTER3_BASIC_AUTH_TOKEN: ${{ secrets.CLUSTER3_BASIC_AUTH_TOKEN }}
+        run: yarn --cwd packages/cron start:nft-ttr
+      - name: Heartbeat
+        if: ${{ success() }}
+        run: ./packages/tools/cli.js heartbeat --token ${{ secrets.OPSGENIE_KEY }} --name cron-nft-ttr

packages/cron/package.json

@@ -12,11 +12,13 @@
   },
   "scripts": {
     "start": "run-s start:*",
+    "start:nft-ttr": "node src/bin/nft-ttr.js",
     "start:pins": "NODE_TLS_REJECT_UNAUTHORIZED=0 node src/bin/pins.js",
     "start:pins-failed": "NODE_TLS_REJECT_UNAUTHORIZED=0 node src/bin/pins-failed.js",
     "start:pinata": "node src/bin/pinata.js",
     "start:dagcargo:sizes": "NODE_TLS_REJECT_UNAUTHORIZED=0 node src/bin/dagcargo-sizes.js",
-    "start:metrics": "NODE_TLS_REJECT_UNAUTHORIZED=0 node src/bin/metrics.js"
+    "start:metrics": "NODE_TLS_REJECT_UNAUTHORIZED=0 node src/bin/metrics.js",
+    "test": "jest"
   },
   "author": "Alan Shaw",
   "license": "(Apache-2.0 OR MIT)",
@@ -26,6 +28,7 @@
     "debug": "^4.3.2",
     "dotenv": "^10.0.0",
     "form-data": "^4.0.0",
+    "jest": "^28.1.0",
     "limiter": "2.0.1",
     "nft.storage": "^6.0.0",
     "p-retry": "^4.6.1",

packages/cron/src/bin/nft-ttr.js

@@ -0,0 +1,26 @@
+#!/usr/bin/env node
+
+import path from 'path'
+import { fileURLToPath } from 'url'
+import dotenv from 'dotenv'
+import fetch from '@web-std/fetch'
+import { updatePendingPinStatuses } from '../jobs/pins.js'
+import { getPg, getCluster1, getCluster2, getCluster3 } from '../lib/utils.js'
+import { measureNftTimeToRetrievability } from '../jobs/measureNftTimeToRetrievability.js'
+
+const __dirname = path.dirname(fileURLToPath(import.meta.url))
+/** @ts-ignore */
+global.fetch = fetch
+
+async function main() {
+  const pg = getPg(process.env, 'rw')
+  try {
+    await pg.connect()
+    await measureNftTimeToRetrievability()
+  } finally {
+    await pg.end()
+  }
+}
+
+dotenv.config({ path: path.join(__dirname, '../../../../.env') })
+main()

packages/cron/src/jobs/measureNftTimeToRetrievability.js

@@ -0,0 +1,3 @@
+export async function measureNftTimeToRetrievability() {
+  console.log('start measureNftTimeToRetrievability')
+}

packages/cron/src/lib/utils.spec.js

@@ -0,0 +1,3 @@
+describe('utils', () => {
+  it('has a test', () => {})
+})