# HG changeset patch
# User Goffi <goffi@goffi.org>
# Date 1692277101 -7200
# Node ID 7dbb131bbb9e1b920b9f48c151d18aacef312d38
# Parent  84f312be53b471ae0318fc3dd13c4707a5107727
browser (calls): update status on various events (connection established, connection lost, etc.)

diff -r 84f312be53b4 -r 7dbb131bbb9e libervia/web/pages/calls/_browser/__init__.py
--- a/libervia/web/pages/calls/_browser/__init__.py	Wed Aug 16 18:34:07 2023 +0200
+++ b/libervia/web/pages/calls/_browser/__init__.py	Thu Aug 17 14:58:21 2023 +0200
@@ -14,7 +14,7 @@
 profile = window.profile or ""
 bridge = Bridge()
 GATHER_TIMEOUT = 10000
-ALLOWED_STATUSES = (None, "dialing", "ringing")
+ALLOWED_STATUSES = (None, "dialing", "ringing", "in-call", "on-hold", "connecting", "connection-lost", "reconnecting")
 AUDIO = "audio"
 VIDEO = "video"
 ALLOWED_CALL_MODES = {AUDIO, VIDEO}
@@ -27,6 +27,9 @@
     def __init__(self):
         self.webrtc = WebRTC()
         self.webrtc.screen_sharing_cb = self.on_sharing_screen
+        self.webrtc.on_connection_established_cb = self.on_connection_established
+        self.webrtc.on_reconnect_cb = self.on_reconnect
+        self.webrtc.on_connection_lost_cb = self.on_connection_lost
         self.mode = "search"
         self._status = None
         self._callee = None
@@ -203,6 +206,7 @@
             log.debug(f"Call SID: {sid}")
 
             # Answer the call
+            self.status = "connecting"
             self.switch_mode("call")
         else:
             log.info(f"your are declining the call from {peer_jid}")
@@ -275,6 +279,15 @@
             )
             return
 
+    def on_connection_established(self):
+        self.status = "in-call"
+
+    def on_reconnect(self):
+        self.status = "reconnecting"
+
+    def on_connection_lost(self):
+        self.status = "connection-lost"
+
     async def make_call(self, audio: bool = True, video: bool = True) -> None:
         """Start a WebRTC call
 
diff -r 84f312be53b4 -r 7dbb131bbb9e libervia/web/pages/calls/_browser/webrtc.py
--- a/libervia/web/pages/calls/_browser/webrtc.py	Wed Aug 16 18:34:07 2023 +0200
+++ b/libervia/web/pages/calls/_browser/webrtc.py	Thu Aug 17 14:58:21 2023 +0200
@@ -19,6 +19,9 @@
         self.reset_instance()
         bridge.register_signal("ice_candidates_new", self._on_ice_candidates_new)
         bridge.register_signal("ice_restart", self._on_ice_restart)
+        self.on_connection_established_cb = None
+        self.on_reconnect_cb = None
+        self.on_connection_lost_cb = None
         self.is_audio_muted = None
         self.is_video_muted = None
         self._is_sharing_screen = False
@@ -192,10 +195,15 @@
         state = self._peer_connection.iceConnectionState
         log.info(f"ICE Connection State changed to: {state}")
 
-        if state == "failed":
+        if state == "connected":
+            if self.on_connection_established_cb is not None:
+                self.on_connection_established_cb()
+        elif state == "failed":
             log.error("ICE connection failed. Check network connectivity and ICE configurations.")
         elif state == "disconnected":
             log.warning("ICE connection was disconnected.")
+            if self.on_connection_lost_cb is not None:
+                self.on_connection_lost_cb()
 
     def on_ice_candidate_error(self, event):
         """Log ICE error, useful for debugging"""
@@ -429,6 +437,8 @@
             log.debug(f"ignoring peer ice candidates for {sid=} ({self.sid=}).")
             return
         log.debug("ICE has been restarted")
+        if self.on_reconnect_cb is not None:
+            self.on_reconnect_cb()
 
     async def on_ice_candidates_new(self, candidates: dict) -> None:
         """Called when new ICE canidates are received from peer