Skip to content

Commit 00c97db

Browse files
tbarbuglitbarbugli
authored
fix message pagination type (#162)
1 parent a443e61 commit 00c97db

File tree

7 files changed

+435
-114
lines changed

7 files changed

+435
-114
lines changed

‎getstream/chat/async_rest_client.py‎

Lines changed: 2 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -645,6 +645,7 @@ async def create_channel_type(
645645
blocklist: Optional[str] = None,
646646
blocklist_behavior: Optional[str] = None,
647647
connect_events: Optional[bool] = None,
648+
count_messages: Optional[bool] = None,
648649
custom_events: Optional[bool] = None,
649650
mark_messages_pending: Optional[bool] = None,
650651
message_retention: Optional[str] = None,
@@ -676,6 +677,7 @@ async def create_channel_type(
676677
blocklist=blocklist,
677678
blocklist_behavior=blocklist_behavior,
678679
connect_events=connect_events,
680+
count_messages=count_messages,
679681
custom_events=custom_events,
680682
mark_messages_pending=mark_messages_pending,
681683
message_retention=message_retention,
@@ -1294,32 +1296,20 @@ async def get_replies(
12941296
self,
12951297
parent_id: str,
12961298
limit: Optional[int] = None,
1297-
offset: Optional[int] = None,
12981299
id_gte: Optional[str] = None,
12991300
id_gt: Optional[str] = None,
13001301
id_lte: Optional[str] = None,
13011302
id_lt: Optional[str] = None,
1302-
created_at_after_or_equal: Optional[datetime] = None,
1303-
created_at_after: Optional[datetime] = None,
1304-
created_at_before_or_equal: Optional[datetime] = None,
1305-
created_at_before: Optional[datetime] = None,
13061303
id_around: Optional[str] = None,
1307-
created_at_around: Optional[datetime] = None,
13081304
sort: Optional[List[SortParamRequest]] = None,
13091305
) -> StreamResponse[GetRepliesResponse]:
13101306
query_params = build_query_param(
13111307
limit=limit,
1312-
offset=offset,
13131308
id_gte=id_gte,
13141309
id_gt=id_gt,
13151310
id_lte=id_lte,
13161311
id_lt=id_lt,
1317-
created_at_after_or_equal=created_at_after_or_equal,
1318-
created_at_after=created_at_after,
1319-
created_at_before_or_equal=created_at_before_or_equal,
1320-
created_at_before=created_at_before,
13211312
id_around=id_around,
1322-
created_at_around=created_at_around,
13231313
sort=sort,
13241314
)
13251315
path_params = {

‎getstream/chat/rest_client.py‎

Lines changed: 2 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -641,6 +641,7 @@ def create_channel_type(
641641
blocklist: Optional[str] = None,
642642
blocklist_behavior: Optional[str] = None,
643643
connect_events: Optional[bool] = None,
644+
count_messages: Optional[bool] = None,
644645
custom_events: Optional[bool] = None,
645646
mark_messages_pending: Optional[bool] = None,
646647
message_retention: Optional[str] = None,
@@ -672,6 +673,7 @@ def create_channel_type(
672673
blocklist=blocklist,
673674
blocklist_behavior=blocklist_behavior,
674675
connect_events=connect_events,
676+
count_messages=count_messages,
675677
custom_events=custom_events,
676678
mark_messages_pending=mark_messages_pending,
677679
message_retention=message_retention,
@@ -1284,32 +1286,20 @@ def get_replies(
12841286
self,
12851287
parent_id: str,
12861288
limit: Optional[int] = None,
1287-
offset: Optional[int] = None,
12881289
id_gte: Optional[str] = None,
12891290
id_gt: Optional[str] = None,
12901291
id_lte: Optional[str] = None,
12911292
id_lt: Optional[str] = None,
1292-
created_at_after_or_equal: Optional[datetime] = None,
1293-
created_at_after: Optional[datetime] = None,
1294-
created_at_before_or_equal: Optional[datetime] = None,
1295-
created_at_before: Optional[datetime] = None,
12961293
id_around: Optional[str] = None,
1297-
created_at_around: Optional[datetime] = None,
12981294
sort: Optional[List[SortParamRequest]] = None,
12991295
) -> StreamResponse[GetRepliesResponse]:
13001296
query_params = build_query_param(
13011297
limit=limit,
1302-
offset=offset,
13031298
id_gte=id_gte,
13041299
id_gt=id_gt,
13051300
id_lte=id_lte,
13061301
id_lt=id_lt,
1307-
created_at_after_or_equal=created_at_after_or_equal,
1308-
created_at_after=created_at_after,
1309-
created_at_before_or_equal=created_at_before_or_equal,
1310-
created_at_before=created_at_before,
13111302
id_around=id_around,
1312-
created_at_around=created_at_around,
13131303
sort=sort,
13141304
)
13151305
path_params = {

‎getstream/common/async_rest_client.py‎

Lines changed: 22 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -153,10 +153,19 @@ async def create_block_list(
153153
self,
154154
name: str,
155155
words: List[str],
156+
is_leet_check_enabled: Optional[bool] = None,
157+
is_plural_check_enabled: Optional[bool] = None,
156158
team: Optional[str] = None,
157159
type: Optional[str] = None,
158160
) -> StreamResponse[CreateBlockListResponse]:
159-
json = build_body_dict(name=name, words=words, team=team, type=type)
161+
json = build_body_dict(
162+
name=name,
163+
words=words,
164+
is_leet_check_enabled=is_leet_check_enabled,
165+
is_plural_check_enabled=is_plural_check_enabled,
166+
team=team,
167+
type=type,
168+
)
160169
return await self.post("/api/v2/blocklists", CreateBlockListResponse, json=json)
161170

162171
@telemetry.operation_name("getstream.api.common.delete_block_list")
@@ -191,12 +200,22 @@ async def get_block_list(
191200

192201
@telemetry.operation_name("getstream.api.common.update_block_list")
193202
async def update_block_list(
194-
self, name: str, team: Optional[str] = None, words: Optional[List[str]] = None
203+
self,
204+
name: str,
205+
is_leet_check_enabled: Optional[bool] = None,
206+
is_plural_check_enabled: Optional[bool] = None,
207+
team: Optional[str] = None,
208+
words: Optional[List[str]] = None,
195209
) -> StreamResponse[UpdateBlockListResponse]:
196210
path_params = {
197211
"name": name,
198212
}
199-
json = build_body_dict(team=team, words=words)
213+
json = build_body_dict(
214+
is_leet_check_enabled=is_leet_check_enabled,
215+
is_plural_check_enabled=is_plural_check_enabled,
216+
team=team,
217+
words=words,
218+
)
200219
return await self.put(
201220
"/api/v2/blocklists/{name}",
202221
UpdateBlockListResponse,

‎getstream/common/rest_client.py‎

Lines changed: 22 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -153,10 +153,19 @@ def create_block_list(
153153
self,
154154
name: str,
155155
words: List[str],
156+
is_leet_check_enabled: Optional[bool] = None,
157+
is_plural_check_enabled: Optional[bool] = None,
156158
team: Optional[str] = None,
157159
type: Optional[str] = None,
158160
) -> StreamResponse[CreateBlockListResponse]:
159-
json = build_body_dict(name=name, words=words, team=team, type=type)
161+
json = build_body_dict(
162+
name=name,
163+
words=words,
164+
is_leet_check_enabled=is_leet_check_enabled,
165+
is_plural_check_enabled=is_plural_check_enabled,
166+
team=team,
167+
type=type,
168+
)
160169
return self.post("/api/v2/blocklists", CreateBlockListResponse, json=json)
161170

162171
@telemetry.operation_name("getstream.api.common.delete_block_list")
@@ -191,12 +200,22 @@ def get_block_list(
191200

192201
@telemetry.operation_name("getstream.api.common.update_block_list")
193202
def update_block_list(
194-
self, name: str, team: Optional[str] = None, words: Optional[List[str]] = None
203+
self,
204+
name: str,
205+
is_leet_check_enabled: Optional[bool] = None,
206+
is_plural_check_enabled: Optional[bool] = None,
207+
team: Optional[str] = None,
208+
words: Optional[List[str]] = None,
195209
) -> StreamResponse[UpdateBlockListResponse]:
196210
path_params = {
197211
"name": name,
198212
}
199-
json = build_body_dict(team=team, words=words)
213+
json = build_body_dict(
214+
is_leet_check_enabled=is_leet_check_enabled,
215+
is_plural_check_enabled=is_plural_check_enabled,
216+
team=team,
217+
words=words,
218+
)
200219
return self.put(
201220
"/api/v2/blocklists/{name}",
202221
UpdateBlockListResponse,

0 commit comments

Comments
 (0)