Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions livekit-rtc/livekit/rtc/_proto/participant_pb2.py

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 2 additions & 0 deletions livekit-rtc/livekit/rtc/_proto/participant_pb2.pyi

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

468 changes: 234 additions & 234 deletions livekit-rtc/livekit/rtc/_proto/room_pb2.py

Large diffs are not rendered by default.

7 changes: 5 additions & 2 deletions livekit-rtc/livekit/rtc/_proto/room_pb2.pyi

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

9 changes: 6 additions & 3 deletions livekit-rtc/livekit/rtc/room.py
Original file line number Diff line number Diff line change
Expand Up @@ -573,7 +573,9 @@ def unregister_text_stream_handler(self, topic: str):
if self._text_stream_handlers.get(topic):
self._text_stream_handlers.pop(topic)

async def disconnect(self) -> None:
async def disconnect(
self, *, reason: DisconnectReason = DisconnectReason.CLIENT_INITIATED
) -> None:
"""Disconnects from the room."""
if not self.isconnected():
return
Expand All @@ -583,6 +585,7 @@ async def disconnect(self) -> None:

req = proto_ffi.FfiRequest()
req.disconnect.room_handle = self._ffi_handle.handle # type: ignore
req.disconnect.reason = reason # type: ignore
queue = FfiClient.instance.queue.subscribe()
try:
resp = FfiClient.instance.request(req)
Expand All @@ -596,10 +599,10 @@ async def disconnect(self) -> None:
# we should manually flip the state, since the connection could have been torn down before
# the callbacks were processed
if self._connection_state != ConnectionState.CONN_DISCONNECTED:
self.local_participant._info.disconnect_reason = DisconnectReason.CLIENT_INITIATED
self.local_participant._info.disconnect_reason = reason
self._connection_state = ConnectionState.CONN_DISCONNECTED
self.emit("connection_state_changed", self._connection_state)
self.emit("disconnected", DisconnectReason.CLIENT_INITIATED)
self.emit("disconnected", reason)

async def _listen_task(self) -> None:
# listen to incoming room events
Expand Down
2 changes: 1 addition & 1 deletion livekit-rtc/rust-sdks
Submodule rust-sdks updated 35 files
+44 −11 .github/workflows/ffi-builds.yml
+22 −66 .github/workflows/node-builds.yml
+28 −88 .github/workflows/release.yml
+346 −4 Cargo.lock
+7 −4 download_ffi.py
+85 −0 knope.toml
+1 −1 livekit-api/Cargo.toml
+1 −9 livekit-api/src/access_token.rs
+3 −0 livekit-ffi-node-bindings/.gitignore
+0 −17 livekit-ffi-node-bindings/native.d.ts
+0 −584 livekit-ffi-node-bindings/native.js
+1 −1 livekit-ffi-node-bindings/npm/darwin-arm64/package.json
+1 −1 livekit-ffi-node-bindings/npm/darwin-x64/package.json
+1 −1 livekit-ffi-node-bindings/npm/linux-arm64-gnu/package.json
+1 −1 livekit-ffi-node-bindings/npm/linux-x64-gnu/package.json
+1 −1 livekit-ffi-node-bindings/npm/win32-x64-msvc/package.json
+1 −1 livekit-ffi-node-bindings/package.json
+1 −0 livekit-ffi/Cargo.toml
+1 −0 livekit-ffi/protocol/participant.proto
+1 −0 livekit-ffi/protocol/room.proto
+1 −0 livekit-ffi/src/conversion/participant.rs
+25 −0 livekit-ffi/src/conversion/room.rs
+2 −1 livekit-ffi/src/server/mod.rs
+6 −1 livekit-ffi/src/server/requests.rs
+2 −2 livekit-ffi/src/server/room.rs
+1 −1 livekit-protocol/protocol
+4 −0 livekit-protocol/src/livekit.rs
+3 −0 livekit-protocol/src/livekit.serde.rs
+21 −0 livekit/build.rs
+25 −0 livekit/src/proto.rs
+4 −0 livekit/src/room/mod.rs
+1 −0 livekit/src/room/participant/mod.rs
+2 −2 livekit/src/rtc_engine/mod.rs
+4 −4 livekit/src/rtc_engine/rtc_session.rs
+0 −95 release-plz.toml