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
2 changes: 1 addition & 1 deletion livekit-protocol/protocol
Submodule protocol updated 50 files
+5 −0 .changeset/free-moles-hug.md
+5 −0 .changeset/heavy-scissors-hear.md
+5 −0 .changeset/violet-kings-compare.md
+5 −0 .changeset/wet-peaches-check.md
+3 −0 auth/grants.go
+226 −0 codecs/codecs.go
+365 −0 codecs/mime/mimetype.go
+1 −1 infra/link_grpc.pb.go
+1 −1 livekit/agent/livekit_agent_session.pb.go
+153 −49 livekit/livekit_agent.pb.go
+42 −20 livekit/livekit_ingress.pb.go
+101 −98 livekit/livekit_ingress.twirp.go
+42 −12 livekit/livekit_models.pb.go
+1 −1 livekit/livekit_phone_number.pb.go
+77 −76 livekit/livekit_phone_number.twirp.go
+1 −1 livekit/logger/options.pb.go
+130 −0 livekit/types.go
+365 −0 mimetype/mimetype.go
+1 −1 observability/agentsobs/gen_reporter.go
+1 −1 observability/egressobs/gen_reporter.go
+1 −1 observability/gatewayobs/gen_reporter.go
+63 −0 observability/ingressobs/gen_reporter.go
+87 −0 observability/ingressobs/gen_reporter_noop.go
+33 −0 observability/ingressobs/gen_source.go
+18 −2 observability/reporter.go
+1 −1 observability/roomobs/gen_reporter.go
+46 −0 observability/storageobs/gen_reporter.go
+64 −0 observability/storageobs/gen_reporter_noop.go
+25 −0 observability/storageobs/gen_source.go
+75 −0 observability/telephonycallobs/gen_reporter.go
+93 −0 observability/telephonycallobs/gen_reporter_noop.go
+59 −0 observability/telephonycallobs/gen_source.go
+1 −1 observability/telephonyobs/gen_reporter.go
+2 −0 protobufs/agent/livekit_agent_session.proto
+10 −2 protobufs/livekit_agent.proto
+4 −0 protobufs/livekit_ingress.proto
+9 −2 protobufs/livekit_models.proto
+2 −0 protobufs/livekit_phone_number.proto
+2 −0 protobufs/logger/options.proto
+0 −10 protobufs/rpc/ingress.proto
+31 −25 protobufs/rpc/io.proto
+7 −1 protobufs/rpc/sip.proto
+1 −1 rpc/analytics_grpc.pb.go
+18 −22 rpc/ingress.pb.go
+59 −85 rpc/ingress.psrpc.go
+121 −82 rpc/io.pb.go
+129 −126 rpc/io.psrpc.go
+65 −35 rpc/sip.pb.go
+76 −72 rpc/sip.psrpc.go
+11 −10 utils/hwstats/cpu.go
41 changes: 37 additions & 4 deletions livekit-protocol/src/livekit.rs
Original file line number Diff line number Diff line change
Expand Up @@ -319,6 +319,9 @@ pub struct ParticipantPermission {
/// if a participant can subscribe to metrics
#[prost(bool, tag="12")]
pub can_subscribe_metrics: bool,
/// if a participant can manage an agent session via RemoteSession (control and access state)
#[prost(bool, tag="13")]
pub can_manage_agent_session: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
Expand Down Expand Up @@ -361,6 +364,9 @@ pub struct ParticipantInfo {
pub kind_details: ::prost::alloc::vec::Vec<i32>,
#[prost(message, repeated, tag="19")]
pub data_tracks: ::prost::alloc::vec::Vec<DataTrackInfo>,
/// protocol version used for client feature compatibility
#[prost(int32, tag="20")]
pub client_protocol: i32,
}
/// Nested message and enum types in `ParticipantInfo`.
pub mod participant_info {
Expand Down Expand Up @@ -1063,6 +1069,9 @@ pub struct ClientInfo {
/// e.g. "components-js:1.2.3,track-processors-js:1.2.3"
#[prost(string, tag="11")]
pub other_sdks: ::prost::alloc::string::String,
/// client protocol version
#[prost(int32, tag="12")]
pub client_protocol: i32,
}
/// Nested message and enum types in `ClientInfo`.
pub mod client_info {
Expand Down Expand Up @@ -4423,6 +4432,25 @@ pub struct JobTermination {
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AgentSessionState {
#[prost(uint64, tag="1")]
pub version: u64,
#[prost(oneof="agent_session_state::Data", tags="2, 3")]
pub data: ::core::option::Option<agent_session_state::Data>,
}
/// Nested message and enum types in `AgentSessionState`.
pub mod agent_session_state {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Data {
#[prost(bytes, tag="2")]
Snapshot(::prost::alloc::vec::Vec<u8>),
#[prost(bytes, tag="3")]
Delta(::prost::alloc::vec::Vec<u8>),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TextMessageRequest {
#[prost(string, tag="1")]
pub message_id: ::prost::alloc::string::String,
Expand All @@ -4432,8 +4460,8 @@ pub struct TextMessageRequest {
pub agent_name: ::prost::alloc::string::String,
#[prost(string, tag="4")]
pub metadata: ::prost::alloc::string::String,
#[prost(bytes="vec", tag="5")]
pub session_data: ::prost::alloc::vec::Vec<u8>,
#[prost(message, optional, tag="5")]
pub session_state: ::core::option::Option<AgentSessionState>,
#[prost(string, tag="6")]
pub text: ::prost::alloc::string::String,
}
Expand All @@ -4452,8 +4480,8 @@ pub struct TextMessageResponse {
/// Indicate the request is completed
#[prost(string, tag="1")]
pub message_id: ::prost::alloc::string::String,
#[prost(bytes="vec", tag="2")]
pub session_data: ::prost::alloc::vec::Vec<u8>,
#[prost(message, optional, tag="2")]
pub session_state: ::core::option::Option<AgentSessionState>,
#[prost(string, tag="3")]
pub error: ::prost::alloc::string::String,
}
Expand Down Expand Up @@ -5181,6 +5209,8 @@ pub struct UpdateIngressRequest {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListIngressRequest {
#[prost(message, optional, tag="3")]
pub page_token: ::core::option::Option<TokenPagination>,
/// when blank, lists all ingress endpoints
///
/// (optional, filter by room name)
Expand All @@ -5193,6 +5223,9 @@ pub struct ListIngressRequest {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListIngressResponse {
#[prost(message, optional, tag="2")]
pub next_page_token: ::core::option::Option<TokenPagination>,
/// next field id: 3
#[prost(message, repeated, tag="1")]
pub items: ::prost::alloc::vec::Vec<IngressInfo>,
}
Expand Down
Loading