Skip to content

Commit 1c6092e

Browse files
committed
feat: [CHA-4947] regenerate from latest OpenAPI
1 parent 24096a9 commit 1c6092e

15 files changed

Lines changed: 6104 additions & 5962 deletions

getstream/chat/async_channel.py

Lines changed: 42 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ def __init__(
99
self,
1010
client,
1111
channel_type: str,
12-
channel_id: str = None,
12+
channel_id: str | None = None,
1313
custom_data: Dict = None,
1414
):
1515
self.channel_id = channel_id
@@ -285,6 +285,47 @@ async def get_many_messages(
285285
self._sync_from_response(response.data)
286286
return response
287287

288+
@attach_channel_cid_async
289+
async def get_pinned_messages(
290+
self,
291+
limit: Optional[int] = None,
292+
offset: Optional[int] = None,
293+
id_gte: Optional[str] = None,
294+
id_gt: Optional[str] = None,
295+
id_lte: Optional[str] = None,
296+
id_lt: Optional[str] = None,
297+
pinned_at_after_or_equal: Optional[datetime] = None,
298+
pinned_at_after: Optional[datetime] = None,
299+
pinned_at_before_or_equal: Optional[datetime] = None,
300+
pinned_at_before: Optional[datetime] = None,
301+
id_around: Optional[str] = None,
302+
pinned_at_around: Optional[datetime] = None,
303+
user_id: Optional[str] = None,
304+
sort: Optional[List[SortParamRequest]] = None,
305+
member_custom_include: Optional[List[str]] = None,
306+
) -> StreamResponse[GetPinnedMessagesResponse]:
307+
response = await self.client.get_pinned_messages(
308+
type=self.channel_type,
309+
id=self.channel_id,
310+
limit=limit,
311+
offset=offset,
312+
id_gte=id_gte,
313+
id_gt=id_gt,
314+
id_lte=id_lte,
315+
id_lt=id_lt,
316+
pinned_at_after_or_equal=pinned_at_after_or_equal,
317+
pinned_at_after=pinned_at_after,
318+
pinned_at_before_or_equal=pinned_at_before_or_equal,
319+
pinned_at_before=pinned_at_before,
320+
id_around=id_around,
321+
pinned_at_around=pinned_at_around,
322+
user_id=user_id,
323+
sort=sort,
324+
member_custom_include=member_custom_include,
325+
)
326+
self._sync_from_response(response.data)
327+
return response
328+
288329
@attach_channel_cid_async
289330
async def get_or_create(
290331
self,

0 commit comments

Comments
 (0)