Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion src/endpoints/account-balance.js
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
* @param {String} [commandId='AccountBalance'] Takes only 'AccountBalance' CommandID
* @return {Promise} This returns a promise that resolves to the account balance
*/
module.exports = async function accountBalance (shortCode, idType, queueUrl, resultUrl, remarks = 'Checking account balance', initiator = null, commandId = 'AccountBalance') {
exports.accountBalance = async (shortCode, idType, queueUrl, resultUrl, remarks = 'Checking account balance', initiator = null, commandId = 'AccountBalance') => {
const securityCredential = this.security()
const req = await this.request()
return req.post('/mpesa/accountbalance/v1/query', {
Expand Down
2 changes: 1 addition & 1 deletion src/endpoints/b2b.js
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
* @param {String} [remarks='B2B Request'] Comments that are sent along with the transaction.
* @return {Promise}
*/
module.exports = async function (senderParty, receiverParty, amount, queueUrl, resultUrl, senderType = 4, receiverType = 4, initiator = null, commandId = 'BusinessToBusinessTransfer', accountRef = null, remarks = 'B2B Request') {
module.exports = async (senderParty, receiverParty, amount, queueUrl, resultUrl, senderType = 4, receiverType = 4, initiator = null, commandId = 'BusinessToBusinessTransfer', accountRef = null, remarks = 'B2B Request') => {
const req = await this.request()
const securityCredential = this.security()
return req.post('/mpesa/b2b/v1/paymentrequest', {
Expand Down
2 changes: 1 addition & 1 deletion src/endpoints/b2c.js
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* @param {string} occasion
* @return {Promise}
*/
module.exports = async function (senderParty, receiverParty, amount, queueUrl, resultUrl, commandId = 'BusinessPayment', initiatorName = null, remarks = 'B2C Payment', occasion) {
module.exports = async (senderParty, receiverParty, amount, queueUrl, resultUrl, commandId = 'BusinessPayment', initiatorName = null, remarks = 'B2C Payment', occasion) => {
const securityCredential = this.security()
const req = await this.request()
return req.post('/mpesa/b2c/v1/paymentrequest', {
Expand Down
2 changes: 1 addition & 1 deletion src/endpoints/c2b-register.js
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
* @param {string} [responseType='Completed'] Default response type for timeout. Incase a tranaction times out, Mpesa will by default Complete or Cancel the transaction
* @return {Promise}
*/
module.exports = async function (confirmationUrl, validationUrl, shortCode = null, responseType = 'Completed') {
module.exports = async (confirmationUrl, validationUrl, shortCode = null, responseType = 'Completed') => {
const req = await this.request()
return req.post('/mpesa/c2b/v1/registerurl', {
'ShortCode': shortCode || this.configs.shortCode,
Expand Down
2 changes: 1 addition & 1 deletion src/endpoints/c2b-simulate.js
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@
* @param {number} [shortCode=null] Short Code receiving the amount being transacted
* @return {Promise}
*/
module.exports = async function (msisdn, amount, billRefNumber, commandId = 'CustomerPayBillOnline', shortCode = null) {
module.exports = async (msisdn, amount, billRefNumber, commandId = 'CustomerPayBillOnline', shortCode = null) => {
const req = await this.request()
return req.post('/mpesa/c2b/v1/simulate', {
'ShortCode': shortCode || this.configs.shortCode,
Expand Down
31 changes: 10 additions & 21 deletions src/endpoints/index.js
Original file line number Diff line number Diff line change
@@ -1,23 +1,12 @@
const accountBalance = require('./account-balance')
const b2b = require('./b2b')
const b2c = require('./b2c')
const c2bRegister = require('./c2b-register')
const c2bSimulate = require('./c2b-simulate')
const lipaNaMpesaOnline = require('./lipa-na-mpesa-online')
const lipaNaMpesaQuery = require('./lipa-na-mpesa-query')
const oAuth = require('./oauth')
const reversal = require('./reversal')
const transactionStatus = require('./transaction-status')

module.exports = {
accountBalance,
b2b,
b2c,
c2bRegister,
c2bSimulate,
lipaNaMpesaOnline,
lipaNaMpesaQuery,
reversal,
transactionStatus,
oAuth
accountBalance: require('./account-balance'),
b2b: require('./b2b'),
b2c: require('./b2b'),
c2bRegister: require('./c2b-register'),
c2bSimulate: require('./c2b-simulate'),
lipaNaMpesaOnline: require('./lipa-na-mpesa-online'),
lipaNaMpesaQuery: require('./lipa-na-mpesa-query'),
reversal: require('./reversal'),
transactionStatus: require('./transaction-status'),
oAuth: require('./oauth')
}
2 changes: 1 addition & 1 deletion src/endpoints/lipa-na-mpesa-online.js
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
* @param {string} [passKey=null] Lipa na mpesa passKey
* @return {Promise}
*/
module.exports = async function (senderMsisdn, amount, callbackUrl, accountRef, transactionDesc = 'Lipa na mpesa online', transactionType = 'CustomerPayBillOnline', shortCode = null, passKey = null) {
module.exports = async (senderMsisdn, amount, callbackUrl, accountRef, transactionDesc = 'Lipa na mpesa online', transactionType = 'CustomerPayBillOnline', shortCode = null, passKey = null) =>{
const _shortCode = shortCode || this.configs.lipaNaMpesaShortCode
const _passKey = passKey || this.configs.lipaNaMpesaShortPass
const timeStamp = (new Date()).toISOString().replace(/[^0-9]/g, '').slice(0, -3)
Expand Down
2 changes: 1 addition & 1 deletion src/endpoints/lipa-na-mpesa-query.js
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
* @param {string} [passKey=null] lipaNaMpesa Pass Key
* @return {Promise}
*/
module.exports = async function (checkoutRequestId, shortCode = null, passKey = null) {
module.exports = async (checkoutRequestId, shortCode = null, passKey = null) => {
const _shortCode = shortCode || this.configs.lipaNaMpesaShortCode
const _passKey = passKey || this.configs.lipaNaMpesaShortPass
const timeStamp = (new Date()).toISOString().replace(/[^0-9]/g, '').slice(0, -3)
Expand Down
2 changes: 1 addition & 1 deletion src/endpoints/oauth.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
const axios = require('axios')
module.exports = function (consumerKey, consumerSecret, baseURL = null) {
module.exports = async (consumerKey, consumerSecret, baseURL = null) => {
const auth = Buffer.from(consumerKey + ':' + consumerSecret).toString('base64')
return axios.get((baseURL || this.baseURL) + '/oauth/v1/generate?grant_type=client_credentials', {
headers: {
Expand Down
2 changes: 1 addition & 1 deletion src/endpoints/reversal.js
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* @param {String} [commandId='TransactionReversal'] Takes only 'TransactionReversal' Command id
* @return {Promise}
*/
module.exports = async function (transactionId, amount, queueUrl, resultUrl, shortCode = null, remarks = 'Reversal', occasion = 'Reversal', initiator = null, receiverIdType = '11', commandId = 'TransactionReversal') {
module.exports = async (transactionId, amount, queueUrl, resultUrl, shortCode = null, remarks = 'Reversal', occasion = 'Reversal', initiator = null, receiverIdType = '11', commandId = 'TransactionReversal') => {
const securityCredential = this.security()
const req = await this.request()
return req.post('/mpesa/reversal/v1/request', {
Expand Down
2 changes: 1 addition & 1 deletion src/endpoints/transaction-status.js
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* @param {String} [commandId='TransactionStatusQuery'] Takes only 'TransactionStatusQuery' command id
* @return {Promise}
*/
module.exports = async function (transactionId, receiverParty, idType, queueUrl, resultUrl, remarks = 'TransactionReversal', occasion = 'TransactionReversal', initiator = null, commandId = 'TransactionStatusQuery') {
module.exports = async (transactionId, receiverParty, idType, queueUrl, resultUrl, remarks = 'TransactionReversal', occasion = 'TransactionReversal', initiator = null, commandId = 'TransactionStatusQuery') => {
const securityCredential = this.security()
const req = await this.request()
return req.post('/mpesa/transactionstatus/v1/query', {
Expand Down
7 changes: 2 additions & 5 deletions src/helpers/index.js
Original file line number Diff line number Diff line change
@@ -1,7 +1,4 @@
const request = require('./request')
const security = require('./security')

module.exports = {
request,
security
request: require('./request'),
security: require('./security')
}
2 changes: 1 addition & 1 deletion src/helpers/request.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
const axios = require('axios')
module.exports = async function (_baseURL = null) {
module.exports = async (_baseURL = null) => {
const credentials = await this.oAuth()
const instance = axios.create({
baseURL: _baseURL || this.baseURL,
Expand Down
2 changes: 1 addition & 1 deletion src/helpers/security.js
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ const fs = require('fs')
const path = require('path')
const crypto = require('crypto')

module.exports = (certPath, shortCodeSecurityCredential) => {
module.exports = async (certPath, shortCodeSecurityCredential) => {
const bufferToEncrypt = Buffer.from(shortCodeSecurityCredential)
const data = fs.readFileSync(path.resolve(certPath))
const privateKey = String(data)
Expand Down