Skip to content

feat: regenerate client from latest OpenAPI spec #294

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
Acconut wants to merge 1 commit into from
Closed

feat: regenerate client from latest OpenAPI spec #294

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
130 changes: 72 additions & 58 deletions getstream/chat/async_rest_client.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -110,7 +110,7 @@ async def get_campaign(
next: Optional[str] = None,
limit: Optional[int] = None,
) -> StreamResponse[GetCampaignResponse]:
query_params = build_query_param(prev=prev, next=next, limit=limit)
query_params = build_query_param(**{"prev": prev, "next": next, "limit": limit})
path_params = {
"id": id,
}
Expand Down Expand Up @@ -244,6 +244,7 @@ async def channel_batch_update(
operation: str,
filter: Dict[str, object],
hide_history_before: Optional[datetime] = None,
synchronous: Optional[bool] = None,
custom_unset: Optional[List[str]] = None,
members: Optional[List[ChannelBatchMemberRequest]] = None,
custom_set: Optional[Dict[str, object]] = None,
Expand All @@ -253,6 +254,7 @@ async def channel_batch_update(
operation=operation,
filter=filter,
hide_history_before=hide_history_before,
synchronous=synchronous,
custom_unset=custom_unset,
members=members,
custom_set=custom_set,
Expand Down Expand Up @@ -282,7 +284,7 @@ async def mark_delivered(
user_id: Optional[str] = None,
latest_delivered_messages: Optional[List[DeliveredMessagePayload]] = None,
) -> StreamResponse[MarkDeliveredResponse]:
query_params = build_query_param(user_id=user_id)
query_params = build_query_param(**{"user_id": user_id})
json = MarkDeliveredRequest(
latest_delivered_messages=latest_delivered_messages
).to_dict()
Expand Down Expand Up @@ -364,7 +366,7 @@ async def delete_channel(
skip_truncate: Optional[bool] = None,
) -> StreamResponse[DeleteChannelResponse]:
query_params = build_query_param(
hard_delete=hard_delete, skip_truncate=skip_truncate
**{"hard_delete": hard_delete, "skip_truncate": skip_truncate}
)
path_params = {
"type": type,
Expand Down Expand Up @@ -394,16 +396,18 @@ async def get_channel(
user_id: Optional[str] = None,
) -> StreamResponse[ChannelStateResponse]:
query_params = build_query_param(
state=state,
messages_limit=messages_limit,
members_limit=members_limit,
watchers_limit=watchers_limit,
messages_id_lt=messages_id_lt,
messages_id_lte=messages_id_lte,
messages_id_gt=messages_id_gt,
messages_id_gte=messages_id_gte,
messages_id_around=messages_id_around,
user_id=user_id,
**{
"state": state,
"messages_limit": messages_limit,
"members_limit": members_limit,
"watchers_limit": watchers_limit,
"messages_id_lt": messages_id_lt,
"messages_id_lte": messages_id_lte,
"messages_id_gt": messages_id_gt,
"messages_id_gte": messages_id_gte,
"messages_id_around": messages_id_around,
"user_id": user_id,
}
)
path_params = {
"type": type,
Expand Down Expand Up @@ -503,7 +507,7 @@ async def delete_draft(
parent_id: Optional[str] = None,
user_id: Optional[str] = None,
) -> StreamResponse[Response]:
query_params = build_query_param(parent_id=parent_id, user_id=user_id)
query_params = build_query_param(**{"parent_id": parent_id, "user_id": user_id})
path_params = {
"type": type,
"id": id,
Expand All @@ -523,7 +527,7 @@ async def get_draft(
parent_id: Optional[str] = None,
user_id: Optional[str] = None,
) -> StreamResponse[GetDraftResponse]:
query_params = build_query_param(parent_id=parent_id, user_id=user_id)
query_params = build_query_param(**{"parent_id": parent_id, "user_id": user_id})
path_params = {
"type": type,
"id": id,
Expand Down Expand Up @@ -555,7 +559,7 @@ async def send_event(
async def delete_channel_file(
self, type: str, id: str, url: Optional[str] = None
) -> StreamResponse[Response]:
query_params = build_query_param(url=url)
query_params = build_query_param(**{"url": url})
path_params = {
"type": type,
"id": id,
Expand Down Expand Up @@ -614,7 +618,7 @@ async def hide_channel(
async def delete_channel_image(
self, type: str, id: str, url: Optional[str] = None
) -> StreamResponse[Response]:
query_params = build_query_param(url=url)
query_params = build_query_param(**{"url": url})
path_params = {
"type": type,
"id": id,
Expand Down Expand Up @@ -658,7 +662,7 @@ async def update_member_partial(
unset: Optional[List[str]] = None,
set: Optional[Dict[str, object]] = None,
) -> StreamResponse[UpdateMemberPartialResponse]:
query_params = build_query_param(user_id=user_id)
query_params = build_query_param(**{"user_id": user_id})
path_params = {
"type": type,
"id": id,
Expand Down Expand Up @@ -718,7 +722,7 @@ async def get_many_messages(
member_custom_include: Optional[List[str]] = None,
) -> StreamResponse[GetManyMessagesResponse]:
query_params = build_query_param(
ids=ids, member_custom_include=member_custom_include
**{"ids": ids, "member_custom_include": member_custom_include}
)
path_params = {
"type": type,
Expand Down Expand Up @@ -753,21 +757,23 @@ async def get_pinned_messages(
member_custom_include: Optional[List[str]] = None,
) -> StreamResponse[GetPinnedMessagesResponse]:
query_params = build_query_param(
limit=limit,
offset=offset,
id_gte=id_gte,
id_gt=id_gt,
id_lte=id_lte,
id_lt=id_lt,
pinned_at_after_or_equal=pinned_at_after_or_equal,
pinned_at_after=pinned_at_after,
pinned_at_before_or_equal=pinned_at_before_or_equal,
pinned_at_before=pinned_at_before,
id_around=id_around,
pinned_at_around=pinned_at_around,
user_id=user_id,
sort=sort,
member_custom_include=member_custom_include,
**{
"limit": limit,
"offset": offset,
"id_gte": id_gte,
"id_gt": id_gt,
"id_lte": id_lte,
"id_lt": id_lt,
"pinned_at_after_or_equal": pinned_at_after_or_equal,
"pinned_at_after": pinned_at_after,
"pinned_at_before_or_equal": pinned_at_before_or_equal,
"pinned_at_before": pinned_at_before,
"id_around": id_around,
"pinned_at_around": pinned_at_around,
"user_id": user_id,
"sort": sort,
"member_custom_include": member_custom_include,
}
)
path_params = {
"type": type,
Expand Down Expand Up @@ -1226,7 +1232,7 @@ async def export_channels(
async def query_members(
self, payload: Optional[QueryMembersPayload] = None
) -> StreamResponse[MembersResponse]:
query_params = build_query_param(payload=payload)
query_params = build_query_param(**{"payload": payload})
return await self.get(
"/api/v2/chat/members", MembersResponse, query_params=query_params
)
Expand Down Expand Up @@ -1256,7 +1262,7 @@ async def delete_message(
delete_for_me: Optional[bool] = None,
) -> StreamResponse[DeleteMessageResponse]:
query_params = build_query_param(
hard=hard, deleted_by=deleted_by, delete_for_me=delete_for_me
**{"hard": hard, "deleted_by": deleted_by, "delete_for_me": delete_for_me}
)
path_params = {
"id": id,
Expand All @@ -1272,7 +1278,9 @@ async def delete_message(
async def get_message(
self, id: str, show_deleted_message: Optional[bool] = None
) -> StreamResponse[GetMessageResponse]:
query_params = build_query_param(show_deleted_message=show_deleted_message)
query_params = build_query_param(
**{"show_deleted_message": show_deleted_message}
)
path_params = {
"id": id,
}
Expand Down Expand Up @@ -1424,7 +1432,7 @@ async def send_reaction(
async def delete_reaction(
self, id: str, type: str, user_id: Optional[str] = None
) -> StreamResponse[DeleteReactionResponse]:
query_params = build_query_param(user_id=user_id)
query_params = build_query_param(**{"user_id": user_id})
path_params = {
"id": id,
"type": type,
Expand All @@ -1440,7 +1448,7 @@ async def delete_reaction(
async def get_reactions(
self, id: str, limit: Optional[int] = None, offset: Optional[int] = None
) -> StreamResponse[GetReactionsResponse]:
query_params = build_query_param(limit=limit, offset=offset)
query_params = build_query_param(**{"limit": limit, "offset": offset})
path_params = {
"id": id,
}
Expand Down Expand Up @@ -1537,7 +1545,7 @@ async def cast_poll_vote(
async def delete_poll_vote(
self, message_id: str, poll_id: str, vote_id: str, user_id: Optional[str] = None
) -> StreamResponse[PollVoteResponse]:
query_params = build_query_param(user_id=user_id)
query_params = build_query_param(**{"user_id": user_id})
path_params = {
"message_id": message_id,
"poll_id": poll_id,
Expand All @@ -1554,7 +1562,7 @@ async def delete_poll_vote(
async def delete_reminder(
self, message_id: str, user_id: Optional[str] = None
) -> StreamResponse[DeleteReminderResponse]:
query_params = build_query_param(user_id=user_id)
query_params = build_query_param(**{"user_id": user_id})
path_params = {
"message_id": message_id,
}
Expand Down Expand Up @@ -1621,14 +1629,16 @@ async def get_replies(
member_custom_include: Optional[List[str]] = None,
) -> StreamResponse[GetRepliesResponse]:
query_params = build_query_param(
limit=limit,
id_gte=id_gte,
id_gt=id_gt,
id_lte=id_lte,
id_lt=id_lt,
id_around=id_around,
sort=sort,
member_custom_include=member_custom_include,
**{
"limit": limit,
"id_gte": id_gte,
"id_gt": id_gt,
"id_lte": id_lte,
"id_lt": id_lt,
"id_around": id_around,
"sort": sort,
"member_custom_include": member_custom_include,
}
)
path_params = {
"parent_id": parent_id,
Expand All @@ -1644,7 +1654,7 @@ async def get_replies(
async def query_message_flags(
self, payload: Optional[QueryMessageFlagsPayload] = None
) -> StreamResponse[QueryMessageFlagsResponse]:
query_params = build_query_param(payload=payload)
query_params = build_query_param(**{"payload": payload})
return await self.get(
"/api/v2/chat/moderation/flags/message",
QueryMessageFlagsResponse,
Expand Down Expand Up @@ -1687,7 +1697,9 @@ async def get_predefined_filters(
include_stats: Optional[bool] = None,
sort: Optional[List[SortParamRequest]] = None,
) -> StreamResponse[QueryPredefinedFiltersResponse]:
query_params = build_query_param(include_stats=include_stats, sort=sort)
query_params = build_query_param(
**{"include_stats": include_stats, "sort": sort}
)
return await self.get(
"/api/v2/chat/predefined_filters",
QueryPredefinedFiltersResponse,
Expand Down Expand Up @@ -1762,7 +1774,7 @@ async def update_predefined_filter(
async def query_banned_users(
self, payload: Optional[QueryBannedUsersPayload] = None
) -> StreamResponse[QueryBannedUsersResponse]:
query_params = build_query_param(payload=payload)
query_params = build_query_param(**{"payload": payload})
return await self.get(
"/api/v2/chat/query_banned_users",
QueryBannedUsersResponse,
Expand All @@ -1773,7 +1785,7 @@ async def query_banned_users(
async def query_future_channel_bans(
self, payload: Optional[QueryFutureChannelBansPayload] = None
) -> StreamResponse[QueryFutureChannelBansResponse]:
query_params = build_query_param(payload=payload)
query_params = build_query_param(**{"payload": payload})
return await self.get(
"/api/v2/chat/query_future_channel_bans",
QueryFutureChannelBansResponse,
Expand Down Expand Up @@ -1858,7 +1870,7 @@ async def get_retention_policy_runs(
async def search(
self, payload: Optional[SearchPayload] = None
) -> StreamResponse[SearchResponse]:
query_params = build_query_param(payload=payload)
query_params = build_query_param(**{"payload": payload})
return await self.get(
"/api/v2/chat/search", SearchResponse, query_params=query_params
)
Expand Down Expand Up @@ -2068,9 +2080,11 @@ async def get_thread(
member_limit: Optional[int] = None,
) -> StreamResponse[GetThreadResponse]:
query_params = build_query_param(
reply_limit=reply_limit,
participant_limit=participant_limit,
member_limit=member_limit,
**{
"reply_limit": reply_limit,
"participant_limit": participant_limit,
"member_limit": member_limit,
}
)
path_params = {
"message_id": message_id,
Expand Down Expand Up @@ -2108,7 +2122,7 @@ async def update_thread_partial(
async def unread_counts(
self, user_id: Optional[str] = None
) -> StreamResponse[WrappedUnreadCountsResponse]:
query_params = build_query_param(user_id=user_id)
query_params = build_query_param(**{"user_id": user_id})
return await self.get(
"/api/v2/chat/unread",
WrappedUnreadCountsResponse,
Expand Down
Loading
Loading