Skip to content

Commit 2cc7bd3

Browse files
rafaelmf3rafaelmf3
authored
Merge pull request #175 from GetStream/fix-unread-counts-api-spec
[CHA-0] fix unread counts api spec
2 parents 157568c + 44978c6 commit 2cc7bd3

File tree

12 files changed

+1453
-103
lines changed

12 files changed

+1453
-103
lines changed

‎getstream/chat/async_channel.py‎

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -56,14 +56,17 @@ async def update(
5656
accept_invite: Optional[bool] = None,
5757
cooldown: Optional[int] = None,
5858
hide_history: Optional[bool] = None,
59+
hide_history_before: Optional[datetime] = None,
5960
reject_invite: Optional[bool] = None,
6061
skip_push: Optional[bool] = None,
6162
user_id: Optional[str] = None,
62-
add_members: Optional[List[ChannelMember]] = None,
63+
add_filter_tags: Optional[List[str]] = None,
64+
add_members: Optional[List[ChannelMemberRequest]] = None,
6365
add_moderators: Optional[List[str]] = None,
64-
assign_roles: Optional[List[ChannelMember]] = None,
66+
assign_roles: Optional[List[ChannelMemberRequest]] = None,
6567
demote_moderators: Optional[List[str]] = None,
66-
invites: Optional[List[ChannelMember]] = None,
68+
invites: Optional[List[ChannelMemberRequest]] = None,
69+
remove_filter_tags: Optional[List[str]] = None,
6770
remove_members: Optional[List[str]] = None,
6871
data: Optional[ChannelInput] = None,
6972
message: Optional[MessageRequest] = None,
@@ -75,14 +78,17 @@ async def update(
7578
accept_invite=accept_invite,
7679
cooldown=cooldown,
7780
hide_history=hide_history,
81+
hide_history_before=hide_history_before,
7882
reject_invite=reject_invite,
7983
skip_push=skip_push,
8084
user_id=user_id,
85+
add_filter_tags=add_filter_tags,
8186
add_members=add_members,
8287
add_moderators=add_moderators,
8388
assign_roles=assign_roles,
8489
demote_moderators=demote_moderators,
8590
invites=invites,
91+
remove_filter_tags=remove_filter_tags,
8692
remove_members=remove_members,
8793
data=data,
8894
message=message,

‎getstream/chat/async_rest_client.py‎

Lines changed: 22 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -234,14 +234,17 @@ async def update_channel(
234234
accept_invite: Optional[bool] = None,
235235
cooldown: Optional[int] = None,
236236
hide_history: Optional[bool] = None,
237+
hide_history_before: Optional[datetime] = None,
237238
reject_invite: Optional[bool] = None,
238239
skip_push: Optional[bool] = None,
239240
user_id: Optional[str] = None,
240-
add_members: Optional[List[ChannelMember]] = None,
241+
add_filter_tags: Optional[List[str]] = None,
242+
add_members: Optional[List[ChannelMemberRequest]] = None,
241243
add_moderators: Optional[List[str]] = None,
242-
assign_roles: Optional[List[ChannelMember]] = None,
244+
assign_roles: Optional[List[ChannelMemberRequest]] = None,
243245
demote_moderators: Optional[List[str]] = None,
244-
invites: Optional[List[ChannelMember]] = None,
246+
invites: Optional[List[ChannelMemberRequest]] = None,
247+
remove_filter_tags: Optional[List[str]] = None,
245248
remove_members: Optional[List[str]] = None,
246249
data: Optional[ChannelInput] = None,
247250
message: Optional[MessageRequest] = None,
@@ -255,14 +258,17 @@ async def update_channel(
255258
accept_invite=accept_invite,
256259
cooldown=cooldown,
257260
hide_history=hide_history,
261+
hide_history_before=hide_history_before,
258262
reject_invite=reject_invite,
259263
skip_push=skip_push,
260264
user_id=user_id,
265+
add_filter_tags=add_filter_tags,
261266
add_members=add_members,
262267
add_moderators=add_moderators,
263268
assign_roles=assign_roles,
264269
demote_moderators=demote_moderators,
265270
invites=invites,
271+
remove_filter_tags=remove_filter_tags,
266272
remove_members=remove_members,
267273
data=data,
268274
message=message,
@@ -647,6 +653,7 @@ async def create_channel_type(
647653
connect_events: Optional[bool] = None,
648654
count_messages: Optional[bool] = None,
649655
custom_events: Optional[bool] = None,
656+
delivery_events: Optional[bool] = None,
650657
mark_messages_pending: Optional[bool] = None,
651658
message_retention: Optional[str] = None,
652659
mutes: Optional[bool] = None,
@@ -679,6 +686,7 @@ async def create_channel_type(
679686
connect_events=connect_events,
680687
count_messages=count_messages,
681688
custom_events=custom_events,
689+
delivery_events=delivery_events,
682690
mark_messages_pending=mark_messages_pending,
683691
message_retention=message_retention,
684692
mutes=mutes,
@@ -739,6 +747,7 @@ async def update_channel_type(
739747
connect_events: Optional[bool] = None,
740748
count_messages: Optional[bool] = None,
741749
custom_events: Optional[bool] = None,
750+
delivery_events: Optional[bool] = None,
742751
mark_messages_pending: Optional[bool] = None,
743752
mutes: Optional[bool] = None,
744753
partition_size: Optional[int] = None,
@@ -776,6 +785,7 @@ async def update_channel_type(
776785
connect_events=connect_events,
777786
count_messages=count_messages,
778787
custom_events=custom_events,
788+
delivery_events=delivery_events,
779789
mark_messages_pending=mark_messages_pending,
780790
mutes=mutes,
781791
partition_size=partition_size,
@@ -1565,8 +1575,15 @@ async def update_thread_partial(
15651575
)
15661576

15671577
@telemetry.operation_name("getstream.api.chat.unread_counts")
1568-
async def unread_counts(self) -> StreamResponse[WrappedUnreadCountsResponse]:
1569-
return await self.get("/api/v2/chat/unread", WrappedUnreadCountsResponse)
1578+
async def unread_counts(
1579+
self, user_id: Optional[str] = None
1580+
) -> StreamResponse[WrappedUnreadCountsResponse]:
1581+
query_params = build_query_param(user_id=user_id)
1582+
return await self.get(
1583+
"/api/v2/chat/unread",
1584+
WrappedUnreadCountsResponse,
1585+
query_params=query_params,
1586+
)
15701587

15711588
@telemetry.operation_name("getstream.api.chat.unread_counts_batch")
15721589
async def unread_counts_batch(

‎getstream/chat/channel.py‎

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -56,14 +56,17 @@ def update(
5656
accept_invite: Optional[bool] = None,
5757
cooldown: Optional[int] = None,
5858
hide_history: Optional[bool] = None,
59+
hide_history_before: Optional[datetime] = None,
5960
reject_invite: Optional[bool] = None,
6061
skip_push: Optional[bool] = None,
6162
user_id: Optional[str] = None,
62-
add_members: Optional[List[ChannelMember]] = None,
63+
add_filter_tags: Optional[List[str]] = None,
64+
add_members: Optional[List[ChannelMemberRequest]] = None,
6365
add_moderators: Optional[List[str]] = None,
64-
assign_roles: Optional[List[ChannelMember]] = None,
66+
assign_roles: Optional[List[ChannelMemberRequest]] = None,
6567
demote_moderators: Optional[List[str]] = None,
66-
invites: Optional[List[ChannelMember]] = None,
68+
invites: Optional[List[ChannelMemberRequest]] = None,
69+
remove_filter_tags: Optional[List[str]] = None,
6770
remove_members: Optional[List[str]] = None,
6871
data: Optional[ChannelInput] = None,
6972
message: Optional[MessageRequest] = None,
@@ -75,14 +78,17 @@ def update(
7578
accept_invite=accept_invite,
7679
cooldown=cooldown,
7780
hide_history=hide_history,
81+
hide_history_before=hide_history_before,
7882
reject_invite=reject_invite,
7983
skip_push=skip_push,
8084
user_id=user_id,
85+
add_filter_tags=add_filter_tags,
8186
add_members=add_members,
8287
add_moderators=add_moderators,
8388
assign_roles=assign_roles,
8489
demote_moderators=demote_moderators,
8590
invites=invites,
91+
remove_filter_tags=remove_filter_tags,
8692
remove_members=remove_members,
8793
data=data,
8894
message=message,

‎getstream/chat/rest_client.py‎

Lines changed: 22 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -230,14 +230,17 @@ def update_channel(
230230
accept_invite: Optional[bool] = None,
231231
cooldown: Optional[int] = None,
232232
hide_history: Optional[bool] = None,
233+
hide_history_before: Optional[datetime] = None,
233234
reject_invite: Optional[bool] = None,
234235
skip_push: Optional[bool] = None,
235236
user_id: Optional[str] = None,
236-
add_members: Optional[List[ChannelMember]] = None,
237+
add_filter_tags: Optional[List[str]] = None,
238+
add_members: Optional[List[ChannelMemberRequest]] = None,
237239
add_moderators: Optional[List[str]] = None,
238-
assign_roles: Optional[List[ChannelMember]] = None,
240+
assign_roles: Optional[List[ChannelMemberRequest]] = None,
239241
demote_moderators: Optional[List[str]] = None,
240-
invites: Optional[List[ChannelMember]] = None,
242+
invites: Optional[List[ChannelMemberRequest]] = None,
243+
remove_filter_tags: Optional[List[str]] = None,
241244
remove_members: Optional[List[str]] = None,
242245
data: Optional[ChannelInput] = None,
243246
message: Optional[MessageRequest] = None,
@@ -251,14 +254,17 @@ def update_channel(
251254
accept_invite=accept_invite,
252255
cooldown=cooldown,
253256
hide_history=hide_history,
257+
hide_history_before=hide_history_before,
254258
reject_invite=reject_invite,
255259
skip_push=skip_push,
256260
user_id=user_id,
261+
add_filter_tags=add_filter_tags,
257262
add_members=add_members,
258263
add_moderators=add_moderators,
259264
assign_roles=assign_roles,
260265
demote_moderators=demote_moderators,
261266
invites=invites,
267+
remove_filter_tags=remove_filter_tags,
262268
remove_members=remove_members,
263269
data=data,
264270
message=message,
@@ -643,6 +649,7 @@ def create_channel_type(
643649
connect_events: Optional[bool] = None,
644650
count_messages: Optional[bool] = None,
645651
custom_events: Optional[bool] = None,
652+
delivery_events: Optional[bool] = None,
646653
mark_messages_pending: Optional[bool] = None,
647654
message_retention: Optional[str] = None,
648655
mutes: Optional[bool] = None,
@@ -675,6 +682,7 @@ def create_channel_type(
675682
connect_events=connect_events,
676683
count_messages=count_messages,
677684
custom_events=custom_events,
685+
delivery_events=delivery_events,
678686
mark_messages_pending=mark_messages_pending,
679687
message_retention=message_retention,
680688
mutes=mutes,
@@ -733,6 +741,7 @@ def update_channel_type(
733741
connect_events: Optional[bool] = None,
734742
count_messages: Optional[bool] = None,
735743
custom_events: Optional[bool] = None,
744+
delivery_events: Optional[bool] = None,
736745
mark_messages_pending: Optional[bool] = None,
737746
mutes: Optional[bool] = None,
738747
partition_size: Optional[int] = None,
@@ -770,6 +779,7 @@ def update_channel_type(
770779
connect_events=connect_events,
771780
count_messages=count_messages,
772781
custom_events=custom_events,
782+
delivery_events=delivery_events,
773783
mark_messages_pending=mark_messages_pending,
774784
mutes=mutes,
775785
partition_size=partition_size,
@@ -1555,8 +1565,15 @@ def update_thread_partial(
15551565
)
15561566

15571567
@telemetry.operation_name("getstream.api.chat.unread_counts")
1558-
def unread_counts(self) -> StreamResponse[WrappedUnreadCountsResponse]:
1559-
return self.get("/api/v2/chat/unread", WrappedUnreadCountsResponse)
1568+
def unread_counts(
1569+
self, user_id: Optional[str] = None
1570+
) -> StreamResponse[WrappedUnreadCountsResponse]:
1571+
query_params = build_query_param(user_id=user_id)
1572+
return self.get(
1573+
"/api/v2/chat/unread",
1574+
WrappedUnreadCountsResponse,
1575+
query_params=query_params,
1576+
)
15601577

15611578
@telemetry.operation_name("getstream.api.chat.unread_counts_batch")
15621579
def unread_counts_batch(

0 commit comments

Comments
 (0)