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

Slack: Add zerver_defaultstream feature.

Browse source 
Thanks to @rheaparekh for pointing out the doc for sanity check ;)
This commit is contained in:
rht 2017-10-08 09:04:51 +02:00 committed by showell
parent 46fd234824
commit b3a7a4f937
1 changed files with 13 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
zulip/integrations/slack/slackdata2zulipdata.py
View file

@ -121,7 +121,7 @@ def users2zerver_userprofile(slack_dir: str, realm_id: int, timestamp: Any,
return zerver_userprofile, added_users return zerver_userprofile, added_users
def channels2zerver_stream(slack_dir, realm_id, added_users): def channels2zerver_stream(slack_dir, realm_id, added_users):
# type: (Dict[str, Dict[str, str]]) -> None # type: (Dict[str, Dict[str, Any]]) -> None
print('######### IMPORTING CHANNELS STARTED #########\n') print('######### IMPORTING CHANNELS STARTED #########\n')
channels = json.load(open(slack_dir + '/channels.json')) channels = json.load(open(slack_dir + '/channels.json'))
added_channels = {} added_channels = {}
@ -130,6 +130,8 @@ def channels2zerver_stream(slack_dir, realm_id, added_users):
zerver_subscription = [] zerver_subscription = []
zerver_recipient = [] zerver_recipient = []
subscription_id_count = 1 subscription_id_count = 1
zerver_defaultstream = {}
for channel in channels: for channel in channels:
# slack_channel_id = channel['id'] # slack_channel_id = channel['id']
@ -149,6 +151,9 @@ def channels2zerver_stream(slack_dir, realm_id, added_users):
invite_only=not channel["is_general"], invite_only=not channel["is_general"],
date_created=channel["created"], date_created=channel["created"],
id=stream_id_count) id=stream_id_count)
if channel["name"] == 'general':
zerver_defaultstream = stream
else:
zerver_stream.append(stream) zerver_stream.append(stream)
added_channels[stream['name']] = stream_id_count added_channels[stream['name']] = stream_id_count
@ -207,7 +212,7 @@ def channels2zerver_stream(slack_dir, realm_id, added_users):
# } # }
# ], # ],
print('######### IMPORTING STREAMS FINISHED #########\n') print('######### IMPORTING STREAMS FINISHED #########\n')
return zerver_stream, added_channels, zerver_subscription, zerver_recipient return zerver_defaultstream, zerver_stream, added_channels, zerver_subscription, zerver_recipient
def channelmessage2zerver_message(slack_dir, channel, added_users, added_channels): def channelmessage2zerver_message(slack_dir, channel, added_users, added_channels):
json_names = os.listdir(slack_dir + '/' + channel) json_names = os.listdir(slack_dir + '/' + channel)
@ -295,8 +300,7 @@ def main(slack_zip_file: str) -> None:
rm_tree(output_dir) rm_tree(output_dir)
os.makedirs(output_dir) os.makedirs(output_dir)
realm = dict(zerver_defaultstream=[], # TODO realm = dict(zerver_client=[{"name": "populate_db", "id": 1},
zerver_client=[{"name": "populate_db", "id": 1},
{"name": "website", "id": 2}, {"name": "website", "id": 2},
{"name": "API", "id": 3}], {"name": "API", "id": 3}],
zerver_userpresence=[], # TODO zerver_userpresence=[], # TODO
@ -319,7 +323,10 @@ def main(slack_zip_file: str) -> None:
DOMAIN_NAME) DOMAIN_NAME)
realm['zerver_userprofile'] = zerver_userprofile realm['zerver_userprofile'] = zerver_userprofile
zerver_stream, added_channels, zerver_subscription, zerver_recipient = channels2zerver_stream(slack_dir, REALM_ID, added_users) zerver_defaultstream, zerver_stream, added_channels, zerver_subscription, zerver_recipient = channels2zerver_stream(slack_dir, REALM_ID, added_users)
# See https://zulipchat.com/help/set-default-streams-for-new-users
# for documentation on zerver_defaultstream
realm['zerver_defaultstream'] = [zerver_defaultstream]
realm['zerver_stream'] = zerver_stream realm['zerver_stream'] = zerver_stream
realm['zerver_subscription'] = zerver_subscription realm['zerver_subscription'] = zerver_subscription
realm['zerver_recipient'] = zerver_recipient realm['zerver_recipient'] = zerver_recipient