kosmos/hal8000
kosmos/hal8000
8
0
Fork 0
Code Issues Pull Requests Releases Activity

Use module from npm instead of local script

Browse Source
This commit is contained in:
Basti 2017-05-06 15:36:22 +02:00
parent 4b86a351ff
commit 9c26850621
3 changed files with 4 additions and 171 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
external-scripts.json
View File

@ -10,5 +10,6 @@
"hubot-seen",
"hubot-rss-reader",
"hubot-incoming-webhook",
"hubot-yubikey-invalidation"
"hubot-yubikey-invalidation",
"hubot-kredits"
]

8
package.json
View File

@ -19,6 +19,7 @@
"hubot-help": "^0.1.1",
"hubot-incoming-webhook": "^1.0.1",
"hubot-irc": "^0.2.9",
"hubot-kredits": ">=1.1.0",
"hubot-plusplus": "^1.1.5",
"hubot-read-tweet": "0.0.2",
"hubot-redis-brain": "0.0.2",
@ -29,14 +30,9 @@
"hubot-shipit": "^0.2.0",
"hubot-tell": "^1.2.3",
"hubot-yubikey-invalidation": "0.0.3",
"request": "2.30.0",
"node-fetch": "^1.6.3",
"request": "2.30.0",
"ethereumjs-wallet": "mvayngrib/ethereumjs-wallet",
"kredits-contracts": "67p/kredits-contracts",
"node-fetch": "^1.6.3",
"web3": "^0.18.4",
"web3-provider-engine": "^12.0.3"
"request": "2.30.0"
},
"engines": {
"node": "6.x.x",

164
scripts/hubot-kredts.js
View File

@ -1,164 +0,0 @@
// Description:
// Kosmos Kredits chat integration
//
// Configuration:
// KREDITS_WEBHOOK_TOKEN: A string for building your secret webhook URL
// KREDITS_ROOM: Kredit proposals are posted to this chatroom
//
// Authors:
// Sebastian Kippe <sebastian@kip.pe>
// const fs = require('fs');
const fetch = require('node-fetch');
const kreditsContracts = require('kredits-contracts');
const fs = require('fs');
const ProviderEngine = require('web3-provider-engine');
const Wallet = require('ethereumjs-wallet');
const WalletSubprovider = require('ethereumjs-wallet/provider-engine');
const Web3Subprovider = require('web3-provider-engine/subproviders/web3.js');
const Web3 = require('web3');
let engine = new ProviderEngine();
let walletPath = process.env.KREDITS_WALLET_PATH || './wallet.json';
let walletJson = fs.readFileSync(walletPath);
let wallet = Wallet.fromV3(JSON.parse(walletJson), process.env.KREDITS_WALLET_PASSWORD);
let providerUrl = process.env.KREDITS_PROVIDER_URL || 'http://localhost:8545';
let hubotWalletAddress = '0x' + wallet.getAddress().toString('hex');
engine.addProvider(new WalletSubprovider(wallet, {}));
engine.addProvider(new Web3Subprovider(new Web3.providers.HttpProvider(providerUrl)));
engine.start();
let web3 = new Web3(engine);
web3.eth.defaultAccount = hubotWalletAddress;
let contracts = kreditsContracts(web3, {'Kredits': '0x722956CE1fB83dD88d3e56Cf446f9c7e34D1Fc52'});
let Kredits = contracts['Kredits'];
let Token = contracts['Token'];
console.log('[HUBOT-KREDITS] wallet address: ' + hubotWalletAddress);
web3.eth.getBalance('eee2de74de31d2e3ef24cb0f6959fd88b59267bd', function (err, balance) {
if (err) { console.log('[HUBOT-KREDITS] error checking balance'); return; }
if (!balance > 0) {
console.log('[HUBOT-KREDITS] Hubot is broke. Please sond some eth to ' + hubotWalletAddress);
}
});
(function() {
"use strict";
module.exports = function(robot) {
function amountFromIssueLabels(issue) {
let kreditsLabel = issue.labels.map(l => l.name)
.filter(n => n.match(/^kredits/))[0];
// No label, no kredits
if (typeof kreditsLabel === 'undefined') { return 0; }
// TODO move to config maybe?
let amount;
switch(kreditsLabel) {
case 'kredits-1':
amount = 50;
break;
case 'kredits-2':
amount = 150;
break;
case 'kredits-3':
amount = 500;
break;
}
return amount;
}
function createProposal(recipient, amount, url/*, metaData*/) {
return new Promise((resolve/*, reject*/) => {
// TODO write metaData to IPFS
console.log(`Creating proposal to issue ${amount}₭S to ${recipient} for ${url}...`);
recipient = '0x74d05F57e14b16018938F60F78a4a687586A484d';
Kredits.addProposal(address, amount, url, '', function (err, response) {
robot.messageRoom(process.env.KREDITS_ROOM, `new proposal: ${amount} for ${recipient} - https://kredits.kosmos.org`);
resolve();
});
});
}
function handleGitHubIssueClosed(data) {
return new Promise((resolve/*, reject*/) => {
// fs.writeFileSync('tmp/github-issue.json', JSON.stringify(data, null, 4));
let recipients;
let issue = data.issue;
let assignees = issue.assignees.map(a => a.login);
let web_url = issue.html_url;
let amount = amountFromIssueLabels(issue);
if (amount === 0) { resolve(); return; }
if (assignees.length > 0) {
recipients = assignees;
} else {
recipients = [issue.user.login];
}
recipients.forEach(recipient => {
createProposal(recipient, amount, web_url, issue);
});
resolve();
});
}
function handleGitHubPullRequestClosed(data) {
return new Promise((resolve, reject) => {
// fs.writeFileSync('tmp/github-pr.json', JSON.stringify(data, null, 4));
let recipients;
let pull_request = data.pull_request;
let assignees = pull_request.assignees.map(a => a.login);
let web_url = pull_request._links.html.href;
let pr_issue_url = pull_request.issue_url;
if (assignees.length > 0) {
recipients = assignees;
} else {
recipients = [pull_request.user.login];
}
fetch(pr_issue_url)
.then(response => {
if (response.status >= 400) {
reject('Bad response from fetching PR issue');
}
return response.json();
})
.then(issue => {
// fs.writeFileSync('tmp/github-pr-issue.json', JSON.stringify(data, null, 4));
let amount = amountFromIssueLabels(issue);
if (amount === 0) { resolve(); return; }
recipients.forEach(recipient => {
createProposal(recipient, amount, web_url, pull_request);
});
resolve();
});
});
}
robot.router.post('/incoming/kredits/github/'+process.env.KREDITS_WEBHOOK_TOKEN, (req, res) => {
let evt = req.header('X-GitHub-Event');
let data = req.body;
console.log(`Received GitHub hook. Event: ${evt}, action: ${data.action}`);
if (evt === 'pull_request' && data.action === 'closed') {
handleGitHubPullRequestClosed(data).then(() => res.send(200));
}
else if (evt === 'issues' && data.action === 'closed') {
handleGitHubIssueClosed(data).then(() => res.send(200));
}
});
};
}());