kredits/hubot-kredits
9
0
Fork 0
Code Issues 8 Pull Requests Releases 9 Activity

Create contributions for PR reviews #66

Merged
galfert merged 1 commits from feature/49-create_review_contributions into master 2021-03-29 08:43:22 +00:00
Conversation 4 Commits 1 Files Changed 1 +34 -5
1 changed files with 34 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
scripts/review-kredits.js
View File

@ -5,12 +5,15 @@ const GiteaReviews = require('./lib/gitea-reviews');
const GithubReviews = require('./lib/github-reviews');
const ethers = require('ethers');
const NonceManager = require('@ethersproject/experimental').NonceManager;
const Kredits = require('kredits-contracts');
const util = require('util');
const yargs = require('yargs/yargs')
const { hideBin } = require('yargs/helpers')
const walletPath = process.env.KREDITS_WALLET_PATH || '../wallet.json';
const walletJson = require(walletPath);
const providerUrl = process.env.KREDITS_PROVIDER_URL;
const daoAddress = process.env.KREDITS_DAO_ADDRESS;
@ -84,12 +87,23 @@ async function getAllReviews(repos, startDate, endDate) {
githubReviews.getReviewContributions(repos.github, startDate, endDate),
giteaReviews.getReviewContributions(repos.gitea, startDate, endDate)
]).then(reviews => {
// console.log(util.inspect(reviews[0], { depth: 3, colors: true }));
return { github: reviews[0], gitea: reviews[1] }
});
}
async function initializeKredits () {
//
// Ethereum wallet setup
//
let wallet;
try {
wallet = await ethers.Wallet.fromEncryptedJson(walletJson, process.env.KREDITS_WALLET_PASSWORD);
} catch(error) {
console.log('Could not load wallet:', error);
process.exit(1);
}
//
// Ethereum provider/node setup
//
@ -100,6 +114,7 @@ async function initializeKredits () {
} else {
ethProvider = new ethers.getDefaultProvider('rinkeby');
}
const signer = new NonceManager(wallet.connect(ethProvider));
//
// Kredits contracts setup
@ -112,7 +127,7 @@ async function initializeKredits () {
let kredits;
try {
kredits = await new Kredits(ethProvider, null, opts).init();
kredits = await new Kredits(signer.provider, signer, opts).init();
} catch(error) {
console.log('Could not set up kredits:', error);
process.exit(1);
@ -121,6 +136,17 @@ async function initializeKredits () {
return kredits;
}
function createContribution(contributorName, contributionAttributes, Contribution) {
console.log(`Creating contribution token for ${contributionAttributes.amount}₭S to ${contributorName} for ${contributionAttributes.description}...`);
return Contribution.add(contributionAttributes).catch(error => {
console.log(`I tried to add a contribution for ${contributorName}, but I encountered an error when submitting the tx:`);
console.log(`Error:`, error);
console.log('Contribution attributes:');
console.log(util.inspect(contributionAttributes, { depth: 2, colors: true }));
});
}
async function generateContributionData(reviews, Contributor, startDate, endDate) {
const dateFormatOptions = { year: 'numeric', month: 'long', day: 'numeric' };
const contributors = await Contributor.all();
@ -179,11 +205,14 @@ Promise.all([initializeKredits(), getAllReviews(repos, startDate, endDate)]).the
generateContributionData(reviews, kredits.Contributor, startDate, endDate).then(contributionData => {
if (argv.dry) {
console.log('contributions:');
console.log('Contributions:');
console.log(util.inspect(contributionData, { depth: 3, colors: true }));
} else {
// create contributions
for (const [username, contributionAttributes] of Object.entries(contributionData)) {
createContribution(username, contributionAttributes, kredits.Contribution);
}
}
// TODO create contributions
});
});