xenofem/python-zulip-api
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

slack-bridge: Use slack_sdk instead of the deprecated slackclient.

Browse source
This commit is contained in:
rht 2021-05-20 09:20:07 -04:00 committed by Tim Abbott
parent 470967cfdb
commit 2d9cf64db8
2 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
zulip/integrations/bridge_with_slack/requirements.txt
View file

@ -1 +1 @@
slackclient==2.0.0 slack-sdk==3.5.1

9
zulip/integrations/bridge_with_slack/run-slack-bridge
View file

@ -7,7 +7,8 @@ import argparse
import traceback import traceback
import multiprocessing as mp import multiprocessing as mp
import zulip import zulip
import slack import slack_sdk
from slack_sdk.rtm import RTMClient
from typing import Any, Dict, Callable from typing import Any, Dict, Callable
import bridge_with_slack_config import bridge_with_slack_config
@ -44,10 +45,10 @@ class SlackBridge:
# slack-specific # slack-specific
self.channel = self.slack_config["channel"] self.channel = self.slack_config["channel"]
self.slack_client = slack.RTMClient(token=self.slack_config["token"], auto_reconnect=True) self.slack_client = RTMClient(token=self.slack_config["token"], auto_reconnect=True)
# Spawn a non-websocket client for getting the users # Spawn a non-websocket client for getting the users
# list and for posting messages in Slack. # list and for posting messages in Slack.
self.slack_webclient = slack.WebClient(token=self.slack_config["token"]) self.slack_webclient = slack_sdk.WebClient(token=self.slack_config["token"])
def wrap_slack_mention_with_bracket(self, zulip_msg: Dict[str, Any]) -> None: def wrap_slack_mention_with_bracket(self, zulip_msg: Dict[str, Any]) -> None:
words = zulip_msg["content"].split(' ') words = zulip_msg["content"].split(' ')
@ -81,7 +82,7 @@ class SlackBridge:
self.slack_id_to_name = {u["id"]: u["profile"].get("display_name", u["profile"]["real_name"]) for u in members} self.slack_id_to_name = {u["id"]: u["profile"].get("display_name", u["profile"]["real_name"]) for u in members}
self.slack_name_to_id = {v: k for k, v in self.slack_id_to_name.items()} self.slack_name_to_id = {v: k for k, v in self.slack_id_to_name.items()}
@slack.RTMClient.run_on(event='message') @RTMClient.run_on(event='message')
def slack_to_zulip(**payload: Any) -> None: def slack_to_zulip(**payload: Any) -> None:
msg = payload['data'] msg = payload['data']
if msg['channel'] != self.channel: if msg['channel'] != self.channel: