91 lines
2.5 KiB
JavaScript
91 lines
2.5 KiB
JavaScript
/*
|
|
* Bot that receives a POST request (from a GitHub issue comment webhook)
|
|
* and in case it's a comment that has "@autobounty <decimal> <currency>"
|
|
* awards that bounty to the address posted earlier in the thread (by the
|
|
* commiteth bot).
|
|
* TODO tests
|
|
* REVIEW parsing, non-persisting storage of addresses, hardcoded string length.
|
|
* Depends on commiteth version as of 2017-06-10.
|
|
*/
|
|
|
|
const config = require('./config');
|
|
const bot = require('./bot');
|
|
|
|
var express = require('express'),
|
|
cors = require('cors'),
|
|
helmet = require('helmet'),
|
|
app = express(),
|
|
bodyParser = require('body-parser'),
|
|
jsonParser = bodyParser.json();
|
|
|
|
app.use(cors());
|
|
app.use(helmet());
|
|
|
|
// Receive a POST request at the address specified by an env. var.
|
|
app.post(`${config.urlEndpoint}`, jsonParser, function(req, res, next) {
|
|
// TODO decide how long the delay to start everything should be
|
|
console.log('Request: ', req)
|
|
if (!req.body || !req.body.action) {
|
|
|
|
bot.error('', 'Wrong format');
|
|
return res.sendStatus(400);
|
|
}
|
|
|
|
if (!bot.needsFunding(req)) {
|
|
return res.sendStatus(204);
|
|
}
|
|
|
|
const eth = bot.eth;
|
|
const from = config.sourceAddress;
|
|
const to = bot.getAddress(req);
|
|
|
|
// Asynchronous requests for Gas Price and Amount
|
|
const amountPromise = bot.getAmount(req);
|
|
const gasPricePromise = bot.getGasPrice();
|
|
|
|
Promise.all([amountPromise, gasPricePromise])
|
|
.then(function(amount, gasPrice){
|
|
sendTransaction(eth, from, to, amount, gasPrice);
|
|
})
|
|
.catch(function(error) {
|
|
bot.error(req.body, error);
|
|
});
|
|
|
|
});
|
|
|
|
|
|
const sendTransaction = function(eth, from, to, amount, gasPrice){
|
|
if (!config.debug){
|
|
|
|
eth.getTransactionCount(from, (err, nonce) => {
|
|
eth.sendTransaction({
|
|
from: from,
|
|
to: to,
|
|
gas: gas,
|
|
gasPrice: gasPrice,
|
|
value: amount,
|
|
nonce,
|
|
}, (err, txID) => {
|
|
if (err) {
|
|
bot.error(req.body, err)
|
|
return res.status(500).json(err)
|
|
}
|
|
else {
|
|
bot.logTransaction(txID, from, to, amount, gasPrice);
|
|
res.json({ txID })
|
|
}
|
|
});
|
|
});
|
|
|
|
return res.sendStatus(200);
|
|
} else {
|
|
let txID = -1;
|
|
bot.logTransaction(txID, from, to, amount, gasPrice);
|
|
}
|
|
}
|
|
|
|
const port = process.env.PORT || 8181
|
|
app.listen(port, function(){
|
|
bot.log('Autobounty listening on port', port);
|
|
});
|