cli.py 文件源码

def download(loglevel, savedir, path):
    try:
        os.environ['loglevel'] = loglevel
        logger = get_logger()

        if savedir == '.':
            savedir = b''
        elif os.path.exists(savedir):
            savedir = bytes(savedir.encode('utf-8'))
        else:
            logger.info("Directory {} doesn't exist".format(savedir))
            exit(1)

        loop = asyncio.get_event_loop()
        loop.set_debug(True)
        client = Client()
        task = loop.create_task(client.download(path, savedir))
        try:
            loop.run_until_complete(task)
        except CancelledError:
            logging.warning('Event was cancelled')
        finally:
            task.cancel()
            try:
                loop.run_until_complete(task)
            except Exception:
                pass 
            loop.close()
    except (bencodepy.DecodingError,
            FileNotFoundError) as e:
        logger.error(e)