From fc5a41123a9a0dbf050fc655ac5f4da664f89a95 Mon Sep 17 00:00:00 2001
From: Michael Bumann <hello@michaelbumann.com>
Date: Tue, 11 Jun 2019 21:48:50 +0200
Subject: [PATCH] Add IPFS pinning script

This script loads the IPFS hashes for contributors and contributions and
pins them on the connected IPFS node.

usage:

    $ node script/ipfs-pinner.js

    $ ETH_RPC_URL=http://localhost:7547 APM_DOMAIN=aragonpm.eth node scripts/ipfs.pinner.js
---
 scripts/ipfs-pinner.js | 60 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 60 insertions(+)
 create mode 100644 scripts/ipfs-pinner.js

diff --git a/scripts/ipfs-pinner.js b/scripts/ipfs-pinner.js
new file mode 100644
index 0000000..b53608a
--- /dev/null
+++ b/scripts/ipfs-pinner.js
@@ -0,0 +1,60 @@
+//const Kredits = require('kredits-contracts');
+const Kredits = require('../lib/kredits');
+const multihashes = require('multihashes');
+
+async function pinContributor (kredits, id) {
+  const data = await kredits.Contributor.functions.getContributorById(id);
+  const ipfsHash = multihashes.toB58String(kredits.ipfs.encodeHash(data));
+  console.log(`Pinning Contributor ${id} ${ipfsHash}`);
+  kredits.ipfs._ipfsAPI.pin.add(ipfsHash, (err) => {
+    if (err) {
+      console.log(`Failed to pin ${ipfsHash}`);
+      console.log(err);
+    }
+  });
+}
+
+async function pinContribution (kredits, id) {
+  const data = await kredits.Contribution.functions.getContribution(id);
+  const ipfsHash = multihashes.toB58String(kredits.ipfs.encodeHash(data));
+  console.log(`Pinning Contribution ${id} ${ipfsHash}`);
+  kredits.ipfs._ipfsAPI.pin.add(ipfsHash, (err) => {
+    if (err) {
+      console.log(`Failed to pin ${ipfsHash}`);
+      console.log(err);
+    }
+  });
+}
+
+async function all (kredits) {
+  const contributionCount = await kredits.Contribution.count;
+  for (let id=1; id<=contributionCount; id++) {
+    pinContribution(kredits, id);
+  }
+  const contributorCount = await kredits.Contributor.count;
+  for (let id=1; id<=contributorCount; id++) {
+    pinContributor(kredits, id);
+  }
+}
+
+function subscribe (kredits) {
+  kredits.Contribution.on('ContributionAdded', async (id) => {
+    pinContribution(kredits, id);
+  });
+  kredits.Contributor.on('ContributorAdded', async (id) => {
+    pinContribution(kredits, id);
+  });
+  kredits.Contributor.on('ContributorProfileUpdated', async (id) => {
+    pinContributor(kredits, id);
+  });
+}
+
+const network = process.env.ETH_NETWORK || 'rinkeby';
+const rpcUrl = process.env.ETH_RPC_URL;
+const apm = process.env.APM_DOMAIN || 'open.aragonpm.eth';
+
+Kredits.for({ network, rpcUrl }, { apm }).init().then(async (kredits) => {
+  all(kredits);
+  subscribe (kredits);
+  console.log(`Subscribed to new events for DAO: ${kredits.Kernel.contract.address}`);
+});