From 2316e8f15ac92f9b197b3addf560c443aae8e98e Mon Sep 17 00:00:00 2001 From: Michael Bumann Date: Tue, 2 Jul 2019 19:09:26 +0200 Subject: [PATCH] Remove IPFS pinner The pinner now lives in its own npm package --- lib/contracts/record.js | 12 ------------ lib/utils/ipfs-pinner.js | 32 -------------------------------- scripts/ipfs-pinner.js | 31 ------------------------------- 3 files changed, 75 deletions(-) delete mode 100644 lib/utils/ipfs-pinner.js delete mode 100644 scripts/ipfs-pinner.js diff --git a/lib/contracts/record.js b/lib/contracts/record.js index 52099af..1e1f83a 100644 --- a/lib/contracts/record.js +++ b/lib/contracts/record.js @@ -9,18 +9,6 @@ class Record extends Base { return Promise.all(records); }); } - - pinIpfsHashes () { - return this.count.then(count => { - let promises = [...Array(count).keys()].map(i => { - let id = i + 1; // 0 => 1 - ids start with 1 and not with 0 - return this.getData(id).then(data => { - return this.ipfs.pin(data); - }); - }); - return Promise.all(promises); - }); - } } module.exports = Record; diff --git a/lib/utils/ipfs-pinner.js b/lib/utils/ipfs-pinner.js deleted file mode 100644 index 59d158f..0000000 --- a/lib/utils/ipfs-pinner.js +++ /dev/null @@ -1,32 +0,0 @@ -class IpfsPinner { - constructor (kredits) { - this.kredits = kredits; - } - - pinAll () { - return Promise.all([ - this.kredits.Contributor.pinIpfsHashes(), - this.kredits.Contribution.pinIpfsHashes(), - ]); - } - - monitor (callback) { - this.kredits.Contribution.on('ContributionAdded', (id) => { - this.kredits.Contribution.getData(id) - .then(data => { return this.kredits.ipfs.pin(data); }) - .then(callback); - }); - this.kredits.Contributor.on('ContributorAdded', (id) => { - this.kredits.Contribution.getData(id) - .then(data => { return this.kredits.ipfs.pin(data); }) - .then(callback); - }); - this.kredits.Contributor.on('ContributorProfileUpdated', (id) => { - this.kredits.Contributor.getData(id) - .then(data => { return this.kredits.ipfs.pin(data); }) - .then(callback); - }); - } - -} -module.exports = IpfsPinner; diff --git a/scripts/ipfs-pinner.js b/scripts/ipfs-pinner.js deleted file mode 100644 index 985dc01..0000000 --- a/scripts/ipfs-pinner.js +++ /dev/null @@ -1,31 +0,0 @@ -const Kredits = require('../lib/kredits'); -const IpfsPinner = require('../lib/utils/ipfs-pinner'); - -const network = process.env.ETH_NETWORK || 'rinkeby'; -const rpcUrl = process.env.ETH_RPC_URL; -const apm = process.env.APM_DOMAIN || 'open.aragonpm.eth'; - -const ipfsConfig = { - host: process.env.IPFS_HOST || 'localhost', - port: process.env.IPFS_PORT || '5001', - protocol: process.env.IPFS_PROTOCOL || 'http', -}; -console.log(`Using IPFS:`, ipfsConfig); - -(async () => { - try { - const kredits = await Kredits.for({ network, rpcUrl }, { apm, ipfsConfig }).init(); - const ipfsPinner = new IpfsPinner(kredits); - - ipfsPinner.pinAll().then(pins => { - console.log('Pinned', JSON.stringify(pins, null, 2)); - }); - ipfsPinner.monitor((pin) => { - console.log('Pinned', JSON.stringify(pin)); - }); - console.log(`Subscribed to DAO: ${kredits.Kernel.contract.address}`); - } catch(e) { - console.log(e); - process.exit(1); - } -})();