ID:FPCO-30582;DONE:100;HOURS:4; Add dynamic arguments in middleware

Author: ManishPrajapati-GoFynd

fdk_extension/utilities/aiohttp_retry.py

@@ -1,6 +1,6 @@
 import asyncio
 
-async def retry_middleware(handler, request_type, url, headers, *args):
+async def retry_middleware(handler, *args, **kwargs):
     initial_delay = 30
     delay = initial_delay
     max_retries = float('inf')  # Retry forever
@@ -11,7 +11,7 @@ async def retry_middleware(handler, request_type, url, headers, *args):
         attempt += 1
         try:
             # Call the handler to execute the actual request
-            response = await handler(request_type, url, headers, *args)
+            response = await handler(*args, **kwargs)
             status_code = response.get('status_code')
             if status_code in allowed_codes:
                 if attempt <= 3:

fdk_extension/webhook.py

@@ -345,7 +345,7 @@ async def get_event_config(self, handler_config: dict) -> dict:
                 body=data,
                 exclude_headers=list(headers.keys())
             )
-            response = await retry_middleware(AiohttpHelper().aiohttp_request, request_type="POST", url=url, headers=headers, data=data)
+            response = await retry_middleware(AiohttpHelper().aiohttp_request, request_type="POST", url=url, data=data, headers=headers)
             response_data: dict = response["json"]
             event_config["event_configs"] = response_data.get("event_configs")
             logger.debug(f"Webhook events config received: {ujson.dumps(response_data)}")