From 851e30395d43fbd8706334cfba8b59fa9ff10f82 Mon Sep 17 00:00:00 2001 From: Paul Wells Date: Mon, 8 Sep 2025 10:39:26 -0700 Subject: [PATCH 1/5] add recording store request header --- infra/link.pb.go | 4 +- infra/link_grpc.pb.go | 2 +- livekit/livekit_agent.pb.go | 4 +- livekit/livekit_agent_dispatch.pb.go | 4 +- livekit/livekit_analytics.pb.go | 4 +- livekit/livekit_cloud_agent.pb.go | 4 +- livekit/livekit_egress.pb.go | 4 +- livekit/livekit_ingress.pb.go | 4 +- livekit/livekit_internal.pb.go | 4 +- livekit/livekit_metrics.pb.go | 150 +++++++++++++++++++++++---- livekit/livekit_models.pb.go | 4 +- livekit/livekit_phone_number.pb.go | 4 +- livekit/livekit_room.pb.go | 4 +- livekit/livekit_rtc.pb.go | 4 +- livekit/livekit_sip.pb.go | 4 +- livekit/livekit_webhook.pb.go | 4 +- protobufs/livekit_metrics.proto | 11 +- replay/cloud_replay.pb.go | 4 +- rpc/agent.pb.go | 4 +- rpc/agent_dispatch.pb.go | 4 +- rpc/analytics.pb.go | 4 +- rpc/analytics_grpc.pb.go | 2 +- rpc/egress.pb.go | 4 +- rpc/ingress.pb.go | 4 +- rpc/io.pb.go | 4 +- rpc/keepalive.pb.go | 4 +- rpc/participant.pb.go | 4 +- rpc/room.pb.go | 4 +- rpc/roommanager.pb.go | 4 +- rpc/signal.pb.go | 4 +- rpc/sip.pb.go | 4 +- rpc/whip_signal.pb.go | 4 +- utils/guid/id.go | 7 ++ utils/guid/id_test.go | 9 ++ 34 files changed, 214 insertions(+), 79 deletions(-) diff --git a/infra/link.pb.go b/infra/link.pb.go index 40e1c24cb..a6f0840ff 100644 --- a/infra/link.pb.go +++ b/infra/link.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: infra/link.proto package infra diff --git a/infra/link_grpc.pb.go b/infra/link_grpc.pb.go index 281cec953..6cacc86d2 100644 --- a/infra/link_grpc.pb.go +++ b/infra/link_grpc.pb.go @@ -15,7 +15,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.5.1 -// - protoc v4.23.4 +// - protoc v5.29.3 // source: infra/link.proto package infra diff --git a/livekit/livekit_agent.pb.go b/livekit/livekit_agent.pb.go index 205de50bd..56e72258b 100644 --- a/livekit/livekit_agent.pb.go +++ b/livekit/livekit_agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_agent.proto package livekit diff --git a/livekit/livekit_agent_dispatch.pb.go b/livekit/livekit_agent_dispatch.pb.go index e4ec23b56..a61bc8d29 100644 --- a/livekit/livekit_agent_dispatch.pb.go +++ b/livekit/livekit_agent_dispatch.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_agent_dispatch.proto package livekit diff --git a/livekit/livekit_analytics.pb.go b/livekit/livekit_analytics.pb.go index b988e5cc1..2cb4a2600 100644 --- a/livekit/livekit_analytics.pb.go +++ b/livekit/livekit_analytics.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_analytics.proto package livekit diff --git a/livekit/livekit_cloud_agent.pb.go b/livekit/livekit_cloud_agent.pb.go index 2d9bf96fc..414cbfaaa 100644 --- a/livekit/livekit_cloud_agent.pb.go +++ b/livekit/livekit_cloud_agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_cloud_agent.proto package livekit diff --git a/livekit/livekit_egress.pb.go b/livekit/livekit_egress.pb.go index 82947f286..f441a683f 100644 --- a/livekit/livekit_egress.pb.go +++ b/livekit/livekit_egress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_egress.proto package livekit diff --git a/livekit/livekit_ingress.pb.go b/livekit/livekit_ingress.pb.go index 0a12d0c30..5fbd44029 100644 --- a/livekit/livekit_ingress.pb.go +++ b/livekit/livekit_ingress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_ingress.proto package livekit diff --git a/livekit/livekit_internal.pb.go b/livekit/livekit_internal.pb.go index 048210dc8..b31f40e5c 100644 --- a/livekit/livekit_internal.pb.go +++ b/livekit/livekit_internal.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_internal.proto package livekit diff --git a/livekit/livekit_metrics.pb.go b/livekit/livekit_metrics.pb.go index a84fa761d..e6e8accf1 100644 --- a/livekit/livekit_metrics.pb.go +++ b/livekit/livekit_metrics.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_metrics.proto package livekit @@ -454,6 +454,102 @@ func (x *EventMetric) GetRid() uint32 { return 0 } +type MetricsRecordingHeader struct { + state protoimpl.MessageState `protogen:"open.v1"` + RoomId string `protobuf:"bytes,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"` + Parts map[string]*MetricsRecordingHeader_Part `protobuf:"bytes,2,rep,name=parts,proto3" json:"parts,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *MetricsRecordingHeader) Reset() { + *x = MetricsRecordingHeader{} + mi := &file_livekit_metrics_proto_msgTypes[4] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *MetricsRecordingHeader) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MetricsRecordingHeader) ProtoMessage() {} + +func (x *MetricsRecordingHeader) ProtoReflect() protoreflect.Message { + mi := &file_livekit_metrics_proto_msgTypes[4] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use MetricsRecordingHeader.ProtoReflect.Descriptor instead. +func (*MetricsRecordingHeader) Descriptor() ([]byte, []int) { + return file_livekit_metrics_proto_rawDescGZIP(), []int{4} +} + +func (x *MetricsRecordingHeader) GetRoomId() string { + if x != nil { + return x.RoomId + } + return "" +} + +func (x *MetricsRecordingHeader) GetParts() map[string]*MetricsRecordingHeader_Part { + if x != nil { + return x.Parts + } + return nil +} + +type MetricsRecordingHeader_Part struct { + state protoimpl.MessageState `protogen:"open.v1"` + ContentLength uint32 `protobuf:"varint,1,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *MetricsRecordingHeader_Part) Reset() { + *x = MetricsRecordingHeader_Part{} + mi := &file_livekit_metrics_proto_msgTypes[5] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *MetricsRecordingHeader_Part) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MetricsRecordingHeader_Part) ProtoMessage() {} + +func (x *MetricsRecordingHeader_Part) ProtoReflect() protoreflect.Message { + mi := &file_livekit_metrics_proto_msgTypes[5] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use MetricsRecordingHeader_Part.ProtoReflect.Descriptor instead. +func (*MetricsRecordingHeader_Part) Descriptor() ([]byte, []int) { + return file_livekit_metrics_proto_rawDescGZIP(), []int{4, 0} +} + +func (x *MetricsRecordingHeader_Part) GetContentLength() uint32 { + if x != nil { + return x.ContentLength + } + return 0 +} + var File_livekit_metrics_proto protoreflect.FileDescriptor const file_livekit_metrics_proto_rawDesc = "" + @@ -487,7 +583,16 @@ const file_livekit_metrics_proto_rawDesc = "" + "\bmetadata\x18\b \x01(\tR\bmetadata\x12\x10\n" + "\x03rid\x18\t \x01(\rR\x03ridB\x13\n" + "\x11_end_timestamp_msB\x1b\n" + - "\x19_normalized_end_timestamp*\x81\a\n" + + "\x19_normalized_end_timestamp\"\x82\x02\n" + + "\x16MetricsRecordingHeader\x12\x17\n" + + "\aroom_id\x18\x01 \x01(\tR\x06roomId\x12@\n" + + "\x05parts\x18\x02 \x03(\v2*.livekit.MetricsRecordingHeader.PartsEntryR\x05parts\x1a-\n" + + "\x04Part\x12%\n" + + "\x0econtent_length\x18\x01 \x01(\rR\rcontentLength\x1a^\n" + + "\n" + + "PartsEntry\x12\x10\n" + + "\x03key\x18\x01 \x01(\tR\x03key\x12:\n" + + "\x05value\x18\x02 \x01(\v2$.livekit.MetricsRecordingHeader.PartR\x05value:\x028\x01*\x81\a\n" + "\vMetricLabel\x12\x13\n" + "\x0fAGENTS_LLM_TTFT\x10\x00\x12\x13\n" + "\x0fAGENTS_STT_TTFT\x10\x01\x12\x13\n" + @@ -525,28 +630,33 @@ func file_livekit_metrics_proto_rawDescGZIP() []byte { } var file_livekit_metrics_proto_enumTypes = make([]protoimpl.EnumInfo, 1) -var file_livekit_metrics_proto_msgTypes = make([]protoimpl.MessageInfo, 4) +var file_livekit_metrics_proto_msgTypes = make([]protoimpl.MessageInfo, 7) var file_livekit_metrics_proto_goTypes = []any{ - (MetricLabel)(0), // 0: livekit.MetricLabel - (*MetricsBatch)(nil), // 1: livekit.MetricsBatch - (*TimeSeriesMetric)(nil), // 2: livekit.TimeSeriesMetric - (*MetricSample)(nil), // 3: livekit.MetricSample - (*EventMetric)(nil), // 4: livekit.EventMetric - (*timestamppb.Timestamp)(nil), // 5: google.protobuf.Timestamp + (MetricLabel)(0), // 0: livekit.MetricLabel + (*MetricsBatch)(nil), // 1: livekit.MetricsBatch + (*TimeSeriesMetric)(nil), // 2: livekit.TimeSeriesMetric + (*MetricSample)(nil), // 3: livekit.MetricSample + (*EventMetric)(nil), // 4: livekit.EventMetric + (*MetricsRecordingHeader)(nil), // 5: livekit.MetricsRecordingHeader + (*MetricsRecordingHeader_Part)(nil), // 6: livekit.MetricsRecordingHeader.Part + nil, // 7: livekit.MetricsRecordingHeader.PartsEntry + (*timestamppb.Timestamp)(nil), // 8: google.protobuf.Timestamp } var file_livekit_metrics_proto_depIdxs = []int32{ - 5, // 0: livekit.MetricsBatch.normalized_timestamp:type_name -> google.protobuf.Timestamp + 8, // 0: livekit.MetricsBatch.normalized_timestamp:type_name -> google.protobuf.Timestamp 2, // 1: livekit.MetricsBatch.time_series:type_name -> livekit.TimeSeriesMetric 4, // 2: livekit.MetricsBatch.events:type_name -> livekit.EventMetric 3, // 3: livekit.TimeSeriesMetric.samples:type_name -> livekit.MetricSample - 5, // 4: livekit.MetricSample.normalized_timestamp:type_name -> google.protobuf.Timestamp - 5, // 5: livekit.EventMetric.normalized_start_timestamp:type_name -> google.protobuf.Timestamp - 5, // 6: livekit.EventMetric.normalized_end_timestamp:type_name -> google.protobuf.Timestamp - 7, // [7:7] is the sub-list for method output_type - 7, // [7:7] is the sub-list for method input_type - 7, // [7:7] is the sub-list for extension type_name - 7, // [7:7] is the sub-list for extension extendee - 0, // [0:7] is the sub-list for field type_name + 8, // 4: livekit.MetricSample.normalized_timestamp:type_name -> google.protobuf.Timestamp + 8, // 5: livekit.EventMetric.normalized_start_timestamp:type_name -> google.protobuf.Timestamp + 8, // 6: livekit.EventMetric.normalized_end_timestamp:type_name -> google.protobuf.Timestamp + 7, // 7: livekit.MetricsRecordingHeader.parts:type_name -> livekit.MetricsRecordingHeader.PartsEntry + 6, // 8: livekit.MetricsRecordingHeader.PartsEntry.value:type_name -> livekit.MetricsRecordingHeader.Part + 9, // [9:9] is the sub-list for method output_type + 9, // [9:9] is the sub-list for method input_type + 9, // [9:9] is the sub-list for extension type_name + 9, // [9:9] is the sub-list for extension extendee + 0, // [0:9] is the sub-list for field type_name } func init() { file_livekit_metrics_proto_init() } @@ -561,7 +671,7 @@ func file_livekit_metrics_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: unsafe.Slice(unsafe.StringData(file_livekit_metrics_proto_rawDesc), len(file_livekit_metrics_proto_rawDesc)), NumEnums: 1, - NumMessages: 4, + NumMessages: 7, NumExtensions: 0, NumServices: 0, }, diff --git a/livekit/livekit_models.pb.go b/livekit/livekit_models.pb.go index ee8b80a43..e85882ccd 100644 --- a/livekit/livekit_models.pb.go +++ b/livekit/livekit_models.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_models.proto package livekit diff --git a/livekit/livekit_phone_number.pb.go b/livekit/livekit_phone_number.pb.go index 43bcdadd8..9f0cf3564 100644 --- a/livekit/livekit_phone_number.pb.go +++ b/livekit/livekit_phone_number.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_phone_number.proto package livekit diff --git a/livekit/livekit_room.pb.go b/livekit/livekit_room.pb.go index 76e56a6ce..5d1972a00 100644 --- a/livekit/livekit_room.pb.go +++ b/livekit/livekit_room.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_room.proto package livekit diff --git a/livekit/livekit_rtc.pb.go b/livekit/livekit_rtc.pb.go index 6c19398ef..823e32d23 100644 --- a/livekit/livekit_rtc.pb.go +++ b/livekit/livekit_rtc.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_rtc.proto package livekit diff --git a/livekit/livekit_sip.pb.go b/livekit/livekit_sip.pb.go index 41f557d83..8f3f942a5 100644 --- a/livekit/livekit_sip.pb.go +++ b/livekit/livekit_sip.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_sip.proto package livekit diff --git a/livekit/livekit_webhook.pb.go b/livekit/livekit_webhook.pb.go index 02c479aad..f14b4a41b 100644 --- a/livekit/livekit_webhook.pb.go +++ b/livekit/livekit_webhook.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_webhook.proto package livekit diff --git a/protobufs/livekit_metrics.proto b/protobufs/livekit_metrics.proto index 6ac497596..cc6c3502b 100644 --- a/protobufs/livekit_metrics.proto +++ b/protobufs/livekit_metrics.proto @@ -53,7 +53,7 @@ message MetricsBatch { // This is useful for storing participant identities, track names, etc. // There is also a predefined list of labels that can be used to reference common metrics. // They have reserved indices from 0 to (METRIC_LABEL_PREDEFINED_MAX_VALUE - 1). - // Indexes pointing at str_data should start from METRIC_LABEL_PREDEFINED_MAX_VALUE, + // Indexes pointing at str_data should start from METRIC_LABEL_PREDEFINED_MAX_VALUE, // such that str_data[0] == index of METRIC_LABEL_PREDEFINED_MAX_VALUE. repeated string str_data = 3; repeated TimeSeriesMetric time_series = 4; @@ -87,3 +87,12 @@ message EventMetric { string metadata = 8; uint32 rid = 9; // index into 'str_data' } + +message MetricsRecordingHeader { + message Part { + uint32 content_length = 1; + } + + string room_id = 1; + map parts = 2; +} diff --git a/replay/cloud_replay.pb.go b/replay/cloud_replay.pb.go index 1d7635c7d..25326c20d 100644 --- a/replay/cloud_replay.pb.go +++ b/replay/cloud_replay.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: cloud_replay.proto package replay diff --git a/rpc/agent.pb.go b/rpc/agent.pb.go index aea574ef5..71db5934a 100644 --- a/rpc/agent.pb.go +++ b/rpc/agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/agent.proto package rpc diff --git a/rpc/agent_dispatch.pb.go b/rpc/agent_dispatch.pb.go index 13028ff37..c06b3631f 100644 --- a/rpc/agent_dispatch.pb.go +++ b/rpc/agent_dispatch.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/agent_dispatch.proto package rpc diff --git a/rpc/analytics.pb.go b/rpc/analytics.pb.go index 8e97f206a..655d51ae0 100644 --- a/rpc/analytics.pb.go +++ b/rpc/analytics.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/analytics.proto package rpc diff --git a/rpc/analytics_grpc.pb.go b/rpc/analytics_grpc.pb.go index 6217bb431..f59684f38 100644 --- a/rpc/analytics_grpc.pb.go +++ b/rpc/analytics_grpc.pb.go @@ -15,7 +15,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.5.1 -// - protoc v4.23.4 +// - protoc v5.29.3 // source: rpc/analytics.proto package rpc diff --git a/rpc/egress.pb.go b/rpc/egress.pb.go index a1b382858..cd5d763ae 100644 --- a/rpc/egress.pb.go +++ b/rpc/egress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/egress.proto package rpc diff --git a/rpc/ingress.pb.go b/rpc/ingress.pb.go index ff707bbac..3bbeca0e5 100644 --- a/rpc/ingress.pb.go +++ b/rpc/ingress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/ingress.proto package rpc diff --git a/rpc/io.pb.go b/rpc/io.pb.go index bfed9dae2..767b3fa71 100644 --- a/rpc/io.pb.go +++ b/rpc/io.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/io.proto package rpc diff --git a/rpc/keepalive.pb.go b/rpc/keepalive.pb.go index 4325587ce..e5509237f 100644 --- a/rpc/keepalive.pb.go +++ b/rpc/keepalive.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/keepalive.proto package rpc diff --git a/rpc/participant.pb.go b/rpc/participant.pb.go index d6cabcf3e..36920980a 100644 --- a/rpc/participant.pb.go +++ b/rpc/participant.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/participant.proto package rpc diff --git a/rpc/room.pb.go b/rpc/room.pb.go index df41b8b8f..95468f44a 100644 --- a/rpc/room.pb.go +++ b/rpc/room.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/room.proto package rpc diff --git a/rpc/roommanager.pb.go b/rpc/roommanager.pb.go index a447b0bf3..5b3a7b365 100644 --- a/rpc/roommanager.pb.go +++ b/rpc/roommanager.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/roommanager.proto package rpc diff --git a/rpc/signal.pb.go b/rpc/signal.pb.go index 65f9bf05d..26d310469 100644 --- a/rpc/signal.pb.go +++ b/rpc/signal.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/signal.proto package rpc diff --git a/rpc/sip.pb.go b/rpc/sip.pb.go index d48be7de3..fa65dd2ba 100644 --- a/rpc/sip.pb.go +++ b/rpc/sip.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/sip.proto package rpc diff --git a/rpc/whip_signal.pb.go b/rpc/whip_signal.pb.go index c8365aade..09250c2cb 100644 --- a/rpc/whip_signal.pb.go +++ b/rpc/whip_signal.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.8 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/whip_signal.proto package rpc diff --git a/utils/guid/id.go b/utils/guid/id.go index 68ebba0d9..703d39e16 100644 --- a/utils/guid/id.go +++ b/utils/guid/id.go @@ -21,6 +21,7 @@ import ( "fmt" mrand "math/rand/v2" "os" + "regexp" "sync" "unsafe" @@ -197,3 +198,9 @@ func Unmarshal[T livekit.Guid](b livekit.GuidBlock) T { } return T(unsafe.String(unsafe.SliceData(id), len(id))) } + +var validIDPattern = regexp.MustCompile(`^([a-zA-Z0-9]{1,16}_){1,2}[a-zA-Z0-9]{0,12}$`) + +func IsValidID[T ~string](id T) bool { + return validIDPattern.MatchString(string(id)) +} diff --git a/utils/guid/id_test.go b/utils/guid/id_test.go index c322e3f5c..e80b932e1 100644 --- a/utils/guid/id_test.go +++ b/utils/guid/id_test.go @@ -55,3 +55,12 @@ func BenchmarkNew(b *testing.B) { _ = guid }) } + +func TestIsValidID(t *testing.T) { + require.True(t, IsValidID("A_SFo4igEG5Dg5")) + require.True(t, IsValidID("NM_OJOHANNESBURG1A_K6SMQw2ZCZyB")) + require.False(t, IsValidID("A_A_A_SFo4igEG5Dg5")) + require.False(t, IsValidID("_A_SFo4igEG5Dg5")) + require.False(t, IsValidID("_SFo4igEG5Dg5")) + require.False(t, IsValidID("SFo4igEG5Dg5")) +} From af8c64d985b7e92beae9d25c514f1b8b4bae7e63 Mon Sep 17 00:00:00 2001 From: github-actions <41898282+github-actions[bot]@users.noreply.github.com> Date: Mon, 8 Sep 2025 17:40:50 +0000 Subject: [PATCH 2/5] generated protobuf --- infra/link.pb.go | 4 ++-- infra/link_grpc.pb.go | 2 +- livekit/livekit_agent.pb.go | 4 ++-- livekit/livekit_agent_dispatch.pb.go | 4 ++-- livekit/livekit_analytics.pb.go | 4 ++-- livekit/livekit_cloud_agent.pb.go | 4 ++-- livekit/livekit_egress.pb.go | 4 ++-- livekit/livekit_ingress.pb.go | 4 ++-- livekit/livekit_internal.pb.go | 4 ++-- livekit/livekit_metrics.pb.go | 4 ++-- livekit/livekit_models.pb.go | 4 ++-- livekit/livekit_phone_number.pb.go | 4 ++-- livekit/livekit_room.pb.go | 4 ++-- livekit/livekit_rtc.pb.go | 4 ++-- livekit/livekit_sip.pb.go | 4 ++-- livekit/livekit_webhook.pb.go | 4 ++-- replay/cloud_replay.pb.go | 4 ++-- rpc/agent.pb.go | 4 ++-- rpc/agent_dispatch.pb.go | 4 ++-- rpc/analytics.pb.go | 4 ++-- rpc/analytics_grpc.pb.go | 2 +- rpc/egress.pb.go | 4 ++-- rpc/ingress.pb.go | 4 ++-- rpc/io.pb.go | 4 ++-- rpc/keepalive.pb.go | 4 ++-- rpc/participant.pb.go | 4 ++-- rpc/room.pb.go | 4 ++-- rpc/roommanager.pb.go | 4 ++-- rpc/signal.pb.go | 4 ++-- rpc/sip.pb.go | 4 ++-- rpc/whip_signal.pb.go | 4 ++-- 31 files changed, 60 insertions(+), 60 deletions(-) diff --git a/infra/link.pb.go b/infra/link.pb.go index a6f0840ff..40e1c24cb 100644 --- a/infra/link.pb.go +++ b/infra/link.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: infra/link.proto package infra diff --git a/infra/link_grpc.pb.go b/infra/link_grpc.pb.go index 6cacc86d2..281cec953 100644 --- a/infra/link_grpc.pb.go +++ b/infra/link_grpc.pb.go @@ -15,7 +15,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.5.1 -// - protoc v5.29.3 +// - protoc v4.23.4 // source: infra/link.proto package infra diff --git a/livekit/livekit_agent.pb.go b/livekit/livekit_agent.pb.go index 56e72258b..205de50bd 100644 --- a/livekit/livekit_agent.pb.go +++ b/livekit/livekit_agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: livekit_agent.proto package livekit diff --git a/livekit/livekit_agent_dispatch.pb.go b/livekit/livekit_agent_dispatch.pb.go index a61bc8d29..e4ec23b56 100644 --- a/livekit/livekit_agent_dispatch.pb.go +++ b/livekit/livekit_agent_dispatch.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: livekit_agent_dispatch.proto package livekit diff --git a/livekit/livekit_analytics.pb.go b/livekit/livekit_analytics.pb.go index 2cb4a2600..b988e5cc1 100644 --- a/livekit/livekit_analytics.pb.go +++ b/livekit/livekit_analytics.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: livekit_analytics.proto package livekit diff --git a/livekit/livekit_cloud_agent.pb.go b/livekit/livekit_cloud_agent.pb.go index 414cbfaaa..2d9bf96fc 100644 --- a/livekit/livekit_cloud_agent.pb.go +++ b/livekit/livekit_cloud_agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: livekit_cloud_agent.proto package livekit diff --git a/livekit/livekit_egress.pb.go b/livekit/livekit_egress.pb.go index f441a683f..82947f286 100644 --- a/livekit/livekit_egress.pb.go +++ b/livekit/livekit_egress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: livekit_egress.proto package livekit diff --git a/livekit/livekit_ingress.pb.go b/livekit/livekit_ingress.pb.go index 5fbd44029..0a12d0c30 100644 --- a/livekit/livekit_ingress.pb.go +++ b/livekit/livekit_ingress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: livekit_ingress.proto package livekit diff --git a/livekit/livekit_internal.pb.go b/livekit/livekit_internal.pb.go index b31f40e5c..048210dc8 100644 --- a/livekit/livekit_internal.pb.go +++ b/livekit/livekit_internal.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: livekit_internal.proto package livekit diff --git a/livekit/livekit_metrics.pb.go b/livekit/livekit_metrics.pb.go index e6e8accf1..b6c24387f 100644 --- a/livekit/livekit_metrics.pb.go +++ b/livekit/livekit_metrics.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: livekit_metrics.proto package livekit diff --git a/livekit/livekit_models.pb.go b/livekit/livekit_models.pb.go index e85882ccd..ee8b80a43 100644 --- a/livekit/livekit_models.pb.go +++ b/livekit/livekit_models.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: livekit_models.proto package livekit diff --git a/livekit/livekit_phone_number.pb.go b/livekit/livekit_phone_number.pb.go index 9f0cf3564..43bcdadd8 100644 --- a/livekit/livekit_phone_number.pb.go +++ b/livekit/livekit_phone_number.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: livekit_phone_number.proto package livekit diff --git a/livekit/livekit_room.pb.go b/livekit/livekit_room.pb.go index 5d1972a00..76e56a6ce 100644 --- a/livekit/livekit_room.pb.go +++ b/livekit/livekit_room.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: livekit_room.proto package livekit diff --git a/livekit/livekit_rtc.pb.go b/livekit/livekit_rtc.pb.go index 823e32d23..6c19398ef 100644 --- a/livekit/livekit_rtc.pb.go +++ b/livekit/livekit_rtc.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: livekit_rtc.proto package livekit diff --git a/livekit/livekit_sip.pb.go b/livekit/livekit_sip.pb.go index 8f3f942a5..41f557d83 100644 --- a/livekit/livekit_sip.pb.go +++ b/livekit/livekit_sip.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: livekit_sip.proto package livekit diff --git a/livekit/livekit_webhook.pb.go b/livekit/livekit_webhook.pb.go index f14b4a41b..02c479aad 100644 --- a/livekit/livekit_webhook.pb.go +++ b/livekit/livekit_webhook.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: livekit_webhook.proto package livekit diff --git a/replay/cloud_replay.pb.go b/replay/cloud_replay.pb.go index 25326c20d..1d7635c7d 100644 --- a/replay/cloud_replay.pb.go +++ b/replay/cloud_replay.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: cloud_replay.proto package replay diff --git a/rpc/agent.pb.go b/rpc/agent.pb.go index 71db5934a..aea574ef5 100644 --- a/rpc/agent.pb.go +++ b/rpc/agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: rpc/agent.proto package rpc diff --git a/rpc/agent_dispatch.pb.go b/rpc/agent_dispatch.pb.go index c06b3631f..13028ff37 100644 --- a/rpc/agent_dispatch.pb.go +++ b/rpc/agent_dispatch.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: rpc/agent_dispatch.proto package rpc diff --git a/rpc/analytics.pb.go b/rpc/analytics.pb.go index 655d51ae0..8e97f206a 100644 --- a/rpc/analytics.pb.go +++ b/rpc/analytics.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: rpc/analytics.proto package rpc diff --git a/rpc/analytics_grpc.pb.go b/rpc/analytics_grpc.pb.go index f59684f38..6217bb431 100644 --- a/rpc/analytics_grpc.pb.go +++ b/rpc/analytics_grpc.pb.go @@ -15,7 +15,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.5.1 -// - protoc v5.29.3 +// - protoc v4.23.4 // source: rpc/analytics.proto package rpc diff --git a/rpc/egress.pb.go b/rpc/egress.pb.go index cd5d763ae..a1b382858 100644 --- a/rpc/egress.pb.go +++ b/rpc/egress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: rpc/egress.proto package rpc diff --git a/rpc/ingress.pb.go b/rpc/ingress.pb.go index 3bbeca0e5..ff707bbac 100644 --- a/rpc/ingress.pb.go +++ b/rpc/ingress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: rpc/ingress.proto package rpc diff --git a/rpc/io.pb.go b/rpc/io.pb.go index 767b3fa71..bfed9dae2 100644 --- a/rpc/io.pb.go +++ b/rpc/io.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: rpc/io.proto package rpc diff --git a/rpc/keepalive.pb.go b/rpc/keepalive.pb.go index e5509237f..4325587ce 100644 --- a/rpc/keepalive.pb.go +++ b/rpc/keepalive.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: rpc/keepalive.proto package rpc diff --git a/rpc/participant.pb.go b/rpc/participant.pb.go index 36920980a..d6cabcf3e 100644 --- a/rpc/participant.pb.go +++ b/rpc/participant.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: rpc/participant.proto package rpc diff --git a/rpc/room.pb.go b/rpc/room.pb.go index 95468f44a..df41b8b8f 100644 --- a/rpc/room.pb.go +++ b/rpc/room.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: rpc/room.proto package rpc diff --git a/rpc/roommanager.pb.go b/rpc/roommanager.pb.go index 5b3a7b365..a447b0bf3 100644 --- a/rpc/roommanager.pb.go +++ b/rpc/roommanager.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: rpc/roommanager.proto package rpc diff --git a/rpc/signal.pb.go b/rpc/signal.pb.go index 26d310469..65f9bf05d 100644 --- a/rpc/signal.pb.go +++ b/rpc/signal.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: rpc/signal.proto package rpc diff --git a/rpc/sip.pb.go b/rpc/sip.pb.go index fa65dd2ba..d48be7de3 100644 --- a/rpc/sip.pb.go +++ b/rpc/sip.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: rpc/sip.proto package rpc diff --git a/rpc/whip_signal.pb.go b/rpc/whip_signal.pb.go index 09250c2cb..c8365aade 100644 --- a/rpc/whip_signal.pb.go +++ b/rpc/whip_signal.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.8 +// protoc v4.23.4 // source: rpc/whip_signal.proto package rpc From 84d61dc4bf9bf8aafc1713d4d495a8b4085a7b0f Mon Sep 17 00:00:00 2001 From: Paul Wells Date: Wed, 10 Sep 2025 17:13:47 -0700 Subject: [PATCH 3/5] wip --- auth/grants.go | 45 ++++++++++++++++++----- infra/link.pb.go | 4 +-- infra/link_grpc.pb.go | 2 +- livekit/livekit_agent.pb.go | 4 +-- livekit/livekit_agent_dispatch.pb.go | 4 +-- livekit/livekit_analytics.pb.go | 4 +-- livekit/livekit_cloud_agent.pb.go | 4 +-- livekit/livekit_egress.pb.go | 4 +-- livekit/livekit_ingress.pb.go | 4 +-- livekit/livekit_internal.pb.go | 4 +-- livekit/livekit_metrics.pb.go | 4 +-- livekit/livekit_models.pb.go | 4 +-- livekit/livekit_phone_number.pb.go | 4 +-- livekit/livekit_room.pb.go | 4 +-- livekit/livekit_rtc.pb.go | 4 +-- livekit/livekit_sip.pb.go | 4 +-- livekit/livekit_webhook.pb.go | 4 +-- replay/cloud_replay.pb.go | 4 +-- rpc/agent.pb.go | 4 +-- rpc/agent.psrpc.go | 25 +++++++++++++ rpc/agent_dispatch.pb.go | 4 +-- rpc/agent_dispatch.psrpc.go | 18 ++++++++++ rpc/analytics.pb.go | 4 +-- rpc/analytics_grpc.pb.go | 2 +- rpc/egress.pb.go | 4 +-- rpc/egress.psrpc.go | 31 ++++++++++++++++ rpc/ingress.pb.go | 4 +-- rpc/ingress.psrpc.go | 47 ++++++++++++++++++++++++ rpc/io.pb.go | 4 +-- rpc/io.psrpc.go | 54 ++++++++++++++++++++++++++++ rpc/keepalive.pb.go | 4 +-- rpc/keepalive.psrpc.go | 10 ++++++ rpc/participant.pb.go | 4 +-- rpc/participant.psrpc.go | 34 ++++++++++++++++++ rpc/room.pb.go | 4 +-- rpc/room.psrpc.go | 18 ++++++++++ rpc/roommanager.pb.go | 4 +-- rpc/roommanager.psrpc.go | 10 ++++++ rpc/signal.pb.go | 4 +-- rpc/signal.psrpc.go | 10 ++++++ rpc/sip.pb.go | 4 +-- rpc/sip.psrpc.go | 17 +++++++++ rpc/whip_signal.pb.go | 4 +-- rpc/whip_signal.psrpc.go | 28 +++++++++++++++ 44 files changed, 399 insertions(+), 68 deletions(-) diff --git a/auth/grants.go b/auth/grants.go index b1b4cd0bc..8567f09eb 100644 --- a/auth/grants.go +++ b/auth/grants.go @@ -162,13 +162,14 @@ func checkOutputForCredentials(output any) error { } type ClaimGrants struct { - Identity string `json:"identity,omitempty"` - Name string `json:"name,omitempty"` - Kind string `json:"kind,omitempty"` - Video *VideoGrant `json:"video,omitempty"` - SIP *SIPGrant `json:"sip,omitempty"` - Agent *AgentGrant `json:"agent,omitempty"` - Inference *InferenceGrant `json:"inference,omitempty"` + Identity string `json:"identity,omitempty"` + Name string `json:"name,omitempty"` + Kind string `json:"kind,omitempty"` + Video *VideoGrant `json:"video,omitempty"` + SIP *SIPGrant `json:"sip,omitempty"` + Agent *AgentGrant `json:"agent,omitempty"` + Inference *InferenceGrant `json:"inference,omitempty"` + Observability *ObservabilityGrant `json:"observability,omitempty"` // Room configuration to use if this participant initiates the room RoomConfig *RoomConfiguration `json:"roomConfig,omitempty"` // Cloud-only, config preset to use @@ -206,6 +207,7 @@ func (c *ClaimGrants) Clone() *ClaimGrants { clone.SIP = c.SIP.Clone() clone.Agent = c.Agent.Clone() clone.Inference = c.Inference.Clone() + clone.Observability = c.Observability.Clone() clone.Attributes = maps.Clone(c.Attributes) clone.RoomConfig = c.RoomConfig.Clone() @@ -223,6 +225,7 @@ func (c *ClaimGrants) MarshalLogObject(e zapcore.ObjectEncoder) error { e.AddObject("SIP", c.SIP) e.AddObject("Agent", c.Agent) e.AddObject("Inference", c.Inference) + e.AddObject("Observability", c.Observability) e.AddObject("RoomConfig", logger.Proto((*livekit.RoomConfiguration)(c.RoomConfig))) e.AddString("RoomPreset", c.RoomPreset) return nil @@ -560,7 +563,7 @@ func (s *AgentGrant) MarshalLogObject(e zapcore.ObjectEncoder) error { // ------------------------------------------------------------------ type InferenceGrant struct { - // Admin grants to all inference features (LLM, STT, TTS) + // Perform grants to all inference features (LLM, STT, TTS) Perform bool `json:"perform,omitempty"` } @@ -585,6 +588,32 @@ func (s *InferenceGrant) MarshalLogObject(e zapcore.ObjectEncoder) error { // ------------------------------------------------------------------ +type ObservabilityGrant struct { + // Write grants to publish observability data + Write bool `json:"write,omitempty"` +} + +func (s *ObservabilityGrant) Clone() *ObservabilityGrant { + if s == nil { + return nil + } + + clone := *s + + return &clone +} + +func (s *ObservabilityGrant) MarshalLogObject(e zapcore.ObjectEncoder) error { + if s == nil { + return nil + } + + e.AddBool("Write", s.Write) + return nil +} + +// ------------------------------------------------------------------ + func sourceToString(source livekit.TrackSource) string { return strings.ToLower(source.String()) } diff --git a/infra/link.pb.go b/infra/link.pb.go index f636bb3a6..a6f0840ff 100644 --- a/infra/link.pb.go +++ b/infra/link.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: infra/link.proto package infra diff --git a/infra/link_grpc.pb.go b/infra/link_grpc.pb.go index 281cec953..6cacc86d2 100644 --- a/infra/link_grpc.pb.go +++ b/infra/link_grpc.pb.go @@ -15,7 +15,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.5.1 -// - protoc v4.23.4 +// - protoc v5.29.3 // source: infra/link.proto package infra diff --git a/livekit/livekit_agent.pb.go b/livekit/livekit_agent.pb.go index 77a264d2e..56e72258b 100644 --- a/livekit/livekit_agent.pb.go +++ b/livekit/livekit_agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_agent.proto package livekit diff --git a/livekit/livekit_agent_dispatch.pb.go b/livekit/livekit_agent_dispatch.pb.go index 147c54bbe..a61bc8d29 100644 --- a/livekit/livekit_agent_dispatch.pb.go +++ b/livekit/livekit_agent_dispatch.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_agent_dispatch.proto package livekit diff --git a/livekit/livekit_analytics.pb.go b/livekit/livekit_analytics.pb.go index 7031d1921..2cb4a2600 100644 --- a/livekit/livekit_analytics.pb.go +++ b/livekit/livekit_analytics.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_analytics.proto package livekit diff --git a/livekit/livekit_cloud_agent.pb.go b/livekit/livekit_cloud_agent.pb.go index ede8db9ec..f98bf1a78 100644 --- a/livekit/livekit_cloud_agent.pb.go +++ b/livekit/livekit_cloud_agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_cloud_agent.proto package livekit diff --git a/livekit/livekit_egress.pb.go b/livekit/livekit_egress.pb.go index a09910513..f441a683f 100644 --- a/livekit/livekit_egress.pb.go +++ b/livekit/livekit_egress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_egress.proto package livekit diff --git a/livekit/livekit_ingress.pb.go b/livekit/livekit_ingress.pb.go index 1605a6822..5fbd44029 100644 --- a/livekit/livekit_ingress.pb.go +++ b/livekit/livekit_ingress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_ingress.proto package livekit diff --git a/livekit/livekit_internal.pb.go b/livekit/livekit_internal.pb.go index 0cad406f1..b31f40e5c 100644 --- a/livekit/livekit_internal.pb.go +++ b/livekit/livekit_internal.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_internal.proto package livekit diff --git a/livekit/livekit_metrics.pb.go b/livekit/livekit_metrics.pb.go index fc1707e53..e6e8accf1 100644 --- a/livekit/livekit_metrics.pb.go +++ b/livekit/livekit_metrics.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_metrics.proto package livekit diff --git a/livekit/livekit_models.pb.go b/livekit/livekit_models.pb.go index 26e7d95a3..9e83de6f9 100644 --- a/livekit/livekit_models.pb.go +++ b/livekit/livekit_models.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_models.proto package livekit diff --git a/livekit/livekit_phone_number.pb.go b/livekit/livekit_phone_number.pb.go index b8a58b2e0..e7543cbec 100644 --- a/livekit/livekit_phone_number.pb.go +++ b/livekit/livekit_phone_number.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_phone_number.proto package livekit diff --git a/livekit/livekit_room.pb.go b/livekit/livekit_room.pb.go index 5f6ca0215..ff06b480e 100644 --- a/livekit/livekit_room.pb.go +++ b/livekit/livekit_room.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_room.proto package livekit diff --git a/livekit/livekit_rtc.pb.go b/livekit/livekit_rtc.pb.go index c90b16eee..823e32d23 100644 --- a/livekit/livekit_rtc.pb.go +++ b/livekit/livekit_rtc.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_rtc.proto package livekit diff --git a/livekit/livekit_sip.pb.go b/livekit/livekit_sip.pb.go index 08f83a03d..8f3f942a5 100644 --- a/livekit/livekit_sip.pb.go +++ b/livekit/livekit_sip.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_sip.proto package livekit diff --git a/livekit/livekit_webhook.pb.go b/livekit/livekit_webhook.pb.go index f5b87fead..f14b4a41b 100644 --- a/livekit/livekit_webhook.pb.go +++ b/livekit/livekit_webhook.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: livekit_webhook.proto package livekit diff --git a/replay/cloud_replay.pb.go b/replay/cloud_replay.pb.go index 90717043e..ef49cd889 100644 --- a/replay/cloud_replay.pb.go +++ b/replay/cloud_replay.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: cloud_replay.proto package replay diff --git a/rpc/agent.pb.go b/rpc/agent.pb.go index 5dc973385..71db5934a 100644 --- a/rpc/agent.pb.go +++ b/rpc/agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/agent.proto package rpc diff --git a/rpc/agent.psrpc.go b/rpc/agent.psrpc.go index 365996bd0..25c29c347 100644 --- a/rpc/agent.psrpc.go +++ b/rpc/agent.psrpc.go @@ -180,6 +180,31 @@ func (s *agentInternalServer) Kill() { s.rpc.Close(true) } +// ================================== +// AgentInternal Unimplemented Server +// ================================== + +type UnimplementedAgentInternalServer struct{} + +func (UnimplementedAgentInternalServer) CheckEnabled(context.Context, *CheckEnabledRequest) (*CheckEnabledResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedAgentInternalServer) JobRequest(context.Context, *livekit2.Job) (*JobRequestResponse, error) { + return nil, psrpc.ErrUnimplemented +} +func (UnimplementedAgentInternalServer) JobRequestAffinity(context.Context, *livekit2.Job) float32 { + return -1 +} + +func (UnimplementedAgentInternalServer) JobTerminate(context.Context, *JobTerminateRequest) (*JobTerminateResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedAgentInternalServer) WorkerRegistered(context.Context, *google_protobuf.Empty) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor0 = []byte{ // 566 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x53, 0xdf, 0x8e, 0xd2, 0x4e, diff --git a/rpc/agent_dispatch.pb.go b/rpc/agent_dispatch.pb.go index 88a3a9134..c06b3631f 100644 --- a/rpc/agent_dispatch.pb.go +++ b/rpc/agent_dispatch.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/agent_dispatch.proto package rpc diff --git a/rpc/agent_dispatch.psrpc.go b/rpc/agent_dispatch.psrpc.go index 8f2b4ea0e..e99f61d51 100644 --- a/rpc/agent_dispatch.psrpc.go +++ b/rpc/agent_dispatch.psrpc.go @@ -186,6 +186,24 @@ func (s *agentDispatchInternalServer[RoomTopicType]) Kill() { s.rpc.Close(true) } +// ========================================== +// AgentDispatchInternal Unimplemented Server +// ========================================== + +type UnimplementedAgentDispatchInternalServer struct{} + +func (UnimplementedAgentDispatchInternalServer) CreateDispatch(context.Context, *livekit3.AgentDispatch) (*livekit3.AgentDispatch, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedAgentDispatchInternalServer) DeleteDispatch(context.Context, *livekit3.DeleteAgentDispatchRequest) (*livekit3.AgentDispatch, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedAgentDispatchInternalServer) ListDispatch(context.Context, *livekit3.ListAgentDispatchRequest) (*livekit3.ListAgentDispatchResponse, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor1 = []byte{ // 228 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x92, 0x28, 0x2a, 0x48, 0xd6, diff --git a/rpc/analytics.pb.go b/rpc/analytics.pb.go index 306fffa89..655d51ae0 100644 --- a/rpc/analytics.pb.go +++ b/rpc/analytics.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/analytics.proto package rpc diff --git a/rpc/analytics_grpc.pb.go b/rpc/analytics_grpc.pb.go index 6217bb431..f59684f38 100644 --- a/rpc/analytics_grpc.pb.go +++ b/rpc/analytics_grpc.pb.go @@ -15,7 +15,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.5.1 -// - protoc v4.23.4 +// - protoc v5.29.3 // source: rpc/analytics.proto package rpc diff --git a/rpc/egress.pb.go b/rpc/egress.pb.go index 06662bb3a..cd5d763ae 100644 --- a/rpc/egress.pb.go +++ b/rpc/egress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/egress.proto package rpc diff --git a/rpc/egress.psrpc.go b/rpc/egress.psrpc.go index fa1a43f94..c9af986bc 100644 --- a/rpc/egress.psrpc.go +++ b/rpc/egress.psrpc.go @@ -149,6 +149,23 @@ func (s *egressInternalServer) Kill() { s.rpc.Close(true) } +// =================================== +// EgressInternal Unimplemented Server +// =================================== + +type UnimplementedEgressInternalServer struct{} + +func (UnimplementedEgressInternalServer) StartEgress(context.Context, *StartEgressRequest) (*livekit4.EgressInfo, error) { + return nil, psrpc.ErrUnimplemented +} +func (UnimplementedEgressInternalServer) StartEgressAffinity(context.Context, *StartEgressRequest) float32 { + return -1 +} + +func (UnimplementedEgressInternalServer) ListActiveEgress(context.Context, *ListActiveEgressRequest) (*ListActiveEgressResponse, error) { + return nil, psrpc.ErrUnimplemented +} + // ============================== // EgressHandler Client Interface // ============================== @@ -280,6 +297,20 @@ func (s *egressHandlerServer) Kill() { s.rpc.Close(true) } +// ================================== +// EgressHandler Unimplemented Server +// ================================== + +type UnimplementedEgressHandlerServer struct{} + +func (UnimplementedEgressHandlerServer) UpdateStream(context.Context, *livekit4.UpdateStreamRequest) (*livekit4.EgressInfo, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedEgressHandlerServer) StopEgress(context.Context, *livekit4.StopEgressRequest) (*livekit4.EgressInfo, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor2 = []byte{ // 544 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x93, 0xd1, 0x4e, 0xdb, 0x3e, diff --git a/rpc/ingress.pb.go b/rpc/ingress.pb.go index f42584535..12fc82f27 100644 --- a/rpc/ingress.pb.go +++ b/rpc/ingress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/ingress.proto package rpc diff --git a/rpc/ingress.psrpc.go b/rpc/ingress.psrpc.go index ef84589ad..b454eb49c 100644 --- a/rpc/ingress.psrpc.go +++ b/rpc/ingress.psrpc.go @@ -167,6 +167,27 @@ func (s *ingressInternalServer) Kill() { s.rpc.Close(true) } +// ==================================== +// IngressInternal Unimplemented Server +// ==================================== + +type UnimplementedIngressInternalServer struct{} + +func (UnimplementedIngressInternalServer) StartIngress(context.Context, *StartIngressRequest) (*livekit5.IngressInfo, error) { + return nil, psrpc.ErrUnimplemented +} +func (UnimplementedIngressInternalServer) StartIngressAffinity(context.Context, *StartIngressRequest) float32 { + return -1 +} + +func (UnimplementedIngressInternalServer) ListActiveIngress(context.Context, *ListActiveIngressRequest) (*ListActiveIngressResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIngressInternalServer) KillIngressSession(context.Context, *KillIngressSessionRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + // =============================== // IngressHandler Client Interface // =============================== @@ -358,6 +379,32 @@ func (s *ingressHandlerServer) Kill() { s.rpc.Close(true) } +// =================================== +// IngressHandler Unimplemented Server +// =================================== + +type UnimplementedIngressHandlerServer struct{} + +func (UnimplementedIngressHandlerServer) UpdateIngress(context.Context, *livekit5.UpdateIngressRequest) (*livekit5.IngressState, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIngressHandlerServer) DeleteIngress(context.Context, *livekit5.DeleteIngressRequest) (*livekit5.IngressState, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIngressHandlerServer) DeleteWHIPResource(context.Context, *DeleteWHIPResourceRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIngressHandlerServer) ICERestartWHIPResource(context.Context, *ICERestartWHIPResourceRequest) (*ICERestartWHIPResourceResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIngressHandlerServer) WHIPRTCConnectionNotify(context.Context, *WHIPRTCConnectionNotifyRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor3 = []byte{ // 863 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x55, 0xdd, 0x4e, 0xe3, 0x46, diff --git a/rpc/io.pb.go b/rpc/io.pb.go index 2271746ba..767b3fa71 100644 --- a/rpc/io.pb.go +++ b/rpc/io.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/io.proto package rpc diff --git a/rpc/io.psrpc.go b/rpc/io.psrpc.go index c8d637f4c..d8be55bd9 100644 --- a/rpc/io.psrpc.go +++ b/rpc/io.psrpc.go @@ -309,6 +309,60 @@ func (s *iOInfoServer) Kill() { s.rpc.Close(true) } +// =========================== +// IOInfo Unimplemented Server +// =========================== + +type UnimplementedIOInfoServer struct{} + +func (UnimplementedIOInfoServer) CreateEgress(context.Context, *livekit4.EgressInfo) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) UpdateEgress(context.Context, *livekit4.EgressInfo) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) GetEgress(context.Context, *GetEgressRequest) (*livekit4.EgressInfo, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) ListEgress(context.Context, *livekit4.ListEgressRequest) (*livekit4.ListEgressResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) UpdateMetrics(context.Context, *UpdateMetricsRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) CreateIngress(context.Context, *livekit5.IngressInfo) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) GetIngressInfo(context.Context, *GetIngressInfoRequest) (*GetIngressInfoResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) UpdateIngressState(context.Context, *UpdateIngressStateRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) GetSIPTrunkAuthentication(context.Context, *GetSIPTrunkAuthenticationRequest) (*GetSIPTrunkAuthenticationResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) EvaluateSIPDispatchRules(context.Context, *EvaluateSIPDispatchRulesRequest) (*EvaluateSIPDispatchRulesResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) UpdateSIPCallState(context.Context, *UpdateSIPCallStateRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedIOInfoServer) RecordCallContext(context.Context, *RecordCallContextRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor4 = []byte{ // 1743 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x18, 0xdd, 0x56, 0x1b, 0xc7, diff --git a/rpc/keepalive.pb.go b/rpc/keepalive.pb.go index 761edd1b8..e5509237f 100644 --- a/rpc/keepalive.pb.go +++ b/rpc/keepalive.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/keepalive.proto package rpc diff --git a/rpc/keepalive.psrpc.go b/rpc/keepalive.psrpc.go index 36e69d21a..f73ff9797 100644 --- a/rpc/keepalive.psrpc.go +++ b/rpc/keepalive.psrpc.go @@ -121,6 +121,16 @@ func (s *keepaliveServer[NodeIDTopicType]) Kill() { s.rpc.Close(true) } +// ============================== +// Keepalive Unimplemented Server +// ============================== + +type UnimplementedKeepaliveServer struct{} + +func (UnimplementedKeepaliveServer) Ping(context.Context, *KeepalivePing) (*KeepalivePing, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor5 = []byte{ // 178 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x12, 0x2e, 0x2a, 0x48, 0xd6, diff --git a/rpc/participant.pb.go b/rpc/participant.pb.go index e919d1a6e..c5ea43c41 100644 --- a/rpc/participant.pb.go +++ b/rpc/participant.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/participant.proto package rpc diff --git a/rpc/participant.psrpc.go b/rpc/participant.psrpc.go index b163527b8..9d6209cbd 100644 --- a/rpc/participant.psrpc.go +++ b/rpc/participant.psrpc.go @@ -271,6 +271,40 @@ func (s *participantServer[ParticipantTopicType]) Kill() { s.rpc.Close(true) } +// ================================ +// Participant Unimplemented Server +// ================================ + +type UnimplementedParticipantServer struct{} + +func (UnimplementedParticipantServer) RemoveParticipant(context.Context, *livekit6.RoomParticipantIdentity) (*livekit6.RemoveParticipantResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedParticipantServer) MutePublishedTrack(context.Context, *livekit6.MuteRoomTrackRequest) (*livekit6.MuteRoomTrackResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedParticipantServer) UpdateParticipant(context.Context, *livekit6.UpdateParticipantRequest) (*livekit1.ParticipantInfo, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedParticipantServer) UpdateSubscriptions(context.Context, *livekit6.UpdateSubscriptionsRequest) (*livekit6.UpdateSubscriptionsResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedParticipantServer) ForwardParticipant(context.Context, *livekit6.ForwardParticipantRequest) (*livekit6.ForwardParticipantResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedParticipantServer) MoveParticipant(context.Context, *livekit6.MoveParticipantRequest) (*livekit6.MoveParticipantResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedParticipantServer) PerformRpc(context.Context, *livekit6.PerformRpcRequest) (*livekit6.PerformRpcResponse, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor6 = []byte{ // 358 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x53, 0x4d, 0x4b, 0xc3, 0x40, diff --git a/rpc/room.pb.go b/rpc/room.pb.go index 6454b489c..95468f44a 100644 --- a/rpc/room.pb.go +++ b/rpc/room.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/room.proto package rpc diff --git a/rpc/room.psrpc.go b/rpc/room.psrpc.go index a29ef514d..4c46880bb 100644 --- a/rpc/room.psrpc.go +++ b/rpc/room.psrpc.go @@ -187,6 +187,24 @@ func (s *roomServer[RoomTopicType]) Kill() { s.rpc.Close(true) } +// ========================= +// Room Unimplemented Server +// ========================= + +type UnimplementedRoomServer struct{} + +func (UnimplementedRoomServer) DeleteRoom(context.Context, *livekit6.DeleteRoomRequest) (*livekit6.DeleteRoomResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedRoomServer) SendData(context.Context, *livekit6.SendDataRequest) (*livekit6.SendDataResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedRoomServer) UpdateRoomMetadata(context.Context, *livekit6.UpdateRoomMetadataRequest) (*livekit1.Room, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor7 = []byte{ // 230 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0xe2, 0x2b, 0x2a, 0x48, 0xd6, diff --git a/rpc/roommanager.pb.go b/rpc/roommanager.pb.go index 6424aba6b..5b3a7b365 100644 --- a/rpc/roommanager.pb.go +++ b/rpc/roommanager.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/roommanager.proto package rpc diff --git a/rpc/roommanager.psrpc.go b/rpc/roommanager.psrpc.go index 4b532cbc5..98e05ce0d 100644 --- a/rpc/roommanager.psrpc.go +++ b/rpc/roommanager.psrpc.go @@ -145,6 +145,16 @@ func (s *roomManagerServer[NodeIdTopicType]) Kill() { s.rpc.Close(true) } +// ================================ +// RoomManager Unimplemented Server +// ================================ + +type UnimplementedRoomManagerServer struct{} + +func (UnimplementedRoomManagerServer) CreateRoom(context.Context, *livekit6.CreateRoomRequest) (*livekit1.Room, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor8 = []byte{ // 185 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x44, 0xcd, 0x4d, 0x0a, 0xc2, 0x30, diff --git a/rpc/signal.pb.go b/rpc/signal.pb.go index 18564147e..26d310469 100644 --- a/rpc/signal.pb.go +++ b/rpc/signal.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/signal.proto package rpc diff --git a/rpc/signal.psrpc.go b/rpc/signal.psrpc.go index 36e7c0aee..3a86bd61b 100644 --- a/rpc/signal.psrpc.go +++ b/rpc/signal.psrpc.go @@ -143,6 +143,16 @@ func (s *signalServer[NodeIdTopicType]) Kill() { s.rpc.Close(true) } +// =========================== +// Signal Unimplemented Server +// =========================== + +type UnimplementedSignalServer struct{} + +func (UnimplementedSignalServer) RelaySignal(psrpc.ServerStream[*RelaySignalResponse, *RelaySignalRequest]) error { + return psrpc.ErrUnimplemented +} + var psrpcFileDescriptor9 = []byte{ // 313 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x6c, 0x91, 0x4f, 0x4e, 0xf3, 0x30, diff --git a/rpc/sip.pb.go b/rpc/sip.pb.go index 264cb6880..fa65dd2ba 100644 --- a/rpc/sip.pb.go +++ b/rpc/sip.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/sip.proto package rpc diff --git a/rpc/sip.psrpc.go b/rpc/sip.psrpc.go index b7c64249c..223ef56e9 100644 --- a/rpc/sip.psrpc.go +++ b/rpc/sip.psrpc.go @@ -149,6 +149,23 @@ func (s *sIPInternalServer) Kill() { s.rpc.Close(true) } +// ================================ +// SIPInternal Unimplemented Server +// ================================ + +type UnimplementedSIPInternalServer struct{} + +func (UnimplementedSIPInternalServer) CreateSIPParticipant(context.Context, *InternalCreateSIPParticipantRequest) (*InternalCreateSIPParticipantResponse, error) { + return nil, psrpc.ErrUnimplemented +} +func (UnimplementedSIPInternalServer) CreateSIPParticipantAffinity(context.Context, *InternalCreateSIPParticipantRequest) float32 { + return -1 +} + +func (UnimplementedSIPInternalServer) TransferSIPParticipant(context.Context, *InternalTransferSIPParticipantRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor11 = []byte{ // 1013 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x56, 0xcd, 0x72, 0xdb, 0x36, diff --git a/rpc/whip_signal.pb.go b/rpc/whip_signal.pb.go index 47dc35763..54727aeed 100644 --- a/rpc/whip_signal.pb.go +++ b/rpc/whip_signal.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.9 -// protoc v4.23.4 +// protoc-gen-go v1.36.6 +// protoc v5.29.3 // source: rpc/whip_signal.proto package rpc diff --git a/rpc/whip_signal.psrpc.go b/rpc/whip_signal.psrpc.go index 181197924..7a19cd810 100644 --- a/rpc/whip_signal.psrpc.go +++ b/rpc/whip_signal.psrpc.go @@ -144,6 +144,16 @@ func (s *wHIPServer[TopicTopicType]) Kill() { s.rpc.Close(true) } +// ========================= +// WHIP Unimplemented Server +// ========================= + +type UnimplementedWHIPServer struct{} + +func (UnimplementedWHIPServer) Create(context.Context, *WHIPCreateRequest) (*WHIPCreateResponse, error) { + return nil, psrpc.ErrUnimplemented +} + // ================================ // WHIPParticipant Client Interface // ================================ @@ -313,6 +323,24 @@ func (s *wHIPParticipantServer[TopicTopicType]) Kill() { s.rpc.Close(true) } +// ==================================== +// WHIPParticipant Unimplemented Server +// ==================================== + +type UnimplementedWHIPParticipantServer struct{} + +func (UnimplementedWHIPParticipantServer) ICETrickle(context.Context, *WHIPParticipantICETrickleRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedWHIPParticipantServer) ICERestart(context.Context, *WHIPParticipantICERestartRequest) (*WHIPParticipantICERestartResponse, error) { + return nil, psrpc.ErrUnimplemented +} + +func (UnimplementedWHIPParticipantServer) DeleteSession(context.Context, *WHIPParticipantDeleteSessionRequest) (*google_protobuf.Empty, error) { + return nil, psrpc.ErrUnimplemented +} + var psrpcFileDescriptor10 = []byte{ // 726 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xc4, 0x55, 0x5f, 0x4f, 0x1b, 0x39, From aa061bd47dd3829065382699a6a091f4a335c99f Mon Sep 17 00:00:00 2001 From: Paul Wells Date: Mon, 15 Sep 2025 20:43:55 -0700 Subject: [PATCH 4/5] tidy --- livekit/livekit_metrics.pb.go | 116 +++++++++----------------------- protobufs/livekit_metrics.proto | 6 +- 2 files changed, 33 insertions(+), 89 deletions(-) diff --git a/livekit/livekit_metrics.pb.go b/livekit/livekit_metrics.pb.go index e6e8accf1..72f2b97c4 100644 --- a/livekit/livekit_metrics.pb.go +++ b/livekit/livekit_metrics.pb.go @@ -455,11 +455,11 @@ func (x *EventMetric) GetRid() uint32 { } type MetricsRecordingHeader struct { - state protoimpl.MessageState `protogen:"open.v1"` - RoomId string `protobuf:"bytes,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"` - Parts map[string]*MetricsRecordingHeader_Part `protobuf:"bytes,2,rep,name=parts,proto3" json:"parts,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + RoomId string `protobuf:"bytes,1,opt,name=room_id,json=roomId,proto3" json:"room_id,omitempty"` + EnableUserDataTraining *bool `protobuf:"varint,2,opt,name=enable_user_data_training,json=enableUserDataTraining,proto3,oneof" json:"enable_user_data_training,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *MetricsRecordingHeader) Reset() { @@ -499,55 +499,11 @@ func (x *MetricsRecordingHeader) GetRoomId() string { return "" } -func (x *MetricsRecordingHeader) GetParts() map[string]*MetricsRecordingHeader_Part { - if x != nil { - return x.Parts - } - return nil -} - -type MetricsRecordingHeader_Part struct { - state protoimpl.MessageState `protogen:"open.v1"` - ContentLength uint32 `protobuf:"varint,1,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *MetricsRecordingHeader_Part) Reset() { - *x = MetricsRecordingHeader_Part{} - mi := &file_livekit_metrics_proto_msgTypes[5] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *MetricsRecordingHeader_Part) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*MetricsRecordingHeader_Part) ProtoMessage() {} - -func (x *MetricsRecordingHeader_Part) ProtoReflect() protoreflect.Message { - mi := &file_livekit_metrics_proto_msgTypes[5] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms +func (x *MetricsRecordingHeader) GetEnableUserDataTraining() bool { + if x != nil && x.EnableUserDataTraining != nil { + return *x.EnableUserDataTraining } - return mi.MessageOf(x) -} - -// Deprecated: Use MetricsRecordingHeader_Part.ProtoReflect.Descriptor instead. -func (*MetricsRecordingHeader_Part) Descriptor() ([]byte, []int) { - return file_livekit_metrics_proto_rawDescGZIP(), []int{4, 0} -} - -func (x *MetricsRecordingHeader_Part) GetContentLength() uint32 { - if x != nil { - return x.ContentLength - } - return 0 + return false } var File_livekit_metrics_proto protoreflect.FileDescriptor @@ -583,16 +539,11 @@ const file_livekit_metrics_proto_rawDesc = "" + "\bmetadata\x18\b \x01(\tR\bmetadata\x12\x10\n" + "\x03rid\x18\t \x01(\rR\x03ridB\x13\n" + "\x11_end_timestamp_msB\x1b\n" + - "\x19_normalized_end_timestamp\"\x82\x02\n" + + "\x19_normalized_end_timestamp\"\x8f\x01\n" + "\x16MetricsRecordingHeader\x12\x17\n" + - "\aroom_id\x18\x01 \x01(\tR\x06roomId\x12@\n" + - "\x05parts\x18\x02 \x03(\v2*.livekit.MetricsRecordingHeader.PartsEntryR\x05parts\x1a-\n" + - "\x04Part\x12%\n" + - "\x0econtent_length\x18\x01 \x01(\rR\rcontentLength\x1a^\n" + - "\n" + - "PartsEntry\x12\x10\n" + - "\x03key\x18\x01 \x01(\tR\x03key\x12:\n" + - "\x05value\x18\x02 \x01(\v2$.livekit.MetricsRecordingHeader.PartR\x05value:\x028\x01*\x81\a\n" + + "\aroom_id\x18\x01 \x01(\tR\x06roomId\x12>\n" + + "\x19enable_user_data_training\x18\x02 \x01(\bH\x00R\x16enableUserDataTraining\x88\x01\x01B\x1c\n" + + "\x1a_enable_user_data_training*\x81\a\n" + "\vMetricLabel\x12\x13\n" + "\x0fAGENTS_LLM_TTFT\x10\x00\x12\x13\n" + "\x0fAGENTS_STT_TTFT\x10\x01\x12\x13\n" + @@ -630,33 +581,29 @@ func file_livekit_metrics_proto_rawDescGZIP() []byte { } var file_livekit_metrics_proto_enumTypes = make([]protoimpl.EnumInfo, 1) -var file_livekit_metrics_proto_msgTypes = make([]protoimpl.MessageInfo, 7) +var file_livekit_metrics_proto_msgTypes = make([]protoimpl.MessageInfo, 5) var file_livekit_metrics_proto_goTypes = []any{ - (MetricLabel)(0), // 0: livekit.MetricLabel - (*MetricsBatch)(nil), // 1: livekit.MetricsBatch - (*TimeSeriesMetric)(nil), // 2: livekit.TimeSeriesMetric - (*MetricSample)(nil), // 3: livekit.MetricSample - (*EventMetric)(nil), // 4: livekit.EventMetric - (*MetricsRecordingHeader)(nil), // 5: livekit.MetricsRecordingHeader - (*MetricsRecordingHeader_Part)(nil), // 6: livekit.MetricsRecordingHeader.Part - nil, // 7: livekit.MetricsRecordingHeader.PartsEntry - (*timestamppb.Timestamp)(nil), // 8: google.protobuf.Timestamp + (MetricLabel)(0), // 0: livekit.MetricLabel + (*MetricsBatch)(nil), // 1: livekit.MetricsBatch + (*TimeSeriesMetric)(nil), // 2: livekit.TimeSeriesMetric + (*MetricSample)(nil), // 3: livekit.MetricSample + (*EventMetric)(nil), // 4: livekit.EventMetric + (*MetricsRecordingHeader)(nil), // 5: livekit.MetricsRecordingHeader + (*timestamppb.Timestamp)(nil), // 6: google.protobuf.Timestamp } var file_livekit_metrics_proto_depIdxs = []int32{ - 8, // 0: livekit.MetricsBatch.normalized_timestamp:type_name -> google.protobuf.Timestamp + 6, // 0: livekit.MetricsBatch.normalized_timestamp:type_name -> google.protobuf.Timestamp 2, // 1: livekit.MetricsBatch.time_series:type_name -> livekit.TimeSeriesMetric 4, // 2: livekit.MetricsBatch.events:type_name -> livekit.EventMetric 3, // 3: livekit.TimeSeriesMetric.samples:type_name -> livekit.MetricSample - 8, // 4: livekit.MetricSample.normalized_timestamp:type_name -> google.protobuf.Timestamp - 8, // 5: livekit.EventMetric.normalized_start_timestamp:type_name -> google.protobuf.Timestamp - 8, // 6: livekit.EventMetric.normalized_end_timestamp:type_name -> google.protobuf.Timestamp - 7, // 7: livekit.MetricsRecordingHeader.parts:type_name -> livekit.MetricsRecordingHeader.PartsEntry - 6, // 8: livekit.MetricsRecordingHeader.PartsEntry.value:type_name -> livekit.MetricsRecordingHeader.Part - 9, // [9:9] is the sub-list for method output_type - 9, // [9:9] is the sub-list for method input_type - 9, // [9:9] is the sub-list for extension type_name - 9, // [9:9] is the sub-list for extension extendee - 0, // [0:9] is the sub-list for field type_name + 6, // 4: livekit.MetricSample.normalized_timestamp:type_name -> google.protobuf.Timestamp + 6, // 5: livekit.EventMetric.normalized_start_timestamp:type_name -> google.protobuf.Timestamp + 6, // 6: livekit.EventMetric.normalized_end_timestamp:type_name -> google.protobuf.Timestamp + 7, // [7:7] is the sub-list for method output_type + 7, // [7:7] is the sub-list for method input_type + 7, // [7:7] is the sub-list for extension type_name + 7, // [7:7] is the sub-list for extension extendee + 0, // [0:7] is the sub-list for field type_name } func init() { file_livekit_metrics_proto_init() } @@ -665,13 +612,14 @@ func file_livekit_metrics_proto_init() { return } file_livekit_metrics_proto_msgTypes[3].OneofWrappers = []any{} + file_livekit_metrics_proto_msgTypes[4].OneofWrappers = []any{} type x struct{} out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: unsafe.Slice(unsafe.StringData(file_livekit_metrics_proto_rawDesc), len(file_livekit_metrics_proto_rawDesc)), NumEnums: 1, - NumMessages: 7, + NumMessages: 5, NumExtensions: 0, NumServices: 0, }, diff --git a/protobufs/livekit_metrics.proto b/protobufs/livekit_metrics.proto index cc6c3502b..e6896a4fa 100644 --- a/protobufs/livekit_metrics.proto +++ b/protobufs/livekit_metrics.proto @@ -89,10 +89,6 @@ message EventMetric { } message MetricsRecordingHeader { - message Part { - uint32 content_length = 1; - } - string room_id = 1; - map parts = 2; + optional bool enable_user_data_training = 2; } From 6db7b0c421aba256b924108364c8ad48de9e1236 Mon Sep 17 00:00:00 2001 From: github-actions <41898282+github-actions[bot]@users.noreply.github.com> Date: Tue, 16 Sep 2025 03:45:28 +0000 Subject: [PATCH 5/5] generated protobuf --- infra/link.pb.go | 4 ++-- infra/link_grpc.pb.go | 2 +- livekit/livekit_agent.pb.go | 4 ++-- livekit/livekit_agent_dispatch.pb.go | 4 ++-- livekit/livekit_analytics.pb.go | 4 ++-- livekit/livekit_cloud_agent.pb.go | 4 ++-- livekit/livekit_egress.pb.go | 4 ++-- livekit/livekit_ingress.pb.go | 4 ++-- livekit/livekit_internal.pb.go | 4 ++-- livekit/livekit_metrics.pb.go | 4 ++-- livekit/livekit_models.pb.go | 4 ++-- livekit/livekit_phone_number.pb.go | 4 ++-- livekit/livekit_room.pb.go | 4 ++-- livekit/livekit_rtc.pb.go | 4 ++-- livekit/livekit_sip.pb.go | 4 ++-- livekit/livekit_webhook.pb.go | 4 ++-- replay/cloud_replay.pb.go | 4 ++-- rpc/agent.pb.go | 4 ++-- rpc/agent_dispatch.pb.go | 4 ++-- rpc/analytics.pb.go | 4 ++-- rpc/analytics_grpc.pb.go | 2 +- rpc/egress.pb.go | 4 ++-- rpc/ingress.pb.go | 4 ++-- rpc/io.pb.go | 4 ++-- rpc/keepalive.pb.go | 4 ++-- rpc/participant.pb.go | 4 ++-- rpc/room.pb.go | 4 ++-- rpc/roommanager.pb.go | 4 ++-- rpc/signal.pb.go | 4 ++-- rpc/sip.pb.go | 4 ++-- rpc/whip_signal.pb.go | 4 ++-- 31 files changed, 60 insertions(+), 60 deletions(-) diff --git a/infra/link.pb.go b/infra/link.pb.go index a6f0840ff..f636bb3a6 100644 --- a/infra/link.pb.go +++ b/infra/link.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: infra/link.proto package infra diff --git a/infra/link_grpc.pb.go b/infra/link_grpc.pb.go index 6cacc86d2..281cec953 100644 --- a/infra/link_grpc.pb.go +++ b/infra/link_grpc.pb.go @@ -15,7 +15,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.5.1 -// - protoc v5.29.3 +// - protoc v4.23.4 // source: infra/link.proto package infra diff --git a/livekit/livekit_agent.pb.go b/livekit/livekit_agent.pb.go index 56e72258b..77a264d2e 100644 --- a/livekit/livekit_agent.pb.go +++ b/livekit/livekit_agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: livekit_agent.proto package livekit diff --git a/livekit/livekit_agent_dispatch.pb.go b/livekit/livekit_agent_dispatch.pb.go index a61bc8d29..147c54bbe 100644 --- a/livekit/livekit_agent_dispatch.pb.go +++ b/livekit/livekit_agent_dispatch.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: livekit_agent_dispatch.proto package livekit diff --git a/livekit/livekit_analytics.pb.go b/livekit/livekit_analytics.pb.go index 2cb4a2600..7031d1921 100644 --- a/livekit/livekit_analytics.pb.go +++ b/livekit/livekit_analytics.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: livekit_analytics.proto package livekit diff --git a/livekit/livekit_cloud_agent.pb.go b/livekit/livekit_cloud_agent.pb.go index d6524728b..da0d35a0a 100644 --- a/livekit/livekit_cloud_agent.pb.go +++ b/livekit/livekit_cloud_agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: livekit_cloud_agent.proto package livekit diff --git a/livekit/livekit_egress.pb.go b/livekit/livekit_egress.pb.go index f441a683f..a09910513 100644 --- a/livekit/livekit_egress.pb.go +++ b/livekit/livekit_egress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: livekit_egress.proto package livekit diff --git a/livekit/livekit_ingress.pb.go b/livekit/livekit_ingress.pb.go index 5fbd44029..1605a6822 100644 --- a/livekit/livekit_ingress.pb.go +++ b/livekit/livekit_ingress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: livekit_ingress.proto package livekit diff --git a/livekit/livekit_internal.pb.go b/livekit/livekit_internal.pb.go index b31f40e5c..0cad406f1 100644 --- a/livekit/livekit_internal.pb.go +++ b/livekit/livekit_internal.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: livekit_internal.proto package livekit diff --git a/livekit/livekit_metrics.pb.go b/livekit/livekit_metrics.pb.go index 72f2b97c4..2bc367d5b 100644 --- a/livekit/livekit_metrics.pb.go +++ b/livekit/livekit_metrics.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: livekit_metrics.proto package livekit diff --git a/livekit/livekit_models.pb.go b/livekit/livekit_models.pb.go index cf756793d..00733a0a8 100644 --- a/livekit/livekit_models.pb.go +++ b/livekit/livekit_models.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: livekit_models.proto package livekit diff --git a/livekit/livekit_phone_number.pb.go b/livekit/livekit_phone_number.pb.go index c96949bd9..50b720867 100644 --- a/livekit/livekit_phone_number.pb.go +++ b/livekit/livekit_phone_number.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: livekit_phone_number.proto package livekit diff --git a/livekit/livekit_room.pb.go b/livekit/livekit_room.pb.go index ff06b480e..5f6ca0215 100644 --- a/livekit/livekit_room.pb.go +++ b/livekit/livekit_room.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: livekit_room.proto package livekit diff --git a/livekit/livekit_rtc.pb.go b/livekit/livekit_rtc.pb.go index ee821db4b..9699b1539 100644 --- a/livekit/livekit_rtc.pb.go +++ b/livekit/livekit_rtc.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: livekit_rtc.proto package livekit diff --git a/livekit/livekit_sip.pb.go b/livekit/livekit_sip.pb.go index 8f3f942a5..08f83a03d 100644 --- a/livekit/livekit_sip.pb.go +++ b/livekit/livekit_sip.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: livekit_sip.proto package livekit diff --git a/livekit/livekit_webhook.pb.go b/livekit/livekit_webhook.pb.go index f14b4a41b..f5b87fead 100644 --- a/livekit/livekit_webhook.pb.go +++ b/livekit/livekit_webhook.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: livekit_webhook.proto package livekit diff --git a/replay/cloud_replay.pb.go b/replay/cloud_replay.pb.go index ef49cd889..90717043e 100644 --- a/replay/cloud_replay.pb.go +++ b/replay/cloud_replay.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: cloud_replay.proto package replay diff --git a/rpc/agent.pb.go b/rpc/agent.pb.go index 71db5934a..5dc973385 100644 --- a/rpc/agent.pb.go +++ b/rpc/agent.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: rpc/agent.proto package rpc diff --git a/rpc/agent_dispatch.pb.go b/rpc/agent_dispatch.pb.go index c06b3631f..88a3a9134 100644 --- a/rpc/agent_dispatch.pb.go +++ b/rpc/agent_dispatch.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: rpc/agent_dispatch.proto package rpc diff --git a/rpc/analytics.pb.go b/rpc/analytics.pb.go index 655d51ae0..306fffa89 100644 --- a/rpc/analytics.pb.go +++ b/rpc/analytics.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: rpc/analytics.proto package rpc diff --git a/rpc/analytics_grpc.pb.go b/rpc/analytics_grpc.pb.go index f59684f38..6217bb431 100644 --- a/rpc/analytics_grpc.pb.go +++ b/rpc/analytics_grpc.pb.go @@ -15,7 +15,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.5.1 -// - protoc v5.29.3 +// - protoc v4.23.4 // source: rpc/analytics.proto package rpc diff --git a/rpc/egress.pb.go b/rpc/egress.pb.go index cd5d763ae..06662bb3a 100644 --- a/rpc/egress.pb.go +++ b/rpc/egress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: rpc/egress.proto package rpc diff --git a/rpc/ingress.pb.go b/rpc/ingress.pb.go index 12fc82f27..f42584535 100644 --- a/rpc/ingress.pb.go +++ b/rpc/ingress.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: rpc/ingress.proto package rpc diff --git a/rpc/io.pb.go b/rpc/io.pb.go index 767b3fa71..2271746ba 100644 --- a/rpc/io.pb.go +++ b/rpc/io.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: rpc/io.proto package rpc diff --git a/rpc/keepalive.pb.go b/rpc/keepalive.pb.go index e5509237f..761edd1b8 100644 --- a/rpc/keepalive.pb.go +++ b/rpc/keepalive.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: rpc/keepalive.proto package rpc diff --git a/rpc/participant.pb.go b/rpc/participant.pb.go index c5ea43c41..e919d1a6e 100644 --- a/rpc/participant.pb.go +++ b/rpc/participant.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: rpc/participant.proto package rpc diff --git a/rpc/room.pb.go b/rpc/room.pb.go index 95468f44a..6454b489c 100644 --- a/rpc/room.pb.go +++ b/rpc/room.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: rpc/room.proto package rpc diff --git a/rpc/roommanager.pb.go b/rpc/roommanager.pb.go index 5b3a7b365..6424aba6b 100644 --- a/rpc/roommanager.pb.go +++ b/rpc/roommanager.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: rpc/roommanager.proto package rpc diff --git a/rpc/signal.pb.go b/rpc/signal.pb.go index 26d310469..18564147e 100644 --- a/rpc/signal.pb.go +++ b/rpc/signal.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: rpc/signal.proto package rpc diff --git a/rpc/sip.pb.go b/rpc/sip.pb.go index fa65dd2ba..264cb6880 100644 --- a/rpc/sip.pb.go +++ b/rpc/sip.pb.go @@ -14,8 +14,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: rpc/sip.proto package rpc diff --git a/rpc/whip_signal.pb.go b/rpc/whip_signal.pb.go index 54727aeed..47dc35763 100644 --- a/rpc/whip_signal.pb.go +++ b/rpc/whip_signal.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.36.6 -// protoc v5.29.3 +// protoc-gen-go v1.36.9 +// protoc v4.23.4 // source: rpc/whip_signal.proto package rpc