Skip to content

Commit f9779b3

Browse files
mogitamogita
committed
refactor: code generated from refactored openapi specs
1 parent 30dc844 commit f9779b3

File tree

11 files changed

+2508
-1509
lines changed

11 files changed

+2508
-1509
lines changed

‎getstream/chat/async_channel.py‎

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ async def update(
6868
invites: Optional[List[ChannelMemberRequest]] = None,
6969
remove_filter_tags: Optional[List[str]] = None,
7070
remove_members: Optional[List[str]] = None,
71-
data: Optional[ChannelInput] = None,
71+
data: Optional[ChannelInputRequest] = None,
7272
message: Optional[MessageRequest] = None,
7373
user: Optional[UserRequest] = None,
7474
) -> StreamResponse[UpdateChannelResponse]:
@@ -330,6 +330,7 @@ async def truncate(
330330
async def mark_unread(
331331
self,
332332
message_id: Optional[str] = None,
333+
message_timestamp: Optional[datetime] = None,
333334
thread_id: Optional[str] = None,
334335
user_id: Optional[str] = None,
335336
user: Optional[UserRequest] = None,
@@ -338,6 +339,7 @@ async def mark_unread(
338339
type=self.channel_type,
339340
id=self.channel_id,
340341
message_id=message_id,
342+
message_timestamp=message_timestamp,
341343
thread_id=thread_id,
342344
user_id=user_id,
343345
user=user,

‎getstream/chat/async_rest_client.py‎

Lines changed: 22 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -143,6 +143,21 @@ async def delete_channels(
143143
"/api/v2/chat/channels/delete", DeleteChannelsResponse, json=json
144144
)
145145

146+
@telemetry.operation_name("getstream.api.chat.mark_delivered")
147+
async def mark_delivered(
148+
self,
149+
user_id: Optional[str] = None,
150+
latest_delivered_messages: Optional[List[DeliveredMessagePayload]] = None,
151+
) -> StreamResponse[MarkDeliveredResponse]:
152+
query_params = build_query_param(user_id=user_id)
153+
json = build_body_dict(latest_delivered_messages=latest_delivered_messages)
154+
return await self.post(
155+
"/api/v2/chat/channels/delivered",
156+
MarkDeliveredResponse,
157+
query_params=query_params,
158+
json=json,
159+
)
160+
146161
@telemetry.operation_name("getstream.api.chat.mark_channels_read")
147162
async def mark_channels_read(
148163
self,
@@ -246,7 +261,7 @@ async def update_channel(
246261
invites: Optional[List[ChannelMemberRequest]] = None,
247262
remove_filter_tags: Optional[List[str]] = None,
248263
remove_members: Optional[List[str]] = None,
249-
data: Optional[ChannelInput] = None,
264+
data: Optional[ChannelInputRequest] = None,
250265
message: Optional[MessageRequest] = None,
251266
user: Optional[UserRequest] = None,
252267
) -> StreamResponse[UpdateChannelResponse]:
@@ -619,6 +634,7 @@ async def mark_unread(
619634
type: str,
620635
id: str,
621636
message_id: Optional[str] = None,
637+
message_timestamp: Optional[datetime] = None,
622638
thread_id: Optional[str] = None,
623639
user_id: Optional[str] = None,
624640
user: Optional[UserRequest] = None,
@@ -628,7 +644,11 @@ async def mark_unread(
628644
"id": id,
629645
}
630646
json = build_body_dict(
631-
message_id=message_id, thread_id=thread_id, user_id=user_id, user=user
647+
message_id=message_id,
648+
message_timestamp=message_timestamp,
649+
thread_id=thread_id,
650+
user_id=user_id,
651+
user=user,
632652
)
633653
return await self.post(
634654
"/api/v2/chat/channels/{type}/{id}/unread",

‎getstream/chat/channel.py‎

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ def update(
6868
invites: Optional[List[ChannelMemberRequest]] = None,
6969
remove_filter_tags: Optional[List[str]] = None,
7070
remove_members: Optional[List[str]] = None,
71-
data: Optional[ChannelInput] = None,
71+
data: Optional[ChannelInputRequest] = None,
7272
message: Optional[MessageRequest] = None,
7373
user: Optional[UserRequest] = None,
7474
) -> StreamResponse[UpdateChannelResponse]:
@@ -330,6 +330,7 @@ def truncate(
330330
def mark_unread(
331331
self,
332332
message_id: Optional[str] = None,
333+
message_timestamp: Optional[datetime] = None,
333334
thread_id: Optional[str] = None,
334335
user_id: Optional[str] = None,
335336
user: Optional[UserRequest] = None,
@@ -338,6 +339,7 @@ def mark_unread(
338339
type=self.channel_type,
339340
id=self.channel_id,
340341
message_id=message_id,
342+
message_timestamp=message_timestamp,
341343
thread_id=thread_id,
342344
user_id=user_id,
343345
user=user,

‎getstream/chat/rest_client.py‎

Lines changed: 22 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -141,6 +141,21 @@ def delete_channels(
141141
"/api/v2/chat/channels/delete", DeleteChannelsResponse, json=json
142142
)
143143

144+
@telemetry.operation_name("getstream.api.chat.mark_delivered")
145+
def mark_delivered(
146+
self,
147+
user_id: Optional[str] = None,
148+
latest_delivered_messages: Optional[List[DeliveredMessagePayload]] = None,
149+
) -> StreamResponse[MarkDeliveredResponse]:
150+
query_params = build_query_param(user_id=user_id)
151+
json = build_body_dict(latest_delivered_messages=latest_delivered_messages)
152+
return self.post(
153+
"/api/v2/chat/channels/delivered",
154+
MarkDeliveredResponse,
155+
query_params=query_params,
156+
json=json,
157+
)
158+
144159
@telemetry.operation_name("getstream.api.chat.mark_channels_read")
145160
def mark_channels_read(
146161
self,
@@ -242,7 +257,7 @@ def update_channel(
242257
invites: Optional[List[ChannelMemberRequest]] = None,
243258
remove_filter_tags: Optional[List[str]] = None,
244259
remove_members: Optional[List[str]] = None,
245-
data: Optional[ChannelInput] = None,
260+
data: Optional[ChannelInputRequest] = None,
246261
message: Optional[MessageRequest] = None,
247262
user: Optional[UserRequest] = None,
248263
) -> StreamResponse[UpdateChannelResponse]:
@@ -615,6 +630,7 @@ def mark_unread(
615630
type: str,
616631
id: str,
617632
message_id: Optional[str] = None,
633+
message_timestamp: Optional[datetime] = None,
618634
thread_id: Optional[str] = None,
619635
user_id: Optional[str] = None,
620636
user: Optional[UserRequest] = None,
@@ -624,7 +640,11 @@ def mark_unread(
624640
"id": id,
625641
}
626642
json = build_body_dict(
627-
message_id=message_id, thread_id=thread_id, user_id=user_id, user=user
643+
message_id=message_id,
644+
message_timestamp=message_timestamp,
645+
thread_id=thread_id,
646+
user_id=user_id,
647+
user=user,
628648
)
629649
return self.post(
630650
"/api/v2/chat/channels/{type}/{id}/unread",

‎getstream/feeds/feeds.py‎

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,14 +25,15 @@ def delete(
2525

2626
def get_or_create(
2727
self,
28+
id_around: Optional[str] = None,
2829
limit: Optional[int] = None,
2930
next: Optional[str] = None,
3031
prev: Optional[str] = None,
3132
user_id: Optional[str] = None,
3233
view: Optional[str] = None,
3334
watch: Optional[bool] = None,
34-
activity_selector_options: Optional[Dict[str, object]] = None,
3535
data: Optional[FeedInput] = None,
36+
enrichment_options: Optional[EnrichmentOptions] = None,
3637
external_ranking: Optional[Dict[str, object]] = None,
3738
filter: Optional[Dict[str, object]] = None,
3839
followers_pagination: Optional[PagerRequest] = None,
@@ -44,14 +45,15 @@ def get_or_create(
4445
response = self.client.get_or_create_feed(
4546
feed_group_id=self.feed_group,
4647
feed_id=self.id,
48+
id_around=id_around,
4749
limit=limit,
4850
next=next,
4951
prev=prev,
5052
user_id=user_id,
5153
view=view,
5254
watch=watch,
53-
activity_selector_options=activity_selector_options,
5455
data=data,
56+
enrichment_options=enrichment_options,
5557
external_ranking=external_ranking,
5658
filter=filter,
5759
followers_pagination=followers_pagination,

0 commit comments

Comments
 (0)