Michael Bumann
fc5a41123a
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
61 lines
1.9 KiB
JavaScript
61 lines
1.9 KiB
JavaScript
//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}`);
|
|
});
|