kredits/ipfs-pinner
kredits/ipfs-pinner
9
1
Fork 0
Code Issues 2 Pull Requests 1 Actions Releases 9 Activity

WIP: Set native IPFS peering config #9

Draft
raucao wants to merge 3 commits from feature/ipfs_peering into master
pull from: feature/ipfs_peering
merge into: kredits:master
Conversation 1 Commits 3 Files Changed 1 +32 -10
1 changed files with 32 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
index.js
View File

@ -3,6 +3,13 @@
const Kredits = require('kredits-contracts'); const Kredits = require('kredits-contracts');
const IpfsPinner = require('./lib/ipfs-pinner'); const IpfsPinner = require('./lib/ipfs-pinner');
const debug = require('debug')('ipfs-pinner'); const debug = require('debug')('ipfs-pinner');
const { inspect } = require('util');
// TODO make configurable
const peerId = "QmbqZCZ2RzVr4r1UEdFak6ra76kHxtGmfV9r3e1Ev6Tj5D";
const peerAddrs = [ "/dns4/barnard.kosmos.org/tcp/4001" ];
const bootstrapNode = `${peerAddrs[0]}/ipfs/${peerId}`;
const peerConfig = { "ID": peerId, "Addrs": [ peerAddrs ] };
const argv = require('yargs') const argv = require('yargs')
.default({ .default({
@ -12,7 +19,7 @@ const argv = require('yargs')
port: '5001', port: '5001',
protocol: 'http', protocol: 'http',
monitor: true, monitor: true,
bootstrapNode: '/ip4/46.4.18.160/tcp/4001/ipfs/QmZ4Lpzhz8bafbTYvEMMCmrbrMM4JfyHDR23WbCSAd9bo7' bootstrapNode: bootstrapNode
}) })
.boolean('monitor') .boolean('monitor')
.describe({ .describe({
@ -49,18 +56,33 @@ console.log(`Using IPFS:`, ipfsConfig);
await ipfsApi.id(); await ipfsApi.id();
debug(`Connecting to known IPFS node ${argv.bootstrapNode}`); // debug(`Connecting to known IPFS node ${argv.bootstrapNode}`);
await ipfsApi.swarm.connect(argv.bootstrapNode); // await ipfsApi.swarm.connect(argv.bootstrapNode);
const ipfsPinner = new IpfsPinner(kredits); let peers;
ipfsPinner.pinAll().then(pins => { try {
console.log(`Pinned ${pins.length} existing documents`); peers = await ipfsApi.config.get('Peering.Peers');
}); } catch(e) { /* No peers configured */ }
ipfsPinner.monitor(pin => { if (peers) {
console.log('Pinned a new document:', pin[0]["hash"]); // TODO check for kosmos peer
}); debug('IPFS peers configured:');
debug(inspect(peers.map(p => p.ID)));
} else {
debug(`Configuring persistent IPFS peer: ${peerId}`);
await ipfsApi.config.set('Peering', { "Peers": [ peerConfig ]});
}
// const ipfsPinner = new IpfsPinner(kredits);
// ipfsPinner.pinAll().then(pins => {
// console.log(`Pinned ${pins.length} existing documents`);
// });
//
// ipfsPinner.monitor(pin => {
// console.log('Pinned a new document:', pin[0]["hash"]);
// });
console.log(`Subscribed to DAO: ${kredits.Kernel.contract.address}`); console.log(`Subscribed to DAO: ${kredits.Kernel.contract.address}`);
} catch(e) { } catch(e) {