GitHub Actions commited on
Commit
bc0c2ea
·
1 Parent(s): ff86593

fix: self-join relay synchronously (App has no add_event_handler)

Browse files
Files changed (1) hide show
  1. app.py +16 -19
app.py CHANGED
@@ -504,25 +504,22 @@ if _webagent_dir.exists():
504
 
505
  # Auto-join: the Space node registers itself in its own relay hub
506
  # so remote nodes that connect see it in the roster immediately.
507
- async def _self_join_relay() -> None:
508
- try:
509
- caps = [
510
- f"{e.descriptor.name}@{e.descriptor.version[0]}.{e.descriptor.version[1]}"
511
- for e in _node.bus.registry.all_local()
512
- ]
513
- nid = getattr(_node, "node_id_full", _node.node_id)
514
- _relay_hub.join(
515
- nid,
516
- display_name=_node.display_name,
517
- community_id=_node.community_id,
518
- capabilities=caps,
519
- endpoint="",
520
- )
521
- print(f"[hearthnet] Space node '{_node.display_name}' joined local relay hub")
522
- except Exception as _je:
523
- print(f"[hearthnet] self-join relay failed: {_je}")
524
-
525
- result.add_event_handler("startup", _self_join_relay)
526
  return result
527
 
528
  _gr_routes.App.create_app = staticmethod(_patched_create_app)
 
504
 
505
  # Auto-join: the Space node registers itself in its own relay hub
506
  # so remote nodes that connect see it in the roster immediately.
507
+ try:
508
+ _caps = [
509
+ f"{e.descriptor.name}@{e.descriptor.version[0]}.{e.descriptor.version[1]}"
510
+ for e in _node.bus.registry.all_local()
511
+ ]
512
+ _nid = getattr(_node, "node_id_full", _node.node_id)
513
+ _relay_hub.join(
514
+ _nid,
515
+ display_name=_node.display_name,
516
+ community_id=_node.community_id,
517
+ capabilities=_caps,
518
+ endpoint="",
519
+ )
520
+ print(f"[hearthnet] Space node '{_node.display_name}' joined local relay hub")
521
+ except Exception as _je:
522
+ print(f"[hearthnet] self-join relay failed: {_je}")
 
 
 
523
  return result
524
 
525
  _gr_routes.App.create_app = staticmethod(_patched_create_app)