()
| 715 | # ===================== 启动服务 ===================== |
| 716 | |
| 717 | async def main(): |
| 718 | if len(args.certfile) > 0: |
| 719 | ssl_context = ssl.SSLContext(ssl.PROTOCOL_TLS_SERVER) |
| 720 | ssl_context.load_cert_chain(args.certfile, keyfile=args.keyfile) |
| 721 | server = await websockets.serve( |
| 722 | ws_serve, |
| 723 | args.host, |
| 724 | args.port, |
| 725 | subprotocols=["binary"], |
| 726 | ping_interval=None, |
| 727 | ssl=ssl_context, |
| 728 | ) |
| 729 | else: |
| 730 | server = await websockets.serve( |
| 731 | ws_serve, |
| 732 | args.host, |
| 733 | args.port, |
| 734 | subprotocols=["binary"], |
| 735 | ping_interval=None, |
| 736 | ) |
| 737 | |
| 738 | print(f"WS server started at ws(s)://{args.host}:{args.port}") |
| 739 | await server.wait_closed() |
| 740 | |
| 741 | |
| 742 | if __name__ == "__main__": |
no outgoing calls
no test coverage detected
searching dependent graphs…