feat: wip pinata pins

.github/workflows/cron-pinata.yml

@@ -0,0 +1,33 @@
+name: Cron Pinata Sync
+
+on:
+  schedule:
+    - cron: '0 */12 * * *'
+
+jobs:
+  update:
+    name: Sync with Pinata
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        env: ['staging', 'production']
+    timeout-minutes: 60
+    steps:
+      - uses: actions/checkout@v2
+
+      - name: Setup node
+        uses: actions/setup-node@v1
+        with:
+          node-version: 15
+
+      - name: Install dependencies
+        run: yarn install
+
+      - name: Run job
+        env:
+          DEBUG: '*'
+          ENV: ${{ matrix.env }}
+          CF_ACCOUNT: ${{ secrets.CF_ACCOUNT }}
+          CF_TOKEN: ${{ secrets.CF_TOKEN }}
+          PINATA_JWT: ${{ secrets.PINATA_JWT }}
+        run: yarn --cwd packages/cron start:pinata

packages/cron/src/lib/pinata.js

@@ -0,0 +1,41 @@
+import { URL } from 'url'
+import fetch from 'node-fetch'
+
+const endpoint = 'https://api.pinata.cloud'
+
+export class Pinata {
+  /**
+   * @param {{ apiToken: string }} config
+   */
+  constructor({ apiToken }) {
+    this.apiToken = apiToken
+  }
+
+  /**
+   * @param {string} cid
+   * @param {{ pinataOptions?: { hostNodes?: string[] }, pinataMetadata?: { name?: string } }} [options]
+   * @returns {Promise<{ id: string, ipfsHash: string, status: string, name: string }>}
+   */
+  async pinByHash(cid, options) {
+    const url = new URL('/pinning/pinByHash', endpoint)
+
+    const res = await fetch(url.toString(), {
+      method: 'POST',
+      headers: {
+        Authorization: `Bearer ${this.apiToken}`,
+        'Content-Type': 'application/json',
+      },
+      body: JSON.stringify({ hashToPin: cid, ...(options || {}) }),
+    })
+
+    const text = await res.text()
+    if (!res.ok) {
+      throw Object.assign(
+        new Error(`${res.status} ${res.statusText}: ${text}`),
+        { response: res }
+      )
+    }
+
+    return JSON.parse(text)
+  }
+}

packages/cron/src/lib/utils.js

@@ -1,6 +1,7 @@
 import { Cluster } from '@nftstorage/ipfs-cluster'
 import { Cloudflare } from '../lib/cloudflare.js'
 import { IPFS } from './ipfs.js'
+import { Pinata } from './pinata.js'
 
 /**
  * @param {import('./cloudflare').Namespace[]} namespaces
@@ -55,3 +56,13 @@ export function getClusterIPFSProxy(env) {
     headers: { Authorization: `Basic ${basicAuthToken}` },
   })
 }
+
+/**
+ * Create a new IPFS client instance from the passed environment variables.
+ * @param {Record<string, string|undefined>} env
+ */
+export function getPinata(env) {
+  const apiToken = env.PINATA_JWT
+  if (!apiToken) throw new Error('missing Pinata API token')
+  return new Pinata({ apiToken })
+}