diff options
| -rw-r--r-- | server/controllers/transaction.js | 53 |
1 files changed, 42 insertions, 11 deletions
diff --git a/server/controllers/transaction.js b/server/controllers/transaction.js index 57a0ec3..62ffd9c 100644 --- a/server/controllers/transaction.js +++ b/server/controllers/transaction.js @@ -2,10 +2,16 @@ const paypal = require('@paypal/checkout-server-sdk'); const paypalClient = require('../config/paypal'); const {siteUrl} = require('../config/env'); const Product = require('../models/Product'); +const Order = require('../models/Order'); module.exports = { async setup(req, res) { + let newOrderObj = { + status: 'ordered', + paypalOrderId: null, + items: [] + }; let transactionSetupData = { intent: 'CAPTURE', application_context: { @@ -42,7 +48,7 @@ module.exports = { item = await Product.findOne({_id: itemId}); } catch { - return res.status(400).json({status: "Couldn't find one of the given items."}); + return res.status(400).json({status: "Couldn't find one of the given items. CB"}); } if (!item) return res.status(400).json({status: "Couldn't find one of the given items."}); @@ -57,6 +63,11 @@ module.exports = { }); totalToPay += item.price * itemQuantity; + + newOrderObj.items.push({ + productId: itemId, + quantity: itemQuantity + }); } transactionSetupData.purchase_units[0].amount.value = totalToPay; transactionSetupData.purchase_units[0].amount.breakdown.item_total.value = totalToPay; @@ -73,28 +84,48 @@ module.exports = { return res.sendStatus(500); } - res.status(200).json({orderId: order.result.id}); + newOrderObj.paypalOrderId = order.result.id; + + const dbOrder = new Order(newOrderObj); + dbOrder.save() + .then(() => res.status(200).json({orderId: order.result.id})) + .catch(err => { + res.status(500).json({status: "Couldn't save new order to database!"}); + console.error(err); + }); }, async capture(req, res) { + let dbOrder; + try { + dbOrder = await Order.findOne({paypalOrderId: req.body.orderId}); + } + catch { + return res.status(400).json({status: "Couldn't find given order in database! CB"}); + } + if (!dbOrder) + return res.status(400).json({status: "Couldn't find given order in database!"}); + const request = new paypal.orders.OrdersCaptureRequest(req.body.orderId); request.requestBody({}); + let capture; try { - const capture = await paypalClient.execute(request); - console.log("CAPTURE======================================================"); - console.log(capture); - console.log("CAPTURE.RESULT==============================================="); - console.log(capture.result); - console.log("CAPTURE.RESULT.PURCHASE_UNITS[0].SHIPPING===================="); - console.log(capture.result.purchase_units[0].shipping); - console.log("============================================================="); + capture = await paypalClient.execute(request); } catch (err) { console.error(err); return res.sendStatus(500); } - res.sendStatus(200); + dbOrder.status = 'paid'; + dbOrder.shipping = capture.result.purchase_units[0].shipping; + + dbOrder.save() + .then(() => res.sendStatus(200)) + .catch(err => { + res.status(500).json({status: "Couldn't update order in database!"}) + console.error(err); + }); } }; |