added bug monitoring tool to mobile money, transfer and VA services

Author: korneliosyaovi

rave_python/rave_mpesa.py

@@ -1,8 +1,7 @@
 from rave_python.rave_exceptions import RaveError, IncompletePaymentDetailsError, AccountChargeError, TransactionVerificationError, TransactionValidationError, ServerError
-
 from rave_python.rave_payment import Payment
 from rave_python.rave_misc import generateTransactionReference
-import json
+import json, requests
 
 class Mpesa(Payment):
 
@@ -11,11 +10,19 @@ def __init__(self, publicKey, secretKey, production, usingEnv):
 
     # Charge mobile money function
     def charge(self, accountDetails, hasFailed=False):
+        
         """ This is the mpesa charge call.\n
              Parameters include:\n
             accountDetails (dict) -- These are the parameters passed to the function for processing\n
             hasFailed (boolean) -- This is a flag to determine if the attempt had previously failed due to a timeout\n
         """
+        
+        #feature logging
+        tracking_endpoint = self._trackingMap
+        tracking_payload = {"publicKey": self._getPublicKey(),"language": "Python v2", "version": "1.2.5", "title": "Incoming call","message": "Initiate-Mpesa-charge"}
+        tracking_response = requests.post(tracking_endpoint, data=json.dumps(tracking_payload))
+        
+        ## feature logic
         # Setting the endpoint
         endpoint = self._baseUrl + self._endpointMap["account"]["charge"]
         # Adding boilerplate mpesa requirements

rave_python/rave_rwmobile.py

@@ -1,6 +1,6 @@
 from rave_python.rave_payment import Payment
 from rave_python.rave_misc import generateTransactionReference
-import json
+import json, requests
 
 class RWMobile(Payment):
 
@@ -10,16 +10,22 @@ def __init__(self, publicKey, secretKey, production, usingEnv):
 
     # Charge mobile money function
     def charge(self, accountDetails, hasFailed=False):
+        
         """ This is the RWMobile charge call.
              Parameters include:\n
             accountDetails (dict) -- These are the parameters passed to the function for processing\n
             hasFailed (boolean) -- This is a flag to determine if the attempt had previously failed due to a timeout\n
         """
 
+        #feature logging
+        tracking_endpoint = self._trackingMap
+        tracking_payload = {"publicKey": self._getPublicKey(),"language": "Python v2", "version": "1.2.5", "title": "Incoming call","message": "Initiate-Zambia-mobile-money-charge"}
+        tracking_response = requests.post(tracking_endpoint, data=json.dumps(tracking_payload))
+
+        #feature logic
         endpoint = self._baseUrl + self._endpointMap["account"]["charge"]
         # It is faster to add boilerplate than to check if each one is present
         accountDetails.update({"payment_type": "mobilemoneygh", "country":"NG", "is_mobile_money_gh":"1", "currency":"RWF", "network": "RWF"})
-        
         # If transaction reference is not set 
         if not ("txRef" in accountDetails):
             accountDetails.update({"txRef": generateTransactionReference()})

rave_python/rave_transfer.py

@@ -46,25 +46,32 @@ def _handleBulkResponse(self, response, bulkDetails):
 
 
     def initiate(self, transferDetails):
+        
+        #feature logging
+        tracking_endpoint = self._trackingMap
+        tracking_payload = {"publicKey": self._getPublicKey(),"language": "Python v2", "version": "1.2.5", "title": "Incoming call","message": "Initiate-Transfer"}
+        tracking_response = requests.post(tracking_endpoint, data=json.dumps(tracking_payload))
+        
+        ## feature logic
+        
         # Performing shallow copy of transferDetails to avoid public exposing payload with secret key
         transferDetails = copy.copy(transferDetails)
-
+        
         # adding reference if not already included
         if not ("reference" in transferDetails):
             transferDetails.update({"reference": generateTransactionReference()})
         transferDetails.update({"seckey": self._getSecretKey()})
-
+        
         # These are the parameters required to initiate a transfer
         requiredParameters = ["amount", "currency","beneficiary_name"]
-
         checkIfParametersAreComplete(requiredParameters, transferDetails)
         checkTransferParameters(requiredParameters, transferDetails)
-
+        
         # Collating request headers
         headers = {
             'content-type': 'application/json',
         }
-        
+
         endpoint = self._baseUrl + self._endpointMap["transfer"]["initiate"]
         response = requests.post(endpoint, headers=headers, data=json.dumps(transferDetails))
         return self._handleInitiateResponse(response, transferDetails)
@@ -73,21 +80,25 @@ def initiate(self, transferDetails):
 
     def bulk(self, bulkDetails):
 
