feat: deserialize responses into typed Pydantic models

src/archastro/platform/channels/api_activity_feed_channel.py

@@ -1,9 +1,9 @@
 # Copyright (c) 2026 ArchAstro Inc. All Rights Reserved.
 # This file is auto-generated by @archastro/sdk-generator. Do not edit.
-# Content hash: 12874ed2facb
+# Content hash: 8b5c0cda4968
 
 from collections.abc import Callable
-from typing import TYPE_CHECKING, TypedDict
+from typing import TYPE_CHECKING, Any, TypedDict
 
 if TYPE_CHECKING:
     from archastro.phx_channel.socket import Socket
@@ -19,7 +19,7 @@ class ListEntriesInput(TypedDict, total=False):
 
 
 class NewEntryPayload(TypedDict, total=False):
-    entry: dict[str, object] | None
+    entry: dict[str, Any] | None
 
 
 # Phoenix channel for real-time activity feed updates.
@@ -64,7 +64,7 @@ async def leave(self):
         await self._channel.leave()
 
     # List activity feed entries with cursor-based pagination
-    async def list_entries(self, payload: ListEntriesInput) -> dict[str, object]:
+    async def list_entries(self, payload: ListEntriesInput) -> dict[str, Any]:
         return await self._channel.push("list_entries", payload)
 
     def on_new_entry(self, callback: Callable[[NewEntryPayload], None]) -> Callable[[], None]:

src/archastro/platform/channels/api_chat_channel.py

@@ -1,10 +1,10 @@
 # Copyright (c) 2026 ArchAstro Inc. All Rights Reserved.
 # This file is auto-generated by @archastro/sdk-generator. Do not edit.
-# Content hash: 778ff3bdf540
+# Content hash: f168af356eb1
 
 from collections.abc import Callable
 from datetime import datetime
-from typing import TYPE_CHECKING, Required, TypedDict
+from typing import TYPE_CHECKING, Any, Required, TypedDict
 
 if TYPE_CHECKING:
     from archastro.phx_channel.socket import Socket
@@ -34,7 +34,7 @@ class ApiChatPostMessageInput(TypedDict, total=False):
     content: Required[str]
     idempotency_key: str
     reply_to: str
-    uploads: list[dict[str, object]]
+    uploads: list[dict[str, Any]]
 
 
 # Post a simple text message
@@ -130,7 +130,7 @@ class MessageAddedPayloadMessageAttachmentsItem(TypedDict, total=False):
     image_width: int | None  # Preview image width (scraped_link type)
     media_type: str | None  # Media type (media type)
     name: str | None  # Media name (media type)
-    object: dict[str, object] | None  # Embedded object (task, action types)
+    object: dict[str, Any] | None  # Embedded object (task, action types)
     title: str | None  # Title (scraped_link, artifact, task types)
     type: Required[str]  # Attachment type: file, scraped_link, artifact, task, media, action
     url: str | None  # URL to the resource (file, scraped_link, artifact, media types)
@@ -140,7 +140,7 @@ class MessageAddedPayloadMessageAttachmentsItem(TypedDict, total=False):
 
 
 class MessageAddedPayloadMessageReactionsItem(TypedDict, total=False):
-    payload: dict[str, object] | None  # Reaction payload (e.g., {emoji: '👍'})
+    payload: dict[str, Any] | None  # Reaction payload (e.g., {emoji: '👍'})
     type: Required[str]  # Reaction type (e.g., emoji_reaction)
     user: str | None  # User who added the reaction
 
@@ -156,15 +156,15 @@ class MessageAddedPayloadMessage(TypedDict, total=False):
     id: Required[str]  # Message ID (msg_...)
     idempotency_key: str | None  # Client-provided idempotency key
     legacy_agent: str | None  # Legacy agent if sent by legacy chat agent
-    metadata: dict[str, object] | None  # Message metadata
+    metadata: dict[str, Any] | None  # Message metadata
     org: str | None  # Organization
     reactions: list[MessageAddedPayloadMessageReactionsItem] | None  # Message reactions
     rendering_mode: str | None  # Rendering mode hint
