(20241230) Method correction.

api/blueprints/finstitutions/trading/oauth/request.py

@@ -112,7 +112,7 @@ def init(blueprint_setup_state):
 # ---------------------------------------------------------------------------------------------------------------------
 
 
-@trading_oauth_request_bp.route("", methods = ["GET"])
+@trading_oauth_request_bp.route("", methods = ["GET", "POST"])
 @set_api_version(api_version = "1.0.0")
 @read_input(sanitize_headers = False, sanitize_data = False)
 @get_session_info(key = "X-Session-Token", session_coro = "get_session")

controllers_v2/core/auth_token.py

@@ -394,6 +394,15 @@ class CoreAuthTokenController(CoreBaseModel):
         # Done here:
         return success
 
+    async def modify_status(
+            self,
+            sql_conn: AsyncMySQL,
+            mongo_data_conn: AsyncMongo,
+            auth_token: CoreAuthTokenModel,
+    ):
+
+        pass
+
     # ┏┓┳┓┳┳┳┓      ┳┓     •
     # ┃ ┣┫┃┃┃┃  ━━  ┣┫┏┓╋┏┓┓┏┓┓┏┏┓
     # ┗┛┛┗┗┛┻┛      ┛┗┗ ┗┛ ┗┗ ┗┛┗

controllers_v2/finstitutions/payments/all_payments.py

@@ -178,6 +178,11 @@ class AllPaymentsController(PaymentsController):
         :return: A structured response about the process of updating the payment event.
         """
 
+        # There are 3 main steps here:
+        # 01. Add the payment's update event to the main record,
+        # 02. Add the receipt (if payment successful),
+        # 03. Disable the payment auth-token if the gateway says that the credentials are invalid.
+
         raise NotImplementedError
 
 

controllers_v2/finstitutions/payments/base.py

@@ -538,6 +538,11 @@ class PaymentsController(CoreAuthTokenController, ABC):
         :return: A structured response about the process of updating the payment event.
         """
 
+        # There are 3 main steps here:
+        # 01. Add the payment's update event to the main record,
+        # 02. Add the receipt (if payment successful),
+        # 03. Disable the payment auth-token if the gateway says that the credentials are invalid.
+
         pass
 
 

controllers_v2/finstitutions/payments/safaricom_mpesa_express.py

@@ -269,6 +269,11 @@ class SafaricomMPesaExpressPaymentsController(PaymentsController):
         :return: A structured response about the process of updating the payment event.
         """
 
+        # There are 3 main steps here:
+        # 01. Add the payment's update event to the main record,
+        # 02. Add the receipt (if payment successful),
+        # 03. Disable the payment auth-token if the gateway says that the credentials are invalid.
+
         # Start by assuming failure:
         result = PaymentCallbackResult()
 

wsio/finstitutions/trading/main.py

@@ -331,12 +331,12 @@ async def init():
     cwd = files.get_cwd()
     parent_dir = cwd
     ssl_context = get_ssl_context(
-        ca_file = "/etc/ssl/dbu/ca.pem",
-        cert_file = "/etc/ssl/dbu/fullchain.pem",
-        key_file = "/etc/ssl/dbu/privkey.pem"
-        # ca_file = os.path.join(parent_dir, "creds", "kafka", "cert_authority.pem"),
-        # cert_file = os.path.join(parent_dir, "creds", "kafka", "fullchain.pem"),
-        # key_file = os.path.join(parent_dir, "creds", "kafka", "privkey.pem")
+        # ca_file = "/etc/ssl/dbu/ca.pem",
+        # cert_file = "/etc/ssl/dbu/fullchain.pem",
+        # key_file = "/etc/ssl/dbu/privkey.pem"
+        ca_file = os.path.join(parent_dir, "creds", "kafka", "cert_authority.pem"),
+        cert_file = os.path.join(parent_dir, "creds", "kafka", "fullchain.pem"),
+        key_file = os.path.join(parent_dir, "creds", "kafka", "privkey.pem")
     )
     sio.start_background_task(
         ticks_from_kafka,