tax file service initial updated

Author: mendozagit

fiscalapi/services/base_service.py

@@ -1,6 +1,6 @@
 import urllib3 
 urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
-from typing import Type, TypeVar
+from typing import Type, TypeVar, get_args, get_origin
 import certifi
 from pydantic import BaseModel
 import requests
@@ -61,6 +61,63 @@ def _request(self, method: str, endpoint: str, **kwargs) -> requests.Response:
 
         return response
 
+    # def _process_response(self, response: requests.Response, response_model: Type[T]) -> ApiResponse[T]:
+    #     status_code = response.status_code
+    #     raw_content = response.text
+
+    #     try:
+    #         response_data = response.json()
+    #     except ValueError:
+    #         return ApiResponse[T](
+    #             succeeded=False,
+    #             http_status_code=status_code,
+    #             message="Error processing server response",
+    #             details=raw_content,
+    #             data=None
+    #         )
+
+    #     if 200 <= status_code < 300:
+            
+    #         if issubclass(response_model, BaseModel) and isinstance(response_data["data"], dict):
+    #             response_data["data"] = response_model.model_validate(response_data["data"])
+                
+    #         return ApiResponse[T].model_validate(response_data)
+
+    #     try:
+    #         generic_error = ApiResponse[object].model_validate(response_data)
+    #     except Exception:
+    #         return ApiResponse[T](
+    #             succeeded=False,
+    #             http_status_code=status_code,
+    #             message="Error processing server error response",
+    #             details=raw_content,
+    #             data=None
+    #         )
+
+    #     if status_code == 400 and isinstance(response_data.get("data"), list):
+    #         try:
+    #             failures = [ValidationFailure.model_validate(item) for item in response_data["data"]]
+    #             if failures:
+    #                 details_str = "; ".join(f"{f.propertyName}: {f.errorMessage}" for f in failures)
+    #                 return ApiResponse[T](
+    #                     succeeded=False,
+    #                     http_status_code=400,
+    #                     message=generic_error.message,
+    #                     details=details_str,
+    #                     data=None
+    #                 )
+    #         except Exception:
+    #             pass
+
+    #     return ApiResponse[T](
+    #         succeeded=False,
+    #         http_status_code=status_code,
+    #         message=generic_error.message or f"HTTP Error {status_code}",
+    #         details=generic_error.details or raw_content,
+    #         data=None
+    #     )
+
+    
     def _process_response(self, response: requests.Response, response_model: Type[T]) -> ApiResponse[T]:
         status_code = response.status_code
         raw_content = response.text
@@ -77,12 +134,30 @@ def _process_response(self, response: requests.Response, response_model: Type[T]
             )
 
         if 200 <= status_code < 300:
-            
-            if issubclass(response_model, BaseModel) and isinstance(response_data["data"], dict):
-                response_data["data"] = response_model.model_validate(response_data["data"])
-                
+            # -- Manejo de data con modelos pydantic o lista de modelos pydantic
+            origin = get_origin(response_model)
+            if origin == list:
+                # Significa que es algo como list[TaxFile]
+                (model_type,) = get_args(response_model)
+                # Validar cada elemento de la lista si data es una lista
+                if issubclass(model_type, BaseModel) and isinstance(response_data["data"], list):
+                    response_data["data"] = [
+                        model_type.model_validate(item) 
+                        for item in response_data["data"]
+                    ]
+            else:
+                # Manejo de caso donde response_model es un modelo Pydantic "simple"
+                if (
+                    isinstance(response_model, type) 
+                    and issubclass(response_model, BaseModel) 
+                    and isinstance(response_data["data"], dict)
+                ):
+                    response_data["data"] = response_model.model_validate(response_data["data"])
+
+            # Finalmente se parsea la respuesta como ApiResponse[T]
             return ApiResponse[T].model_validate(response_data)
 
+        # -- Manejo de respuestas de error --
         try:
             generic_error = ApiResponse[object].model_validate(response_data)
         except Exception:
@@ -116,12 +191,16 @@ def _process_response(self, response: requests.Response, response_model: Type[T]
             details=generic_error.details or raw_content,
             data=None
         )
-
+    
+    
+    
     def send_request(self, method: str, endpoint: str, response_model: Type[T], **kwargs) -> ApiResponse[T]:
         payload = kwargs.pop("payload", None)
         if payload is not None and isinstance(payload, BaseModel):
             # Excluir propiedades con valor None
             kwargs["json"] = payload.model_dump(mode="json", by_alias=True, exclude_none=True)
 
         response = self._request(method, endpoint, **kwargs)
-        return self._process_response(response, response_model)
+        return self._process_response(response, response_model)
+    
+