bot.py 文件源码

def _loop_messages(self):
        '''Slack message loop.'''

        if not self._slack.rtm_connect():
            raise Exception("Could not connect to Slack RTM API.\nBot token might be invalid.")

        while self.is_running:
            try:
                events = self._slack.rtm_read()
            except websocket._exceptions.WebSocketConnectionClosedException:
                self._slack.rtm_connect()
                continue

            bot_events = self._get_bot_events(events)

            if bot_events:
                for event in bot_events:
                    self._send_typing(event['channel'])
                    self._process_event(event)

            time.sleep(self._reaction_interval)