From fb5e80c03086add9e94d8b66dccede2842292b90 Mon Sep 17 00:00:00 2001 From: Adam Soltys Date: Wed, 16 Dec 2020 16:14:59 -0800 Subject: script for checking uploads folder --- scripts/check.js | 22 ++++++++++++++++++++++ scripts/createExceptions.js | 32 ++++++++++++++++++++++++++++++++ 2 files changed, 54 insertions(+) create mode 100644 scripts/check.js create mode 100644 scripts/createExceptions.js (limited to 'scripts') diff --git a/scripts/check.js b/scripts/check.js new file mode 100644 index 00000000..f14a313a --- /dev/null +++ b/scripts/check.js @@ -0,0 +1,22 @@ +let config = require('./config'); +let fs = require('fs'); + +let mailgun = require('mailgun-js')({apiKey: config.mailgun, domain: config.domain }); + +let data = { + ...config.mail, + subject: 'User Documents', + text: 'Documents uploaded', +}; + +fs.readdir('./uploads', (err, files) => { + files.forEach(file => { + console.log(file); + data.text = file; + fs.rename(file, '../verified' + file); + mailgun.messages().send(data, function (error, body) { + console.log(body); + }); + }); +}); + diff --git a/scripts/createExceptions.js b/scripts/createExceptions.js new file mode 100644 index 00000000..bec6ebc6 --- /dev/null +++ b/scripts/createExceptions.js @@ -0,0 +1,32 @@ +BitcoinCore = require("bitcoin-core"); +fs = require("fs"); +config = require("./config"); +bc = new BitcoinCore(config.bitcoin); +l = require("pino")(); +require("./db"); + +console.log(db.Payment); + +(async () => { + payments = ( + await db.Payment.findAll({ + attributes: ["hash"], + }) + ).map((p) => p.hash); + const transactions = await bc.listTransactions("*", 1000); + var stream = fs.createWriteStream("exceptions", { + flags: "a", + emitClose: true, + }); + transactions.map((tx) => { + if (!payments.includes(tx.txid)) { + l.info("writing", tx.txid); + stream.write(tx.txid + "\n"); + } + }); + stream.end(); + stream.on("close", () => { + l.info("done"); + process.exit(); + }); +})(); -- cgit v1.2.3