X-Git-Url: https://git.cworth.org/git?a=blobdiff_plain;f=turbot%2Fevents.py;h=4099ac5a25c11f30f45f7994ed2328a8846cce45;hb=d47444e021aab4d3a89fd0e1b75c0a49867290b7;hp=eb5bcc46c69a8e8bfa09c275081a6f650e71de69;hpb=c6ad0733c2613b899a30291b14222ef6c322c6cb;p=turbot diff --git a/turbot/events.py b/turbot/events.py index eb5bcc4..4099ac5 100644 --- a/turbot/events.py +++ b/turbot/events.py @@ -2,6 +2,9 @@ from turbot.blocks import ( section_block, text_block, button_block, actions_block, divider_block ) from turbot.hunt import find_hunt_for_hunt_id +from turbot.puzzle import ( + puzzle_channel_topic, puzzle_channel_description, +) from turbot.sheets import ( sheets_create, sheets_create_for_puzzle, sheets_create_folder ) @@ -125,8 +128,17 @@ def hunt_channel_created(turb, channel_name, channel_id): "Welcome to the channel for the {} hunt! ".format(hunt['name']) + "Please wait a moment or two while I create some backend resources.") - # Create a new folder within Google drive for the hunt - hunt['folder_id'] = sheets_create_folder(turb, hunt['hunt_id']) + # Create a new folder within Google drive for the hunt in two parts: + + # ... first, a top-level folder named for the hunt + hunt_folder = sheets_create_folder(turb, hunt['hunt_id']) + + # ... second, a folder within that named "turbot" + # + # The concept here is that non-turbot related content could + # be placed adjacent to the turbot folder. + hunt['folder_id'] = sheets_create_folder(turb, "turbot", + parents = [hunt_folder]) # Create a sheet for the hunt sheet = sheets_create(turb, hunt['name'], hunt['folder_id']) @@ -150,25 +162,17 @@ def hunt_channel_created(turb, channel_name, channel_id): return lambda_success -def set_channel_description(turb, puzzle): - channel_id = puzzle['channel_id'] - description = puzzle['name'] - url = puzzle.get('url', None) - sheet_url = puzzle.get('sheet_url', None) +def set_channel_topic_and_description(turb, puzzle): - links = [] - if url: - links.append("<{}|Puzzle>".format(url)) - if sheet_url: - links.append("<{}|Sheet>".format(sheet_url)) + channel_id = puzzle['channel_id'] - if len(links): - description += "({})".format(', '.join(links)) + topic = puzzle_channel_topic(puzzle) + description = puzzle_channel_description(puzzle) turb.slack_client.conversations_setPurpose(channel=channel_id, purpose=description) turb.slack_client.conversations_setTopic(channel=channel_id, - topic=description) + topic=topic) def puzzle_channel_created(turb, channel_name, channel_id): """Creates sheet and invites user for a newly-created puzzle channel""" @@ -193,7 +197,8 @@ def puzzle_channel_created(turb, channel_name, channel_id): # We need hunt from the database to know which folder to create # the sheet in. - hunt = find_hunt_for_hunt_id(turb, puzzle['hunt_id']) + hunt_id = puzzle['hunt_id'] + hunt = find_hunt_for_hunt_id(turb, hunt_id) # Before launching into sheet creation, indicate that we're doing this # in the database. This way, if we take too long to create the sheet @@ -210,8 +215,30 @@ def puzzle_channel_created(turb, channel_name, channel_id): puzzle['sheet_url'] = sheet['url'] turb.table.put_item(Item=puzzle) - # Get the new sheet_url into the channel description - set_channel_description(turb, puzzle) + # Get the new sheet_url into the channel topic and description + set_channel_topic_and_description(turb, puzzle) + + # Lookup and invite all users from this hunt to this new puzzle + + # Find all members of the hunt channel + members = slack_channel_members(turb.slack_client, hunt['channel_id']) + + # Filter out Turbot's own ID to avoid inviting itself + # has opted out of being auto-invited + members = [m for m in members if m != TURBOT_USER_ID] + + slack_send_message( + turb.slack_client, channel_id, + "Inviting all members from the hunt channel: " + + "<#{}>".format(hunt['channel_id'])) + + # Invite those members to the puzzle channel (in chunks of 500) + cursor = 0 + while cursor < len(members): + turb.slack_client.conversations_invite( + channel=channel_id, + users=members[cursor:cursor + 500]) + cursor += 500 # And finally, give a welcome message with some documentation # on how to update the state of the puzzle in the database. @@ -239,7 +266,6 @@ def puzzle_channel_created(turb, channel_name, channel_id): turb.slack_client.chat_postMessage(channel=channel_id, text=welcome_msg) # Finally, finally, notify the hunt channel about the new puzzle - hunt = find_hunt_for_hunt_id(turb, puzzle['hunt_id']) slack_send_message( turb.slack_client, hunt['channel_id'], "New puzzle available: <{}|{}>".format(