const express = require('express'); const common = require('../../lib/common'); const { indexOrders } = require('../../lib/indexing'); const router = express.Router(); const axios = require('axios').default; router.get('/checkout_cancel', (req, res, next) => { // return to checkout for adjustment or repayment res.redirect('/checkout'); }); router.get('/checkout_return', async (req, res, next) => { const db = req.app.db; const config = req.app.config; const status = req.query.status || -1; const address = req.query.addr || 'na'; const amount = (req.query.value || 0) / 1e8; const txid = req.query.txid || 'na'; if(Number(status) === 2){ // we are interested only in final confirmations const order = await db.orders.findOne({ orderPaymentId: address }); if(order){ if(amount >= order.orderExpectedBtc){ try{ await db.orders.updateOne({ _id: order._id }, { $set: { orderStatus: 'Paid', orderReceivedBtc: amount, orderBlockonomicsTxid: txid } }, { multi: false }); // if approved, send email etc // set payment results for email const paymentResults = { message: 'Your payment was successfully completed', messageType: 'success', paymentEmailAddr: order.orderEmail, paymentApproved: true, paymentDetails: '

Order ID: ' + order._id + '

Transaction ID: ' + order.orderPaymentId + '

' }; // send the email with the response // TODO: Should fix this to properly handle result common.sendEmail(req.session.paymentEmailAddr, 'Your payment with ' + config.cartTitle, common.getEmailTemplate(paymentResults)); res.status(200).json({ err: '' }); }catch(ex){ console.info('Error updating status success blockonomics', ex); res.status(200).json({ err: 'Error updating status' }); } return; } console.info('Amount not sufficient blockonomics', address); try{ await db.orders.updateOne({ _id: order._id }, { $set: { orderStatus: 'Declined', orderReceivedBtc: amount } }, { multi: false }); }catch(ex){ console.info('Error updating status insufficient blockonomics', ex); } res.status(200).json({ err: 'Amount not sufficient' }); return; } res.status(200).json({ err: 'Order not found' }); console.info('Order not found blockonomics', address); return; } res.status(200).json({ err: 'Payment not final' }); console.info('Payment not final blockonomics', address); }); router.post('/checkout_action', (req, res, next) => { const blockonomicsConfig = common.getPaymentConfig(); const config = req.app.config; const db = req.app.db; const blockonomicsParams = {}; // get current rate axios .get(blockonomicsConfig.hostUrl + blockonomicsConfig.priceApi + config.currencyISO) .then((response) => { blockonomicsParams.expectedBtc = Math.round(req.session.totalCartAmount / response.data.price * Math.pow(10, 8)) / Math.pow(10, 8); // get new address axios .post(blockonomicsConfig.hostUrl + blockonomicsConfig.newAddressApi, {}, { headers: { 'Content-Type': 'application/json', 'User-Agent': 'blockonomics', Accept: 'application/json', Authorization: 'Bearer ' + blockonomicsConfig.apiKey } }) .then((response) => { blockonomicsParams.address = response.data.address; blockonomicsParams.timestamp = Math.floor(new Date() / 1000); // create order with status Pending and save ref const orderDoc = { orderPaymentId: blockonomicsParams.address, orderPaymentGateway: 'Blockonomics', orderExpectedBtc: blockonomicsParams.expectedBtc, orderTotal: req.session.totalCartAmount, orderShipping: req.session.totalCartShipping, orderItemCount: req.session.totalCartItems, orderProductCount: req.session.totalCartProducts, orderEmail: req.session.customerEmail, orderCompany: req.session.customerCompany, orderFirstname: req.session.customerFirstname, orderLastname: req.session.customerLastname, orderAddr1: req.session.customerAddress1, orderAddr2: req.session.customerAddress2, orderCountry: req.session.customerCountry, orderState: req.session.customerState, orderPostcode: req.session.customerPostcode, orderPhoneNumber: req.session.customerPhone, orderComment: req.session.orderComment, orderStatus: 'Pending', orderDate: new Date(), orderProducts: req.session.cart, orderType: 'Single' }; db.orders.insertOne(orderDoc, (err, newDoc) => { if(err){ console.info(err.stack); } // get the new ID const newId = newDoc.insertedId; // add to lunr index indexOrders(req.app) .then(() => { // set the order ID in the session, to link to it from blockonomics payment page blockonomicsParams.pendingOrderId = newId; req.session.blockonomicsParams = blockonomicsParams; res.redirect('/blockonomics_payment'); }); }); }); }); }); module.exports = router;