Skip to content

Commit 97c018b

Browse files
committed
Add token refreshed event
1 parent 789a726 commit 97c018b

File tree

2 files changed

+11
-1
lines changed

2 files changed

+11
-1
lines changed

livekit-rtc/livekit/rtc/room.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -75,6 +75,7 @@
7575
"reconnected",
7676
"room_updated",
7777
"moved",
78+
"token_refreshed",
7879
]
7980

8081

@@ -168,6 +169,9 @@ def __init__(
168169
self._text_stream_handlers: Dict[str, TextStreamHandler] = {}
169170
self._byte_stream_handlers: Dict[str, ByteStreamHandler] = {}
170171

172+
self._token: str | None = None
173+
self._server_url: str | None = None
174+
171175
def __del__(self) -> None:
172176
if self._ffi_handle is not None:
173177
FfiClient.instance.queue.unsubscribe(self._ffi_queue)
@@ -416,6 +420,8 @@ def on_participant_connected(participant):
416420
await room.connect("ws://localhost:7880", "your_token")
417421
```
418422
"""
423+
self._server_url = url
424+
self._token = token
419425
req = proto_ffi.FfiRequest()
420426
req.connect.url = url
421427
req.connect.token = token
@@ -886,6 +892,10 @@ def _on_room_event(self, event: proto_room.RoomEvent):
886892
if participant:
887893
participant._info = info
888894

895+
elif which == "token_refreshed":
896+
self._token = event.token_refreshed.token
897+
self.emit("token_refreshed")
898+
889899
def _handle_stream_header(
890900
self, header: proto_room.DataStream.Header, participant_identity: str
891901
):

0 commit comments

Comments
 (0)