handlers.py 文件源码

def open(self, username, args):
        util.logger.info('({}) Websocket connected'.format(username))

        # We don't do validation since we assume that the LandingHandler did
        # it, so this isn't very secure.
        is_file_request = ('file' in args)

        try:
            if is_file_request:
                message = yield thread_pool.submit(
                    download_file_and_redirect,
                    username=username,
                    file_url=args['file'],
                    config=options.config,
                )
            else:
                message = yield thread_pool.submit(
                    pull_from_github,
                    username=username,
                    repo_name=args['repo'],
                    paths=args['path'],
                    config=options.config,
                    progress=Progress(username, self.write_message)
                )

            util.logger.info('Sent message: {}'.format(message))
            self.write_message(message)
        except Exception as e:
            # If something bad happens, the client should see it
            message = messages.error(str(e))
            util.logger.error('Sent message: {}'.format(message))
            self.write_message(message)