Skip to content

Commit 7a9190e

Browse files
zimegzimeg
authored
Merge branch 'ai-apps' into zimeg-feat-web-api-assistant-thread-loading-messages
2 parents c808b69 + f60e37c commit 7a9190e

File tree

4 files changed

+299
-80
lines changed

4 files changed

+299
-80
lines changed

‎slack_sdk/web/async_client.py‎

Lines changed: 95 additions & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -2623,6 +2623,26 @@ async def channels_unarchive(
26232623

26242624
# --------------------------
26252625

2626+
async def chat_appendStream(
2627+
self,
2628+
*,
2629+
channel: str,
2630+
ts: str,
2631+
markdown_text: str,
2632+
**kwargs,
2633+
) -> AsyncSlackResponse:
2634+
"""Appends text to an existing streaming conversation.
2635+
https://api.slack.com/methods/chat.appendStream
2636+
"""
2637+
kwargs.update(
2638+
{
2639+
"channel": channel,
2640+
"ts": ts,
2641+
"markdown_text": markdown_text,
2642+
}
2643+
)
2644+
return await self.api_call("chat.appendStream", params=kwargs)
2645+
26262646
async def chat_delete(
26272647
self,
26282648
*,
@@ -2827,6 +2847,81 @@ async def chat_scheduleMessage(
28272847
# NOTE: intentionally using json over params for the API methods using blocks/attachments
28282848
return await self.api_call("chat.scheduleMessage", json=kwargs)
28292849

2850+
async def chat_scheduledMessages_list(
2851+
self,
2852+
*,
2853+
channel: Optional[str] = None,
2854+
cursor: Optional[str] = None,
2855+
latest: Optional[str] = None,
2856+
limit: Optional[int] = None,
2857+
oldest: Optional[str] = None,
2858+
team_id: Optional[str] = None,
2859+
**kwargs,
2860+
) -> AsyncSlackResponse:
2861+
"""Lists all scheduled messages.
2862+
https://api.slack.com/methods/chat.scheduledMessages.list
2863+
"""
2864+
kwargs.update(
2865+
{
2866+
"channel": channel,
2867+
"cursor": cursor,
2868+
"latest": latest,
2869+
"limit": limit,
2870+
"oldest": oldest,
2871+
"team_id": team_id,
2872+
}
2873+
)
2874+
return await self.api_call("chat.scheduledMessages.list", params=kwargs)
2875+
2876+
async def chat_startStream(
2877+
self,
2878+
*,
2879+
channel: str,
2880+
thread_ts: Optional[str] = None,
2881+
markdown_text: Optional[str] = None,
2882+
unfurl_links: Optional[bool] = None,
2883+
unfurl_media: Optional[bool] = None,
2884+
**kwargs,
2885+
) -> AsyncSlackResponse:
2886+
"""Starts a new streaming conversation.
2887+
https://api.slack.com/methods/chat.startStream
2888+
"""
2889+
kwargs.update(
2890+
{
2891+
"channel": channel,
2892+
"thread_ts": thread_ts,
2893+
"markdown_text": markdown_text,
2894+
"unfurl_links": unfurl_links,
2895+
"unfurl_media": unfurl_media,
2896+
}
2897+
)
2898+
return await self.api_call("chat.startStream", params=kwargs)
2899+
2900+
async def chat_stopStream(
2901+
self,
2902+
*,
2903+
channel: str,
2904+
ts: str,
2905+
markdown_text: Optional[str] = None,
2906+
blocks: Optional[Union[str, Sequence[Union[Dict, Block]]]] = None,
2907+
metadata: Optional[Union[Dict, Metadata]] = None,
2908+
**kwargs,
2909+
) -> AsyncSlackResponse:
2910+
"""Stops a streaming conversation.
2911+
https://api.slack.com/methods/chat.stopStream
2912+
"""
2913+
kwargs.update(
2914+
{
2915+
"channel": channel,
2916+
"ts": ts,
2917+
"markdown_text": markdown_text,
2918+
"blocks": blocks,
2919+
"metadata": metadata,
2920+
}
2921+
)
2922+
_parse_web_class_objects(kwargs)
2923+
return await self.api_call("chat.stopStream", params=kwargs)
2924+
28302925
async def chat_unfurl(
28312926
self,
28322927
*,
@@ -2907,32 +3002,6 @@ async def chat_update(
29073002
# NOTE: intentionally using json over params for API methods using blocks/attachments
29083003
return await self.api_call("chat.update", json=kwargs)
29093004

2910-
async def chat_scheduledMessages_list(
2911-
self,
2912-
*,
2913-
channel: Optional[str] = None,
2914-
cursor: Optional[str] = None,
2915-
latest: Optional[str] = None,
2916-
limit: Optional[int] = None,
2917-
oldest: Optional[str] = None,
2918-
team_id: Optional[str] = None,
2919-
**kwargs,
2920-
) -> AsyncSlackResponse:
2921-
"""Lists all scheduled messages.
2922-
https://api.slack.com/methods/chat.scheduledMessages.list
2923-
"""
2924-
kwargs.update(
2925-
{
2926-
"channel": channel,
2927-
"cursor": cursor,
2928-
"latest": latest,
2929-
"limit": limit,
2930-
"oldest": oldest,
2931-
"team_id": team_id,
2932-
}
2933-
)
2934-
return await self.api_call("chat.scheduledMessages.list", params=kwargs)
2935-
29363005
async def conversations_acceptSharedInvite(
29373006
self,
29383007
*,

‎slack_sdk/web/client.py‎

Lines changed: 95 additions & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -2613,6 +2613,26 @@ def channels_unarchive(
26132613

26142614
# --------------------------
26152615

2616+
def chat_appendStream(
2617+
self,
2618+
*,
2619+
channel: str,
2620+
ts: str,
2621+
markdown_text: str,
2622+
**kwargs,
2623+
) -> SlackResponse:
2624+
"""Appends text to an existing streaming conversation.
2625+
https://api.slack.com/methods/chat.appendStream
2626+
"""
2627+
kwargs.update(
2628+
{
2629+
"channel": channel,
2630+
"ts": ts,
2631+
"markdown_text": markdown_text,
2632+
}
2633+
)
2634+
return self.api_call("chat.appendStream", params=kwargs)
2635+
26162636
def chat_delete(
26172637
self,
26182638
*,
@@ -2817,6 +2837,81 @@ def chat_scheduleMessage(
28172837
# NOTE: intentionally using json over params for the API methods using blocks/attachments
28182838
return self.api_call("chat.scheduleMessage", json=kwargs)
28192839

2840+
def chat_scheduledMessages_list(
2841+
self,
2842+
*,
2843+
channel: Optional[str] = None,
2844+
cursor: Optional[str] = None,
2845+
latest: Optional[str] = None,
2846+
limit: Optional[int] = None,
2847+
oldest: Optional[str] = None,
2848+
team_id: Optional[str] = None,
2849+
**kwargs,
2850+
) -> SlackResponse:
2851+
"""Lists all scheduled messages.
2852+
https://api.slack.com/methods/chat.scheduledMessages.list
2853+
"""
2854+
kwargs.update(
2855+
{
2856+
"channel": channel,
2857+
"cursor": cursor,
2858+
"latest": latest,
2859+
"limit": limit,
2860+
"oldest": oldest,
2861+
"team_id": team_id,
2862+
}
2863+
)
2864+
return self.api_call("chat.scheduledMessages.list", params=kwargs)
2865+
2866+
def chat_startStream(
2867+
self,
2868+
*,
2869+
channel: str,
2870+
thread_ts: Optional[str] = None,
2871+
markdown_text: Optional[str] = None,
2872+
unfurl_links: Optional[bool] = None,
2873+
unfurl_media: Optional[bool] = None,
2874+
**kwargs,
2875+
) -> SlackResponse:
2876+
"""Starts a new streaming conversation.
2877+
https://api.slack.com/methods/chat.startStream
2878+
"""
2879+
kwargs.update(
2880+
{
2881+
"channel": channel,
2882+
"thread_ts": thread_ts,
2883+
"markdown_text": markdown_text,
2884+
"unfurl_links": unfurl_links,
2885+
"unfurl_media": unfurl_media,
2886+
}
2887+
)
2888+
return self.api_call("chat.startStream", params=kwargs)
2889+
2890+
def chat_stopStream(
2891+
self,
2892+
*,
2893+
channel: str,
2894+
ts: str,
2895+
markdown_text: Optional[str] = None,
2896+
blocks: Optional[Union[str, Sequence[Union[Dict, Block]]]] = None,
2897+
metadata: Optional[Union[Dict, Metadata]] = None,
2898+
**kwargs,
2899+
) -> SlackResponse:
2900+
"""Stops a streaming conversation.
2901+
https://api.slack.com/methods/chat.stopStream
2902+
"""
2903+
kwargs.update(
2904+
{
2905+
"channel": channel,
2906+
"ts": ts,
2907+
"markdown_text": markdown_text,
2908+
"blocks": blocks,
2909+
"metadata": metadata,
2910+
}
2911+
)
2912+
_parse_web_class_objects(kwargs)
2913+
return self.api_call("chat.stopStream", params=kwargs)
2914+
28202915
def chat_unfurl(
28212916
self,
28222917
*,
@@ -2897,32 +2992,6 @@ def chat_update(
28972992
# NOTE: intentionally using json over params for API methods using blocks/attachments
28982993
return self.api_call("chat.update", json=kwargs)
28992994

2900-
def chat_scheduledMessages_list(
2901-
self,
2902-
*,
2903-
channel: Optional[str] = None,
2904-
cursor: Optional[str] = None,
2905-
latest: Optional[str] = None,
2906-
limit: Optional[int] = None,
2907-
oldest: Optional[str] = None,
2908-
team_id: Optional[str] = None,
2909-
**kwargs,
2910-
) -> SlackResponse:
2911-
"""Lists all scheduled messages.
2912-
https://api.slack.com/methods/chat.scheduledMessages.list
2913-
"""
2914-
kwargs.update(
2915-
{
2916-
"channel": channel,
2917-
"cursor": cursor,
2918-
"latest": latest,
2919-
"limit": limit,
2920-
"oldest": oldest,
2921-
"team_id": team_id,
2922-
}
2923-
)
2924-
return self.api_call("chat.scheduledMessages.list", params=kwargs)
2925-
29262995
def conversations_acceptSharedInvite(
29272996
self,
29282997
*,

0 commit comments

Comments
 (0)