def main(argv=None):
    parser = argparse.ArgumentParser()
    if yaml is None:
        parser.error('You must install pyaml')
    parser.add_argument('-c', '--config',
                        type=argparse.FileType('r'),
                        required=True,
                        help='Config ini file')
    parser.add_argument('-i', '--input',
                        type=argparse.FileType('r'),
                        help='Input yaml file')
    parser.add_argument('-o', '--output',
                        type=argparse.FileType('w'),
                        default='-',
                        help='Stream output file (Default to STDOUT)')
    args = parser.parse_args(argv or sys.argv[1:])
    config = utils.config(args.config)
    config['save_stream'] = args.output
    call_manager = CallManager(**config)
    task = call_manager.connect()

    logging.basicConfig(stream=sys.stderr, level=logging.INFO)
    logging.getLogger('asyncio').setLevel(logging.ERROR)
    log = logging.getLogger('panoramisk')

    def done(future):
        result = future.result()
        log.info('Got result: %r\n', result)
        if isinstance(result, Call):
            while not result.queue.empty():
                print(result.queue.get_nowait())

            def show(f=None):
                if f:
                    print(f.result())
                f = utils.asyncio.Task(result.queue.get())
                f.add_done_callback(show)
            show()

    def send_action(f):
        if args.input:
            action = yaml.load(args.input)
            if action.get('Action').lower() == 'originate':
                future = call_manager.send_originate(action)
            elif action.get('Action').lower() == 'agi':
                future = call_manager.send_agi_command(action)
            elif 'commandid' in [k.lower() for k in action.keys()]:
                future = call_manager.send_command(action)
            else:
                future = call_manager.send_action(action)
            log.info('Action %r sent', action)
            future.add_done_callback(done)

    def connected(f):
        if call_manager.authenticated_future is not None:
            call_manager.authenticated_future.add_done_callback(send_action)
        else:
            send_action(f)

    task.add_done_callback(connected)

    try:
        call_manager.loop.run_forever()
    except KeyboardInterrupt:
        args.output.close()
dataset/ETHPy150Open gawel/panoramisk/panoramisk/command.py/main/original