Skip to content

Commit afacfe8

Browse files
mogitamogita
committed
feat: regenerate from chat v235.17.1
Adds the moderation policy test endpoints, the video daily digest endpoint, message-ID paging on get channel, CSV channel export, and the model fields that came with them.
1 parent b5499a8 commit afacfe8

14 files changed

Lines changed: 2006 additions & 77 deletions

‎getstream/chat/async_channel.py‎

Lines changed: 23 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,12 @@ async def get(
3838
messages_limit: Optional[int] = None,
3939
members_limit: Optional[int] = None,
4040
watchers_limit: Optional[int] = None,
41+
messages_id_lt: Optional[str] = None,
42+
messages_id_lte: Optional[str] = None,
43+
messages_id_gt: Optional[str] = None,
44+
messages_id_gte: Optional[str] = None,
45+
messages_id_around: Optional[str] = None,
46+
user_id: Optional[str] = None,
4147
) -> StreamResponse[ChannelStateResponse]:
4248
response = await self.client.get_channel(
4349
type=self.channel_type,
@@ -46,6 +52,12 @@ async def get(
4652
messages_limit=messages_limit,
4753
members_limit=members_limit,
4854
watchers_limit=watchers_limit,
55+
messages_id_lt=messages_id_lt,
56+
messages_id_lte=messages_id_lte,
57+
messages_id_gt=messages_id_gt,
58+
messages_id_gte=messages_id_gte,
59+
messages_id_around=messages_id_around,
60+
user_id=user_id,
4961
)
5062
self._sync_from_response(response.data)
5163
return response
@@ -236,6 +248,8 @@ async def send_message(
236248
self,
237249
message: MessageRequest,
238250
force_moderation: Optional[bool] = None,
251+
include_channel_context: Optional[bool] = None,
252+
include_mentioned_members: Optional[bool] = None,
239253
keep_channel_hidden: Optional[bool] = None,
240254
pending: Optional[bool] = None,
241255
skip_enrich_url: Optional[bool] = None,
@@ -247,6 +261,8 @@ async def send_message(
247261
id=self.channel_id,
248262
message=message,
249263
force_moderation=force_moderation,
264+
include_channel_context=include_channel_context,
265+
include_mentioned_members=include_mentioned_members,
250266
keep_channel_hidden=keep_channel_hidden,
251267
pending=pending,
252268
skip_enrich_url=skip_enrich_url,
@@ -258,10 +274,13 @@ async def send_message(
258274

259275
@attach_channel_cid_async
260276
async def get_many_messages(
261-
self, ids: List[str]
277+
self, ids: List[str], member_custom_include: Optional[List[str]] = None
262278
) -> StreamResponse[GetManyMessagesResponse]:
263279
response = await self.client.get_many_messages(
264-
type=self.channel_type, id=self.channel_id, ids=ids
280+
type=self.channel_type,
281+
id=self.channel_id,
282+
ids=ids,
283+
member_custom_include=member_custom_include,
265284
)
266285
self._sync_from_response(response.data)
267286
return response
@@ -272,6 +291,7 @@ async def get_or_create(
272291
hide_for_creator: Optional[bool] = None,
273292
state: Optional[bool] = None,
274293
thread_unread_counts: Optional[bool] = None,
294+
member_custom_include: Optional[List[str]] = None,
275295
data: Optional[ChannelInput] = None,
276296
members: Optional[PaginationParams] = None,
277297
messages: Optional[MessagePaginationParams] = None,
@@ -283,6 +303,7 @@ async def get_or_create(
283303
hide_for_creator=hide_for_creator,
284304
state=state,
285305
thread_unread_counts=thread_unread_counts,
306+
member_custom_include=member_custom_include,
286307
data=data,
287308
members=members,
288309
messages=messages,

‎getstream/chat/async_rest_client.py‎

Lines changed: 36 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -212,6 +212,7 @@ async def query_channels(
212212
predefined_filter: Optional[str] = None,
213213
state: Optional[bool] = None,
214214
user_id: Optional[str] = None,
215+
member_custom_include: Optional[List[str]] = None,
215216
sort: Optional[List[SortParamRequest]] = None,
216217
filter_conditions: Optional[Dict[str, object]] = None,
217218
filter_values: Optional[Dict[str, object]] = None,
@@ -226,6 +227,7 @@ async def query_channels(
226227
predefined_filter=predefined_filter,
227228
state=state,
228229
user_id=user_id,
230+
member_custom_include=member_custom_include,
229231
sort=sort,
230232
filter_conditions=filter_conditions,
231233
filter_values=filter_values,
@@ -313,6 +315,7 @@ async def get_or_create_distinct_channel(
313315
hide_for_creator: Optional[bool] = None,
314316
state: Optional[bool] = None,
315317
thread_unread_counts: Optional[bool] = None,
318+
member_custom_include: Optional[List[str]] = None,
316319
data: Optional[ChannelInput] = None,
317320
members: Optional[PaginationParams] = None,
318321
messages: Optional[MessagePaginationParams] = None,
@@ -325,6 +328,7 @@ async def get_or_create_distinct_channel(
325328
hide_for_creator=hide_for_creator,
326329
state=state,
327330
thread_unread_counts=thread_unread_counts,
331+
member_custom_include=member_custom_include,
328332
data=data,
329333
members=members,
330334
messages=messages,
@@ -362,13 +366,25 @@ async def get_channel(
362366
messages_limit: Optional[int] = None,
363367
members_limit: Optional[int] = None,
364368
watchers_limit: Optional[int] = None,
369+
messages_id_lt: Optional[str] = None,
370+
messages_id_lte: Optional[str] = None,
371+
messages_id_gt: Optional[str] = None,
372+
messages_id_gte: Optional[str] = None,
373+
messages_id_around: Optional[str] = None,
374+
user_id: Optional[str] = None,
365375
) -> StreamResponse[ChannelStateResponse]:
366376
query_params = build_query_param(
367377
**{
368378
"state": state,
369379
"messages_limit": messages_limit,
370380
"members_limit": members_limit,
371381
"watchers_limit": watchers_limit,
382+
"messages_id_lt": messages_id_lt,
383+
"messages_id_lte": messages_id_lte,
384+
"messages_id_gt": messages_id_gt,
385+
"messages_id_gte": messages_id_gte,
386+
"messages_id_around": messages_id_around,
387+
"user_id": user_id,
372388
}
373389
)
374390
path_params = {
@@ -645,6 +661,8 @@ async def send_message(
645661
id: str,
646662
message: MessageRequest,
647663
force_moderation: Optional[bool] = None,
664+
include_channel_context: Optional[bool] = None,
665+
include_mentioned_members: Optional[bool] = None,
648666
keep_channel_hidden: Optional[bool] = None,
649667
pending: Optional[bool] = None,
650668
skip_enrich_url: Optional[bool] = None,
@@ -658,6 +676,8 @@ async def send_message(
658676
json = SendMessageRequest(
659677
message=message,
660678
force_moderation=force_moderation,
679+
include_channel_context=include_channel_context,
680+
include_mentioned_members=include_mentioned_members,
661681
keep_channel_hidden=keep_channel_hidden,
662682
pending=pending,
663683
skip_enrich_url=skip_enrich_url,
@@ -673,9 +693,15 @@ async def send_message(
673693

674694
@telemetry.operation_name("getstream.api.chat.get_many_messages")
675695
async def get_many_messages(
676-
self, type: str, id: str, ids: List[str]
696+
self,
697+
type: str,
698+
id: str,
699+
ids: List[str],
700+
member_custom_include: Optional[List[str]] = None,
677701
) -> StreamResponse[GetManyMessagesResponse]:
678-
query_params = build_query_param(**{"ids": ids})
702+
query_params = build_query_param(
703+
**{"ids": ids, "member_custom_include": member_custom_include}
704+
)
679705
path_params = {
680706
"type": type,
681707
"id": id,
@@ -695,6 +721,7 @@ async def get_or_create_channel(
695721
hide_for_creator: Optional[bool] = None,
696722
state: Optional[bool] = None,
697723
thread_unread_counts: Optional[bool] = None,
724+
member_custom_include: Optional[List[str]] = None,
698725
data: Optional[ChannelInput] = None,
699726
members: Optional[PaginationParams] = None,
700727
messages: Optional[MessagePaginationParams] = None,
@@ -708,6 +735,7 @@ async def get_or_create_channel(
708735
hide_for_creator=hide_for_creator,
709736
state=state,
710737
thread_unread_counts=thread_unread_counts,
738+
member_custom_include=member_custom_include,
711739
data=data,
712740
members=members,
713741
messages=messages,
@@ -1105,17 +1133,21 @@ async def export_channels(
11051133
channels: List[ChannelExport],
11061134
clear_deleted_message_text: Optional[bool] = None,
11071135
export_users: Optional[bool] = None,
1136+
format: Optional[str] = None,
11081137
include_soft_deleted_channels: Optional[bool] = None,
11091138
include_truncated_messages: Optional[bool] = None,
11101139
version: Optional[str] = None,
1140+
include_fields: Optional[List[str]] = None,
11111141
) -> StreamResponse[ExportChannelsResponse]:
11121142
json = ExportChannelsRequest(
11131143
channels=channels,
11141144
clear_deleted_message_text=clear_deleted_message_text,
11151145
export_users=export_users,
1146+
format=format,
11161147
include_soft_deleted_channels=include_soft_deleted_channels,
11171148
include_truncated_messages=include_truncated_messages,
11181149
version=version,
1150+
include_fields=include_fields,
11191151
).to_dict()
11201152
return await self.post(
11211153
"/api/v2/chat/export_channels", ExportChannelsResponse, json=json
@@ -1519,6 +1551,7 @@ async def get_replies(
15191551
id_lt: Optional[str] = None,
15201552
id_around: Optional[str] = None,
15211553
sort: Optional[List[SortParamRequest]] = None,
1554+
member_custom_include: Optional[List[str]] = None,
15221555
) -> StreamResponse[GetRepliesResponse]:
15231556
query_params = build_query_param(
15241557
**{
@@ -1529,6 +1562,7 @@ async def get_replies(
15291562
"id_lt": id_lt,
15301563
"id_around": id_around,
15311564
"sort": sort,
1565+
"member_custom_include": member_custom_include,
15321566
}
15331567
)
15341568
path_params = {

‎getstream/chat/channel.py‎

Lines changed: 23 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,12 @@ def get(
3838
messages_limit: Optional[int] = None,
3939
members_limit: Optional[int] = None,
4040
watchers_limit: Optional[int] = None,
41+
messages_id_lt: Optional[str] = None,
42+
messages_id_lte: Optional[str] = None,
43+
messages_id_gt: Optional[str] = None,
44+
messages_id_gte: Optional[str] = None,
45+
messages_id_around: Optional[str] = None,
46+
user_id: Optional[str] = None,
4147
) -> StreamResponse[ChannelStateResponse]:
4248
response = self.client.get_channel(
4349
type=self.channel_type,
@@ -46,6 +52,12 @@ def get(
4652
messages_limit=messages_limit,
4753
members_limit=members_limit,
4854
watchers_limit=watchers_limit,
55+
messages_id_lt=messages_id_lt,
56+
messages_id_lte=messages_id_lte,
57+
messages_id_gt=messages_id_gt,
58+
messages_id_gte=messages_id_gte,
59+
messages_id_around=messages_id_around,
60+
user_id=user_id,
4961
)
5062
self._sync_from_response(response.data)
5163
return response
@@ -236,6 +248,8 @@ def send_message(
236248
self,
237249
message: MessageRequest,
238250
force_moderation: Optional[bool] = None,
251+
include_channel_context: Optional[bool] = None,
252+
include_mentioned_members: Optional[bool] = None,
239253
keep_channel_hidden: Optional[bool] = None,
240254
pending: Optional[bool] = None,
241255
skip_enrich_url: Optional[bool] = None,
@@ -247,6 +261,8 @@ def send_message(
247261
id=self.channel_id,
248262
message=message,
249263
force_moderation=force_moderation,
264+
include_channel_context=include_channel_context,
265+
include_mentioned_members=include_mentioned_members,
250266
keep_channel_hidden=keep_channel_hidden,
251267
pending=pending,
252268
skip_enrich_url=skip_enrich_url,
@@ -258,10 +274,13 @@ def send_message(
258274

259275
@attach_channel_cid
260276
def get_many_messages(
261-
self, ids: List[str]
277+
self, ids: List[str], member_custom_include: Optional[List[str]] = None
262278
) -> StreamResponse[GetManyMessagesResponse]:
263279
response = self.client.get_many_messages(
264-
type=self.channel_type, id=self.channel_id, ids=ids
280+
type=self.channel_type,
281+
id=self.channel_id,
282+
ids=ids,
283+
member_custom_include=member_custom_include,
265284
)
266285
self._sync_from_response(response.data)
267286
return response
@@ -272,6 +291,7 @@ def get_or_create(
272291
hide_for_creator: Optional[bool] = None,
273292
state: Optional[bool] = None,
274293
thread_unread_counts: Optional[bool] = None,
294+
member_custom_include: Optional[List[str]] = None,
275295
data: Optional[ChannelInput] = None,
276296
members: Optional[PaginationParams] = None,
277297
messages: Optional[MessagePaginationParams] = None,
@@ -283,6 +303,7 @@ def get_or_create(
283303
hide_for_creator=hide_for_creator,
284304
state=state,
285305
thread_unread_counts=thread_unread_counts,
306+
member_custom_include=member_custom_include,
286307
data=data,
287308
members=members,
288309
messages=messages,

0 commit comments

Comments
 (0)