app.js

if (process.env.NODE_EV !== "production") require("dotenv").config();
// process date range argument
if (!process.argv[2]) {
    console.log('Please add a date range to the end of your node app.js command\nin the following format: dd/mm/yyyy-dd/mm/yyyy (no spaces, must be exact)');
    return;
}
const dateRange = process.argv[2];
const dates = dateRange.split('-');
let [d,M,y] = dates[0].split('/');
let [d1,M1,y1] = dates[1].split('/');
const startDate = new Date(y,parseInt(M)-1,d);
const endDate = new Date(y1,parseInt(M1)-1,d1);

const testing = process.env.TESTING;
const octokitCore = require("@octokit/core");
const { Octokit } = octokitCore;
const octokit = new Octokit({
    auth: process.env.GH_AUTH_TOKEN,
});
const axios = require('axios');
const tnb = require('thenewboston');
const { Account } = tnb;
const cron = require("node-cron");
const verifiedUsers = [
    22790904, // manishram (Manish)
    77364430, // tspearing (Tristan)
];
// extend console.log and add discord webhook
const originalLogger = console.log;
console.log = async function () {
  axios.post(process.env.WEBHOOK_URL,
    {
      content: Object.values(arguments).join(' ')
    }).then(res => {
      originalLogger.apply(this, ['Successfully posted to Discord']);
    }).catch(err => {
      originalLogger.apply(this, [`Discord Error: ${err.message}`]);
    })
  originalLogger.apply(this, arguments);
}
if (testing.toString().toLowerCase() !== false) {
  console.log('```diff\n' +
              '- Script running in testing mode\n' +
              '```');
  verifiedUsers.push(6356890); //nax3t (Ian) - for testing
}

