refactor(whatsapp): Update expected_status handling in API requests

- Modify expected_status parameter in request methods to accept both int and Sequence[int]
- Update all relevant API request calls to use a list for expected_status values
- Enhance resilience in handling HTTP responses by allowing multiple acceptable status codes

Author: arthurbrenno

agentle/agents/whatsapp/providers/evolution/evolution_api_provider.py

@@ -8,7 +8,7 @@
 import logging
 import re
 import time
-from collections.abc import Mapping, MutableMapping
+from collections.abc import Mapping, MutableMapping, Sequence
 from datetime import datetime
 from typing import Any, override
 from urllib.parse import urljoin
@@ -307,7 +307,7 @@ async def _make_request_with_resilience(
         method: str,
         url: str,
         data: Mapping[str, Any] | None = None,
-        expected_status: int = 200,
+        expected_status: int | Sequence[int] = 200,
     ) -> Mapping[str, Any]:
         """
         Make HTTP request with comprehensive resilience mechanisms.
@@ -416,7 +416,7 @@ async def _make_request(
         method: str,
         url: str,
         data: Mapping[str, Any] | None = None,
-        expected_status: int = 200,
+        expected_status: int | Sequence[int] = 200,
     ) -> Mapping[str, Any]:
         """
         Make HTTP request with proper error handling and metrics.
@@ -531,7 +531,7 @@ def _sanitize_request_data(
     async def _handle_response(
         self,
         response: aiohttp.ClientResponse,
-        expected_status: int,
+        expected_status: int | Sequence[int],
         request_url: str,
         request_data: Mapping[str, Any] | None,
         start_time: float,
@@ -571,7 +571,10 @@ async def _handle_response(
             },
         )
 
-        if response.status == expected_status:
+        if isinstance(expected_status, int):
+            expected_status = [expected_status]
+
+        if response.status not in expected_status:
             try:
                 response_data = await response.json()
                 logger.debug(f"Response data received: {response_data}")
@@ -771,7 +774,7 @@ async def send_text_message(
 
             url = self._build_url(f"sendText/{self.config.instance_name}")
             response_data = await self._make_request_with_resilience(
-                "POST", url, payload, expected_status=201
+                "POST", url, payload, expected_status=[200, 201]
             )
 
             message_id = response_data["key"]["id"]
@@ -885,7 +888,7 @@ async def send_media_message(
 
             url = self._build_url(f"{endpoint}/{self.config.instance_name}")
             response_data = await self._make_request_with_resilience(
-                "POST", url, payload, expected_status=201
+                "POST", url, payload, expected_status=[200, 201]
             )
 
             message_id = response_data["key"]["id"]
@@ -982,7 +985,7 @@ async def send_audio_message(
 
             url = self._build_url(f"sendWhatsAppAudio/{self.config.instance_name}")
             response_data = await self._make_request_with_resilience(
-                "POST", url, payload, expected_status=201
+                "POST", url, payload, expected_status=[200, 201]
             )
 
             message_id = response_data["key"]["id"]
@@ -1060,7 +1063,7 @@ async def send_typing_indicator(self, to: str, duration: int = 3) -> None:
                 use_message_prefix=False,
             )
             await self._make_request_with_resilience(
-                "POST", url, payload, expected_status=201
+                "POST", url, payload, expected_status=[200, 201]
             )
 
             logger.debug(
@@ -1122,7 +1125,7 @@ async def send_recording_indicator(self, to: str, duration: int = 3) -> None:
                 use_message_prefix=False,
             )
             await self._make_request_with_resilience(
-                "POST", url, payload, expected_status=201
+                "POST", url, payload, expected_status=[200, 201]
             )
 
             logger.debug(
@@ -1173,7 +1176,7 @@ async def mark_message_as_read(self, message_id: str) -> None:
                 use_message_prefix=False,
             )
             await self._make_request_with_resilience(
-                "POST", url, payload, expected_status=201
+                "POST", url, payload, expected_status=[200, 201]
             )
 
             logger.debug(
@@ -1423,7 +1426,7 @@ async def download_media(self, media_id: str) -> DownloadedMedia:
             payload = {"message": {"key": {"id": media_id}}}
 
             response_data = await self._make_request_with_resilience(
-                "POST", url, payload, expected_status=201
+                "POST", url, payload, expected_status=[200, 201]
             )
 
             if "base64" not in response_data: