diff --git a/livekit-protocol/livekit/protocol/agent.py b/livekit-protocol/livekit/protocol/agent.py index 5f8bf8ab..b83ff034 100644 --- a/livekit-protocol/livekit/protocol/agent.py +++ b/livekit-protocol/livekit/protocol/agent.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: livekit_agent.proto +# Protobuf Python Version: 4.25.3 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -20,9 +21,8 @@ _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'agent', _globals) if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' + _globals['DESCRIPTOR']._options = None + _globals['DESCRIPTOR']._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' _globals['_JOBTYPE']._serialized_start=2206 _globals['_JOBTYPE']._serialized_end=2246 _globals['_WORKERSTATUS']._serialized_start=2248 diff --git a/livekit-protocol/livekit/protocol/agent.pyi b/livekit-protocol/livekit/protocol/agent.pyi index 004ce082..502f695b 100644 --- a/livekit-protocol/livekit/protocol/agent.pyi +++ b/livekit-protocol/livekit/protocol/agent.pyi @@ -7,17 +7,17 @@ from typing import ClassVar as _ClassVar, Mapping as _Mapping, Optional as _Opti DESCRIPTOR: _descriptor.FileDescriptor class JobType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () JT_ROOM: _ClassVar[JobType] JT_PUBLISHER: _ClassVar[JobType] class WorkerStatus(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () WS_AVAILABLE: _ClassVar[WorkerStatus] WS_FULL: _ClassVar[WorkerStatus] class JobStatus(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () JS_UNKNOWN: _ClassVar[JobStatus] JS_SUCCESS: _ClassVar[JobStatus] JS_FAILED: _ClassVar[JobStatus] @@ -30,7 +30,7 @@ JS_SUCCESS: JobStatus JS_FAILED: JobStatus class WorkerInfo(_message.Message): - __slots__ = ["id", "namespace", "version", "name", "type", "allowed_permissions"] + __slots__ = ("id", "namespace", "version", "name", "type", "allowed_permissions") ID_FIELD_NUMBER: _ClassVar[int] NAMESPACE_FIELD_NUMBER: _ClassVar[int] VERSION_FIELD_NUMBER: _ClassVar[int] @@ -46,7 +46,7 @@ class WorkerInfo(_message.Message): def __init__(self, id: _Optional[str] = ..., namespace: _Optional[str] = ..., version: _Optional[str] = ..., name: _Optional[str] = ..., type: _Optional[_Union[JobType, str]] = ..., allowed_permissions: _Optional[_Union[_models.ParticipantPermission, _Mapping]] = ...) -> None: ... class AgentInfo(_message.Message): - __slots__ = ["id", "name", "version"] + __slots__ = ("id", "name", "version") ID_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] VERSION_FIELD_NUMBER: _ClassVar[int] @@ -56,7 +56,7 @@ class AgentInfo(_message.Message): def __init__(self, id: _Optional[str] = ..., name: _Optional[str] = ..., version: _Optional[str] = ...) -> None: ... class Job(_message.Message): - __slots__ = ["id", "type", "room", "participant", "namespace"] + __slots__ = ("id", "type", "room", "participant", "namespace") ID_FIELD_NUMBER: _ClassVar[int] TYPE_FIELD_NUMBER: _ClassVar[int] ROOM_FIELD_NUMBER: _ClassVar[int] @@ -70,7 +70,7 @@ class Job(_message.Message): def __init__(self, id: _Optional[str] = ..., type: _Optional[_Union[JobType, str]] = ..., room: _Optional[_Union[_models.Room, _Mapping]] = ..., participant: _Optional[_Union[_models.ParticipantInfo, _Mapping]] = ..., namespace: _Optional[str] = ...) -> None: ... class WorkerMessage(_message.Message): - __slots__ = ["register", "availability", "update_worker", "update_job", "ping", "simulate_job", "migrate_job"] + __slots__ = ("register", "availability", "update_worker", "update_job", "ping", "simulate_job", "migrate_job") REGISTER_FIELD_NUMBER: _ClassVar[int] AVAILABILITY_FIELD_NUMBER: _ClassVar[int] UPDATE_WORKER_FIELD_NUMBER: _ClassVar[int] @@ -88,7 +88,7 @@ class WorkerMessage(_message.Message): def __init__(self, register: _Optional[_Union[RegisterWorkerRequest, _Mapping]] = ..., availability: _Optional[_Union[AvailabilityResponse, _Mapping]] = ..., update_worker: _Optional[_Union[UpdateWorkerStatus, _Mapping]] = ..., update_job: _Optional[_Union[UpdateJobStatus, _Mapping]] = ..., ping: _Optional[_Union[WorkerPing, _Mapping]] = ..., simulate_job: _Optional[_Union[SimulateJobRequest, _Mapping]] = ..., migrate_job: _Optional[_Union[MigrateJobRequest, _Mapping]] = ...) -> None: ... class ServerMessage(_message.Message): - __slots__ = ["register", "availability", "assignment", "pong"] + __slots__ = ("register", "availability", "assignment", "pong") REGISTER_FIELD_NUMBER: _ClassVar[int] AVAILABILITY_FIELD_NUMBER: _ClassVar[int] ASSIGNMENT_FIELD_NUMBER: _ClassVar[int] @@ -100,7 +100,7 @@ class ServerMessage(_message.Message): def __init__(self, register: _Optional[_Union[RegisterWorkerResponse, _Mapping]] = ..., availability: _Optional[_Union[AvailabilityRequest, _Mapping]] = ..., assignment: _Optional[_Union[JobAssignment, _Mapping]] = ..., pong: _Optional[_Union[WorkerPong, _Mapping]] = ...) -> None: ... class SimulateJobRequest(_message.Message): - __slots__ = ["type", "room", "participant"] + __slots__ = ("type", "room", "participant") TYPE_FIELD_NUMBER: _ClassVar[int] ROOM_FIELD_NUMBER: _ClassVar[int] PARTICIPANT_FIELD_NUMBER: _ClassVar[int] @@ -110,13 +110,13 @@ class SimulateJobRequest(_message.Message): def __init__(self, type: _Optional[_Union[JobType, str]] = ..., room: _Optional[_Union[_models.Room, _Mapping]] = ..., participant: _Optional[_Union[_models.ParticipantInfo, _Mapping]] = ...) -> None: ... class WorkerPing(_message.Message): - __slots__ = ["timestamp"] + __slots__ = ("timestamp",) TIMESTAMP_FIELD_NUMBER: _ClassVar[int] timestamp: int def __init__(self, timestamp: _Optional[int] = ...) -> None: ... class WorkerPong(_message.Message): - __slots__ = ["last_timestamp", "timestamp"] + __slots__ = ("last_timestamp", "timestamp") LAST_TIMESTAMP_FIELD_NUMBER: _ClassVar[int] TIMESTAMP_FIELD_NUMBER: _ClassVar[int] last_timestamp: int @@ -124,7 +124,7 @@ class WorkerPong(_message.Message): def __init__(self, last_timestamp: _Optional[int] = ..., timestamp: _Optional[int] = ...) -> None: ... class RegisterWorkerRequest(_message.Message): - __slots__ = ["type", "version", "name", "ping_interval", "namespace", "allowed_permissions"] + __slots__ = ("type", "version", "name", "ping_interval", "namespace", "allowed_permissions") TYPE_FIELD_NUMBER: _ClassVar[int] VERSION_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] @@ -140,7 +140,7 @@ class RegisterWorkerRequest(_message.Message): def __init__(self, type: _Optional[_Union[JobType, str]] = ..., version: _Optional[str] = ..., name: _Optional[str] = ..., ping_interval: _Optional[int] = ..., namespace: _Optional[str] = ..., allowed_permissions: _Optional[_Union[_models.ParticipantPermission, _Mapping]] = ...) -> None: ... class RegisterWorkerResponse(_message.Message): - __slots__ = ["worker_id", "server_info"] + __slots__ = ("worker_id", "server_info") WORKER_ID_FIELD_NUMBER: _ClassVar[int] SERVER_INFO_FIELD_NUMBER: _ClassVar[int] worker_id: str @@ -148,13 +148,13 @@ class RegisterWorkerResponse(_message.Message): def __init__(self, worker_id: _Optional[str] = ..., server_info: _Optional[_Union[_models.ServerInfo, _Mapping]] = ...) -> None: ... class MigrateJobRequest(_message.Message): - __slots__ = ["job_id"] + __slots__ = ("job_id",) JOB_ID_FIELD_NUMBER: _ClassVar[int] job_id: str def __init__(self, job_id: _Optional[str] = ...) -> None: ... class AvailabilityRequest(_message.Message): - __slots__ = ["job", "resuming"] + __slots__ = ("job", "resuming") JOB_FIELD_NUMBER: _ClassVar[int] RESUMING_FIELD_NUMBER: _ClassVar[int] job: Job @@ -162,7 +162,7 @@ class AvailabilityRequest(_message.Message): def __init__(self, job: _Optional[_Union[Job, _Mapping]] = ..., resuming: bool = ...) -> None: ... class AvailabilityResponse(_message.Message): - __slots__ = ["job_id", "available", "supports_resume", "participant_name", "participant_identity", "participant_metadata"] + __slots__ = ("job_id", "available", "supports_resume", "participant_name", "participant_identity", "participant_metadata") JOB_ID_FIELD_NUMBER: _ClassVar[int] AVAILABLE_FIELD_NUMBER: _ClassVar[int] SUPPORTS_RESUME_FIELD_NUMBER: _ClassVar[int] @@ -178,7 +178,7 @@ class AvailabilityResponse(_message.Message): def __init__(self, job_id: _Optional[str] = ..., available: bool = ..., supports_resume: bool = ..., participant_name: _Optional[str] = ..., participant_identity: _Optional[str] = ..., participant_metadata: _Optional[str] = ...) -> None: ... class UpdateJobStatus(_message.Message): - __slots__ = ["job_id", "status", "error", "metadata", "load"] + __slots__ = ("job_id", "status", "error", "metadata", "load") JOB_ID_FIELD_NUMBER: _ClassVar[int] STATUS_FIELD_NUMBER: _ClassVar[int] ERROR_FIELD_NUMBER: _ClassVar[int] @@ -192,7 +192,7 @@ class UpdateJobStatus(_message.Message): def __init__(self, job_id: _Optional[str] = ..., status: _Optional[_Union[JobStatus, str]] = ..., error: _Optional[str] = ..., metadata: _Optional[str] = ..., load: _Optional[float] = ...) -> None: ... class UpdateWorkerStatus(_message.Message): - __slots__ = ["status", "metadata", "load"] + __slots__ = ("status", "metadata", "load") STATUS_FIELD_NUMBER: _ClassVar[int] METADATA_FIELD_NUMBER: _ClassVar[int] LOAD_FIELD_NUMBER: _ClassVar[int] @@ -202,7 +202,7 @@ class UpdateWorkerStatus(_message.Message): def __init__(self, status: _Optional[_Union[WorkerStatus, str]] = ..., metadata: _Optional[str] = ..., load: _Optional[float] = ...) -> None: ... class JobAssignment(_message.Message): - __slots__ = ["job", "url", "token"] + __slots__ = ("job", "url", "token") JOB_FIELD_NUMBER: _ClassVar[int] URL_FIELD_NUMBER: _ClassVar[int] TOKEN_FIELD_NUMBER: _ClassVar[int] diff --git a/livekit-protocol/livekit/protocol/analytics.py b/livekit-protocol/livekit/protocol/analytics.py index 50defd2c..15fef1ba 100644 --- a/livekit-protocol/livekit/protocol/analytics.py +++ b/livekit-protocol/livekit/protocol/analytics.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: livekit_analytics.proto +# Protobuf Python Version: 4.25.3 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -23,9 +24,8 @@ _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'analytics', _globals) if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' + _globals['DESCRIPTOR']._options = None + _globals['DESCRIPTOR']._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' _globals['_STREAMTYPE']._serialized_start=2625 _globals['_STREAMTYPE']._serialized_end=2667 _globals['_ANALYTICSEVENTTYPE']._serialized_start=2670 diff --git a/livekit-protocol/livekit/protocol/analytics.pyi b/livekit-protocol/livekit/protocol/analytics.pyi index 5a5142ae..30cfbd50 100644 --- a/livekit-protocol/livekit/protocol/analytics.pyi +++ b/livekit-protocol/livekit/protocol/analytics.pyi @@ -11,12 +11,12 @@ from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Map DESCRIPTOR: _descriptor.FileDescriptor class StreamType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () UPSTREAM: _ClassVar[StreamType] DOWNSTREAM: _ClassVar[StreamType] class AnalyticsEventType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () ROOM_CREATED: _ClassVar[AnalyticsEventType] ROOM_ENDED: _ClassVar[AnalyticsEventType] PARTICIPANT_JOINED: _ClassVar[AnalyticsEventType] @@ -77,7 +77,7 @@ INGRESS_ENDED: AnalyticsEventType INGRESS_UPDATED: AnalyticsEventType class AnalyticsVideoLayer(_message.Message): - __slots__ = ["layer", "packets", "bytes", "frames"] + __slots__ = ("layer", "packets", "bytes", "frames") LAYER_FIELD_NUMBER: _ClassVar[int] PACKETS_FIELD_NUMBER: _ClassVar[int] BYTES_FIELD_NUMBER: _ClassVar[int] @@ -89,7 +89,7 @@ class AnalyticsVideoLayer(_message.Message): def __init__(self, layer: _Optional[int] = ..., packets: _Optional[int] = ..., bytes: _Optional[int] = ..., frames: _Optional[int] = ...) -> None: ... class AnalyticsStream(_message.Message): - __slots__ = ["ssrc", "primary_packets", "primary_bytes", "retransmit_packets", "retransmit_bytes", "padding_packets", "padding_bytes", "packets_lost", "frames", "rtt", "jitter", "nacks", "plis", "firs", "video_layers", "start_time", "end_time"] + __slots__ = ("ssrc", "primary_packets", "primary_bytes", "retransmit_packets", "retransmit_bytes", "padding_packets", "padding_bytes", "packets_lost", "frames", "rtt", "jitter", "nacks", "plis", "firs", "video_layers", "start_time", "end_time") SSRC_FIELD_NUMBER: _ClassVar[int] PRIMARY_PACKETS_FIELD_NUMBER: _ClassVar[int] PRIMARY_BYTES_FIELD_NUMBER: _ClassVar[int] @@ -127,7 +127,7 @@ class AnalyticsStream(_message.Message): def __init__(self, ssrc: _Optional[int] = ..., primary_packets: _Optional[int] = ..., primary_bytes: _Optional[int] = ..., retransmit_packets: _Optional[int] = ..., retransmit_bytes: _Optional[int] = ..., padding_packets: _Optional[int] = ..., padding_bytes: _Optional[int] = ..., packets_lost: _Optional[int] = ..., frames: _Optional[int] = ..., rtt: _Optional[int] = ..., jitter: _Optional[int] = ..., nacks: _Optional[int] = ..., plis: _Optional[int] = ..., firs: _Optional[int] = ..., video_layers: _Optional[_Iterable[_Union[AnalyticsVideoLayer, _Mapping]]] = ..., start_time: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., end_time: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ...) -> None: ... class AnalyticsStat(_message.Message): - __slots__ = ["id", "analytics_key", "kind", "time_stamp", "node", "room_id", "room_name", "participant_id", "track_id", "score", "streams", "mime", "min_score", "median_score"] + __slots__ = ("id", "analytics_key", "kind", "time_stamp", "node", "room_id", "room_name", "participant_id", "track_id", "score", "streams", "mime", "min_score", "median_score") ID_FIELD_NUMBER: _ClassVar[int] ANALYTICS_KEY_FIELD_NUMBER: _ClassVar[int] KIND_FIELD_NUMBER: _ClassVar[int] @@ -159,13 +159,13 @@ class AnalyticsStat(_message.Message): def __init__(self, id: _Optional[str] = ..., analytics_key: _Optional[str] = ..., kind: _Optional[_Union[StreamType, str]] = ..., time_stamp: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., node: _Optional[str] = ..., room_id: _Optional[str] = ..., room_name: _Optional[str] = ..., participant_id: _Optional[str] = ..., track_id: _Optional[str] = ..., score: _Optional[float] = ..., streams: _Optional[_Iterable[_Union[AnalyticsStream, _Mapping]]] = ..., mime: _Optional[str] = ..., min_score: _Optional[float] = ..., median_score: _Optional[float] = ...) -> None: ... class AnalyticsStats(_message.Message): - __slots__ = ["stats"] + __slots__ = ("stats",) STATS_FIELD_NUMBER: _ClassVar[int] stats: _containers.RepeatedCompositeFieldContainer[AnalyticsStat] def __init__(self, stats: _Optional[_Iterable[_Union[AnalyticsStat, _Mapping]]] = ...) -> None: ... class AnalyticsClientMeta(_message.Message): - __slots__ = ["region", "node", "client_addr", "client_connect_time", "connection_type", "reconnect_reason", "geo_hash", "country", "isp_asn"] + __slots__ = ("region", "node", "client_addr", "client_connect_time", "connection_type", "reconnect_reason", "geo_hash", "country", "isp_asn") REGION_FIELD_NUMBER: _ClassVar[int] NODE_FIELD_NUMBER: _ClassVar[int] CLIENT_ADDR_FIELD_NUMBER: _ClassVar[int] @@ -187,7 +187,7 @@ class AnalyticsClientMeta(_message.Message): def __init__(self, region: _Optional[str] = ..., node: _Optional[str] = ..., client_addr: _Optional[str] = ..., client_connect_time: _Optional[int] = ..., connection_type: _Optional[str] = ..., reconnect_reason: _Optional[_Union[_models.ReconnectReason, str]] = ..., geo_hash: _Optional[str] = ..., country: _Optional[str] = ..., isp_asn: _Optional[int] = ...) -> None: ... class AnalyticsEvent(_message.Message): - __slots__ = ["id", "type", "timestamp", "room_id", "room", "participant_id", "participant", "track_id", "track", "analytics_key", "client_info", "client_meta", "egress_id", "ingress_id", "max_subscribed_video_quality", "publisher", "mime", "egress", "ingress", "error", "rtp_stats", "video_layer", "node_id"] + __slots__ = ("id", "type", "timestamp", "room_id", "room", "participant_id", "participant", "track_id", "track", "analytics_key", "client_info", "client_meta", "egress_id", "ingress_id", "max_subscribed_video_quality", "publisher", "mime", "egress", "ingress", "error", "rtp_stats", "video_layer", "node_id") ID_FIELD_NUMBER: _ClassVar[int] TYPE_FIELD_NUMBER: _ClassVar[int] TIMESTAMP_FIELD_NUMBER: _ClassVar[int] @@ -237,13 +237,13 @@ class AnalyticsEvent(_message.Message): def __init__(self, id: _Optional[str] = ..., type: _Optional[_Union[AnalyticsEventType, str]] = ..., timestamp: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., room_id: _Optional[str] = ..., room: _Optional[_Union[_models.Room, _Mapping]] = ..., participant_id: _Optional[str] = ..., participant: _Optional[_Union[_models.ParticipantInfo, _Mapping]] = ..., track_id: _Optional[str] = ..., track: _Optional[_Union[_models.TrackInfo, _Mapping]] = ..., analytics_key: _Optional[str] = ..., client_info: _Optional[_Union[_models.ClientInfo, _Mapping]] = ..., client_meta: _Optional[_Union[AnalyticsClientMeta, _Mapping]] = ..., egress_id: _Optional[str] = ..., ingress_id: _Optional[str] = ..., max_subscribed_video_quality: _Optional[_Union[_models.VideoQuality, str]] = ..., publisher: _Optional[_Union[_models.ParticipantInfo, _Mapping]] = ..., mime: _Optional[str] = ..., egress: _Optional[_Union[_egress.EgressInfo, _Mapping]] = ..., ingress: _Optional[_Union[_ingress.IngressInfo, _Mapping]] = ..., error: _Optional[str] = ..., rtp_stats: _Optional[_Union[_models.RTPStats, _Mapping]] = ..., video_layer: _Optional[int] = ..., node_id: _Optional[str] = ...) -> None: ... class AnalyticsEvents(_message.Message): - __slots__ = ["events"] + __slots__ = ("events",) EVENTS_FIELD_NUMBER: _ClassVar[int] events: _containers.RepeatedCompositeFieldContainer[AnalyticsEvent] def __init__(self, events: _Optional[_Iterable[_Union[AnalyticsEvent, _Mapping]]] = ...) -> None: ... class AnalyticsRoomParticipant(_message.Message): - __slots__ = ["id", "identity", "name", "state", "joined_at"] + __slots__ = ("id", "identity", "name", "state", "joined_at") ID_FIELD_NUMBER: _ClassVar[int] IDENTITY_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] @@ -257,7 +257,7 @@ class AnalyticsRoomParticipant(_message.Message): def __init__(self, id: _Optional[str] = ..., identity: _Optional[str] = ..., name: _Optional[str] = ..., state: _Optional[_Union[_models.ParticipantInfo.State, str]] = ..., joined_at: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ...) -> None: ... class AnalyticsRoom(_message.Message): - __slots__ = ["id", "name", "project_id", "created_at", "participants"] + __slots__ = ("id", "name", "project_id", "created_at", "participants") ID_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] PROJECT_ID_FIELD_NUMBER: _ClassVar[int] @@ -271,7 +271,7 @@ class AnalyticsRoom(_message.Message): def __init__(self, id: _Optional[str] = ..., name: _Optional[str] = ..., project_id: _Optional[str] = ..., created_at: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., participants: _Optional[_Iterable[_Union[AnalyticsRoomParticipant, _Mapping]]] = ...) -> None: ... class AnalyticsNodeRooms(_message.Message): - __slots__ = ["node_id", "sequence_number", "timestamp", "rooms"] + __slots__ = ("node_id", "sequence_number", "timestamp", "rooms") NODE_ID_FIELD_NUMBER: _ClassVar[int] SEQUENCE_NUMBER_FIELD_NUMBER: _ClassVar[int] TIMESTAMP_FIELD_NUMBER: _ClassVar[int] diff --git a/livekit-protocol/livekit/protocol/egress.py b/livekit-protocol/livekit/protocol/egress.py index c7848fe5..1fc90211 100644 --- a/livekit-protocol/livekit/protocol/egress.py +++ b/livekit-protocol/livekit/protocol/egress.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: livekit_egress.proto +# Protobuf Python Version: 4.25.3 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -20,37 +21,36 @@ _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'egress', _globals) if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' - _ROOMCOMPOSITEEGRESSREQUEST.fields_by_name['file']._options = None - _ROOMCOMPOSITEEGRESSREQUEST.fields_by_name['file']._serialized_options = b'\030\001' - _ROOMCOMPOSITEEGRESSREQUEST.fields_by_name['stream']._options = None - _ROOMCOMPOSITEEGRESSREQUEST.fields_by_name['stream']._serialized_options = b'\030\001' - _ROOMCOMPOSITEEGRESSREQUEST.fields_by_name['segments']._options = None - _ROOMCOMPOSITEEGRESSREQUEST.fields_by_name['segments']._serialized_options = b'\030\001' - _WEBEGRESSREQUEST.fields_by_name['file']._options = None - _WEBEGRESSREQUEST.fields_by_name['file']._serialized_options = b'\030\001' - _WEBEGRESSREQUEST.fields_by_name['stream']._options = None - _WEBEGRESSREQUEST.fields_by_name['stream']._serialized_options = b'\030\001' - _WEBEGRESSREQUEST.fields_by_name['segments']._options = None - _WEBEGRESSREQUEST.fields_by_name['segments']._serialized_options = b'\030\001' - _TRACKCOMPOSITEEGRESSREQUEST.fields_by_name['file']._options = None - _TRACKCOMPOSITEEGRESSREQUEST.fields_by_name['file']._serialized_options = b'\030\001' - _TRACKCOMPOSITEEGRESSREQUEST.fields_by_name['stream']._options = None - _TRACKCOMPOSITEEGRESSREQUEST.fields_by_name['stream']._serialized_options = b'\030\001' - _TRACKCOMPOSITEEGRESSREQUEST.fields_by_name['segments']._options = None - _TRACKCOMPOSITEEGRESSREQUEST.fields_by_name['segments']._serialized_options = b'\030\001' - _S3UPLOAD_METADATAENTRY._options = None - _S3UPLOAD_METADATAENTRY._serialized_options = b'8\001' - _EGRESSINFO.fields_by_name['stream']._options = None - _EGRESSINFO.fields_by_name['stream']._serialized_options = b'\030\001' - _EGRESSINFO.fields_by_name['file']._options = None - _EGRESSINFO.fields_by_name['file']._serialized_options = b'\030\001' - _EGRESSINFO.fields_by_name['segments']._options = None - _EGRESSINFO.fields_by_name['segments']._serialized_options = b'\030\001' - _STREAMINFOLIST._options = None - _STREAMINFOLIST._serialized_options = b'\030\001' + _globals['DESCRIPTOR']._options = None + _globals['DESCRIPTOR']._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' + _globals['_ROOMCOMPOSITEEGRESSREQUEST'].fields_by_name['file']._options = None + _globals['_ROOMCOMPOSITEEGRESSREQUEST'].fields_by_name['file']._serialized_options = b'\030\001' + _globals['_ROOMCOMPOSITEEGRESSREQUEST'].fields_by_name['stream']._options = None + _globals['_ROOMCOMPOSITEEGRESSREQUEST'].fields_by_name['stream']._serialized_options = b'\030\001' + _globals['_ROOMCOMPOSITEEGRESSREQUEST'].fields_by_name['segments']._options = None + _globals['_ROOMCOMPOSITEEGRESSREQUEST'].fields_by_name['segments']._serialized_options = b'\030\001' + _globals['_WEBEGRESSREQUEST'].fields_by_name['file']._options = None + _globals['_WEBEGRESSREQUEST'].fields_by_name['file']._serialized_options = b'\030\001' + _globals['_WEBEGRESSREQUEST'].fields_by_name['stream']._options = None + _globals['_WEBEGRESSREQUEST'].fields_by_name['stream']._serialized_options = b'\030\001' + _globals['_WEBEGRESSREQUEST'].fields_by_name['segments']._options = None + _globals['_WEBEGRESSREQUEST'].fields_by_name['segments']._serialized_options = b'\030\001' + _globals['_TRACKCOMPOSITEEGRESSREQUEST'].fields_by_name['file']._options = None + _globals['_TRACKCOMPOSITEEGRESSREQUEST'].fields_by_name['file']._serialized_options = b'\030\001' + _globals['_TRACKCOMPOSITEEGRESSREQUEST'].fields_by_name['stream']._options = None + _globals['_TRACKCOMPOSITEEGRESSREQUEST'].fields_by_name['stream']._serialized_options = b'\030\001' + _globals['_TRACKCOMPOSITEEGRESSREQUEST'].fields_by_name['segments']._options = None + _globals['_TRACKCOMPOSITEEGRESSREQUEST'].fields_by_name['segments']._serialized_options = b'\030\001' + _globals['_S3UPLOAD_METADATAENTRY']._options = None + _globals['_S3UPLOAD_METADATAENTRY']._serialized_options = b'8\001' + _globals['_EGRESSINFO'].fields_by_name['stream']._options = None + _globals['_EGRESSINFO'].fields_by_name['stream']._serialized_options = b'\030\001' + _globals['_EGRESSINFO'].fields_by_name['file']._options = None + _globals['_EGRESSINFO'].fields_by_name['file']._serialized_options = b'\030\001' + _globals['_EGRESSINFO'].fields_by_name['segments']._options = None + _globals['_EGRESSINFO'].fields_by_name['segments']._serialized_options = b'\030\001' + _globals['_STREAMINFOLIST']._options = None + _globals['_STREAMINFOLIST']._serialized_options = b'\030\001' _globals['_ENCODEDFILETYPE']._serialized_start=6929 _globals['_ENCODEDFILETYPE']._serialized_end=6986 _globals['_SEGMENTEDFILEPROTOCOL']._serialized_start=6988 diff --git a/livekit-protocol/livekit/protocol/egress.pyi b/livekit-protocol/livekit/protocol/egress.pyi index 054d149b..50d0ed2f 100644 --- a/livekit-protocol/livekit/protocol/egress.pyi +++ b/livekit-protocol/livekit/protocol/egress.pyi @@ -8,33 +8,33 @@ from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Map DESCRIPTOR: _descriptor.FileDescriptor class EncodedFileType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () DEFAULT_FILETYPE: _ClassVar[EncodedFileType] MP4: _ClassVar[EncodedFileType] OGG: _ClassVar[EncodedFileType] class SegmentedFileProtocol(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () DEFAULT_SEGMENTED_FILE_PROTOCOL: _ClassVar[SegmentedFileProtocol] HLS_PROTOCOL: _ClassVar[SegmentedFileProtocol] class SegmentedFileSuffix(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () INDEX: _ClassVar[SegmentedFileSuffix] TIMESTAMP: _ClassVar[SegmentedFileSuffix] class ImageFileSuffix(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () IMAGE_SUFFIX_INDEX: _ClassVar[ImageFileSuffix] IMAGE_SUFFIX_TIMESTAMP: _ClassVar[ImageFileSuffix] class StreamProtocol(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () DEFAULT_PROTOCOL: _ClassVar[StreamProtocol] RTMP: _ClassVar[StreamProtocol] class EncodingOptionsPreset(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () H264_720P_30: _ClassVar[EncodingOptionsPreset] H264_720P_60: _ClassVar[EncodingOptionsPreset] H264_1080P_30: _ClassVar[EncodingOptionsPreset] @@ -45,7 +45,7 @@ class EncodingOptionsPreset(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): PORTRAIT_H264_1080P_60: _ClassVar[EncodingOptionsPreset] class EgressStatus(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () EGRESS_STARTING: _ClassVar[EgressStatus] EGRESS_ACTIVE: _ClassVar[EgressStatus] EGRESS_ENDING: _ClassVar[EgressStatus] @@ -81,7 +81,7 @@ EGRESS_ABORTED: EgressStatus EGRESS_LIMIT_REACHED: EgressStatus class RoomCompositeEgressRequest(_message.Message): - __slots__ = ["room_name", "layout", "audio_only", "video_only", "custom_base_url", "file", "stream", "segments", "preset", "advanced", "file_outputs", "stream_outputs", "segment_outputs", "image_outputs"] + __slots__ = ("room_name", "layout", "audio_only", "video_only", "custom_base_url", "file", "stream", "segments", "preset", "advanced", "file_outputs", "stream_outputs", "segment_outputs", "image_outputs") ROOM_NAME_FIELD_NUMBER: _ClassVar[int] LAYOUT_FIELD_NUMBER: _ClassVar[int] AUDIO_ONLY_FIELD_NUMBER: _ClassVar[int] @@ -113,7 +113,7 @@ class RoomCompositeEgressRequest(_message.Message): def __init__(self, room_name: _Optional[str] = ..., layout: _Optional[str] = ..., audio_only: bool = ..., video_only: bool = ..., custom_base_url: _Optional[str] = ..., file: _Optional[_Union[EncodedFileOutput, _Mapping]] = ..., stream: _Optional[_Union[StreamOutput, _Mapping]] = ..., segments: _Optional[_Union[SegmentedFileOutput, _Mapping]] = ..., preset: _Optional[_Union[EncodingOptionsPreset, str]] = ..., advanced: _Optional[_Union[EncodingOptions, _Mapping]] = ..., file_outputs: _Optional[_Iterable[_Union[EncodedFileOutput, _Mapping]]] = ..., stream_outputs: _Optional[_Iterable[_Union[StreamOutput, _Mapping]]] = ..., segment_outputs: _Optional[_Iterable[_Union[SegmentedFileOutput, _Mapping]]] = ..., image_outputs: _Optional[_Iterable[_Union[ImageOutput, _Mapping]]] = ...) -> None: ... class WebEgressRequest(_message.Message): - __slots__ = ["url", "audio_only", "video_only", "await_start_signal", "file", "stream", "segments", "preset", "advanced", "file_outputs", "stream_outputs", "segment_outputs", "image_outputs"] + __slots__ = ("url", "audio_only", "video_only", "await_start_signal", "file", "stream", "segments", "preset", "advanced", "file_outputs", "stream_outputs", "segment_outputs", "image_outputs") URL_FIELD_NUMBER: _ClassVar[int] AUDIO_ONLY_FIELD_NUMBER: _ClassVar[int] VIDEO_ONLY_FIELD_NUMBER: _ClassVar[int] @@ -143,7 +143,7 @@ class WebEgressRequest(_message.Message): def __init__(self, url: _Optional[str] = ..., audio_only: bool = ..., video_only: bool = ..., await_start_signal: bool = ..., file: _Optional[_Union[EncodedFileOutput, _Mapping]] = ..., stream: _Optional[_Union[StreamOutput, _Mapping]] = ..., segments: _Optional[_Union[SegmentedFileOutput, _Mapping]] = ..., preset: _Optional[_Union[EncodingOptionsPreset, str]] = ..., advanced: _Optional[_Union[EncodingOptions, _Mapping]] = ..., file_outputs: _Optional[_Iterable[_Union[EncodedFileOutput, _Mapping]]] = ..., stream_outputs: _Optional[_Iterable[_Union[StreamOutput, _Mapping]]] = ..., segment_outputs: _Optional[_Iterable[_Union[SegmentedFileOutput, _Mapping]]] = ..., image_outputs: _Optional[_Iterable[_Union[ImageOutput, _Mapping]]] = ...) -> None: ... class ParticipantEgressRequest(_message.Message): - __slots__ = ["room_name", "identity", "screen_share", "preset", "advanced", "file_outputs", "stream_outputs", "segment_outputs", "image_outputs"] + __slots__ = ("room_name", "identity", "screen_share", "preset", "advanced", "file_outputs", "stream_outputs", "segment_outputs", "image_outputs") ROOM_NAME_FIELD_NUMBER: _ClassVar[int] IDENTITY_FIELD_NUMBER: _ClassVar[int] SCREEN_SHARE_FIELD_NUMBER: _ClassVar[int] @@ -165,7 +165,7 @@ class ParticipantEgressRequest(_message.Message): def __init__(self, room_name: _Optional[str] = ..., identity: _Optional[str] = ..., screen_share: bool = ..., preset: _Optional[_Union[EncodingOptionsPreset, str]] = ..., advanced: _Optional[_Union[EncodingOptions, _Mapping]] = ..., file_outputs: _Optional[_Iterable[_Union[EncodedFileOutput, _Mapping]]] = ..., stream_outputs: _Optional[_Iterable[_Union[StreamOutput, _Mapping]]] = ..., segment_outputs: _Optional[_Iterable[_Union[SegmentedFileOutput, _Mapping]]] = ..., image_outputs: _Optional[_Iterable[_Union[ImageOutput, _Mapping]]] = ...) -> None: ... class TrackCompositeEgressRequest(_message.Message): - __slots__ = ["room_name", "audio_track_id", "video_track_id", "file", "stream", "segments", "preset", "advanced", "file_outputs", "stream_outputs", "segment_outputs", "image_outputs"] + __slots__ = ("room_name", "audio_track_id", "video_track_id", "file", "stream", "segments", "preset", "advanced", "file_outputs", "stream_outputs", "segment_outputs", "image_outputs") ROOM_NAME_FIELD_NUMBER: _ClassVar[int] AUDIO_TRACK_ID_FIELD_NUMBER: _ClassVar[int] VIDEO_TRACK_ID_FIELD_NUMBER: _ClassVar[int] @@ -193,7 +193,7 @@ class TrackCompositeEgressRequest(_message.Message): def __init__(self, room_name: _Optional[str] = ..., audio_track_id: _Optional[str] = ..., video_track_id: _Optional[str] = ..., file: _Optional[_Union[EncodedFileOutput, _Mapping]] = ..., stream: _Optional[_Union[StreamOutput, _Mapping]] = ..., segments: _Optional[_Union[SegmentedFileOutput, _Mapping]] = ..., preset: _Optional[_Union[EncodingOptionsPreset, str]] = ..., advanced: _Optional[_Union[EncodingOptions, _Mapping]] = ..., file_outputs: _Optional[_Iterable[_Union[EncodedFileOutput, _Mapping]]] = ..., stream_outputs: _Optional[_Iterable[_Union[StreamOutput, _Mapping]]] = ..., segment_outputs: _Optional[_Iterable[_Union[SegmentedFileOutput, _Mapping]]] = ..., image_outputs: _Optional[_Iterable[_Union[ImageOutput, _Mapping]]] = ...) -> None: ... class TrackEgressRequest(_message.Message): - __slots__ = ["room_name", "track_id", "file", "websocket_url"] + __slots__ = ("room_name", "track_id", "file", "websocket_url") ROOM_NAME_FIELD_NUMBER: _ClassVar[int] TRACK_ID_FIELD_NUMBER: _ClassVar[int] FILE_FIELD_NUMBER: _ClassVar[int] @@ -205,7 +205,7 @@ class TrackEgressRequest(_message.Message): def __init__(self, room_name: _Optional[str] = ..., track_id: _Optional[str] = ..., file: _Optional[_Union[DirectFileOutput, _Mapping]] = ..., websocket_url: _Optional[str] = ...) -> None: ... class EncodedFileOutput(_message.Message): - __slots__ = ["file_type", "filepath", "disable_manifest", "s3", "gcp", "azure", "aliOSS"] + __slots__ = ("file_type", "filepath", "disable_manifest", "s3", "gcp", "azure", "aliOSS") FILE_TYPE_FIELD_NUMBER: _ClassVar[int] FILEPATH_FIELD_NUMBER: _ClassVar[int] DISABLE_MANIFEST_FIELD_NUMBER: _ClassVar[int] @@ -223,7 +223,7 @@ class EncodedFileOutput(_message.Message): def __init__(self, file_type: _Optional[_Union[EncodedFileType, str]] = ..., filepath: _Optional[str] = ..., disable_manifest: bool = ..., s3: _Optional[_Union[S3Upload, _Mapping]] = ..., gcp: _Optional[_Union[GCPUpload, _Mapping]] = ..., azure: _Optional[_Union[AzureBlobUpload, _Mapping]] = ..., aliOSS: _Optional[_Union[AliOSSUpload, _Mapping]] = ...) -> None: ... class SegmentedFileOutput(_message.Message): - __slots__ = ["protocol", "filename_prefix", "playlist_name", "live_playlist_name", "segment_duration", "filename_suffix", "disable_manifest", "s3", "gcp", "azure", "aliOSS"] + __slots__ = ("protocol", "filename_prefix", "playlist_name", "live_playlist_name", "segment_duration", "filename_suffix", "disable_manifest", "s3", "gcp", "azure", "aliOSS") PROTOCOL_FIELD_NUMBER: _ClassVar[int] FILENAME_PREFIX_FIELD_NUMBER: _ClassVar[int] PLAYLIST_NAME_FIELD_NUMBER: _ClassVar[int] @@ -249,7 +249,7 @@ class SegmentedFileOutput(_message.Message): def __init__(self, protocol: _Optional[_Union[SegmentedFileProtocol, str]] = ..., filename_prefix: _Optional[str] = ..., playlist_name: _Optional[str] = ..., live_playlist_name: _Optional[str] = ..., segment_duration: _Optional[int] = ..., filename_suffix: _Optional[_Union[SegmentedFileSuffix, str]] = ..., disable_manifest: bool = ..., s3: _Optional[_Union[S3Upload, _Mapping]] = ..., gcp: _Optional[_Union[GCPUpload, _Mapping]] = ..., azure: _Optional[_Union[AzureBlobUpload, _Mapping]] = ..., aliOSS: _Optional[_Union[AliOSSUpload, _Mapping]] = ...) -> None: ... class DirectFileOutput(_message.Message): - __slots__ = ["filepath", "disable_manifest", "s3", "gcp", "azure", "aliOSS"] + __slots__ = ("filepath", "disable_manifest", "s3", "gcp", "azure", "aliOSS") FILEPATH_FIELD_NUMBER: _ClassVar[int] DISABLE_MANIFEST_FIELD_NUMBER: _ClassVar[int] S3_FIELD_NUMBER: _ClassVar[int] @@ -265,7 +265,7 @@ class DirectFileOutput(_message.Message): def __init__(self, filepath: _Optional[str] = ..., disable_manifest: bool = ..., s3: _Optional[_Union[S3Upload, _Mapping]] = ..., gcp: _Optional[_Union[GCPUpload, _Mapping]] = ..., azure: _Optional[_Union[AzureBlobUpload, _Mapping]] = ..., aliOSS: _Optional[_Union[AliOSSUpload, _Mapping]] = ...) -> None: ... class ImageOutput(_message.Message): - __slots__ = ["capture_interval", "width", "height", "filename_prefix", "filename_suffix", "image_codec", "disable_manifest", "s3", "gcp", "azure", "aliOSS"] + __slots__ = ("capture_interval", "width", "height", "filename_prefix", "filename_suffix", "image_codec", "disable_manifest", "s3", "gcp", "azure", "aliOSS") CAPTURE_INTERVAL_FIELD_NUMBER: _ClassVar[int] WIDTH_FIELD_NUMBER: _ClassVar[int] HEIGHT_FIELD_NUMBER: _ClassVar[int] @@ -291,9 +291,9 @@ class ImageOutput(_message.Message): def __init__(self, capture_interval: _Optional[int] = ..., width: _Optional[int] = ..., height: _Optional[int] = ..., filename_prefix: _Optional[str] = ..., filename_suffix: _Optional[_Union[ImageFileSuffix, str]] = ..., image_codec: _Optional[_Union[_models.ImageCodec, str]] = ..., disable_manifest: bool = ..., s3: _Optional[_Union[S3Upload, _Mapping]] = ..., gcp: _Optional[_Union[GCPUpload, _Mapping]] = ..., azure: _Optional[_Union[AzureBlobUpload, _Mapping]] = ..., aliOSS: _Optional[_Union[AliOSSUpload, _Mapping]] = ...) -> None: ... class S3Upload(_message.Message): - __slots__ = ["access_key", "secret", "session_token", "region", "endpoint", "bucket", "force_path_style", "metadata", "tagging", "content_disposition", "proxy"] + __slots__ = ("access_key", "secret", "session_token", "region", "endpoint", "bucket", "force_path_style", "metadata", "tagging", "content_disposition", "proxy") class MetadataEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str @@ -324,7 +324,7 @@ class S3Upload(_message.Message): def __init__(self, access_key: _Optional[str] = ..., secret: _Optional[str] = ..., session_token: _Optional[str] = ..., region: _Optional[str] = ..., endpoint: _Optional[str] = ..., bucket: _Optional[str] = ..., force_path_style: bool = ..., metadata: _Optional[_Mapping[str, str]] = ..., tagging: _Optional[str] = ..., content_disposition: _Optional[str] = ..., proxy: _Optional[_Union[ProxyConfig, _Mapping]] = ...) -> None: ... class GCPUpload(_message.Message): - __slots__ = ["credentials", "bucket", "proxy"] + __slots__ = ("credentials", "bucket", "proxy") CREDENTIALS_FIELD_NUMBER: _ClassVar[int] BUCKET_FIELD_NUMBER: _ClassVar[int] PROXY_FIELD_NUMBER: _ClassVar[int] @@ -334,7 +334,7 @@ class GCPUpload(_message.Message): def __init__(self, credentials: _Optional[str] = ..., bucket: _Optional[str] = ..., proxy: _Optional[_Union[ProxyConfig, _Mapping]] = ...) -> None: ... class AzureBlobUpload(_message.Message): - __slots__ = ["account_name", "account_key", "container_name"] + __slots__ = ("account_name", "account_key", "container_name") ACCOUNT_NAME_FIELD_NUMBER: _ClassVar[int] ACCOUNT_KEY_FIELD_NUMBER: _ClassVar[int] CONTAINER_NAME_FIELD_NUMBER: _ClassVar[int] @@ -344,7 +344,7 @@ class AzureBlobUpload(_message.Message): def __init__(self, account_name: _Optional[str] = ..., account_key: _Optional[str] = ..., container_name: _Optional[str] = ...) -> None: ... class AliOSSUpload(_message.Message): - __slots__ = ["access_key", "secret", "region", "endpoint", "bucket"] + __slots__ = ("access_key", "secret", "region", "endpoint", "bucket") ACCESS_KEY_FIELD_NUMBER: _ClassVar[int] SECRET_FIELD_NUMBER: _ClassVar[int] REGION_FIELD_NUMBER: _ClassVar[int] @@ -358,7 +358,7 @@ class AliOSSUpload(_message.Message): def __init__(self, access_key: _Optional[str] = ..., secret: _Optional[str] = ..., region: _Optional[str] = ..., endpoint: _Optional[str] = ..., bucket: _Optional[str] = ...) -> None: ... class ProxyConfig(_message.Message): - __slots__ = ["url", "username", "password"] + __slots__ = ("url", "username", "password") URL_FIELD_NUMBER: _ClassVar[int] USERNAME_FIELD_NUMBER: _ClassVar[int] PASSWORD_FIELD_NUMBER: _ClassVar[int] @@ -368,7 +368,7 @@ class ProxyConfig(_message.Message): def __init__(self, url: _Optional[str] = ..., username: _Optional[str] = ..., password: _Optional[str] = ...) -> None: ... class StreamOutput(_message.Message): - __slots__ = ["protocol", "urls"] + __slots__ = ("protocol", "urls") PROTOCOL_FIELD_NUMBER: _ClassVar[int] URLS_FIELD_NUMBER: _ClassVar[int] protocol: StreamProtocol @@ -376,7 +376,7 @@ class StreamOutput(_message.Message): def __init__(self, protocol: _Optional[_Union[StreamProtocol, str]] = ..., urls: _Optional[_Iterable[str]] = ...) -> None: ... class EncodingOptions(_message.Message): - __slots__ = ["width", "height", "depth", "framerate", "audio_codec", "audio_bitrate", "audio_quality", "audio_frequency", "video_codec", "video_bitrate", "video_quality", "key_frame_interval"] + __slots__ = ("width", "height", "depth", "framerate", "audio_codec", "audio_bitrate", "audio_quality", "audio_frequency", "video_codec", "video_bitrate", "video_quality", "key_frame_interval") WIDTH_FIELD_NUMBER: _ClassVar[int] HEIGHT_FIELD_NUMBER: _ClassVar[int] DEPTH_FIELD_NUMBER: _ClassVar[int] @@ -404,7 +404,7 @@ class EncodingOptions(_message.Message): def __init__(self, width: _Optional[int] = ..., height: _Optional[int] = ..., depth: _Optional[int] = ..., framerate: _Optional[int] = ..., audio_codec: _Optional[_Union[_models.AudioCodec, str]] = ..., audio_bitrate: _Optional[int] = ..., audio_quality: _Optional[int] = ..., audio_frequency: _Optional[int] = ..., video_codec: _Optional[_Union[_models.VideoCodec, str]] = ..., video_bitrate: _Optional[int] = ..., video_quality: _Optional[int] = ..., key_frame_interval: _Optional[float] = ...) -> None: ... class UpdateLayoutRequest(_message.Message): - __slots__ = ["egress_id", "layout"] + __slots__ = ("egress_id", "layout") EGRESS_ID_FIELD_NUMBER: _ClassVar[int] LAYOUT_FIELD_NUMBER: _ClassVar[int] egress_id: str @@ -412,7 +412,7 @@ class UpdateLayoutRequest(_message.Message): def __init__(self, egress_id: _Optional[str] = ..., layout: _Optional[str] = ...) -> None: ... class UpdateStreamRequest(_message.Message): - __slots__ = ["egress_id", "add_output_urls", "remove_output_urls"] + __slots__ = ("egress_id", "add_output_urls", "remove_output_urls") EGRESS_ID_FIELD_NUMBER: _ClassVar[int] ADD_OUTPUT_URLS_FIELD_NUMBER: _ClassVar[int] REMOVE_OUTPUT_URLS_FIELD_NUMBER: _ClassVar[int] @@ -422,7 +422,7 @@ class UpdateStreamRequest(_message.Message): def __init__(self, egress_id: _Optional[str] = ..., add_output_urls: _Optional[_Iterable[str]] = ..., remove_output_urls: _Optional[_Iterable[str]] = ...) -> None: ... class ListEgressRequest(_message.Message): - __slots__ = ["room_name", "egress_id", "active"] + __slots__ = ("room_name", "egress_id", "active") ROOM_NAME_FIELD_NUMBER: _ClassVar[int] EGRESS_ID_FIELD_NUMBER: _ClassVar[int] ACTIVE_FIELD_NUMBER: _ClassVar[int] @@ -432,19 +432,19 @@ class ListEgressRequest(_message.Message): def __init__(self, room_name: _Optional[str] = ..., egress_id: _Optional[str] = ..., active: bool = ...) -> None: ... class ListEgressResponse(_message.Message): - __slots__ = ["items"] + __slots__ = ("items",) ITEMS_FIELD_NUMBER: _ClassVar[int] items: _containers.RepeatedCompositeFieldContainer[EgressInfo] def __init__(self, items: _Optional[_Iterable[_Union[EgressInfo, _Mapping]]] = ...) -> None: ... class StopEgressRequest(_message.Message): - __slots__ = ["egress_id"] + __slots__ = ("egress_id",) EGRESS_ID_FIELD_NUMBER: _ClassVar[int] egress_id: str def __init__(self, egress_id: _Optional[str] = ...) -> None: ... class EgressInfo(_message.Message): - __slots__ = ["egress_id", "room_id", "room_name", "status", "started_at", "ended_at", "updated_at", "details", "error", "error_code", "room_composite", "web", "participant", "track_composite", "track", "stream", "file", "segments", "stream_results", "file_results", "segment_results", "image_results"] + __slots__ = ("egress_id", "room_id", "room_name", "status", "started_at", "ended_at", "updated_at", "details", "error", "error_code", "room_composite", "web", "participant", "track_composite", "track", "stream", "file", "segments", "stream_results", "file_results", "segment_results", "image_results") EGRESS_ID_FIELD_NUMBER: _ClassVar[int] ROOM_ID_FIELD_NUMBER: _ClassVar[int] ROOM_NAME_FIELD_NUMBER: _ClassVar[int] @@ -492,15 +492,15 @@ class EgressInfo(_message.Message): def __init__(self, egress_id: _Optional[str] = ..., room_id: _Optional[str] = ..., room_name: _Optional[str] = ..., status: _Optional[_Union[EgressStatus, str]] = ..., started_at: _Optional[int] = ..., ended_at: _Optional[int] = ..., updated_at: _Optional[int] = ..., details: _Optional[str] = ..., error: _Optional[str] = ..., error_code: _Optional[int] = ..., room_composite: _Optional[_Union[RoomCompositeEgressRequest, _Mapping]] = ..., web: _Optional[_Union[WebEgressRequest, _Mapping]] = ..., participant: _Optional[_Union[ParticipantEgressRequest, _Mapping]] = ..., track_composite: _Optional[_Union[TrackCompositeEgressRequest, _Mapping]] = ..., track: _Optional[_Union[TrackEgressRequest, _Mapping]] = ..., stream: _Optional[_Union[StreamInfoList, _Mapping]] = ..., file: _Optional[_Union[FileInfo, _Mapping]] = ..., segments: _Optional[_Union[SegmentsInfo, _Mapping]] = ..., stream_results: _Optional[_Iterable[_Union[StreamInfo, _Mapping]]] = ..., file_results: _Optional[_Iterable[_Union[FileInfo, _Mapping]]] = ..., segment_results: _Optional[_Iterable[_Union[SegmentsInfo, _Mapping]]] = ..., image_results: _Optional[_Iterable[_Union[ImagesInfo, _Mapping]]] = ...) -> None: ... class StreamInfoList(_message.Message): - __slots__ = ["info"] + __slots__ = ("info",) INFO_FIELD_NUMBER: _ClassVar[int] info: _containers.RepeatedCompositeFieldContainer[StreamInfo] def __init__(self, info: _Optional[_Iterable[_Union[StreamInfo, _Mapping]]] = ...) -> None: ... class StreamInfo(_message.Message): - __slots__ = ["url", "started_at", "ended_at", "duration", "status", "error"] + __slots__ = ("url", "started_at", "ended_at", "duration", "status", "error") class Status(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () ACTIVE: _ClassVar[StreamInfo.Status] FINISHED: _ClassVar[StreamInfo.Status] FAILED: _ClassVar[StreamInfo.Status] @@ -522,7 +522,7 @@ class StreamInfo(_message.Message): def __init__(self, url: _Optional[str] = ..., started_at: _Optional[int] = ..., ended_at: _Optional[int] = ..., duration: _Optional[int] = ..., status: _Optional[_Union[StreamInfo.Status, str]] = ..., error: _Optional[str] = ...) -> None: ... class FileInfo(_message.Message): - __slots__ = ["filename", "started_at", "ended_at", "duration", "size", "location"] + __slots__ = ("filename", "started_at", "ended_at", "duration", "size", "location") FILENAME_FIELD_NUMBER: _ClassVar[int] STARTED_AT_FIELD_NUMBER: _ClassVar[int] ENDED_AT_FIELD_NUMBER: _ClassVar[int] @@ -538,7 +538,7 @@ class FileInfo(_message.Message): def __init__(self, filename: _Optional[str] = ..., started_at: _Optional[int] = ..., ended_at: _Optional[int] = ..., duration: _Optional[int] = ..., size: _Optional[int] = ..., location: _Optional[str] = ...) -> None: ... class SegmentsInfo(_message.Message): - __slots__ = ["playlist_name", "live_playlist_name", "duration", "size", "playlist_location", "live_playlist_location", "segment_count", "started_at", "ended_at"] + __slots__ = ("playlist_name", "live_playlist_name", "duration", "size", "playlist_location", "live_playlist_location", "segment_count", "started_at", "ended_at") PLAYLIST_NAME_FIELD_NUMBER: _ClassVar[int] LIVE_PLAYLIST_NAME_FIELD_NUMBER: _ClassVar[int] DURATION_FIELD_NUMBER: _ClassVar[int] @@ -560,7 +560,7 @@ class SegmentsInfo(_message.Message): def __init__(self, playlist_name: _Optional[str] = ..., live_playlist_name: _Optional[str] = ..., duration: _Optional[int] = ..., size: _Optional[int] = ..., playlist_location: _Optional[str] = ..., live_playlist_location: _Optional[str] = ..., segment_count: _Optional[int] = ..., started_at: _Optional[int] = ..., ended_at: _Optional[int] = ...) -> None: ... class ImagesInfo(_message.Message): - __slots__ = ["image_count", "started_at", "ended_at"] + __slots__ = ("image_count", "started_at", "ended_at") IMAGE_COUNT_FIELD_NUMBER: _ClassVar[int] STARTED_AT_FIELD_NUMBER: _ClassVar[int] ENDED_AT_FIELD_NUMBER: _ClassVar[int] @@ -570,7 +570,7 @@ class ImagesInfo(_message.Message): def __init__(self, image_count: _Optional[int] = ..., started_at: _Optional[int] = ..., ended_at: _Optional[int] = ...) -> None: ... class AutoParticipantEgress(_message.Message): - __slots__ = ["preset", "advanced", "file_outputs", "segment_outputs"] + __slots__ = ("preset", "advanced", "file_outputs", "segment_outputs") PRESET_FIELD_NUMBER: _ClassVar[int] ADVANCED_FIELD_NUMBER: _ClassVar[int] FILE_OUTPUTS_FIELD_NUMBER: _ClassVar[int] @@ -582,7 +582,7 @@ class AutoParticipantEgress(_message.Message): def __init__(self, preset: _Optional[_Union[EncodingOptionsPreset, str]] = ..., advanced: _Optional[_Union[EncodingOptions, _Mapping]] = ..., file_outputs: _Optional[_Iterable[_Union[EncodedFileOutput, _Mapping]]] = ..., segment_outputs: _Optional[_Iterable[_Union[SegmentedFileOutput, _Mapping]]] = ...) -> None: ... class AutoTrackEgress(_message.Message): - __slots__ = ["filepath", "disable_manifest", "s3", "gcp", "azure", "aliOSS"] + __slots__ = ("filepath", "disable_manifest", "s3", "gcp", "azure", "aliOSS") FILEPATH_FIELD_NUMBER: _ClassVar[int] DISABLE_MANIFEST_FIELD_NUMBER: _ClassVar[int] S3_FIELD_NUMBER: _ClassVar[int] diff --git a/livekit-protocol/livekit/protocol/ingress.py b/livekit-protocol/livekit/protocol/ingress.py index da6d8cdf..7e29ad86 100644 --- a/livekit-protocol/livekit/protocol/ingress.py +++ b/livekit-protocol/livekit/protocol/ingress.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: livekit_ingress.proto +# Protobuf Python Version: 4.25.3 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -20,15 +21,14 @@ _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'ingress', _globals) if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' - _CREATEINGRESSREQUEST.fields_by_name['bypass_transcoding']._options = None - _CREATEINGRESSREQUEST.fields_by_name['bypass_transcoding']._serialized_options = b'\030\001' - _INGRESSINFO.fields_by_name['bypass_transcoding']._options = None - _INGRESSINFO.fields_by_name['bypass_transcoding']._serialized_options = b'\030\001' - _UPDATEINGRESSREQUEST.fields_by_name['bypass_transcoding']._options = None - _UPDATEINGRESSREQUEST.fields_by_name['bypass_transcoding']._serialized_options = b'\030\001' + _globals['DESCRIPTOR']._options = None + _globals['DESCRIPTOR']._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' + _globals['_CREATEINGRESSREQUEST'].fields_by_name['bypass_transcoding']._options = None + _globals['_CREATEINGRESSREQUEST'].fields_by_name['bypass_transcoding']._serialized_options = b'\030\001' + _globals['_INGRESSINFO'].fields_by_name['bypass_transcoding']._options = None + _globals['_INGRESSINFO'].fields_by_name['bypass_transcoding']._serialized_options = b'\030\001' + _globals['_UPDATEINGRESSREQUEST'].fields_by_name['bypass_transcoding']._options = None + _globals['_UPDATEINGRESSREQUEST'].fields_by_name['bypass_transcoding']._serialized_options = b'\030\001' _globals['_INGRESSINPUT']._serialized_start=2742 _globals['_INGRESSINPUT']._serialized_end=2803 _globals['_INGRESSAUDIOENCODINGPRESET']._serialized_start=2805 diff --git a/livekit-protocol/livekit/protocol/ingress.pyi b/livekit-protocol/livekit/protocol/ingress.pyi index 49d8a497..fb9f8273 100644 --- a/livekit-protocol/livekit/protocol/ingress.pyi +++ b/livekit-protocol/livekit/protocol/ingress.pyi @@ -8,18 +8,18 @@ from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Map DESCRIPTOR: _descriptor.FileDescriptor class IngressInput(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () RTMP_INPUT: _ClassVar[IngressInput] WHIP_INPUT: _ClassVar[IngressInput] URL_INPUT: _ClassVar[IngressInput] class IngressAudioEncodingPreset(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () OPUS_STEREO_96KBPS: _ClassVar[IngressAudioEncodingPreset] OPUS_MONO_64KBS: _ClassVar[IngressAudioEncodingPreset] class IngressVideoEncodingPreset(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () H264_720P_30FPS_3_LAYERS: _ClassVar[IngressVideoEncodingPreset] H264_1080P_30FPS_3_LAYERS: _ClassVar[IngressVideoEncodingPreset] H264_540P_25FPS_2_LAYERS: _ClassVar[IngressVideoEncodingPreset] @@ -47,7 +47,7 @@ H264_720P_30FPS_1_LAYER_HIGH_MOTION: IngressVideoEncodingPreset H264_1080P_30FPS_1_LAYER_HIGH_MOTION: IngressVideoEncodingPreset class CreateIngressRequest(_message.Message): - __slots__ = ["input_type", "url", "name", "room_name", "participant_identity", "participant_name", "participant_metadata", "bypass_transcoding", "enable_transcoding", "audio", "video"] + __slots__ = ("input_type", "url", "name", "room_name", "participant_identity", "participant_name", "participant_metadata", "bypass_transcoding", "enable_transcoding", "audio", "video") INPUT_TYPE_FIELD_NUMBER: _ClassVar[int] URL_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] @@ -73,7 +73,7 @@ class CreateIngressRequest(_message.Message): def __init__(self, input_type: _Optional[_Union[IngressInput, str]] = ..., url: _Optional[str] = ..., name: _Optional[str] = ..., room_name: _Optional[str] = ..., participant_identity: _Optional[str] = ..., participant_name: _Optional[str] = ..., participant_metadata: _Optional[str] = ..., bypass_transcoding: bool = ..., enable_transcoding: bool = ..., audio: _Optional[_Union[IngressAudioOptions, _Mapping]] = ..., video: _Optional[_Union[IngressVideoOptions, _Mapping]] = ...) -> None: ... class IngressAudioOptions(_message.Message): - __slots__ = ["name", "source", "preset", "options"] + __slots__ = ("name", "source", "preset", "options") NAME_FIELD_NUMBER: _ClassVar[int] SOURCE_FIELD_NUMBER: _ClassVar[int] PRESET_FIELD_NUMBER: _ClassVar[int] @@ -85,7 +85,7 @@ class IngressAudioOptions(_message.Message): def __init__(self, name: _Optional[str] = ..., source: _Optional[_Union[_models.TrackSource, str]] = ..., preset: _Optional[_Union[IngressAudioEncodingPreset, str]] = ..., options: _Optional[_Union[IngressAudioEncodingOptions, _Mapping]] = ...) -> None: ... class IngressVideoOptions(_message.Message): - __slots__ = ["name", "source", "preset", "options"] + __slots__ = ("name", "source", "preset", "options") NAME_FIELD_NUMBER: _ClassVar[int] SOURCE_FIELD_NUMBER: _ClassVar[int] PRESET_FIELD_NUMBER: _ClassVar[int] @@ -97,7 +97,7 @@ class IngressVideoOptions(_message.Message): def __init__(self, name: _Optional[str] = ..., source: _Optional[_Union[_models.TrackSource, str]] = ..., preset: _Optional[_Union[IngressVideoEncodingPreset, str]] = ..., options: _Optional[_Union[IngressVideoEncodingOptions, _Mapping]] = ...) -> None: ... class IngressAudioEncodingOptions(_message.Message): - __slots__ = ["audio_codec", "bitrate", "disable_dtx", "channels"] + __slots__ = ("audio_codec", "bitrate", "disable_dtx", "channels") AUDIO_CODEC_FIELD_NUMBER: _ClassVar[int] BITRATE_FIELD_NUMBER: _ClassVar[int] DISABLE_DTX_FIELD_NUMBER: _ClassVar[int] @@ -109,7 +109,7 @@ class IngressAudioEncodingOptions(_message.Message): def __init__(self, audio_codec: _Optional[_Union[_models.AudioCodec, str]] = ..., bitrate: _Optional[int] = ..., disable_dtx: bool = ..., channels: _Optional[int] = ...) -> None: ... class IngressVideoEncodingOptions(_message.Message): - __slots__ = ["video_codec", "frame_rate", "layers"] + __slots__ = ("video_codec", "frame_rate", "layers") VIDEO_CODEC_FIELD_NUMBER: _ClassVar[int] FRAME_RATE_FIELD_NUMBER: _ClassVar[int] LAYERS_FIELD_NUMBER: _ClassVar[int] @@ -119,7 +119,7 @@ class IngressVideoEncodingOptions(_message.Message): def __init__(self, video_codec: _Optional[_Union[_models.VideoCodec, str]] = ..., frame_rate: _Optional[float] = ..., layers: _Optional[_Iterable[_Union[_models.VideoLayer, _Mapping]]] = ...) -> None: ... class IngressInfo(_message.Message): - __slots__ = ["ingress_id", "name", "stream_key", "url", "input_type", "bypass_transcoding", "enable_transcoding", "audio", "video", "room_name", "participant_identity", "participant_name", "participant_metadata", "reusable", "state"] + __slots__ = ("ingress_id", "name", "stream_key", "url", "input_type", "bypass_transcoding", "enable_transcoding", "audio", "video", "room_name", "participant_identity", "participant_name", "participant_metadata", "reusable", "state") INGRESS_ID_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] STREAM_KEY_FIELD_NUMBER: _ClassVar[int] @@ -153,9 +153,9 @@ class IngressInfo(_message.Message): def __init__(self, ingress_id: _Optional[str] = ..., name: _Optional[str] = ..., stream_key: _Optional[str] = ..., url: _Optional[str] = ..., input_type: _Optional[_Union[IngressInput, str]] = ..., bypass_transcoding: bool = ..., enable_transcoding: bool = ..., audio: _Optional[_Union[IngressAudioOptions, _Mapping]] = ..., video: _Optional[_Union[IngressVideoOptions, _Mapping]] = ..., room_name: _Optional[str] = ..., participant_identity: _Optional[str] = ..., participant_name: _Optional[str] = ..., participant_metadata: _Optional[str] = ..., reusable: bool = ..., state: _Optional[_Union[IngressState, _Mapping]] = ...) -> None: ... class IngressState(_message.Message): - __slots__ = ["status", "error", "video", "audio", "room_id", "started_at", "ended_at", "updated_at", "resource_id", "tracks"] + __slots__ = ("status", "error", "video", "audio", "room_id", "started_at", "ended_at", "updated_at", "resource_id", "tracks") class Status(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () ENDPOINT_INACTIVE: _ClassVar[IngressState.Status] ENDPOINT_BUFFERING: _ClassVar[IngressState.Status] ENDPOINT_PUBLISHING: _ClassVar[IngressState.Status] @@ -189,7 +189,7 @@ class IngressState(_message.Message): def __init__(self, status: _Optional[_Union[IngressState.Status, str]] = ..., error: _Optional[str] = ..., video: _Optional[_Union[InputVideoState, _Mapping]] = ..., audio: _Optional[_Union[InputAudioState, _Mapping]] = ..., room_id: _Optional[str] = ..., started_at: _Optional[int] = ..., ended_at: _Optional[int] = ..., updated_at: _Optional[int] = ..., resource_id: _Optional[str] = ..., tracks: _Optional[_Iterable[_Union[_models.TrackInfo, _Mapping]]] = ...) -> None: ... class InputVideoState(_message.Message): - __slots__ = ["mime_type", "average_bitrate", "width", "height", "framerate"] + __slots__ = ("mime_type", "average_bitrate", "width", "height", "framerate") MIME_TYPE_FIELD_NUMBER: _ClassVar[int] AVERAGE_BITRATE_FIELD_NUMBER: _ClassVar[int] WIDTH_FIELD_NUMBER: _ClassVar[int] @@ -203,7 +203,7 @@ class InputVideoState(_message.Message): def __init__(self, mime_type: _Optional[str] = ..., average_bitrate: _Optional[int] = ..., width: _Optional[int] = ..., height: _Optional[int] = ..., framerate: _Optional[float] = ...) -> None: ... class InputAudioState(_message.Message): - __slots__ = ["mime_type", "average_bitrate", "channels", "sample_rate"] + __slots__ = ("mime_type", "average_bitrate", "channels", "sample_rate") MIME_TYPE_FIELD_NUMBER: _ClassVar[int] AVERAGE_BITRATE_FIELD_NUMBER: _ClassVar[int] CHANNELS_FIELD_NUMBER: _ClassVar[int] @@ -215,7 +215,7 @@ class InputAudioState(_message.Message): def __init__(self, mime_type: _Optional[str] = ..., average_bitrate: _Optional[int] = ..., channels: _Optional[int] = ..., sample_rate: _Optional[int] = ...) -> None: ... class UpdateIngressRequest(_message.Message): - __slots__ = ["ingress_id", "name", "room_name", "participant_identity", "participant_name", "participant_metadata", "bypass_transcoding", "enable_transcoding", "audio", "video"] + __slots__ = ("ingress_id", "name", "room_name", "participant_identity", "participant_name", "participant_metadata", "bypass_transcoding", "enable_transcoding", "audio", "video") INGRESS_ID_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] ROOM_NAME_FIELD_NUMBER: _ClassVar[int] @@ -239,7 +239,7 @@ class UpdateIngressRequest(_message.Message): def __init__(self, ingress_id: _Optional[str] = ..., name: _Optional[str] = ..., room_name: _Optional[str] = ..., participant_identity: _Optional[str] = ..., participant_name: _Optional[str] = ..., participant_metadata: _Optional[str] = ..., bypass_transcoding: bool = ..., enable_transcoding: bool = ..., audio: _Optional[_Union[IngressAudioOptions, _Mapping]] = ..., video: _Optional[_Union[IngressVideoOptions, _Mapping]] = ...) -> None: ... class ListIngressRequest(_message.Message): - __slots__ = ["room_name", "ingress_id"] + __slots__ = ("room_name", "ingress_id") ROOM_NAME_FIELD_NUMBER: _ClassVar[int] INGRESS_ID_FIELD_NUMBER: _ClassVar[int] room_name: str @@ -247,13 +247,13 @@ class ListIngressRequest(_message.Message): def __init__(self, room_name: _Optional[str] = ..., ingress_id: _Optional[str] = ...) -> None: ... class ListIngressResponse(_message.Message): - __slots__ = ["items"] + __slots__ = ("items",) ITEMS_FIELD_NUMBER: _ClassVar[int] items: _containers.RepeatedCompositeFieldContainer[IngressInfo] def __init__(self, items: _Optional[_Iterable[_Union[IngressInfo, _Mapping]]] = ...) -> None: ... class DeleteIngressRequest(_message.Message): - __slots__ = ["ingress_id"] + __slots__ = ("ingress_id",) INGRESS_ID_FIELD_NUMBER: _ClassVar[int] ingress_id: str def __init__(self, ingress_id: _Optional[str] = ...) -> None: ... diff --git a/livekit-protocol/livekit/protocol/models.py b/livekit-protocol/livekit/protocol/models.py index a9964aa9..16037c31 100644 --- a/livekit-protocol/livekit/protocol/models.py +++ b/livekit-protocol/livekit/protocol/models.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: livekit_models.proto +# Protobuf Python Version: 4.25.3 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -20,29 +21,28 @@ _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'models', _globals) if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' - _PARTICIPANTPERMISSION.fields_by_name['recorder']._options = None - _PARTICIPANTPERMISSION.fields_by_name['recorder']._serialized_options = b'\030\001' - _PARTICIPANTPERMISSION.fields_by_name['agent']._options = None - _PARTICIPANTPERMISSION.fields_by_name['agent']._serialized_options = b'\030\001' - _PARTICIPANTINFO_ATTRIBUTESENTRY._options = None - _PARTICIPANTINFO_ATTRIBUTESENTRY._serialized_options = b'8\001' - _DATAPACKET.fields_by_name['kind']._options = None - _DATAPACKET.fields_by_name['kind']._serialized_options = b'\030\001' - _DATAPACKET.fields_by_name['speaker']._options = None - _DATAPACKET.fields_by_name['speaker']._serialized_options = b'\030\001' - _USERPACKET.fields_by_name['participant_sid']._options = None - _USERPACKET.fields_by_name['participant_sid']._serialized_options = b'\030\001' - _USERPACKET.fields_by_name['participant_identity']._options = None - _USERPACKET.fields_by_name['participant_identity']._serialized_options = b'\030\001' - _USERPACKET.fields_by_name['destination_sids']._options = None - _USERPACKET.fields_by_name['destination_sids']._serialized_options = b'\030\001' - _USERPACKET.fields_by_name['destination_identities']._options = None - _USERPACKET.fields_by_name['destination_identities']._serialized_options = b'\030\001' - _RTPSTATS_GAPHISTOGRAMENTRY._options = None - _RTPSTATS_GAPHISTOGRAMENTRY._serialized_options = b'8\001' + _globals['DESCRIPTOR']._options = None + _globals['DESCRIPTOR']._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' + _globals['_PARTICIPANTPERMISSION'].fields_by_name['recorder']._options = None + _globals['_PARTICIPANTPERMISSION'].fields_by_name['recorder']._serialized_options = b'\030\001' + _globals['_PARTICIPANTPERMISSION'].fields_by_name['agent']._options = None + _globals['_PARTICIPANTPERMISSION'].fields_by_name['agent']._serialized_options = b'\030\001' + _globals['_PARTICIPANTINFO_ATTRIBUTESENTRY']._options = None + _globals['_PARTICIPANTINFO_ATTRIBUTESENTRY']._serialized_options = b'8\001' + _globals['_DATAPACKET'].fields_by_name['kind']._options = None + _globals['_DATAPACKET'].fields_by_name['kind']._serialized_options = b'\030\001' + _globals['_DATAPACKET'].fields_by_name['speaker']._options = None + _globals['_DATAPACKET'].fields_by_name['speaker']._serialized_options = b'\030\001' + _globals['_USERPACKET'].fields_by_name['participant_sid']._options = None + _globals['_USERPACKET'].fields_by_name['participant_sid']._serialized_options = b'\030\001' + _globals['_USERPACKET'].fields_by_name['participant_identity']._options = None + _globals['_USERPACKET'].fields_by_name['participant_identity']._serialized_options = b'\030\001' + _globals['_USERPACKET'].fields_by_name['destination_sids']._options = None + _globals['_USERPACKET'].fields_by_name['destination_sids']._serialized_options = b'\030\001' + _globals['_USERPACKET'].fields_by_name['destination_identities']._options = None + _globals['_USERPACKET'].fields_by_name['destination_identities']._serialized_options = b'\030\001' + _globals['_RTPSTATS_GAPHISTOGRAMENTRY']._options = None + _globals['_RTPSTATS_GAPHISTOGRAMENTRY']._serialized_options = b'8\001' _globals['_AUDIOCODEC']._serialized_start=5814 _globals['_AUDIOCODEC']._serialized_end=5861 _globals['_VIDEOCODEC']._serialized_start=5863 diff --git a/livekit-protocol/livekit/protocol/models.pyi b/livekit-protocol/livekit/protocol/models.pyi index 15f8b67a..cdef3e6c 100644 --- a/livekit-protocol/livekit/protocol/models.pyi +++ b/livekit-protocol/livekit/protocol/models.pyi @@ -8,13 +8,13 @@ from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Map DESCRIPTOR: _descriptor.FileDescriptor class AudioCodec(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () DEFAULT_AC: _ClassVar[AudioCodec] OPUS: _ClassVar[AudioCodec] AAC: _ClassVar[AudioCodec] class VideoCodec(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () DEFAULT_VC: _ClassVar[VideoCodec] H264_BASELINE: _ClassVar[VideoCodec] H264_MAIN: _ClassVar[VideoCodec] @@ -22,18 +22,18 @@ class VideoCodec(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): VP8: _ClassVar[VideoCodec] class ImageCodec(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () IC_DEFAULT: _ClassVar[ImageCodec] IC_JPEG: _ClassVar[ImageCodec] class TrackType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () AUDIO: _ClassVar[TrackType] VIDEO: _ClassVar[TrackType] DATA: _ClassVar[TrackType] class TrackSource(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () UNKNOWN: _ClassVar[TrackSource] CAMERA: _ClassVar[TrackSource] MICROPHONE: _ClassVar[TrackSource] @@ -41,27 +41,27 @@ class TrackSource(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): SCREEN_SHARE_AUDIO: _ClassVar[TrackSource] class VideoQuality(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () LOW: _ClassVar[VideoQuality] MEDIUM: _ClassVar[VideoQuality] HIGH: _ClassVar[VideoQuality] OFF: _ClassVar[VideoQuality] class ConnectionQuality(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () POOR: _ClassVar[ConnectionQuality] GOOD: _ClassVar[ConnectionQuality] EXCELLENT: _ClassVar[ConnectionQuality] LOST: _ClassVar[ConnectionQuality] class ClientConfigSetting(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () UNSET: _ClassVar[ClientConfigSetting] DISABLED: _ClassVar[ClientConfigSetting] ENABLED: _ClassVar[ClientConfigSetting] class DisconnectReason(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () UNKNOWN_REASON: _ClassVar[DisconnectReason] CLIENT_INITIATED: _ClassVar[DisconnectReason] DUPLICATE_IDENTITY: _ClassVar[DisconnectReason] @@ -74,7 +74,7 @@ class DisconnectReason(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): SIGNAL_CLOSE: _ClassVar[DisconnectReason] class ReconnectReason(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () RR_UNKNOWN: _ClassVar[ReconnectReason] RR_SIGNAL_DISCONNECTED: _ClassVar[ReconnectReason] RR_PUBLISHER_FAILED: _ClassVar[ReconnectReason] @@ -82,13 +82,13 @@ class ReconnectReason(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): RR_SWITCH_CANDIDATE: _ClassVar[ReconnectReason] class SubscriptionError(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () SE_UNKNOWN: _ClassVar[SubscriptionError] SE_CODEC_UNSUPPORTED: _ClassVar[SubscriptionError] SE_TRACK_NOTFOUND: _ClassVar[SubscriptionError] class AudioTrackFeature(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () TF_STEREO: _ClassVar[AudioTrackFeature] TF_NO_DTX: _ClassVar[AudioTrackFeature] TF_AUTO_GAIN_CONTROL: _ClassVar[AudioTrackFeature] @@ -150,7 +150,7 @@ TF_NOISE_SUPPRESSION: AudioTrackFeature TF_ENHANCED_NOISE_CANCELLATION: AudioTrackFeature class Room(_message.Message): - __slots__ = ["sid", "name", "empty_timeout", "departure_timeout", "max_participants", "creation_time", "turn_password", "enabled_codecs", "metadata", "num_participants", "num_publishers", "active_recording", "version"] + __slots__ = ("sid", "name", "empty_timeout", "departure_timeout", "max_participants", "creation_time", "turn_password", "enabled_codecs", "metadata", "num_participants", "num_publishers", "active_recording", "version") SID_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] EMPTY_TIMEOUT_FIELD_NUMBER: _ClassVar[int] @@ -180,7 +180,7 @@ class Room(_message.Message): def __init__(self, sid: _Optional[str] = ..., name: _Optional[str] = ..., empty_timeout: _Optional[int] = ..., departure_timeout: _Optional[int] = ..., max_participants: _Optional[int] = ..., creation_time: _Optional[int] = ..., turn_password: _Optional[str] = ..., enabled_codecs: _Optional[_Iterable[_Union[Codec, _Mapping]]] = ..., metadata: _Optional[str] = ..., num_participants: _Optional[int] = ..., num_publishers: _Optional[int] = ..., active_recording: bool = ..., version: _Optional[_Union[TimedVersion, _Mapping]] = ...) -> None: ... class Codec(_message.Message): - __slots__ = ["mime", "fmtp_line"] + __slots__ = ("mime", "fmtp_line") MIME_FIELD_NUMBER: _ClassVar[int] FMTP_LINE_FIELD_NUMBER: _ClassVar[int] mime: str @@ -188,7 +188,7 @@ class Codec(_message.Message): def __init__(self, mime: _Optional[str] = ..., fmtp_line: _Optional[str] = ...) -> None: ... class PlayoutDelay(_message.Message): - __slots__ = ["enabled", "min", "max"] + __slots__ = ("enabled", "min", "max") ENABLED_FIELD_NUMBER: _ClassVar[int] MIN_FIELD_NUMBER: _ClassVar[int] MAX_FIELD_NUMBER: _ClassVar[int] @@ -198,7 +198,7 @@ class PlayoutDelay(_message.Message): def __init__(self, enabled: bool = ..., min: _Optional[int] = ..., max: _Optional[int] = ...) -> None: ... class ParticipantPermission(_message.Message): - __slots__ = ["can_subscribe", "can_publish", "can_publish_data", "can_publish_sources", "hidden", "recorder", "can_update_metadata", "agent"] + __slots__ = ("can_subscribe", "can_publish", "can_publish_data", "can_publish_sources", "hidden", "recorder", "can_update_metadata", "agent") CAN_SUBSCRIBE_FIELD_NUMBER: _ClassVar[int] CAN_PUBLISH_FIELD_NUMBER: _ClassVar[int] CAN_PUBLISH_DATA_FIELD_NUMBER: _ClassVar[int] @@ -218,9 +218,9 @@ class ParticipantPermission(_message.Message): def __init__(self, can_subscribe: bool = ..., can_publish: bool = ..., can_publish_data: bool = ..., can_publish_sources: _Optional[_Iterable[_Union[TrackSource, str]]] = ..., hidden: bool = ..., recorder: bool = ..., can_update_metadata: bool = ..., agent: bool = ...) -> None: ... class ParticipantInfo(_message.Message): - __slots__ = ["sid", "identity", "state", "tracks", "metadata", "joined_at", "name", "version", "permission", "region", "is_publisher", "kind", "attributes"] + __slots__ = ("sid", "identity", "state", "tracks", "metadata", "joined_at", "name", "version", "permission", "region", "is_publisher", "kind", "attributes") class State(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () JOINING: _ClassVar[ParticipantInfo.State] JOINED: _ClassVar[ParticipantInfo.State] ACTIVE: _ClassVar[ParticipantInfo.State] @@ -230,7 +230,7 @@ class ParticipantInfo(_message.Message): ACTIVE: ParticipantInfo.State DISCONNECTED: ParticipantInfo.State class Kind(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () STANDARD: _ClassVar[ParticipantInfo.Kind] INGRESS: _ClassVar[ParticipantInfo.Kind] EGRESS: _ClassVar[ParticipantInfo.Kind] @@ -242,7 +242,7 @@ class ParticipantInfo(_message.Message): SIP: ParticipantInfo.Kind AGENT: ParticipantInfo.Kind class AttributesEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str @@ -277,9 +277,9 @@ class ParticipantInfo(_message.Message): def __init__(self, sid: _Optional[str] = ..., identity: _Optional[str] = ..., state: _Optional[_Union[ParticipantInfo.State, str]] = ..., tracks: _Optional[_Iterable[_Union[TrackInfo, _Mapping]]] = ..., metadata: _Optional[str] = ..., joined_at: _Optional[int] = ..., name: _Optional[str] = ..., version: _Optional[int] = ..., permission: _Optional[_Union[ParticipantPermission, _Mapping]] = ..., region: _Optional[str] = ..., is_publisher: bool = ..., kind: _Optional[_Union[ParticipantInfo.Kind, str]] = ..., attributes: _Optional[_Mapping[str, str]] = ...) -> None: ... class Encryption(_message.Message): - __slots__ = [] + __slots__ = () class Type(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () NONE: _ClassVar[Encryption.Type] GCM: _ClassVar[Encryption.Type] CUSTOM: _ClassVar[Encryption.Type] @@ -289,7 +289,7 @@ class Encryption(_message.Message): def __init__(self) -> None: ... class SimulcastCodecInfo(_message.Message): - __slots__ = ["mime_type", "mid", "cid", "layers"] + __slots__ = ("mime_type", "mid", "cid", "layers") MIME_TYPE_FIELD_NUMBER: _ClassVar[int] MID_FIELD_NUMBER: _ClassVar[int] CID_FIELD_NUMBER: _ClassVar[int] @@ -301,7 +301,7 @@ class SimulcastCodecInfo(_message.Message): def __init__(self, mime_type: _Optional[str] = ..., mid: _Optional[str] = ..., cid: _Optional[str] = ..., layers: _Optional[_Iterable[_Union[VideoLayer, _Mapping]]] = ...) -> None: ... class TrackInfo(_message.Message): - __slots__ = ["sid", "type", "name", "muted", "width", "height", "simulcast", "disable_dtx", "source", "layers", "mime_type", "mid", "codecs", "stereo", "disable_red", "encryption", "stream", "version", "audio_features"] + __slots__ = ("sid", "type", "name", "muted", "width", "height", "simulcast", "disable_dtx", "source", "layers", "mime_type", "mid", "codecs", "stereo", "disable_red", "encryption", "stream", "version", "audio_features") SID_FIELD_NUMBER: _ClassVar[int] TYPE_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] @@ -343,7 +343,7 @@ class TrackInfo(_message.Message): def __init__(self, sid: _Optional[str] = ..., type: _Optional[_Union[TrackType, str]] = ..., name: _Optional[str] = ..., muted: bool = ..., width: _Optional[int] = ..., height: _Optional[int] = ..., simulcast: bool = ..., disable_dtx: bool = ..., source: _Optional[_Union[TrackSource, str]] = ..., layers: _Optional[_Iterable[_Union[VideoLayer, _Mapping]]] = ..., mime_type: _Optional[str] = ..., mid: _Optional[str] = ..., codecs: _Optional[_Iterable[_Union[SimulcastCodecInfo, _Mapping]]] = ..., stereo: bool = ..., disable_red: bool = ..., encryption: _Optional[_Union[Encryption.Type, str]] = ..., stream: _Optional[str] = ..., version: _Optional[_Union[TimedVersion, _Mapping]] = ..., audio_features: _Optional[_Iterable[_Union[AudioTrackFeature, str]]] = ...) -> None: ... class VideoLayer(_message.Message): - __slots__ = ["quality", "width", "height", "bitrate", "ssrc"] + __slots__ = ("quality", "width", "height", "bitrate", "ssrc") QUALITY_FIELD_NUMBER: _ClassVar[int] WIDTH_FIELD_NUMBER: _ClassVar[int] HEIGHT_FIELD_NUMBER: _ClassVar[int] @@ -357,9 +357,9 @@ class VideoLayer(_message.Message): def __init__(self, quality: _Optional[_Union[VideoQuality, str]] = ..., width: _Optional[int] = ..., height: _Optional[int] = ..., bitrate: _Optional[int] = ..., ssrc: _Optional[int] = ...) -> None: ... class DataPacket(_message.Message): - __slots__ = ["kind", "participant_identity", "destination_identities", "user", "speaker", "sip_dtmf", "transcription"] + __slots__ = ("kind", "participant_identity", "destination_identities", "user", "speaker", "sip_dtmf", "transcription") class Kind(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () RELIABLE: _ClassVar[DataPacket.Kind] LOSSY: _ClassVar[DataPacket.Kind] RELIABLE: DataPacket.Kind @@ -381,13 +381,13 @@ class DataPacket(_message.Message): def __init__(self, kind: _Optional[_Union[DataPacket.Kind, str]] = ..., participant_identity: _Optional[str] = ..., destination_identities: _Optional[_Iterable[str]] = ..., user: _Optional[_Union[UserPacket, _Mapping]] = ..., speaker: _Optional[_Union[ActiveSpeakerUpdate, _Mapping]] = ..., sip_dtmf: _Optional[_Union[SipDTMF, _Mapping]] = ..., transcription: _Optional[_Union[Transcription, _Mapping]] = ...) -> None: ... class ActiveSpeakerUpdate(_message.Message): - __slots__ = ["speakers"] + __slots__ = ("speakers",) SPEAKERS_FIELD_NUMBER: _ClassVar[int] speakers: _containers.RepeatedCompositeFieldContainer[SpeakerInfo] def __init__(self, speakers: _Optional[_Iterable[_Union[SpeakerInfo, _Mapping]]] = ...) -> None: ... class SpeakerInfo(_message.Message): - __slots__ = ["sid", "level", "active"] + __slots__ = ("sid", "level", "active") SID_FIELD_NUMBER: _ClassVar[int] LEVEL_FIELD_NUMBER: _ClassVar[int] ACTIVE_FIELD_NUMBER: _ClassVar[int] @@ -397,7 +397,7 @@ class SpeakerInfo(_message.Message): def __init__(self, sid: _Optional[str] = ..., level: _Optional[float] = ..., active: bool = ...) -> None: ... class UserPacket(_message.Message): - __slots__ = ["participant_sid", "participant_identity", "payload", "destination_sids", "destination_identities", "topic", "id", "start_time", "end_time"] + __slots__ = ("participant_sid", "participant_identity", "payload", "destination_sids", "destination_identities", "topic", "id", "start_time", "end_time") PARTICIPANT_SID_FIELD_NUMBER: _ClassVar[int] PARTICIPANT_IDENTITY_FIELD_NUMBER: _ClassVar[int] PAYLOAD_FIELD_NUMBER: _ClassVar[int] @@ -419,7 +419,7 @@ class UserPacket(_message.Message): def __init__(self, participant_sid: _Optional[str] = ..., participant_identity: _Optional[str] = ..., payload: _Optional[bytes] = ..., destination_sids: _Optional[_Iterable[str]] = ..., destination_identities: _Optional[_Iterable[str]] = ..., topic: _Optional[str] = ..., id: _Optional[str] = ..., start_time: _Optional[int] = ..., end_time: _Optional[int] = ...) -> None: ... class SipDTMF(_message.Message): - __slots__ = ["code", "digit"] + __slots__ = ("code", "digit") CODE_FIELD_NUMBER: _ClassVar[int] DIGIT_FIELD_NUMBER: _ClassVar[int] code: int @@ -427,7 +427,7 @@ class SipDTMF(_message.Message): def __init__(self, code: _Optional[int] = ..., digit: _Optional[str] = ...) -> None: ... class Transcription(_message.Message): - __slots__ = ["transcribed_participant_identity", "track_id", "segments"] + __slots__ = ("transcribed_participant_identity", "track_id", "segments") TRANSCRIBED_PARTICIPANT_IDENTITY_FIELD_NUMBER: _ClassVar[int] TRACK_ID_FIELD_NUMBER: _ClassVar[int] SEGMENTS_FIELD_NUMBER: _ClassVar[int] @@ -437,7 +437,7 @@ class Transcription(_message.Message): def __init__(self, transcribed_participant_identity: _Optional[str] = ..., track_id: _Optional[str] = ..., segments: _Optional[_Iterable[_Union[TranscriptionSegment, _Mapping]]] = ...) -> None: ... class TranscriptionSegment(_message.Message): - __slots__ = ["id", "text", "start_time", "end_time", "final", "language"] + __slots__ = ("id", "text", "start_time", "end_time", "final", "language") ID_FIELD_NUMBER: _ClassVar[int] TEXT_FIELD_NUMBER: _ClassVar[int] START_TIME_FIELD_NUMBER: _ClassVar[int] @@ -453,7 +453,7 @@ class TranscriptionSegment(_message.Message): def __init__(self, id: _Optional[str] = ..., text: _Optional[str] = ..., start_time: _Optional[int] = ..., end_time: _Optional[int] = ..., final: bool = ..., language: _Optional[str] = ...) -> None: ... class ParticipantTracks(_message.Message): - __slots__ = ["participant_sid", "track_sids"] + __slots__ = ("participant_sid", "track_sids") PARTICIPANT_SID_FIELD_NUMBER: _ClassVar[int] TRACK_SIDS_FIELD_NUMBER: _ClassVar[int] participant_sid: str @@ -461,9 +461,9 @@ class ParticipantTracks(_message.Message): def __init__(self, participant_sid: _Optional[str] = ..., track_sids: _Optional[_Iterable[str]] = ...) -> None: ... class ServerInfo(_message.Message): - __slots__ = ["edition", "version", "protocol", "region", "node_id", "debug_info", "agent_protocol"] + __slots__ = ("edition", "version", "protocol", "region", "node_id", "debug_info", "agent_protocol") class Edition(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () Standard: _ClassVar[ServerInfo.Edition] Cloud: _ClassVar[ServerInfo.Edition] Standard: ServerInfo.Edition @@ -485,9 +485,9 @@ class ServerInfo(_message.Message): def __init__(self, edition: _Optional[_Union[ServerInfo.Edition, str]] = ..., version: _Optional[str] = ..., protocol: _Optional[int] = ..., region: _Optional[str] = ..., node_id: _Optional[str] = ..., debug_info: _Optional[str] = ..., agent_protocol: _Optional[int] = ...) -> None: ... class ClientInfo(_message.Message): - __slots__ = ["sdk", "version", "protocol", "os", "os_version", "device_model", "browser", "browser_version", "address", "network"] + __slots__ = ("sdk", "version", "protocol", "os", "os_version", "device_model", "browser", "browser_version", "address", "network") class SDK(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () UNKNOWN: _ClassVar[ClientInfo.SDK] JS: _ClassVar[ClientInfo.SDK] SWIFT: _ClassVar[ClientInfo.SDK] @@ -533,7 +533,7 @@ class ClientInfo(_message.Message): def __init__(self, sdk: _Optional[_Union[ClientInfo.SDK, str]] = ..., version: _Optional[str] = ..., protocol: _Optional[int] = ..., os: _Optional[str] = ..., os_version: _Optional[str] = ..., device_model: _Optional[str] = ..., browser: _Optional[str] = ..., browser_version: _Optional[str] = ..., address: _Optional[str] = ..., network: _Optional[str] = ...) -> None: ... class ClientConfiguration(_message.Message): - __slots__ = ["video", "screen", "resume_connection", "disabled_codecs", "force_relay"] + __slots__ = ("video", "screen", "resume_connection", "disabled_codecs", "force_relay") VIDEO_FIELD_NUMBER: _ClassVar[int] SCREEN_FIELD_NUMBER: _ClassVar[int] RESUME_CONNECTION_FIELD_NUMBER: _ClassVar[int] @@ -547,13 +547,13 @@ class ClientConfiguration(_message.Message): def __init__(self, video: _Optional[_Union[VideoConfiguration, _Mapping]] = ..., screen: _Optional[_Union[VideoConfiguration, _Mapping]] = ..., resume_connection: _Optional[_Union[ClientConfigSetting, str]] = ..., disabled_codecs: _Optional[_Union[DisabledCodecs, _Mapping]] = ..., force_relay: _Optional[_Union[ClientConfigSetting, str]] = ...) -> None: ... class VideoConfiguration(_message.Message): - __slots__ = ["hardware_encoder"] + __slots__ = ("hardware_encoder",) HARDWARE_ENCODER_FIELD_NUMBER: _ClassVar[int] hardware_encoder: ClientConfigSetting def __init__(self, hardware_encoder: _Optional[_Union[ClientConfigSetting, str]] = ...) -> None: ... class DisabledCodecs(_message.Message): - __slots__ = ["codecs", "publish"] + __slots__ = ("codecs", "publish") CODECS_FIELD_NUMBER: _ClassVar[int] PUBLISH_FIELD_NUMBER: _ClassVar[int] codecs: _containers.RepeatedCompositeFieldContainer[Codec] @@ -561,7 +561,7 @@ class DisabledCodecs(_message.Message): def __init__(self, codecs: _Optional[_Iterable[_Union[Codec, _Mapping]]] = ..., publish: _Optional[_Iterable[_Union[Codec, _Mapping]]] = ...) -> None: ... class RTPDrift(_message.Message): - __slots__ = ["start_time", "end_time", "duration", "start_timestamp", "end_timestamp", "rtp_clock_ticks", "drift_samples", "drift_ms", "clock_rate"] + __slots__ = ("start_time", "end_time", "duration", "start_timestamp", "end_timestamp", "rtp_clock_ticks", "drift_samples", "drift_ms", "clock_rate") START_TIME_FIELD_NUMBER: _ClassVar[int] END_TIME_FIELD_NUMBER: _ClassVar[int] DURATION_FIELD_NUMBER: _ClassVar[int] @@ -583,9 +583,9 @@ class RTPDrift(_message.Message): def __init__(self, start_time: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., end_time: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., duration: _Optional[float] = ..., start_timestamp: _Optional[int] = ..., end_timestamp: _Optional[int] = ..., rtp_clock_ticks: _Optional[int] = ..., drift_samples: _Optional[int] = ..., drift_ms: _Optional[float] = ..., clock_rate: _Optional[float] = ...) -> None: ... class RTPStats(_message.Message): - __slots__ = ["start_time", "end_time", "duration", "packets", "packet_rate", "bytes", "header_bytes", "bitrate", "packets_lost", "packet_loss_rate", "packet_loss_percentage", "packets_duplicate", "packet_duplicate_rate", "bytes_duplicate", "header_bytes_duplicate", "bitrate_duplicate", "packets_padding", "packet_padding_rate", "bytes_padding", "header_bytes_padding", "bitrate_padding", "packets_out_of_order", "frames", "frame_rate", "jitter_current", "jitter_max", "gap_histogram", "nacks", "nack_acks", "nack_misses", "nack_repeated", "plis", "last_pli", "firs", "last_fir", "rtt_current", "rtt_max", "key_frames", "last_key_frame", "layer_lock_plis", "last_layer_lock_pli", "packet_drift", "report_drift", "rebased_report_drift"] + __slots__ = ("start_time", "end_time", "duration", "packets", "packet_rate", "bytes", "header_bytes", "bitrate", "packets_lost", "packet_loss_rate", "packet_loss_percentage", "packets_duplicate", "packet_duplicate_rate", "bytes_duplicate", "header_bytes_duplicate", "bitrate_duplicate", "packets_padding", "packet_padding_rate", "bytes_padding", "header_bytes_padding", "bitrate_padding", "packets_out_of_order", "frames", "frame_rate", "jitter_current", "jitter_max", "gap_histogram", "nacks", "nack_acks", "nack_misses", "nack_repeated", "plis", "last_pli", "firs", "last_fir", "rtt_current", "rtt_max", "key_frames", "last_key_frame", "layer_lock_plis", "last_layer_lock_pli", "packet_drift", "report_drift", "rebased_report_drift") class GapHistogramEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: int @@ -682,7 +682,7 @@ class RTPStats(_message.Message): def __init__(self, start_time: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., end_time: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., duration: _Optional[float] = ..., packets: _Optional[int] = ..., packet_rate: _Optional[float] = ..., bytes: _Optional[int] = ..., header_bytes: _Optional[int] = ..., bitrate: _Optional[float] = ..., packets_lost: _Optional[int] = ..., packet_loss_rate: _Optional[float] = ..., packet_loss_percentage: _Optional[float] = ..., packets_duplicate: _Optional[int] = ..., packet_duplicate_rate: _Optional[float] = ..., bytes_duplicate: _Optional[int] = ..., header_bytes_duplicate: _Optional[int] = ..., bitrate_duplicate: _Optional[float] = ..., packets_padding: _Optional[int] = ..., packet_padding_rate: _Optional[float] = ..., bytes_padding: _Optional[int] = ..., header_bytes_padding: _Optional[int] = ..., bitrate_padding: _Optional[float] = ..., packets_out_of_order: _Optional[int] = ..., frames: _Optional[int] = ..., frame_rate: _Optional[float] = ..., jitter_current: _Optional[float] = ..., jitter_max: _Optional[float] = ..., gap_histogram: _Optional[_Mapping[int, int]] = ..., nacks: _Optional[int] = ..., nack_acks: _Optional[int] = ..., nack_misses: _Optional[int] = ..., nack_repeated: _Optional[int] = ..., plis: _Optional[int] = ..., last_pli: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., firs: _Optional[int] = ..., last_fir: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., rtt_current: _Optional[int] = ..., rtt_max: _Optional[int] = ..., key_frames: _Optional[int] = ..., last_key_frame: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., layer_lock_plis: _Optional[int] = ..., last_layer_lock_pli: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., packet_drift: _Optional[_Union[RTPDrift, _Mapping]] = ..., report_drift: _Optional[_Union[RTPDrift, _Mapping]] = ..., rebased_report_drift: _Optional[_Union[RTPDrift, _Mapping]] = ...) -> None: ... class TimedVersion(_message.Message): - __slots__ = ["unix_micro", "ticks"] + __slots__ = ("unix_micro", "ticks") UNIX_MICRO_FIELD_NUMBER: _ClassVar[int] TICKS_FIELD_NUMBER: _ClassVar[int] unix_micro: int diff --git a/livekit-protocol/livekit/protocol/room.py b/livekit-protocol/livekit/protocol/room.py index 9138d1e9..2caebeb8 100644 --- a/livekit-protocol/livekit/protocol/room.py +++ b/livekit-protocol/livekit/protocol/room.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: livekit_room.proto +# Protobuf Python Version: 4.25.3 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -21,13 +22,12 @@ _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'room', _globals) if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' - _UPDATEPARTICIPANTREQUEST_ATTRIBUTESENTRY._options = None - _UPDATEPARTICIPANTREQUEST_ATTRIBUTESENTRY._serialized_options = b'8\001' - _SENDDATAREQUEST.fields_by_name['destination_sids']._options = None - _SENDDATAREQUEST.fields_by_name['destination_sids']._serialized_options = b'\030\001' + _globals['DESCRIPTOR']._options = None + _globals['DESCRIPTOR']._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' + _globals['_UPDATEPARTICIPANTREQUEST_ATTRIBUTESENTRY']._options = None + _globals['_UPDATEPARTICIPANTREQUEST_ATTRIBUTESENTRY']._serialized_options = b'8\001' + _globals['_SENDDATAREQUEST'].fields_by_name['destination_sids']._options = None + _globals['_SENDDATAREQUEST'].fields_by_name['destination_sids']._serialized_options = b'\030\001' _globals['_CREATEROOMREQUEST']._serialized_start=76 _globals['_CREATEROOMREQUEST']._serialized_end=333 _globals['_ROOMEGRESS']._serialized_start=336 diff --git a/livekit-protocol/livekit/protocol/room.pyi b/livekit-protocol/livekit/protocol/room.pyi index b4247f13..2ba90dd9 100644 --- a/livekit-protocol/livekit/protocol/room.pyi +++ b/livekit-protocol/livekit/protocol/room.pyi @@ -8,7 +8,7 @@ from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Map DESCRIPTOR: _descriptor.FileDescriptor class CreateRoomRequest(_message.Message): - __slots__ = ["name", "empty_timeout", "departure_timeout", "max_participants", "node_id", "metadata", "egress", "min_playout_delay", "max_playout_delay", "sync_streams"] + __slots__ = ("name", "empty_timeout", "departure_timeout", "max_participants", "node_id", "metadata", "egress", "min_playout_delay", "max_playout_delay", "sync_streams") NAME_FIELD_NUMBER: _ClassVar[int] EMPTY_TIMEOUT_FIELD_NUMBER: _ClassVar[int] DEPARTURE_TIMEOUT_FIELD_NUMBER: _ClassVar[int] @@ -32,7 +32,7 @@ class CreateRoomRequest(_message.Message): def __init__(self, name: _Optional[str] = ..., empty_timeout: _Optional[int] = ..., departure_timeout: _Optional[int] = ..., max_participants: _Optional[int] = ..., node_id: _Optional[str] = ..., metadata: _Optional[str] = ..., egress: _Optional[_Union[RoomEgress, _Mapping]] = ..., min_playout_delay: _Optional[int] = ..., max_playout_delay: _Optional[int] = ..., sync_streams: bool = ...) -> None: ... class RoomEgress(_message.Message): - __slots__ = ["room", "participant", "tracks"] + __slots__ = ("room", "participant", "tracks") ROOM_FIELD_NUMBER: _ClassVar[int] PARTICIPANT_FIELD_NUMBER: _ClassVar[int] TRACKS_FIELD_NUMBER: _ClassVar[int] @@ -42,41 +42,41 @@ class RoomEgress(_message.Message): def __init__(self, room: _Optional[_Union[_egress.RoomCompositeEgressRequest, _Mapping]] = ..., participant: _Optional[_Union[_egress.AutoParticipantEgress, _Mapping]] = ..., tracks: _Optional[_Union[_egress.AutoTrackEgress, _Mapping]] = ...) -> None: ... class ListRoomsRequest(_message.Message): - __slots__ = ["names"] + __slots__ = ("names",) NAMES_FIELD_NUMBER: _ClassVar[int] names: _containers.RepeatedScalarFieldContainer[str] def __init__(self, names: _Optional[_Iterable[str]] = ...) -> None: ... class ListRoomsResponse(_message.Message): - __slots__ = ["rooms"] + __slots__ = ("rooms",) ROOMS_FIELD_NUMBER: _ClassVar[int] rooms: _containers.RepeatedCompositeFieldContainer[_models.Room] def __init__(self, rooms: _Optional[_Iterable[_Union[_models.Room, _Mapping]]] = ...) -> None: ... class DeleteRoomRequest(_message.Message): - __slots__ = ["room"] + __slots__ = ("room",) ROOM_FIELD_NUMBER: _ClassVar[int] room: str def __init__(self, room: _Optional[str] = ...) -> None: ... class DeleteRoomResponse(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class ListParticipantsRequest(_message.Message): - __slots__ = ["room"] + __slots__ = ("room",) ROOM_FIELD_NUMBER: _ClassVar[int] room: str def __init__(self, room: _Optional[str] = ...) -> None: ... class ListParticipantsResponse(_message.Message): - __slots__ = ["participants"] + __slots__ = ("participants",) PARTICIPANTS_FIELD_NUMBER: _ClassVar[int] participants: _containers.RepeatedCompositeFieldContainer[_models.ParticipantInfo] def __init__(self, participants: _Optional[_Iterable[_Union[_models.ParticipantInfo, _Mapping]]] = ...) -> None: ... class RoomParticipantIdentity(_message.Message): - __slots__ = ["room", "identity"] + __slots__ = ("room", "identity") ROOM_FIELD_NUMBER: _ClassVar[int] IDENTITY_FIELD_NUMBER: _ClassVar[int] room: str @@ -84,11 +84,11 @@ class RoomParticipantIdentity(_message.Message): def __init__(self, room: _Optional[str] = ..., identity: _Optional[str] = ...) -> None: ... class RemoveParticipantResponse(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class MuteRoomTrackRequest(_message.Message): - __slots__ = ["room", "identity", "track_sid", "muted"] + __slots__ = ("room", "identity", "track_sid", "muted") ROOM_FIELD_NUMBER: _ClassVar[int] IDENTITY_FIELD_NUMBER: _ClassVar[int] TRACK_SID_FIELD_NUMBER: _ClassVar[int] @@ -100,15 +100,15 @@ class MuteRoomTrackRequest(_message.Message): def __init__(self, room: _Optional[str] = ..., identity: _Optional[str] = ..., track_sid: _Optional[str] = ..., muted: bool = ...) -> None: ... class MuteRoomTrackResponse(_message.Message): - __slots__ = ["track"] + __slots__ = ("track",) TRACK_FIELD_NUMBER: _ClassVar[int] track: _models.TrackInfo def __init__(self, track: _Optional[_Union[_models.TrackInfo, _Mapping]] = ...) -> None: ... class UpdateParticipantRequest(_message.Message): - __slots__ = ["room", "identity", "metadata", "permission", "name", "attributes"] + __slots__ = ("room", "identity", "metadata", "permission", "name", "attributes") class AttributesEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str @@ -129,7 +129,7 @@ class UpdateParticipantRequest(_message.Message): def __init__(self, room: _Optional[str] = ..., identity: _Optional[str] = ..., metadata: _Optional[str] = ..., permission: _Optional[_Union[_models.ParticipantPermission, _Mapping]] = ..., name: _Optional[str] = ..., attributes: _Optional[_Mapping[str, str]] = ...) -> None: ... class UpdateSubscriptionsRequest(_message.Message): - __slots__ = ["room", "identity", "track_sids", "subscribe", "participant_tracks"] + __slots__ = ("room", "identity", "track_sids", "subscribe", "participant_tracks") ROOM_FIELD_NUMBER: _ClassVar[int] IDENTITY_FIELD_NUMBER: _ClassVar[int] TRACK_SIDS_FIELD_NUMBER: _ClassVar[int] @@ -143,11 +143,11 @@ class UpdateSubscriptionsRequest(_message.Message): def __init__(self, room: _Optional[str] = ..., identity: _Optional[str] = ..., track_sids: _Optional[_Iterable[str]] = ..., subscribe: bool = ..., participant_tracks: _Optional[_Iterable[_Union[_models.ParticipantTracks, _Mapping]]] = ...) -> None: ... class UpdateSubscriptionsResponse(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class SendDataRequest(_message.Message): - __slots__ = ["room", "data", "kind", "destination_sids", "destination_identities", "topic"] + __slots__ = ("room", "data", "kind", "destination_sids", "destination_identities", "topic") ROOM_FIELD_NUMBER: _ClassVar[int] DATA_FIELD_NUMBER: _ClassVar[int] KIND_FIELD_NUMBER: _ClassVar[int] @@ -163,11 +163,11 @@ class SendDataRequest(_message.Message): def __init__(self, room: _Optional[str] = ..., data: _Optional[bytes] = ..., kind: _Optional[_Union[_models.DataPacket.Kind, str]] = ..., destination_sids: _Optional[_Iterable[str]] = ..., destination_identities: _Optional[_Iterable[str]] = ..., topic: _Optional[str] = ...) -> None: ... class SendDataResponse(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class UpdateRoomMetadataRequest(_message.Message): - __slots__ = ["room", "metadata"] + __slots__ = ("room", "metadata") ROOM_FIELD_NUMBER: _ClassVar[int] METADATA_FIELD_NUMBER: _ClassVar[int] room: str diff --git a/livekit-protocol/livekit/protocol/sip.py b/livekit-protocol/livekit/protocol/sip.py index 0d40cf35..7106c3cc 100644 --- a/livekit-protocol/livekit/protocol/sip.py +++ b/livekit-protocol/livekit/protocol/sip.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: livekit_sip.proto +# Protobuf Python Version: 4.25.3 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -19,31 +20,30 @@ _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'sip', _globals) if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' - _CREATESIPTRUNKREQUEST.fields_by_name['inbound_numbers_regex']._options = None - _CREATESIPTRUNKREQUEST.fields_by_name['inbound_numbers_regex']._serialized_options = b'\030\001' - _CREATESIPTRUNKREQUEST._options = None - _CREATESIPTRUNKREQUEST._serialized_options = b'\030\001' - _SIPTRUNKINFO.fields_by_name['inbound_numbers_regex']._options = None - _SIPTRUNKINFO.fields_by_name['inbound_numbers_regex']._serialized_options = b'\030\001' - _SIPTRUNKINFO._options = None - _SIPTRUNKINFO._serialized_options = b'\030\001' - _LISTSIPTRUNKREQUEST._options = None - _LISTSIPTRUNKREQUEST._serialized_options = b'\030\001' - _LISTSIPTRUNKRESPONSE._options = None - _LISTSIPTRUNKRESPONSE._serialized_options = b'\030\001' - _CREATESIPDISPATCHRULEREQUEST_ATTRIBUTESENTRY._options = None - _CREATESIPDISPATCHRULEREQUEST_ATTRIBUTESENTRY._serialized_options = b'8\001' - _SIPDISPATCHRULEINFO_ATTRIBUTESENTRY._options = None - _SIPDISPATCHRULEINFO_ATTRIBUTESENTRY._serialized_options = b'8\001' - _CREATESIPPARTICIPANTREQUEST_PARTICIPANTATTRIBUTESENTRY._options = None - _CREATESIPPARTICIPANTREQUEST_PARTICIPANTATTRIBUTESENTRY._serialized_options = b'8\001' - _SIP.methods_by_name['CreateSIPTrunk']._options = None - _SIP.methods_by_name['CreateSIPTrunk']._serialized_options = b'\210\002\001' - _SIP.methods_by_name['ListSIPTrunk']._options = None - _SIP.methods_by_name['ListSIPTrunk']._serialized_options = b'\210\002\001' + _globals['DESCRIPTOR']._options = None + _globals['DESCRIPTOR']._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' + _globals['_CREATESIPTRUNKREQUEST'].fields_by_name['inbound_numbers_regex']._options = None + _globals['_CREATESIPTRUNKREQUEST'].fields_by_name['inbound_numbers_regex']._serialized_options = b'\030\001' + _globals['_CREATESIPTRUNKREQUEST']._options = None + _globals['_CREATESIPTRUNKREQUEST']._serialized_options = b'\030\001' + _globals['_SIPTRUNKINFO'].fields_by_name['inbound_numbers_regex']._options = None + _globals['_SIPTRUNKINFO'].fields_by_name['inbound_numbers_regex']._serialized_options = b'\030\001' + _globals['_SIPTRUNKINFO']._options = None + _globals['_SIPTRUNKINFO']._serialized_options = b'\030\001' + _globals['_LISTSIPTRUNKREQUEST']._options = None + _globals['_LISTSIPTRUNKREQUEST']._serialized_options = b'\030\001' + _globals['_LISTSIPTRUNKRESPONSE']._options = None + _globals['_LISTSIPTRUNKRESPONSE']._serialized_options = b'\030\001' + _globals['_CREATESIPDISPATCHRULEREQUEST_ATTRIBUTESENTRY']._options = None + _globals['_CREATESIPDISPATCHRULEREQUEST_ATTRIBUTESENTRY']._serialized_options = b'8\001' + _globals['_SIPDISPATCHRULEINFO_ATTRIBUTESENTRY']._options = None + _globals['_SIPDISPATCHRULEINFO_ATTRIBUTESENTRY']._serialized_options = b'8\001' + _globals['_CREATESIPPARTICIPANTREQUEST_PARTICIPANTATTRIBUTESENTRY']._options = None + _globals['_CREATESIPPARTICIPANTREQUEST_PARTICIPANTATTRIBUTESENTRY']._serialized_options = b'8\001' + _globals['_SIP'].methods_by_name['CreateSIPTrunk']._options = None + _globals['_SIP'].methods_by_name['CreateSIPTrunk']._serialized_options = b'\210\002\001' + _globals['_SIP'].methods_by_name['ListSIPTrunk']._options = None + _globals['_SIP'].methods_by_name['ListSIPTrunk']._serialized_options = b'\210\002\001' _globals['_SIPTRANSPORT']._serialized_start=3306 _globals['_SIPTRANSPORT']._serialized_end=3413 _globals['_CREATESIPTRUNKREQUEST']._serialized_start=31 diff --git a/livekit-protocol/livekit/protocol/sip.pyi b/livekit-protocol/livekit/protocol/sip.pyi index a7d5a995..770b8e30 100644 --- a/livekit-protocol/livekit/protocol/sip.pyi +++ b/livekit-protocol/livekit/protocol/sip.pyi @@ -7,7 +7,7 @@ from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Map DESCRIPTOR: _descriptor.FileDescriptor class SIPTransport(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () SIP_TRANSPORT_AUTO: _ClassVar[SIPTransport] SIP_TRANSPORT_UDP: _ClassVar[SIPTransport] SIP_TRANSPORT_TCP: _ClassVar[SIPTransport] @@ -18,7 +18,7 @@ SIP_TRANSPORT_TCP: SIPTransport SIP_TRANSPORT_TLS: SIPTransport class CreateSIPTrunkRequest(_message.Message): - __slots__ = ["inbound_addresses", "outbound_address", "outbound_number", "inbound_numbers_regex", "inbound_numbers", "inbound_username", "inbound_password", "outbound_username", "outbound_password", "name", "metadata"] + __slots__ = ("inbound_addresses", "outbound_address", "outbound_number", "inbound_numbers_regex", "inbound_numbers", "inbound_username", "inbound_password", "outbound_username", "outbound_password", "name", "metadata") INBOUND_ADDRESSES_FIELD_NUMBER: _ClassVar[int] OUTBOUND_ADDRESS_FIELD_NUMBER: _ClassVar[int] OUTBOUND_NUMBER_FIELD_NUMBER: _ClassVar[int] @@ -44,9 +44,9 @@ class CreateSIPTrunkRequest(_message.Message): def __init__(self, inbound_addresses: _Optional[_Iterable[str]] = ..., outbound_address: _Optional[str] = ..., outbound_number: _Optional[str] = ..., inbound_numbers_regex: _Optional[_Iterable[str]] = ..., inbound_numbers: _Optional[_Iterable[str]] = ..., inbound_username: _Optional[str] = ..., inbound_password: _Optional[str] = ..., outbound_username: _Optional[str] = ..., outbound_password: _Optional[str] = ..., name: _Optional[str] = ..., metadata: _Optional[str] = ...) -> None: ... class SIPTrunkInfo(_message.Message): - __slots__ = ["sip_trunk_id", "kind", "inbound_addresses", "outbound_address", "outbound_number", "transport", "inbound_numbers_regex", "inbound_numbers", "inbound_username", "inbound_password", "outbound_username", "outbound_password", "name", "metadata"] + __slots__ = ("sip_trunk_id", "kind", "inbound_addresses", "outbound_address", "outbound_number", "transport", "inbound_numbers_regex", "inbound_numbers", "inbound_username", "inbound_password", "outbound_username", "outbound_password", "name", "metadata") class TrunkKind(int, metaclass=_enum_type_wrapper.EnumTypeWrapper): - __slots__ = [] + __slots__ = () TRUNK_LEGACY: _ClassVar[SIPTrunkInfo.TrunkKind] TRUNK_INBOUND: _ClassVar[SIPTrunkInfo.TrunkKind] TRUNK_OUTBOUND: _ClassVar[SIPTrunkInfo.TrunkKind] @@ -84,13 +84,13 @@ class SIPTrunkInfo(_message.Message): def __init__(self, sip_trunk_id: _Optional[str] = ..., kind: _Optional[_Union[SIPTrunkInfo.TrunkKind, str]] = ..., inbound_addresses: _Optional[_Iterable[str]] = ..., outbound_address: _Optional[str] = ..., outbound_number: _Optional[str] = ..., transport: _Optional[_Union[SIPTransport, str]] = ..., inbound_numbers_regex: _Optional[_Iterable[str]] = ..., inbound_numbers: _Optional[_Iterable[str]] = ..., inbound_username: _Optional[str] = ..., inbound_password: _Optional[str] = ..., outbound_username: _Optional[str] = ..., outbound_password: _Optional[str] = ..., name: _Optional[str] = ..., metadata: _Optional[str] = ...) -> None: ... class CreateSIPInboundTrunkRequest(_message.Message): - __slots__ = ["trunk"] + __slots__ = ("trunk",) TRUNK_FIELD_NUMBER: _ClassVar[int] trunk: SIPInboundTrunkInfo def __init__(self, trunk: _Optional[_Union[SIPInboundTrunkInfo, _Mapping]] = ...) -> None: ... class SIPInboundTrunkInfo(_message.Message): - __slots__ = ["sip_trunk_id", "name", "metadata", "numbers", "allowed_addresses", "allowed_numbers", "auth_username", "auth_password"] + __slots__ = ("sip_trunk_id", "name", "metadata", "numbers", "allowed_addresses", "allowed_numbers", "auth_username", "auth_password") SIP_TRUNK_ID_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] METADATA_FIELD_NUMBER: _ClassVar[int] @@ -110,13 +110,13 @@ class SIPInboundTrunkInfo(_message.Message): def __init__(self, sip_trunk_id: _Optional[str] = ..., name: _Optional[str] = ..., metadata: _Optional[str] = ..., numbers: _Optional[_Iterable[str]] = ..., allowed_addresses: _Optional[_Iterable[str]] = ..., allowed_numbers: _Optional[_Iterable[str]] = ..., auth_username: _Optional[str] = ..., auth_password: _Optional[str] = ...) -> None: ... class CreateSIPOutboundTrunkRequest(_message.Message): - __slots__ = ["trunk"] + __slots__ = ("trunk",) TRUNK_FIELD_NUMBER: _ClassVar[int] trunk: SIPOutboundTrunkInfo def __init__(self, trunk: _Optional[_Union[SIPOutboundTrunkInfo, _Mapping]] = ...) -> None: ... class SIPOutboundTrunkInfo(_message.Message): - __slots__ = ["sip_trunk_id", "name", "metadata", "address", "transport", "numbers", "auth_username", "auth_password"] + __slots__ = ("sip_trunk_id", "name", "metadata", "address", "transport", "numbers", "auth_username", "auth_password") SIP_TRUNK_ID_FIELD_NUMBER: _ClassVar[int] NAME_FIELD_NUMBER: _ClassVar[int] METADATA_FIELD_NUMBER: _ClassVar[int] @@ -136,43 +136,43 @@ class SIPOutboundTrunkInfo(_message.Message): def __init__(self, sip_trunk_id: _Optional[str] = ..., name: _Optional[str] = ..., metadata: _Optional[str] = ..., address: _Optional[str] = ..., transport: _Optional[_Union[SIPTransport, str]] = ..., numbers: _Optional[_Iterable[str]] = ..., auth_username: _Optional[str] = ..., auth_password: _Optional[str] = ...) -> None: ... class ListSIPTrunkRequest(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class ListSIPTrunkResponse(_message.Message): - __slots__ = ["items"] + __slots__ = ("items",) ITEMS_FIELD_NUMBER: _ClassVar[int] items: _containers.RepeatedCompositeFieldContainer[SIPTrunkInfo] def __init__(self, items: _Optional[_Iterable[_Union[SIPTrunkInfo, _Mapping]]] = ...) -> None: ... class ListSIPInboundTrunkRequest(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class ListSIPInboundTrunkResponse(_message.Message): - __slots__ = ["items"] + __slots__ = ("items",) ITEMS_FIELD_NUMBER: _ClassVar[int] items: _containers.RepeatedCompositeFieldContainer[SIPInboundTrunkInfo] def __init__(self, items: _Optional[_Iterable[_Union[SIPInboundTrunkInfo, _Mapping]]] = ...) -> None: ... class ListSIPOutboundTrunkRequest(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class ListSIPOutboundTrunkResponse(_message.Message): - __slots__ = ["items"] + __slots__ = ("items",) ITEMS_FIELD_NUMBER: _ClassVar[int] items: _containers.RepeatedCompositeFieldContainer[SIPOutboundTrunkInfo] def __init__(self, items: _Optional[_Iterable[_Union[SIPOutboundTrunkInfo, _Mapping]]] = ...) -> None: ... class DeleteSIPTrunkRequest(_message.Message): - __slots__ = ["sip_trunk_id"] + __slots__ = ("sip_trunk_id",) SIP_TRUNK_ID_FIELD_NUMBER: _ClassVar[int] sip_trunk_id: str def __init__(self, sip_trunk_id: _Optional[str] = ...) -> None: ... class SIPDispatchRuleDirect(_message.Message): - __slots__ = ["room_name", "pin"] + __slots__ = ("room_name", "pin") ROOM_NAME_FIELD_NUMBER: _ClassVar[int] PIN_FIELD_NUMBER: _ClassVar[int] room_name: str @@ -180,7 +180,7 @@ class SIPDispatchRuleDirect(_message.Message): def __init__(self, room_name: _Optional[str] = ..., pin: _Optional[str] = ...) -> None: ... class SIPDispatchRuleIndividual(_message.Message): - __slots__ = ["room_prefix", "pin"] + __slots__ = ("room_prefix", "pin") ROOM_PREFIX_FIELD_NUMBER: _ClassVar[int] PIN_FIELD_NUMBER: _ClassVar[int] room_prefix: str @@ -188,7 +188,7 @@ class SIPDispatchRuleIndividual(_message.Message): def __init__(self, room_prefix: _Optional[str] = ..., pin: _Optional[str] = ...) -> None: ... class SIPDispatchRule(_message.Message): - __slots__ = ["dispatch_rule_direct", "dispatch_rule_individual"] + __slots__ = ("dispatch_rule_direct", "dispatch_rule_individual") DISPATCH_RULE_DIRECT_FIELD_NUMBER: _ClassVar[int] DISPATCH_RULE_INDIVIDUAL_FIELD_NUMBER: _ClassVar[int] dispatch_rule_direct: SIPDispatchRuleDirect @@ -196,9 +196,9 @@ class SIPDispatchRule(_message.Message): def __init__(self, dispatch_rule_direct: _Optional[_Union[SIPDispatchRuleDirect, _Mapping]] = ..., dispatch_rule_individual: _Optional[_Union[SIPDispatchRuleIndividual, _Mapping]] = ...) -> None: ... class CreateSIPDispatchRuleRequest(_message.Message): - __slots__ = ["rule", "trunk_ids", "hide_phone_number", "inbound_numbers", "name", "metadata", "attributes"] + __slots__ = ("rule", "trunk_ids", "hide_phone_number", "inbound_numbers", "name", "metadata", "attributes") class AttributesEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str @@ -221,9 +221,9 @@ class CreateSIPDispatchRuleRequest(_message.Message): def __init__(self, rule: _Optional[_Union[SIPDispatchRule, _Mapping]] = ..., trunk_ids: _Optional[_Iterable[str]] = ..., hide_phone_number: bool = ..., inbound_numbers: _Optional[_Iterable[str]] = ..., name: _Optional[str] = ..., metadata: _Optional[str] = ..., attributes: _Optional[_Mapping[str, str]] = ...) -> None: ... class SIPDispatchRuleInfo(_message.Message): - __slots__ = ["sip_dispatch_rule_id", "rule", "trunk_ids", "hide_phone_number", "inbound_numbers", "name", "metadata", "attributes"] + __slots__ = ("sip_dispatch_rule_id", "rule", "trunk_ids", "hide_phone_number", "inbound_numbers", "name", "metadata", "attributes") class AttributesEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str @@ -248,25 +248,25 @@ class SIPDispatchRuleInfo(_message.Message): def __init__(self, sip_dispatch_rule_id: _Optional[str] = ..., rule: _Optional[_Union[SIPDispatchRule, _Mapping]] = ..., trunk_ids: _Optional[_Iterable[str]] = ..., hide_phone_number: bool = ..., inbound_numbers: _Optional[_Iterable[str]] = ..., name: _Optional[str] = ..., metadata: _Optional[str] = ..., attributes: _Optional[_Mapping[str, str]] = ...) -> None: ... class ListSIPDispatchRuleRequest(_message.Message): - __slots__ = [] + __slots__ = () def __init__(self) -> None: ... class ListSIPDispatchRuleResponse(_message.Message): - __slots__ = ["items"] + __slots__ = ("items",) ITEMS_FIELD_NUMBER: _ClassVar[int] items: _containers.RepeatedCompositeFieldContainer[SIPDispatchRuleInfo] def __init__(self, items: _Optional[_Iterable[_Union[SIPDispatchRuleInfo, _Mapping]]] = ...) -> None: ... class DeleteSIPDispatchRuleRequest(_message.Message): - __slots__ = ["sip_dispatch_rule_id"] + __slots__ = ("sip_dispatch_rule_id",) SIP_DISPATCH_RULE_ID_FIELD_NUMBER: _ClassVar[int] sip_dispatch_rule_id: str def __init__(self, sip_dispatch_rule_id: _Optional[str] = ...) -> None: ... class CreateSIPParticipantRequest(_message.Message): - __slots__ = ["sip_trunk_id", "sip_call_to", "room_name", "participant_identity", "participant_name", "participant_metadata", "participant_attributes", "dtmf", "play_ringtone", "hide_phone_number"] + __slots__ = ("sip_trunk_id", "sip_call_to", "room_name", "participant_identity", "participant_name", "participant_metadata", "participant_attributes", "dtmf", "play_ringtone", "hide_phone_number") class ParticipantAttributesEntry(_message.Message): - __slots__ = ["key", "value"] + __slots__ = ("key", "value") KEY_FIELD_NUMBER: _ClassVar[int] VALUE_FIELD_NUMBER: _ClassVar[int] key: str @@ -295,7 +295,7 @@ class CreateSIPParticipantRequest(_message.Message): def __init__(self, sip_trunk_id: _Optional[str] = ..., sip_call_to: _Optional[str] = ..., room_name: _Optional[str] = ..., participant_identity: _Optional[str] = ..., participant_name: _Optional[str] = ..., participant_metadata: _Optional[str] = ..., participant_attributes: _Optional[_Mapping[str, str]] = ..., dtmf: _Optional[str] = ..., play_ringtone: bool = ..., hide_phone_number: bool = ...) -> None: ... class SIPParticipantInfo(_message.Message): - __slots__ = ["participant_id", "participant_identity", "room_name", "sip_call_id"] + __slots__ = ("participant_id", "participant_identity", "room_name", "sip_call_id") PARTICIPANT_ID_FIELD_NUMBER: _ClassVar[int] PARTICIPANT_IDENTITY_FIELD_NUMBER: _ClassVar[int] ROOM_NAME_FIELD_NUMBER: _ClassVar[int] diff --git a/livekit-protocol/livekit/protocol/webhook.py b/livekit-protocol/livekit/protocol/webhook.py index 61b9e22b..7c9f12c4 100644 --- a/livekit-protocol/livekit/protocol/webhook.py +++ b/livekit-protocol/livekit/protocol/webhook.py @@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: livekit_webhook.proto +# Protobuf Python Version: 4.25.3 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -22,9 +23,8 @@ _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'webhook', _globals) if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' + _globals['DESCRIPTOR']._options = None + _globals['DESCRIPTOR']._serialized_options = b'Z#github.com/livekit/protocol/livekit\252\002\rLiveKit.Proto\352\002\016LiveKit::Proto' _globals['_WEBHOOKEVENT']._serialized_start=102 _globals['_WEBHOOKEVENT']._serialized_end=381 # @@protoc_insertion_point(module_scope) diff --git a/livekit-protocol/livekit/protocol/webhook.pyi b/livekit-protocol/livekit/protocol/webhook.pyi index 4a538e78..443a24dc 100644 --- a/livekit-protocol/livekit/protocol/webhook.pyi +++ b/livekit-protocol/livekit/protocol/webhook.pyi @@ -8,7 +8,7 @@ from typing import ClassVar as _ClassVar, Mapping as _Mapping, Optional as _Opti DESCRIPTOR: _descriptor.FileDescriptor class WebhookEvent(_message.Message): - __slots__ = ["event", "room", "participant", "egress_info", "ingress_info", "track", "id", "created_at", "num_dropped"] + __slots__ = ("event", "room", "participant", "egress_info", "ingress_info", "track", "id", "created_at", "num_dropped") EVENT_FIELD_NUMBER: _ClassVar[int] ROOM_FIELD_NUMBER: _ClassVar[int] PARTICIPANT_FIELD_NUMBER: _ClassVar[int]