can't read the received messages?

[deronnax]

Hello.
I played a bit with ws, it's nice, but: the received data can't be read?
Also, on macOS, when running an echo server and ws listen, the ws listen errors pretty quickly with no message, only the following stacktrace, of which I really can't get my head around:

╭─────────────────────────────── Traceback (most recent call last) ────────────────────────────────╮
│ /Users/mathieu/.local/bin/ws:8 in <module>                                                       │
│                                                                                                  │
│   5 from ws.main import cli                                                                      │
│   6 if __name__ == '__main__':                                                                   │
│   7 │   sys.argv[0] = re.sub(r'(-script\.pyw|\.exe)?$', '', sys.argv[0])                         │
│ ❱ 8 │   sys.exit(cli())                                                                          │
│   9                                                                                              │
│                                                                                                  │
│ ╭─────────────────────────────────────────── locals ───────────────────────────────────────────╮ │
│ │ cli = <DYMGroup cli>                                                                         │ │
│ │  re = <module 're' from                                                                      │ │
│ │       '/opt/homebrew/Cellar/python@3.13/3.13.3/Frameworks/Python.framework/Versions/3.13/li… │ │
│ │ sys = <module 'sys' (built-in)>                                                              │ │
│ ╰──────────────────────────────────────────────────────────────────────────────────────────────╯ │
│                                                                                                  │
│ /Users/mathieu/.local/pipx/venvs/websockets-cli/lib/python3.13/site-packages/click/core.py:1161  │
│ in __call__                                                                                      │
│                                                                                                  │
│   1158 │                                                                                         │
│   1159 │   def __call__(self, *args: t.Any, **kwargs: t.Any) -> t.Any:                           │
│   1160 │   │   """Alias for :meth:`main`."""                                                     │
│ ❱ 1161 │   │   return self.main(*args, **kwargs)                                                 │
│   1162                                                                                           │
│   1163                                                                                           │
│   1164 class Command(BaseCommand):                                                               │
│                                                                                                  │
│ ╭──────── locals ─────────╮                                                                      │
│ │   args = ()             │                                                                      │
│ │ kwargs = {}             │                                                                      │
│ │   self = <DYMGroup cli> │                                                                      │
│ ╰─────────────────────────╯                                                                      │
│                                                                                                  │
│ /Users/mathieu/.local/pipx/venvs/websockets-cli/lib/python3.13/site-packages/click/core.py:1082  │
│ in main                                                                                          │
│                                                                                                  │
│   1079 │   │   try:                                                                              │
│   1080 │   │   │   try:                                                                          │
│   1081 │   │   │   │   with self.make_context(prog_name, args, **extra) as ctx:                  │
│ ❱ 1082 │   │   │   │   │   rv = self.invoke(ctx)                                                 │
│   1083 │   │   │   │   │   if not standalone_mode:                                               │
│   1084 │   │   │   │   │   │   return rv                                                         │
│   1085 │   │   │   │   │   # it's not safe to `ctx.exit(rv)` here!                               │
│                                                                                                  │
│ ╭───────────────────────────── locals ─────────────────────────────╮                             │
│ │                args = ['listen', 'ws://localhost:5050']          │                             │
│ │        complete_var = None                                       │                             │
│ │                 ctx = <click.core.Context object at 0x1030e7380> │                             │
│ │               extra = {}                                         │                             │
│ │           prog_name = 'ws'                                       │                             │
│ │                self = <DYMGroup cli>                             │                             │
│ │     standalone_mode = True                                       │                             │
│ │ windows_expand_args = True                                       │                             │
│ ╰──────────────────────────────────────────────────────────────────╯                             │
│                                                                                                  │
│ /Users/mathieu/.local/pipx/venvs/websockets-cli/lib/python3.13/site-packages/click/core.py:1697  │
│ in invoke                                                                                        │
│                                                                                                  │
│   1694 │   │   │   │   super().invoke(ctx)                                                       │
│   1695 │   │   │   │   sub_ctx = cmd.make_context(cmd_name, args, parent=ctx)                    │
│   1696 │   │   │   │   with sub_ctx:                                                             │
│ ❱ 1697 │   │   │   │   │   return _process_result(sub_ctx.command.invoke(sub_ctx))               │
│   1698 │   │                                                                                     │
│   1699 │   │   # In chain mode we create the contexts step by step, but after the                │
│   1700 │   │   # base command has been invoked.  Because at that point we do not                 │
│                                                                                                  │
│ ╭─────────────────────── locals ────────────────────────╮                                        │
│ │     args = []                                         │                                        │
│ │      cmd = <Command listen>                           │                                        │
│ │ cmd_name = 'listen'                                   │                                        │
│ │      ctx = <click.core.Context object at 0x1030e7380> │                                        │
│ │     self = <DYMGroup cli>                             │                                        │
│ │  sub_ctx = <click.core.Context object at 0x10308bc50> │                                        │
│ ╰───────────────────────────────────────────────────────╯                                        │
│                                                                                                  │
│ /Users/mathieu/.local/pipx/venvs/websockets-cli/lib/python3.13/site-packages/click/core.py:1443  │
│ in invoke                                                                                        │
│                                                                                                  │
│   1440 │   │   │   echo(style(message, fg="red"), err=True)                                      │
│   1441 │   │                                                                                     │
│   1442 │   │   if self.callback is not None:                                                     │
│ ❱ 1443 │   │   │   return ctx.invoke(self.callback, **ctx.params)                                │
│   1444 │                                                                                         │
│   1445 │   def shell_complete(self, ctx: Context, incomplete: str) -> t.List["CompletionItem"]:  │
│   1446 │   │   """Return a list of completions for the incomplete value. Looks                   │
│                                                                                                  │
│ ╭───────────────────── locals ──────────────────────╮                                            │
│ │  ctx = <click.core.Context object at 0x10308bc50> │                                            │
│ │ self = <Command listen>                           │                                            │
│ ╰───────────────────────────────────────────────────╯                                            │
│                                                                                                  │
│ /Users/mathieu/.local/pipx/venvs/websockets-cli/lib/python3.13/site-packages/click/core.py:788   │
│ in invoke                                                                                        │
│                                                                                                  │
│    785 │   │                                                                                     │
│    786 │   │   with augment_usage_errors(__self):                                                │
│    787 │   │   │   with ctx:                                                                     │
│ ❱  788 │   │   │   │   return __callback(*args, **kwargs)                                        │
│    789 │                                                                                         │
│    790 │   def forward(__self, __cmd: "Command", *args: t.Any, **kwargs: t.Any) -> t.Any:        │
│    791 │   │   """Similar to :meth:`invoke` but fills in default keyword                         │
│                                                                                                  │
│ ╭────────────────────────── locals ───────────────────────────╮                                  │
│ │ _Context__self = <click.core.Context object at 0x10308bc50> │                                  │
│ │           args = ()                                         │                                  │
│ │            ctx = <click.core.Context object at 0x10308bc50> │                                  │
│ │         kwargs = {                                          │                                  │
│ │                  │   'url': 'ws://localhost:5050/',         │                                  │
│ │                  │   'is_json': False,                      │                                  │
│ │                  │   'duration': None,                      │                                  │
│ │                  │   'filename': None                       │                                  │
│ │                  }                                          │                                  │
│ ╰─────────────────────────────────────────────────────────────╯                                  │
│                                                                                                  │
│ /Users/mathieu/.local/pipx/venvs/websockets-cli/lib/python3.13/site-packages/ws/commands/listen. │
│ py:76 in listen                                                                                  │
│                                                                                                  │
│   73 @filename_option                                                                            │
│   74 def listen(url: str, is_json: bool, duration: float, filename: str):                        │
│   75 │   """Listens messages on a given URL."""                                                  │
│ ❱ 76 │   trio.run(main, url, is_json, duration, filename)                                        │
│   77                                                                                             │
│                                                                                                  │
│ ╭───────────── locals ──────────────╮                                                            │
│ │ duration = None                   │                                                            │
│ │ filename = None                   │                                                            │
│ │  is_json = False                  │                                                            │
│ │      url = 'ws://localhost:5050/' │                                                            │
│ ╰───────────────────────────────────╯                                                            │
│                                                                                                  │
│ /Users/mathieu/.local/pipx/venvs/websockets-cli/lib/python3.13/site-packages/trio/_core/_run.py: │
│ 2435 in run                                                                                      │
│                                                                                                  │
│   2432 │   if isinstance(runner.main_task_outcome, Value):                                       │
│   2433 │   │   return cast("RetT", runner.main_task_outcome.value)                               │
│   2434 │   elif isinstance(runner.main_task_outcome, Error):                                     │
│ ❱ 2435 │   │   raise runner.main_task_outcome.error                                              │
│   2436 │   else:  # pragma: no cover                                                             │
│   2437 │   │   raise AssertionError(runner.main_task_outcome)                                    │
│   2438                                                                                           │
│                                                                                                  │
│ ╭─────────────────────────────────────────── locals ───────────────────────────────────────────╮ │
│ │                                       args = ('ws://localhost:5050/', False, None, None)     │ │
│ │                                      clock = None                                            │ │
│ │                                        gen = <generator object unrolled_run at 0x1030f4860>  │ │
│ │                                instruments = ()                                              │ │
│ │                                  next_send = []                                              │ │
│ │                               prev_library = None                                            │ │
│ │ restrict_keyboard_interrupt_to_checkpoints = False                                           │ │
│ │                                     runner = Runner(                                         │ │
│ │                                              │   clock=SystemClock(                          │ │
│ │                                              │   │   offset=57287.9066539608                 │ │
│ │                                              │   ),                                          │ │
│ │                                              │   instruments={'_all': {}},                   │ │
│ │                                              │   io_manager=KqueueIOManager(                 │ │
│ │                                              │   │   _kqueue=<select.kqueue object at        │ │
│ │                                              0x102e51930>,                                   │ │
│ │                                              │   │   _registered={},                         │ │
│ │                                              │   │                                           │ │
│ │                                              _force_wakeup=<trio._core._wakeup_socketpair.W… │ │
│ │                                              object at 0x1030e78c0>,                         │ │
│ │                                              │   │   _force_wakeup_fd=4                      │ │
│ │                                              │   ),                                          │ │
│ │                                              │   ki_manager=KIManager(handler=None),         │ │
│ │                                              │   strict_exception_groups=True,               │ │
│ │                                              │   _locals={                                   │ │
│ │                                              │   │   <RunVar name='limiter'>:                │ │
│ │                                              <trio.CapacityLimiter at 0x1031fc590, 0/40 with │ │
│ │                                              0 waiting>,                                     │ │
│ │                                              │   │   <RunVar name='active_threads'>:         │ │
│ │                                              _ActiveThreadCount(                             │ │
│ │                                              │   │   │   count=0,                            │ │
│ │                                              │   │   │   event=Event(                        │ │
│ │                                              │   │   │   │   _tasks=set(),                   │ │
│ │                                              │   │   │   │   _flag=False                     │ │
│ │                                              │   │   │   )                                   │ │
│ │                                              │   │   )                                       │ │
│ │                                              │   },                                          │ │
│ │                                              │   runq=deque(),                               │ │
│ │                                              │   tasks=set(),                                │ │
│ │                                              │   deadlines=Deadlines(_heap=[], _active=0),   │ │
│ │                                              │   init_task=Task(                             │ │
│ │                                              │   │   _parent_nursery=None,                   │ │
│ │                                              │   │   coro=<coroutine object Runner.init at   │ │
│ │                                              0x10310a3e0>,                                   │ │
│ │                                              │   │   _runner=...,                            │ │
│ │                                              │   │   name='<init>',                          │ │
│ │                                              │   │   context=<_contextvars.Context object at │ │
│ │                                              0x1031e8840>,                                   │ │
│ │                                              │   │   _counter=0,                             │ │
│ │                                              │   │   _ki_protected=True,                     │ │
│ │                                              │   │   _next_send_fn=None,                     │ │
│ │                                              │   │   _next_send=None,                        │ │
│ │                                              │   │   _abort_func=None,                       │ │
│ │                                              │   │   custom_sleep_data=None,                 │ │
│ │                                              │   │   _child_nurseries=[],                    │ │
│ │                                              │   │   _eventual_parent_nursery=None,          │ │
│ │                                              │   │   _cancel_points=3,                       │ │
│ │                                              │   │   _schedule_points=4                      │ │
│ │                                              │   ),                                          │ │
│ │                                              │   system_nursery=<trio.Nursery object at      │ │
│ │                                              0x1031f42d0>,                                   │ │
│ │                                              │   system_context=<_contextvars.Context object │ │
│ │                                              at 0x102666080>,                                │ │
│ │                                              │   main_task=Task(                             │ │
│ │                                              │   │   _parent_nursery=<trio.Nursery object at │ │
│ │                                              0x1031f4550>,                                   │ │
│ │                                              │   │   coro=<coroutine object main at          │ │
│ │                                              0x1031a4e10>,                                   │ │
│ │                                              │   │   _runner=...,                            │ │
│ │                                              │   │   name='ws.commands.listen.main',         │ │
│ │                                              │   │   context=<_contextvars.Context object at │ │
│ │                                              0x1031e8a00>,                                   │ │
│ │                                              │   │   _counter=1,                             │ │
│ │                                              │   │   _ki_protected=False,                    │ │
│ │                                              │   │   _next_send_fn=None,                     │ │
│ │                                              │   │   _next_send=None,                        │ │
│ │                                              │   │   _abort_func=None,                       │ │
│ │                                              │   │   custom_sleep_data=None,                 │ │
│ │                                              │   │   _child_nurseries=[],                    │ │
│ │                                              │   │   _eventual_parent_nursery=None,          │ │
│ │                                              │   │   _cancel_points=1,                       │ │
│ │                                              │   │   _schedule_points=1                      │ │
│ │                                              │   ),                                          │ │
│ │                                              │   main_task_outcome=Error(                    │ │
│ │                                              │   │   _unwrapped=False,                       │ │
│ │                                              │   │   error=ExceptionGroup('Exceptions from   │ │
│ │                                              Trio nursery', [ExceptionGroup('Exceptions from │ │
│ │                                              Trio nursery',                                  │ │
│ │                                              [ConnectionClosed<CloseReason<code=1000,        │ │
│ │                                              name=NORMAL_CLOSURE, reason=None>>])])          │ │
│ │                                              │   ),                                          │ │
│ │                                              │   entry_queue=EntryQueue(                     │ │
│ │                                              │   │   queue=deque(),                          │ │
│ │                                              │   │   idempotent_queue={},                    │ │
│ │                                              │   │                                           │ │
│ │                                              wakeup=<trio._core._wakeup_socketpair.WakeupSo… │ │
│ │                                              object at 0x10308bed0>,                         │ │
│ │                                              │   │   done=True,                              │ │
│ │                                              │   │   lock=<unlocked _thread.RLock object     │ │
│ │                                              owner=0 count=0 at 0x1031e83c0>                 │ │
│ │                                              │   ),                                          │ │
│ │                                              │   trio_token=TrioToken(                       │ │
│ │                                              │   │   _reentry_queue=EntryQueue(              │ │
│ │                                              │   │   │   queue=deque(),                      │ │
│ │                                              │   │   │   idempotent_queue={},                │ │
│ │                                              │   │   │                                       │ │
│ │                                              wakeup=<trio._core._wakeup_socketpair.WakeupSo… │ │
│ │                                              object at 0x10308bed0>,                         │ │
│ │                                              │   │   │   done=True,                          │ │
│ │                                              │   │   │   lock=<unlocked _thread.RLock object │ │
│ │                                              owner=0 count=0 at 0x1031e83c0>                 │ │
│ │                                              │   │   )                                       │ │
│ │                                              │   ),                                          │ │
│ │                                              │   asyncgens=AsyncGenerators(                  │ │
│ │                                              │   │   alive=set(),                            │ │
│ │                                              │   │   foreign=set(),                          │ │
│ │                                              │   │   trailing_needs_finalize=set(),          │ │
│ │                                              │   │                                           │ │
│ │                                              prev_hooks=asyncgen_hooks(firstiter=None,       │ │
│ │                                              finalizer=None)                                 │ │
│ │                                              │   ),                                          │ │
│ │                                              │   clock_autojump_threshold=inf,               │ │
│ │                                              │   is_guest=False,                             │ │
│ │                                              │   guest_tick_scheduled=False,                 │ │
│ │                                              │   ki_pending=False,                           │ │
│ │                                              │   waiting_for_idle=SortedDict({})             │ │
│ │                                              )                                               │ │
│ │                    strict_exception_groups = True                                            │ │
│ │                                    timeout = 0                                               │ │
│ ╰──────────────────────────────────────────────────────────────────────────────────────────────╯ │
│                                                                                                  │
│ /Users/mathieu/.local/pipx/venvs/websockets-cli/lib/python3.13/site-packages/ws/commands/listen. │
│ py:60 in main                                                                                    │
│                                                                                                  │
│   57                                                                                             │
│   58                                                                                             │
│   59 async def main(url: str, is_json: bool, duration: Optional[float] = None, filename: Opti    │
│ ❱ 60 │   async with trio.open_nursery() as nursery:                                              │
│   61 │   │   nursery.start_soon(function_runner, nursery.cancel_scope, listen_messages, url,     │
│   62 │   │   nursery.start_soon(signal_handler, nursery.cancel_scope)                            │
│   63 │   │   nursery.start_soon(sleep_until, nursery.cancel_scope, duration)                     │
│                                                                                                  │
│ ╭──────────────────── locals ─────────────────────╮                                              │
│ │ duration = None                                 │                                              │
│ │ filename = None                                 │                                              │
│ │  is_json = False                                │                                              │
│ │  nursery = <trio.Nursery object at 0x103109f30> │                                              │
│ │      url = 'ws://localhost:5050/'               │                                              │
│ ╰─────────────────────────────────────────────────╯                                              │
│                                                                                                  │
│ /Users/mathieu/.local/pipx/venvs/websockets-cli/lib/python3.13/site-packages/trio/_core/_run.py: │
│ 1070 in __aexit__                                                                                │
│                                                                                                  │
│   1067 │   │   │   # allow us to encapsulate this __context__ fixup.                             │
│   1068 │   │   │   old_context = combined_error_from_nursery.__context__                         │
│   1069 │   │   │   try:                                                                          │
│ ❱ 1070 │   │   │   │   raise combined_error_from_nursery                                         │
│   1071 │   │   │   finally:                                                                      │
│   1072 │   │   │   │   _, value, _ = sys.exc_info()                                              │
│   1073 │   │   │   │   assert value is combined_error_from_nursery                               │
│                                                                                                  │
│ ╭────────────────────────── locals ──────────────────────────╮                                   │
│ │       etype = None                                         │                                   │
│ │         exc = None                                         │                                   │
│ │ old_context = None                                         │                                   │
│ │        self = NurseryManager(strict_exception_groups=True) │                                   │
│ │          tb = None                                         │                                   │
│ ╰────────────────────────────────────────────────────────────╯                                   │
╰──────────────────────────────────────────────────────────────────────────────────────────────────╯
ExceptionGroup: Exceptions from Trio nursery (1 sub-exception)