chore: Correct type annotation to accurately identify (#60)

- Fixed type annotation issue to correctly recognize model's Iterable
type
- Ensured proper unpacking of sub-elements within the Iterable

cozepy/chat/message/__init__.py

@@ -33,7 +33,7 @@ def list(
             "conversation_id": conversation_id,
             "chat_id": chat_id,
         }
-        return self._requester.request("post", url, List[Message], params=params)
+        return self._requester.request("post", url, [Message], params=params)
 
 
 class AsyncMessagesClient(object):
@@ -64,4 +64,4 @@ async def list(
             "conversation_id": conversation_id,
             "chat_id": chat_id,
         }
-        return await self._requester.arequest("post", url, List[Message], params=params)
+        return await self._requester.arequest("post", url, [Message], params=params)

cozepy/knowledge/documents/__init__.py

@@ -288,9 +288,7 @@ def create(
             "document_bases": [i.model_dump() for i in document_bases],
             "chunk_strategy": chunk_strategy.model_dump() if chunk_strategy else None,
         }
-        return self._requester.request(
-            "post", url, List[Document], headers=headers, body=body, data_field="document_infos"
-        )
+        return self._requester.request("post", url, [Document], headers=headers, body=body, data_field="document_infos")
 
     def update(
         self,
@@ -431,7 +429,7 @@ async def create(
             "chunk_strategy": chunk_strategy.model_dump() if chunk_strategy else None,
         }
         return await self._requester.arequest(
-            "post", url, List[Document], headers=headers, body=body, data_field="document_infos"
+            "post", url, [Document], headers=headers, body=body, data_field="document_infos"
         )
 
     async def update(

cozepy/request.py

@@ -2,7 +2,6 @@
     TYPE_CHECKING,
     Any,
     AsyncIterator,
-    Iterable,
     Iterator,
     List,
     Optional,
@@ -15,7 +14,6 @@
 import httpx
 from httpx import Response
 from pydantic import BaseModel
-from typing_extensions import get_args, get_origin
 
 from cozepy.config import DEFAULT_CONNECTION_LIMITS, DEFAULT_TIMEOUT
 from cozepy.exception import COZE_PKCE_AUTH_ERROR_TYPE_ENUMS, CozeAPIError, CozePKCEAuthError, CozePKCEAuthErrorType
@@ -58,7 +56,7 @@ def request(
         self,
         method: str,
         url: str,
-        model: Union[Type[T], Type[Iterable[T]], None],
+        model: Union[Type[T], List[Type[T]], None],
         params: dict = None,
         headers: dict = None,
         body: dict = None,
@@ -88,7 +86,7 @@ async def arequest(
         self,
         method: str,
         url: str,
-        model: Union[Type[T], Type[Iterable[T]], None],
+        model: Union[Type[T], List[Type[T]], None],
         params: dict = None,
         headers: dict = None,
         body: dict = None,
@@ -156,7 +154,7 @@ def _parse_response(
         method: str,
         url: str,
         response: httpx.Response,
-        model: Union[Type[T], Iterable[Type[T]], None],
+        model: Union[Type[T], List[Type[T]], None],
         stream: bool = False,
         data_field: str = "data",
         is_async: bool = False,
@@ -177,8 +175,8 @@ def _parse_response(
             if msg in COZE_PKCE_AUTH_ERROR_TYPE_ENUMS:
                 raise CozePKCEAuthError(CozePKCEAuthErrorType(msg), logid)
             raise CozeAPIError(code, msg, logid)
-        if get_origin(model) is list:
-            item_model = get_args(model)[0]
+        if isinstance(model, List):
+            item_model = model[0]
             return [item_model.model_validate(item) for item in data]
         else:
             if model is None: