wehub-resource-sync
4ce4204b6c
CI / Lint (push) Failing after 2s
CI / Build (push) Has been skipped
SDK CI / PHP SDK (push) Failing after 1s
Split PHP SDK / PHP SDK tests (push) Failing after 1s
CI / Test (push) Failing after 1s
CI / Dashboard (push) Failing after 0s
SDK CI / JavaScript SDK (push) Failing after 0s
SDK CI / Python SDK (push) Failing after 2s
SDK CI / Java SDK (push) Failing after 1s
Split PHP SDK / Mirror sdk/php -> rmyndharis/openwa-php (push) Has been skipped
CI / Test (PostgreSQL migrations) (push) Failing after 7m47s
CI / Docker Build (push) Has been skipped
47 lines
1.7 KiB
Python
47 lines
1.7 KiB
Python
"""Chats resource — chat-list operations (read/unread/delete/typing state).
|
|
|
|
These endpoints live under the session controller (``/api/sessions/:id/chats/*``)
|
|
but are surfaced here as a dedicated resource for clarity.
|
|
"""
|
|
|
|
from __future__ import annotations
|
|
|
|
from typing import TYPE_CHECKING, TypedDict
|
|
|
|
from .._http import quote_segment
|
|
from ..types import (
|
|
ChatSummary,
|
|
DeleteChatRequest,
|
|
MarkChatRequest,
|
|
SendChatStateRequest,
|
|
SuccessResult,
|
|
)
|
|
|
|
if TYPE_CHECKING:
|
|
from .._http import HttpExecutor
|
|
|
|
|
|
class ListChatsQuery(TypedDict, total=False):
|
|
limit: int
|
|
offset: int
|
|
|
|
|
|
class ChatsResource:
|
|
def __init__(self, http: "HttpExecutor") -> None:
|
|
self._http = http
|
|
|
|
def list(self, session_id: str, query: ListChatsQuery | None = None) -> list[ChatSummary]:
|
|
return self._http.request("GET", f"/api/sessions/{quote_segment(session_id)}/chats", query=query)
|
|
|
|
def mark_read(self, session_id: str, body: MarkChatRequest) -> SuccessResult:
|
|
return self._http.request("POST", f"/api/sessions/{quote_segment(session_id)}/chats/read", body=body)
|
|
|
|
def mark_unread(self, session_id: str, body: MarkChatRequest) -> SuccessResult:
|
|
return self._http.request("POST", f"/api/sessions/{quote_segment(session_id)}/chats/unread", body=body)
|
|
|
|
def delete(self, session_id: str, body: DeleteChatRequest) -> SuccessResult:
|
|
return self._http.request("POST", f"/api/sessions/{quote_segment(session_id)}/chats/delete", body=body)
|
|
|
|
def send_state(self, session_id: str, body: SendChatStateRequest) -> SuccessResult:
|
|
return self._http.request("POST", f"/api/sessions/{quote_segment(session_id)}/chats/typing", body=body)
|