()
| 397 | |
| 398 | @logger.catch |
| 399 | def main(): |
| 400 | # args = None |
| 401 | # parser = argparse.ArgumentParser(description="Data channels ping/pong") |
| 402 | # parser.add_argument("role", choices=["offer", "answer"]) |
| 403 | # parser.add_argument("--verbose", "-v", action="count") |
| 404 | # add_signaling_arguments(parser) |
| 405 | # args = parser.parse_args() |
| 406 | # if args.verbose: |
| 407 | logger.info('Calling _loadPeerId()') |
| 408 | _loadPeerId() |
| 409 | logger.info('After _loadPeerId()') |
| 410 | exists = _loadConfig() |
| 411 | logger.info('Calling _loadConfig()') |
| 412 | if not exists: |
| 413 | _saveConfig() |
| 414 | _config_logger() |
| 415 | logger.info('After _loadConfig()') |
| 416 | # add formatter to ch |
| 417 | # signaling = create_signaling(args) |
| 418 | # signaling = AmbianicPnpSignaling(args) |
| 419 | # pc = RTCPeerConnection() |
| 420 | # if args.role == "offer": |
| 421 | # coro = _run_offer(pc, signaling) |
| 422 | # else: |
| 423 | # coro = _run_answer(pc, signaling) |
| 424 | |
| 425 | # run event loop |
| 426 | loop = asyncio.get_event_loop() |
| 427 | try: |
| 428 | logger.info('\n>>>>> Starting http-proxy over webrtc. <<<<') |
| 429 | loop.run_until_complete(_start()) |
| 430 | loop.run_forever() |
| 431 | except KeyboardInterrupt: |
| 432 | logger.info('KeyboardInterrupt detected.') |
| 433 | finally: |
| 434 | logger.info('Shutting down...') |
| 435 | loop.run_until_complete(_shutdown()) |
| 436 | loop.close() |
| 437 | logger.info('All done.') |
| 438 | |
| 439 | |
| 440 | if __name__ == "__main__": |
no test coverage detected