nodejs/index.js at master · paykun-code/nodejs · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
const express = require('express');
const app = express();
const { parse } = require('querystring');
const Payment = require('./paykun/Payment').Payment;
var biguint = require('biguint-format');
const crypto = require('crypto');
var config = require('./config/config.global');
app.set('view engine', 'pug');
app.get('/', function (req, res) {
    res.sendFile('views/payment.html', { root: __dirname })
});

app.post('/start/payment', function (req, res) {
    let body = '';
    let requestData = null;
    req.on('data', chunk => {
        body += chunk.toString(); // convert Buffer to string
        let result = parse(body);
        let obj = new Payment(config.MERCHANT_ID, config.ACCESS_TOKEN, config.ENC_KEY, config.IS_LIVE);
        obj.initOrder("ORD_" + biguint(random(8), 'dec'), result.productName, result.amount,
            'http://localhost:3000/paykun/success', 'http://localhost:3000/paykun/fail', 'INR');
        obj.addCustomer(result.customerName, result.customerEmail, result.customerMobile);
        obj.setCustomFields({'udf_1': 'some dummy data'});
        requestData = obj.submit();
    });

    req.on('end', () => {
        res.render(__dirname + '/views/request', {
            action:requestData.action,
            encrypted_request: requestData.encrypted_request,
            merchant_id: requestData.merchant_id,
            access_token: requestData.access_token,
        });
    });

});

app.get('/paykun/success', function (req, res) {
    let queryParam = req.query;
    let obj = new Payment(config.MERCHANT_ID, config.ACCESS_TOKEN, config.ENC_KEY, config.IS_LIVE);
    if(queryParam['payment-id']) {
        obj.getStatus(queryParam['payment-id'],
            function(transactionDetail){
                if(transactionDetail.data.transaction.status == "Success") {
                    res.render(__dirname + '/views/success', {
                        transactionId: transactionDetail.data.transaction.payment_id,
                        status: transactionDetail.data.transaction.status,
                        message: transactionDetail.data.message,
                        amount: transactionDetail.data.transaction.order.gross_amount,
                    });
                } else {
                    res.render(__dirname + '/views/fail', {
                        transactionId: transactionDetail.data.transaction.payment_id,
                        status: transactionDetail.data.transaction.status,
                        message: transactionDetail.data.message,
                        amount: transactionDetail.data.transaction.order.gross_amount,
                    });
                }
            }
        );
    } else {
        console.log("Handle request without payment-id");
    }

});
app.get('/paykun/fail', function (req, res) {
    let queryParam = req.query;
    if(queryParam['payment-id']) {
        let obj = new Payment(config.MERCHANT_ID, config.ACCESS_TOKEN, config.ENC_KEY, config.IS_LIVE);
        obj.getStatus(queryParam['payment-id'],
            function(transactionDetail){
                res.render(__dirname + '/views/fail', {
                    transactionId: transactionDetail.data.transaction.payment_id,
                    status: transactionDetail.data.transaction.status,
                    message: transactionDetail.data.message,
                    amount: transactionDetail.data.transaction.order.gross_amount,
                });
            }
        );
    } else {
        console.log("Handle request without payment-id");
    }

});

app.post('/process/webhook', express.json({type: '*/*'}), (req, res) => {
    let webhookData = req.body;
    if(webhookData.hasOwnProperty("transaction") && webhookData.transaction != null) {
        let obj = new Payment(config.MERCHANT_ID, config.ACCESS_TOKEN, config.ENC_KEY, config.IS_LIVE);
        if(obj.compareSignature(webhookData.transaction, webhookData.transaction.signature)) {
            //Signature matched
            console.log("Signature matched");
            //now check status and status flag property to verify transaction is success or not

            if(webhookData.transaction.status === 'Success' && webhookData.transaction.status_flag == 1) {
                //Transaction is success
                console.log("Transaction is success");
            } else {
                //Transaction is failed
                console.log("Transaction is failed");
            }
        } else {
            //Signature mismatched
            console.log("Signature mismatched");
        }
    } else {
        //Response not as expected
    }
    res.send(true);
});

function random(qty) {
    return crypto.randomBytes(qty)
}
app.listen(3000, () => console.log('Example app listening on port 3000!'))