autobounty/index.js

/*
* 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 url specified by an env. var.
app.post(`${config.urlEndpoint}`, jsonParser, function(req, res, next) {
    if (!req.body || !req.body.action) {
        bot.error('', 'Wrong format');
        return res.sendStatus(400);
    } else if (!bot.needsFunding(req)) {
        return res.sendStatus(204);
    }

    setTimeout(function (req, res) {
        processRequest(req, res);
    }, config.delayInMiliSeconds);
});

const processRequest = function(req, res) {
    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){
        let transaction = sendTransaction(eth, from, to, amount, gasPrice);
        
        transaction
        .then(function() {
            return res.sendStatus(200);
        })
        .catch(function(error) {
            bot.error(req.body, error);
        });
        
    })
    .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 })
                }
            });
        });
    } 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);
});