- ${transactionHash - ? `If you're curious, here is your transaction id: ${transactionHash}` - : ''} -
- - - -` - -app.get('/', (req, res) => { - res.send(template()) -}) - -app.get('/send', async (req, res) => { +app.get("/", (req, res) => { + //res.send(template()); + res.render("index.ejs", { message: null, success: false }); +}); +app.get("/send", async (req, res) => { try { + let ipAddress = + req.headers["x-forwarded-for"] || req.connection.remoteAddress; + console.log(`ip address - `, ipAddress); + const url_parts = url.parse(req.url, true); + const query = url_parts.query; - let ipAddress = req.headers['x-forwarded-for'] || req.connection.remoteAddress - console.log(`ip address - `, ipAddress) - const url_parts = url.parse(req.url, true) - const query = url_parts.query - - const from = process.env.FROM - const to = query.address - const value = web3.utils.toWei(process.env.TOKEN_AMOUNT, 'ether') + const from = process.env.FROM; + const to = query.address; + const value = web3.utils.toWei(process.env.TOKEN_AMOUNT, "ether"); //check if this user is in cool down period - await find({ $or: [{ "ip": ipAddress }, { "wallet": query.address }] }, shouldTransfer => { - if (shouldTransfer) { - res.send( - template('', "You have to wait 24 hours between faucet requests", undefined) - ) + await find( + { + $or: [{ wallet: query.address }] + }, + async records => { + console.log(records[0]); + if (records[0] && !isAllowed(records[0].lastUpdatedOn)) { + res.render("index.ejs", { + message: "You have to wait 24 hours between faucet requests", + success: false + }); + } else { + //insert ip address into db + await insert( + { ip: ipAddress, wallet: to, lastUpdatedOn: Date.now() }, + result => console.log(result) + ); + + //create token instance from abi and contract address + const tokenInstance = new web3.eth.Contract( + abi, + process.env.TOKEN_CONTRACT_ADDRESS + ); + + tokenInstance.methods + .transfer(to, value) + .send({ from }, function(error, txHash) { + if (!error) { + console.log("txHash - ", txHash); + res.render("index.ejs", { + message: `Great!! test OCEANs are on the way - ${txHash}`, + link: `https://rinkeby.etherscan.io/tx/${txHash}`, + success: true + }); + } else { + console.error(err); + } + }); + } } - }) - - //insert ip address into db - await insert({ ip: ipAddress, wallet: to, lastUpdatedOn: Date.now() }, (result) => console.log(result)) - - //create token instance from abi and contract address - const tokenInstance = new web3.eth.Contract(abi, process.env.TOKEN_CONTRACT_ADDRESS) - - tokenInstance.methods.transfer(to, value).send({ from }, function (error, txHash) { - if (!error) { - console.log(txHash) - res.send( - template('', 'Great, test OCEANs are on the way!', txHash) - ) - } else { - console.error(err) - } - }) - + ); } catch (err) { - console.error(err) + console.error(err); } -}) +}); + +const port = process.env.PORT || 4000; + +app.set("view engine", "ejs"); +app.set("views", path.join(__dirname, "/public")); +app.use(express.static(__dirname + "/public")); -const port = process.env.PORT || 4000 app.listen(port, async () => { - client = await connection() - console.log('Listening on port - ', port) -}) \ No newline at end of file + client = await connection(); + console.log("Listening on port - ", port); +}); diff --git a/src/util.js b/src/util.js new file mode 100644 index 0000000..836f1cf --- /dev/null +++ b/src/util.js @@ -0,0 +1,14 @@ +const isAllowed = lastUpdatedOn => { + let currentTime = Date.now(); + let threshold = parseInt(process.env.COOLING_PERIOD_IN_HOURS) * 3600000; + console.log("currentTime - ", currentTime); + console.log("Threshold - ", threshold); + console.log("Last Updated - ", lastUpdatedOn); + console.log("Total - ", lastUpdatedOn + threshold); + if (lastUpdatedOn + threshold <= currentTime) { + return true; + } + return false; +}; + +module.exports = { isAllowed };