-    replies: list[dict[str, object]] | None  # Inline replies (if loaded)
+    replies: list[dict[str, Any]] | None  # Inline replies (if loaded)
     replies_after_cursor: str | None  # Cursor for replies pagination
     replies_before_cursor: str | None  # Cursor for replies pagination
     reply_count: int | None  # Number of replies
-    reply_to: dict[str, object] | None  # Parent message object (if loaded)
+    reply_to: dict[str, Any] | None  # Parent message object (if loaded)
     sandbox: str | None  # Sandbox identifier
     team: str | None  # Team
     thread: str | None  # Parent thread
@@ -242,7 +242,7 @@ class MessageUpdatedPayloadMessageAttachmentsItem(TypedDict, total=False):
     image_width: int | None  # Preview image width (scraped_link type)
     media_type: str | None  # Media type (media type)
     name: str | None  # Media name (media type)
-    object: dict[str, object] | None  # Embedded object (task, action types)
+    object: dict[str, Any] | None  # Embedded object (task, action types)
     title: str | None  # Title (scraped_link, artifact, task types)
     type: Required[str]  # Attachment type: file, scraped_link, artifact, task, media, action
     url: str | None  # URL to the resource (file, scraped_link, artifact, media types)
@@ -252,7 +252,7 @@ class MessageUpdatedPayloadMessageAttachmentsItem(TypedDict, total=False):
 
 
 class MessageUpdatedPayloadMessageReactionsItem(TypedDict, total=False):
-    payload: dict[str, object] | None  # Reaction payload (e.g., {emoji: '👍'})
+    payload: dict[str, Any] | None  # Reaction payload (e.g., {emoji: '👍'})
     type: Required[str]  # Reaction type (e.g., emoji_reaction)
     user: str | None  # User who added the reaction
 
@@ -268,15 +268,15 @@ class MessageUpdatedPayloadMessage(TypedDict, total=False):
     id: Required[str]  # Message ID (msg_...)
     idempotency_key: str | None  # Client-provided idempotency key
     legacy_agent: str | None  # Legacy agent if sent by legacy chat agent
-    metadata: dict[str, object] | None  # Message metadata
+    metadata: dict[str, Any] | None  # Message metadata
     org: str | None  # Organization
     reactions: list[MessageUpdatedPayloadMessageReactionsItem] | None  # Message reactions
     rendering_mode: str | None  # Rendering mode hint
-    replies: list[dict[str, object]] | None  # Inline replies (if loaded)
+    replies: list[dict[str, Any]] | None  # Inline replies (if loaded)
     replies_after_cursor: str | None  # Cursor for replies pagination
     replies_before_cursor: str | None  # Cursor for replies pagination
     reply_count: int | None  # Number of replies
-    reply_to: dict[str, object] | None  # Parent message object (if loaded)
+    reply_to: dict[str, Any] | None  # Parent message object (if loaded)
     sandbox: str | None  # Sandbox identifier
     team: str | None  # Team
     thread: str | None  # Parent thread
@@ -291,14 +291,14 @@ class MessageUpdatedPayload(TypedDict, total=False):
 
 # Broadcast thread-level events (agent updates, read state, unread counts)
 class ThreadEventPayload(TypedDict, total=False):
-    payload: dict[str, object] | None
+    payload: dict[str, Any] | None
     thread_id: str | None
     type: str | None
 
 
 # Broadcast system-wide events
 class SystemEventPayload(TypedDict, total=False):
-    event: dict[str, object] | None
+    event: dict[str, Any] | None
 
 
 # Channel for real-time chat messaging.
@@ -503,53 +503,49 @@ async def leave(self):
         await self._channel.leave()
 
     # Fork a sub-thread from an existing message
-    async def api_chat_fork_thread(self, payload: ApiChatForkThreadInput) -> dict[str, object]:
+    async def api_chat_fork_thread(self, payload: ApiChatForkThreadInput) -> dict[str, Any]:
         return await self._channel.push("api:chat:fork_thread", payload)
 
     # Mark a thread as read up to a given message
     async def api_chat_mark_thread_read(
         self, payload: ApiChatMarkThreadReadInput
-    ) -> dict[str, object]:
+    ) -> dict[str, Any]:
         return await self._channel.push("api:chat:mark_thread_read", payload)
 
     # List all messages in the current thread