const main = async () => {
    try {
        // prepare senders account
        const sendersAccount = new Account(process.env.SIGNING_KEY);
        const bankUrl = 'http://54.183.16.194';
        const paymentHandlerOptions = {
            account: sendersAccount,
            bankUrl: bankUrl,
        };
        const paymentHandler = new tnb.AccountPaymentHandler(paymentHandlerOptions);
        // // This is very important.
        // // Method for getting the Bank and Primary validator Transactions fees
        await paymentHandler.init();
        // get core-team data
        const response = await axios.get('https://api.thenewboston.com/core_members');
        const teamMembers = response.data.results;
        // initialize empty array for bank transactions
        const txs = [];
        const owner = testing ? 'nax3t' : 'thenewboston-developers';
        const repo = testing ? 'test-timesheets' : 'Contributor-Payments';

        // get all issues that are labeled as Timesheets, Approved, and Ready to pay
        let { data } = await axios.get(`https://api.github.com/repos/${owner}/${repo}/issues?state=open&labels=Timesheet,%F0%9F%98%8D%20Approved%20%F0%9F%98%8D,Ready%20to%20pay`, {
			headers: {
               'Authorization': `token ${process.env.GH_AUTH_TOKEN}` 
		}});

        // filter results by date
        data = data.filter(d => {
            // parse date from issue title
            const {title} = d;
            let titleDate = title.split('-')[1].trim()
            let [d3,M3,y3] = titleDate.split('/');
            titleDate = new Date(y3,parseInt(M3)-1,d3);
            // check if date is within specified date range
            if(titleDate >= startDate && titleDate <= endDate) {
                return d;
            }
        });

        for (const issue of data) {
            // destructure needed properties from issue object
            const { body, number, title, user, html_url, events_url } = issue;
            // check if Ready to pay label added by correct user
            const { data } = await axios.get(events_url, {
			headers: {
               'Authorization': `token ${process.env.GH_AUTH_TOKEN}` 
		}});
            const isValidLabel = data.find(action =>
                action.label &&
                action.label.name === 'Ready to pay' &&
                verifiedUsers.includes(action.actor.id)
            );
            // if label not added by correct user then skip to next issue
            if (!isValidLabel) {
                console.log(`Invalid label creator for ${title}, skipping to next timesheet.`);
                console.log(events_url);
                continue;
            }
            // parse recipient account number
            const recipient = body.match(/[a-z0-9]{64}/) ? body.match(/[a-z0-9]{64}/)[0] : false;
            // Find number of hours that come after Total Time Spent
            let totalTimeSpent = body.match(/total time spent\r\n *\.?\d+\.?(0|5)? *hour/i) ? body.match(/total time spent\r\n *\.?\d+\.?(0|5)? *hour/i)[0] : 0;
            // If totalTimeSpent doesn't exist then check again, but use Time Spent instead of Total Time Spent and pull last one in the array
            if (!totalTimeSpent) {
                const timeSpent = body.match(/time spent\r\n *\.?\d+\.?(0|5)? *hour/i);
                totalTimeSpent = timeSpent && timeSpent.input ? timeSpent[0] : timeSpent && timeSpent.length > 1 ? timeSpent[timeSpent.length - 1] : 0;
            }
            totalTimeSpent = totalTimeSpent ? totalTimeSpent.match(/\.?\d+\.?(0|5)?/)[0] : 0;
            // pull username and match from teamMembers to pull hourly rate
            const member = teamMembers.find(member => {
                if (member.user.github_username === user.login) {
                    return member;
                }
            });
            const rate = member && member.hourly_rate ? member.hourly_rate : 0;
            // calculate amount to be paid
            const amount = rate * totalTimeSpent;
            const issueId = number;
            let date = title.match(/\d\d\/\d\d\/\d\d\d\d/);
            date = date ? date[0].replace(/\//g, '_') : false;
            // generate memo
            const memo = date ? `TNB_TS_${issueId}_${date}` : false;
            if (amount >= 10000) {
                console.log(paymentMessage(false, html_url, amount, recipient, memo, 'Payment of 10000 TNBC or more!')); 
            } else {
                if (amount && memo && recipient && isValidLabel) {
                    // send individual transaction here
                    // You can use this method to send memos as well
                    try {
                        let res = await paymentHandler.sendCoins(recipient, amount, memo);
                        if (typeof res === 'undefined') {
                            console.log(paymentMessage(true, html_url, amount, recipient, memo));
                        } else {
                            console.log(paymentMessage(false, html_url, amount, recipient, memo, err));
                            continue;
                        }
                    } catch (err) {
                        console.log(paymentMessage(false, html_url, amount, recipient, memo, err));
                        continue;
                    }
                    // upon successful transaction, update issue labels
                    // add paid
                    await octokit.request('POST /repos/{owner}/{repo}/issues/{issue_number}/labels', {
                        owner,
                        repo,
                        issue_number: issueId,
                        labels: ['💰 Paid 💰']
                    });
                    // remove Ready to pay
                    await octokit.request('DELETE /repos/{owner}/{repo}/issues/{issue_number}/labels/{name}', {
                        owner,
                        repo,
                        issue_number: issueId,
                        name: 'Ready to pay'
                    });
                    // close the issue
                    await octokit.request('PATCH /repos/{owner}/{repo}/issues/{issue_number}', {
                        owner,
                        repo,
                        issue_number: issueId,
                        state: 'closed'
                    });
                } else {
                    console.log(`------------------------
                    Payment not made, missing data for:
                    Type of payment: Timesheet
                    Issue link: ${html_url}
                    Amount: ${amount}
                    Receiver account address: ${recipient}
                    Memo: ${memo}
                    ------------------------`);
                }
            }
        }
    } catch (err) {
        console.log(err);
    }
};


function paymentMessage(success, html_url, amount, recipient, memo, err) {
    const color = success ? '+' : '-'; 
    return `\`\`\`diff
${color} ------------------------
${color} Payment ${ success ? 'succeeded' : 'failed' }!
${color} Type of payment: Timesheet
${color} Issue link: ${html_url}
${color} Amount: ${amount}
${color} Receiver account address: ${recipient}
${color} Memo: ${memo}
${color} ${ err ? 'Error: ' + err + '\n- ------------------------' : '------------------------'}
\`\`\``;
};

main();
// see docs: https://github.com/ncb000gt/node-cron
// run function once a week on mondays
// cron.schedule('*/5 * * * * *', () => {
    // console.log('This runs every 5 seconds');
    // main();
// });