autobounty/bot/index.js

123 lines
3.6 KiB
JavaScript
Raw Normal View History

2018-01-22 11:24:19 +00:00
const winston = require('winston');
2018-01-20 16:34:11 +00:00
const prices = require('./prices');
2018-01-20 16:32:11 +00:00
const config = require('../config');
2018-01-22 20:21:31 +00:00
const github = require('./github');
2018-01-22 11:24:19 +00:00
const logger = winston.createLogger({
level: 'info',
format: winston.format.json(),
transports: [
new winston.transports.File({ filename: config.logPath + 'error.log', level: 'error' }),
new winston.transports.File({ filename: config.logPath + 'info.log', level: 'info' }),
]
2018-01-22 11:24:19 +00:00
});
2018-01-20 12:51:57 +00:00
const needsFunding = function (req) {
2018-01-23 13:39:12 +00:00
if (req.body.action !== 'created' || !req.body.hasOwnProperty('comment')) {
return false
} else if (req.body.comment.user.login !== config.githubUsername) {
2018-01-23 13:39:12 +00:00
return false
}
return true
}
const getAddress = function (req) {
2018-01-20 13:15:49 +00:00
let commentBody = req.body.comment.body;
return commentBody.substring(commentBody.search("Contract address:") + 18, commentBody.search("Contract address:") + 60)
}
const getLabelMock = function (req) {
return new Promise((resolve, reject) => {
github.getLabels(req)
.then(labels => {
let bountyLabels = labels.filter(name => config.bountyLabels.hasOwnProperty(name));
if (bountyLabels.length === 1) {
resolve(bountyLabels[0]);
} else {
reject('Error getting bounty labels: ' + bountyLabels);
}
})
.catch((err) => {
reject(err)
});
});
}
const getLabel = function (req) {
if (config.debug) {
return getLabelMock(req);
}
return new Promise((resolve, reject) => {
github.getLabels(req)
.then(labels => {
let bountyLabels = labels.filter(name => config.bountyLabels.hasOwnProperty(name));
if (bountyLabels.length === 1) {
resolve(bountyLabels[0]);
2018-01-22 16:05:42 +00:00
} else {
error(req.body, 'More than 1 label found: [' + labels.length + ']');
reject(new Error('More than 1 label found: ['+ labels.length + ']'));
2018-01-22 16:05:42 +00:00
}
}).catch(err => {
reject(err);
});
2018-01-22 16:05:42 +00:00
});
}
const getAmountMock = function(req) {
2018-01-22 16:05:42 +00:00
return new Promise((resolve, reject) => {
resolve(10);
});
}
const getAmount = function (req) {
return new Promise((resolve, reject) => {
let labelPromise = getLabel(req);
2018-01-22 16:05:42 +00:00
let tokenPricePromise = prices.getTokenPrice(config.token);
2018-01-22 20:21:31 +00:00
Promise.all([labelPromise, tokenPricePromise])
.then(function (values) {
let label = values[0];
let tokenPrice = values[1];
let amountToPayDollar = config.priceHour * config.bountyLabels[label];
resolve(amountToPayDollar / tokenPrice);
})
.catch((err) => {
reject(err);
});
2018-01-22 16:05:42 +00:00
});
}
// Logging functions
const logTransaction = function (txId, from, to, amount, gasPrice) {
2018-01-22 20:21:31 +00:00
logger.info("[OK] Succesfully funded bounty with transaction " + txId);
logger.info(" * From: " + from);
logger.info(" * To: " + to);
logger.info(" * Amount: " + amount);
logger.info(" * Gas Price: " + gasPrice);
logger.info("====================================================");
}
const log = function (msg) {
2018-01-22 11:24:19 +00:00
logger.info(msg);
}
const error = function (errorMessage) {
2018-01-22 20:21:31 +00:00
logger.error("[ERROR] Request processing failed: " + errorMessage);
}
module.exports = {
needsFunding: needsFunding,
getAddress: getAddress,
getAmount: getAmount,
2018-01-22 15:49:41 +00:00
getGasPrice: prices.getGasPrice,
2018-01-22 16:08:23 +00:00
log: log,
logTransaction: logTransaction,
error: error
}