-    async def api_chat_list_messages(self, payload: dict) -> dict[str, object]:
+    async def api_chat_list_messages(self, payload: dict) -> dict[str, Any]:
         return await self._channel.push("api:chat:list_messages", payload)
 
     # Load additional messages with cursor-based pagination
     async def api_chat_load_more_messages(
         self, payload: ApiChatLoadMoreMessagesInput
-    ) -> dict[str, object]:
+    ) -> dict[str, Any]:
         return await self._channel.push("api:chat:load_more_messages", payload)
 
     # Post a new message with optional uploads and reply-to
-    async def api_chat_post_message(self, payload: ApiChatPostMessageInput) -> dict[str, object]:
+    async def api_chat_post_message(self, payload: ApiChatPostMessageInput) -> dict[str, Any]:
         return await self._channel.push("api:chat:post_message", payload)
 
     # Post a simple text message
     async def api_chat_post_simple_message(
         self, payload: ApiChatPostSimpleMessageInput
-    ) -> dict[str, object]:
+    ) -> dict[str, Any]:
         return await self._channel.push("api:chat:post_simple_message", payload)
 
     # Edit an existing message's content
-    async def api_chat_edit_message(self, payload: ApiChatEditMessageInput) -> dict[str, object]:
+    async def api_chat_edit_message(self, payload: ApiChatEditMessageInput) -> dict[str, Any]:
         return await self._channel.push("api:chat:edit_message", payload)
 
     # Delete a message
-    async def api_chat_delete_message(
-        self, payload: ApiChatDeleteMessageInput
-    ) -> dict[str, object]:
+    async def api_chat_delete_message(self, payload: ApiChatDeleteMessageInput) -> dict[str, Any]:
         return await self._channel.push("api:chat:delete_message", payload)
 
     # Add an emoji reaction to a message
-    async def api_chat_add_reaction(self, payload: ApiChatAddReactionInput) -> dict[str, object]:
+    async def api_chat_add_reaction(self, payload: ApiChatAddReactionInput) -> dict[str, Any]:
         return await self._channel.push("api:chat:add_reaction", payload)
 
     # Remove an emoji reaction from a message
-    async def api_chat_remove_reaction(
-        self, payload: ApiChatRemoveReactionInput
-    ) -> dict[str, object]:
+    async def api_chat_remove_reaction(self, payload: ApiChatRemoveReactionInput) -> dict[str, Any]:
         return await self._channel.push("api:chat:remove_reaction", payload)
 
     # Broadcast when a new message is added to a thread

src/archastro/platform/channels/api_object_channel.py

@@ -1,25 +1,25 @@
 # Copyright (c) 2026 ArchAstro Inc. All Rights Reserved.
 # This file is auto-generated by @archastro/sdk-generator. Do not edit.
-# Content hash: 627be1ddbbf4
+# Content hash: 24dfaffabee5
 
 from collections.abc import Callable
-from typing import TYPE_CHECKING, TypedDict
+from typing import TYPE_CHECKING, Any, TypedDict
 
 if TYPE_CHECKING:
     from archastro.phx_channel.socket import Socket
 
 
 class UpdateFieldsInput(TypedDict):
-    fields: dict[str, object]
+    fields: dict[str, Any]
 
 
 class ObjectUpdatedPayload(TypedDict, total=False):
-    fields: dict[str, object] | None
+    fields: dict[str, Any] | None
     id: str | None
 
 
 class ObjectCreatedPayload(TypedDict, total=False):
-    fields: dict[str, object] | None
+    fields: dict[str, Any] | None
     id: str | None
 
 
@@ -59,10 +59,10 @@ async def join_by_row_key(
     async def leave(self):
         await self._channel.leave()
 
-    async def update_fields(self, payload: UpdateFieldsInput) -> dict[str, object]:
+    async def update_fields(self, payload: UpdateFieldsInput) -> dict[str, Any]:
         return await self._channel.push("update_fields", payload)
 
-    async def save(self, payload: dict) -> dict[str, object]:
+    async def save(self, payload: dict) -> dict[str, Any]:
         return await self._channel.push("save", payload)
 
     def on_object_updated(