Compare commits

..

1 Commits

Author SHA1 Message Date
077b6fb1c1 Default to kosmos IPFS
All checks were successful
continuous-integration/drone/pr Build is passing
continuous-integration/drone/push Build is passing
we always had issues with IPFS not finding data from other peers
2022-10-22 15:21:38 +00:00
3 changed files with 12 additions and 41 deletions

View File

@@ -1,10 +1,4 @@
{ {
"31": {
"Contributor": "0x9C66a36fa6296EBb81d8F5D4642B05dF2CE85a8D",
"Contribution": "0xa12630a995337e45bDD746B6baedc1Ce2a1DCC9D",
"Token": "0x12Eb86338076450f86E5B552556028c7D21eaf1F",
"Reimbursement": "0xe2FE7cb00e2f94b8bA0AE526dfbe313f34c66E3C"
},
"1337": { "1337": {
"Contributor": "0xCc66f9A3cA2670972938FAD91d0865c4a62DFB25", "Contributor": "0xCc66f9A3cA2670972938FAD91d0865c4a62DFB25",
"Contribution": "0x8999CaBc43E28202c5A2257f2a95A45b1F8A62BD", "Contribution": "0x8999CaBc43E28202c5A2257f2a95A45b1F8A62BD",

View File

@@ -5,7 +5,7 @@ const fetch = require('node-fetch');
class IPFS { class IPFS {
constructor (config) { constructor (config) {
if (!config) { if (!config) {
config = { host: 'localhost', port: '5001', protocol: 'http' }; config = { host: 'ipfs.kosmos.org', port: '5444', protocol: 'https' };
} }
this._config = config; this._config = config;
this._ipfsAPI = ipfsClient.create(config); this._ipfsAPI = ipfsClient.create(config);

View File

@@ -1,8 +1,6 @@
const fs = require('fs'); const fs = require('fs');
const Kredits = require('../../lib/kredits'); const Kredits = require('../../lib/kredits');
const PARALLEL_TXS = 5;
async function main() { async function main() {
kredits = new Kredits(hre.ethers.provider, hre.ethers.provider.getSigner()) kredits = new Kredits(hre.ethers.provider, hre.ethers.provider.getSigner())
await kredits.init(); await kredits.init();
@@ -20,40 +18,19 @@ async function main() {
const confirmationPeriod = 40320 // blocks const confirmationPeriod = 40320 // blocks
const unconfirmedHeight = currentBlockHeight + confirmationPeriod; const unconfirmedHeight = currentBlockHeight + confirmationPeriod;
const txBundlesAmount = Math.ceil(ids.length / PARALLEL_TXS); for (const contributionId of ids) {
let txBundles = []; const c = contributions[contributionId.toString()];
for (let i = 0; i < txBundlesAmount; i++) { const confirmedAtBlock = c.confirmed ? currentBlockHeight : unconfirmedHeight;
txBundles.push(ids.slice((i * PARALLEL_TXS), (i * PARALLEL_TXS) + PARALLEL_TXS));
}
for (const txBundle of txBundles) { const result = await kredits.Contribution.contract.add(
console.log(`Adding contributions #${txBundle[0]} to #${txBundle[txBundle.length - 1]}`) c.amount, c.contributorId,
c.hashDigest, c.hashFunction, c.hashSize,
let resultPromises = []; confirmedAtBlock, c.vetoed
);
for (const contributionId of txBundle) { // await result.wait();
const c = contributions[contributionId.toString()]; console.log(`Added contribution #${contributionId}: ${result.hash}`);
};
const confirmedAtBlock = c.confirmed ? currentBlockHeight : unconfirmedHeight;
const result = await kredits.Contribution.contract.add(
c.amount, c.contributorId,
c.hashDigest, c.hashFunction, c.hashSize,
confirmedAtBlock, c.vetoed
);
resultPromises.push(result.wait());
console.log(`Added contribution #${contributionId}: ${result.hash}`);
}
console.log(`Waiting for confirmations...`);
await Promise.all(resultPromises);
console.log('Transactions confirmed');
}
} catch(e) { } catch(e) {
console.log(e); console.log(e);
} }