+        #feature logging
+        tracking_endpoint = self._trackingMap
+        tracking_payload = {"publicKey": self._getPublicKey(),"language": "Python v2", "version": "1.2.5", "title": "Incoming call","message": "Initiate-bulk-Transfer"}
+        tracking_response = requests.post(tracking_endpoint, data=json.dumps(tracking_payload))
+        
+        # feature logic
         bulkDetails = copy.copy(bulkDetails)
+        
         # Collating request headers
         headers = {
             'content-type': 'application/json',
         }
 
         bulkDetails.update({"seckey": self._getSecretKey()})
-
         requiredParameters = ["title", "bulk_data"]
-
         checkIfParametersAreComplete(requiredParameters, bulkDetails)
-        
         checkTransferParameters(requiredParameters, bulkDetails)
-
         endpoint = self._baseUrl + self._endpointMap["transfer"]["bulk"]
+        
         # Collating request headers
         headers = {
             'content-type': 'application/json',
@@ -98,6 +109,7 @@ def bulk(self, bulkDetails):
 
     # This makes and handles all requests pertaining to the status of your transfer or account
     def _handleTransferStatusRequests(self, endpoint, isPostRequest=False, data=None):
+        
         # Request headers
         headers = {
             'content-type': 'application/json',
@@ -123,25 +135,54 @@ def _handleTransferStatusRequests(self, endpoint, isPostRequest=False, data=None
 
     # Not elegant but supports python 2 and 3
     def fetch(self, reference=None):
+        
+        #feature logging
+        tracking_endpoint = self._trackingMap
+        tracking_payload = {"publicKey": self._getPublicKey(),"language": "Python v2", "version": "1.2.5", "title": "Incoming call","message": "Fetch-Transfer"}
+        tracking_response = requests.post(tracking_endpoint, data=json.dumps(tracking_payload))
+        
+        #feature logic
         endpoint = self._baseUrl + self._endpointMap["transfer"]["fetch"] + "?seckey="+self._getSecretKey()+'&reference='+str(reference)
         return self._handleTransferStatusRequests(endpoint)
 
     def all(self):
+        
+        #feature logging
+        tracking_endpoint = self._trackingMap
+        tracking_payload = {"publicKey": self._getPublicKey(),"language": "Python v2", "version": "1.2.5", "title": "Incoming call","message": "List-all-Transfers"}
+        tracking_response = requests.post(tracking_endpoint, data=json.dumps(tracking_payload))
+
+        #feature logic
         endpoint = self._baseUrl + self._endpointMap["transfer"]["fetch"] + "?seckey="+self._getSecretKey()
         return self._handleTransferStatusRequests(endpoint)
 
     def getFee(self, currency=None):
+        
+        # feature logging
+        tracking_endpoint = self._trackingMap
+        tracking_payload = {"publicKey": self._getPublicKey(),"language": "Python v2", "version": "1.2.5", "title": "Incoming call","message": "Get-Transfer-fee-by-Currency"}
+        tracking_response = requests.post(tracking_endpoint, data=json.dumps(tracking_payload))
+        
+        # feature logic
         endpoint = self._baseUrl + self._endpointMap["transfer"]["fee"] + "?seckey="+self._getSecretKey() + "&currency="+str(currency)
         return self._handleTransferStatusRequests(endpoint)
 
     def getBalance(self, currency):
+        
+        # feature logging
+        tracking_endpoint = self._trackingMap
+        tracking_payload = {"publicKey": self._getPublicKey(),"language": "Python v2", "version": "1.2.5", "title": "Incoming call","message": "Get-Balance-fee-by-Currency"}
+        tracking_response = requests.post(tracking_endpoint, data=json.dumps(tracking_payload))
+        
+        # feature logic
         if not currency: # i made currency compulsory because if it is not assed in, an error message is returned from the server
             raise IncompletePaymentDetailsError("currency", ["currency"])
         endpoint =  self._baseUrl + self._endpointMap["transfer"]["balance"] 
         data = {
             "seckey": self._getSecretKey(),
             "currency": currency
         }
+
         return self._handleTransferStatusRequests(endpoint, data=data, isPostRequest=True)
 
 

rave_python/rave_ugmobile.py

@@ -1,6 +1,6 @@
 from rave_python.rave_payment import Payment
 from rave_python.rave_misc import generateTransactionReference
-import json
+import json, requests
 
 class UGMobile(Payment):
 
@@ -10,16 +10,22 @@ def __init__(self, publicKey, secretKey, production, usingEnv):
 
     # Charge mobile money function
     def charge(self, accountDetails, hasFailed=False):
+        
         """ This is the ghMobile charge call.
              Parameters include:\n
             accountDetails (dict) -- These are the parameters passed to the function for processing\n
             hasFailed (boolean) -- This is a flag to determine if the attempt had previously failed due to a timeout\n
         """
 
+        #feature logging
+        tracking_endpoint = self._trackingMap
+        tracking_payload = {"publicKey": self._getPublicKey(),"language": "Python v2", "version": "1.2.5", "title": "Incoming call","message": "Initiate-Uganda-mobile-money-charge"}
+        tracking_response = requests.post(tracking_endpoint, data=json.dumps(tracking_payload))
+        
+        ## feature logic
         endpoint = self._baseUrl + self._endpointMap["account"]["charge"]
         # It is faster to add boilerplate than to check if each one is present
         accountDetails.update({"payment_type": "mobilemoneyuganda", "country":"NG", "is_mobile_money_ug":"1", "currency":"UGX", "network": "UGX"})
-        
         # If transaction reference is not set 
         if not ("txRef" in accountDetails):
             accountDetails.update({"txRef": generateTransactionReference()})

rave_python/rave_verify.py

@@ -56,6 +56,13 @@ def _handleVerifyStatusRequests(self, endpoint, isPostRequest=False, data=None):
             raise BVNFetchError({"error": True, "returnedData": responseJson })
 
     def bvnVerify(self, bvn):
+        
+        #feature logging
+        tracking_endpoint = self._trackingMap
+        tracking_payload = {"publicKey": self._getPublicKey(),"language": "Python v2", "version": "1.2.5", "title": "Incoming call","message": "BVN-verification"}
+        tracking_response = requests.post(tracking_endpoint, data=json.dumps(tracking_payload))
+
+        # feature logic
         if not bvn:
             return "BVN was not supplied. Kindly supply one"
         endpoint = self._baseUrl + self._endpointMap["bvn"]["verify"] +str(bvn)+"?seckey=" + self._getSecretKey()

rave_python/rave_virtualaccount.py

@@ -59,12 +59,17 @@ def _handleCreateResponse(self, response, accountDetails):
     #function to create a virtual card 
     #Params: cardDetails - a dict containing email, is_permanent, frequency, duration, narration
     def create(self, accountDetails):
+        
+        #feature logging
+        tracking_endpoint = self._trackingMap
+        tracking_payload = {"publicKey": self._getPublicKey(),"language": "Python v2", "version": "1.2.5", "title": "Incoming call","message": "Create-virtual-account"}
+        tracking_response = requests.post(tracking_endpoint, data=json.dumps(tracking_payload))
+
+        # feature logic
         accountDetails = copy.copy(accountDetails)
         accountDetails.update({"seckey": self._getSecretKey()})
-        
         requiredParameters = ["email", "narration"]
         checkIfParametersAreComplete(requiredParameters, accountDetails)
-
         endpoint = self._baseUrl + self._endpointMap["virtual_account"]["create"]
         response = requests.post(endpoint, headers=self.headers, data=json.dumps(accountDetails))
         return self._handleCreateResponse(response, accountDetails)

rave_python/rave_zbmobile.py

@@ -1,6 +1,6 @@
 from rave_python.rave_payment import Payment
 from rave_python.rave_misc import generateTransactionReference
-import json
+import json, requests
 
 class ZBMobile(Payment):
 
@@ -10,16 +10,22 @@ def __init__(self, publicKey, secretKey, production, usingEnv):
 
     # Charge mobile money function
     def charge(self, accountDetails, hasFailed=False):
+        
         """ This is the ghMobile charge call.
              Parameters include:\n
             accountDetails (dict) -- These are the parameters passed to the function for processing\n
             hasFailed (boolean) -- This is a flag to determine if the attempt had previously failed due to a timeout\n
         """
 
+        #feature logging
+        tracking_endpoint = self._trackingMap
+        tracking_payload = {"publicKey": self._getPublicKey(),"language": "Python v2", "version": "1.2.5", "title": "Incoming call","message": "Initiate-Zambia-mobile-money-charge"}
+        tracking_response = requests.post(tracking_endpoint, data=json.dumps(tracking_payload))
+
+        ## Feature logic
         endpoint = self._baseUrl + self._endpointMap["account"]["charge"]
         # It is faster to add boilerplate than to check if each one is present
         accountDetails.update({"payment_type": "mobilemoneyzambia", "country":"NG", "is_mobile_money_ug":"1", "currency":"ZMW", "network": "MTN"})
-        
         # If transaction reference is not set 
         if not ("txRef" in accountDetails):
             accountDetails.update({"txRef": generateTransactionReference()})