Merge pull request #1393 from Fr1ngg/dev4

Dev4
2025-10-18 01:59:58 +03:00
parent 730a6ae185 bee94bcad0
commit 7326d64fbe
1 changed files with 7 additions and 3 deletions
@@ -169,11 +169,15 @@ class WataWebhookHandler:
            payload.get("transactionStatus"),
        )

+        processed: Optional[bool] = None
        async for db in get_db():
            processed = await self.payment_service.process_wata_webhook(db, payload)
-            if processed:
-                return web.json_response({"status": "ok"}, status=200)
-            return web.json_response({"status": "error", "reason": "not_processed"}, status=400)
+            break
+
+        if processed:
+            return web.json_response({"status": "ok"}, status=200)
+
+        return web.json_response({"status": "error", "reason": "not_processed"}, status=400)

    async def health_check(self, request: web.Request) -> web.Response:
        return web.json_response(