ChiefSoft works
107 lines
3.7 KiB
JavaScript
107 lines
3.7 KiB
JavaScript
'use strict';
|
|
|
|
const axios = require('axios');
|
|
const request = require('request');
|
|
const db = require('../app/db')
|
|
const logger = require('../app/logger');
|
|
|
|
// https://developer.flutterwave.com/reference/create-a-transfer
|
|
const flutterwaveConfigBuffer = new Buffer(process.env.FLUTTERWAVE_API, 'base64');
|
|
const flutterwaveConfig = JSON.parse(flutterwaveConfigBuffer.toString('ascii'));
|
|
|
|
var transfer = {
|
|
create: function(req, res, next) {
|
|
var url = flutterwaveConfig.BaseApiUrl + '/v3/transfers';
|
|
var headersOpt = {
|
|
"Content-Type": "application/json",
|
|
"Authorization": "Bearer " + flutterwaveConfig.SecretKey,
|
|
};
|
|
var data = {
|
|
"account_bank": req.body.account_bank,
|
|
"account_number": req.body.account_number,
|
|
"amount": req.body.amount,
|
|
"narration": req.body.narration,
|
|
"currency": req.body.currency,
|
|
"reference": req.body.reference,
|
|
"debit_currency": req.body.debit_currency
|
|
};
|
|
var options = {
|
|
headers: headersOpt
|
|
};
|
|
logger.info(url);
|
|
logger.info(options);
|
|
logger.info(data);
|
|
// https://blog.logrocket.com/5-ways-to-make-http-requests-in-node-js/
|
|
// https://stackoverflow.com/questions/53846709/how-do-i-use-axios-within-expressjs
|
|
axios.post(url, data, options)
|
|
.then(response => {
|
|
//res.json(response);
|
|
logger.info('-------------------------------');
|
|
logger.info(response.data);
|
|
logger.info('-------------------------------');
|
|
res.json({
|
|
status: response.status,
|
|
statusText: response.statusText,
|
|
data: response.data
|
|
});
|
|
})
|
|
.catch(err => {
|
|
logger.error(err.message);
|
|
//logger.error(err.stack);
|
|
//logger.error(err.response.data);
|
|
//logger.error(err.response.headers);
|
|
res.send({
|
|
status: "failure",
|
|
message: "Invalid response",
|
|
details: err.message,
|
|
code: typeof err.response !== 'undefined' ? err.response.status : null,
|
|
data: typeof err.response !== 'undefined' ? err.response.data : null
|
|
});
|
|
});
|
|
// TODO: Do we save the response in the DB? I assume: YES
|
|
db.query('SELECT NOW()', (err, res) => {
|
|
if (err) {
|
|
throw err;
|
|
}
|
|
logger.info('time:', res.rows[0])
|
|
});
|
|
},
|
|
get: function(req, res, next) {
|
|
var url = flutterwaveConfig.BaseApiUrl + '/v3/transfers/' + req.params.id;
|
|
var headersOpt = {
|
|
"Authorization": "Bearer " + flutterwaveConfig.SecretKey,
|
|
};
|
|
var options = {
|
|
headers: headersOpt
|
|
};
|
|
logger.info(url);
|
|
axios.get(url, options)
|
|
.then(data => {
|
|
res.json(data);
|
|
})
|
|
.catch(err => {
|
|
logger.error(err.message);
|
|
//logger.error(err.stack);
|
|
logger.error(err.response.data);
|
|
//logger.error(err.response.headers);
|
|
res.send({
|
|
status: "failure",
|
|
message: "Invalid response",
|
|
details: err.message,
|
|
code: err.response.status,
|
|
data: err.response.data
|
|
});
|
|
});
|
|
// TODO: Do we save the response in the DB? I assume: YES
|
|
db.query('SELECT NOW()', (err, res) => {
|
|
if (err) {
|
|
throw err;
|
|
}
|
|
logger.info('time:', res.rows[0])
|
|
});
|
|
}
|
|
};
|
|
|
|
module.exports = transfer;
|
|
|