Skip to content

Commit 93242a3

Browse files
Add token refreshed event (#534)
Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>
1 parent 26b785a commit 93242a3

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
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)