diff --git a/.gitignore b/.gitignore index 39622d20..feea0a3d 100644 --- a/.gitignore +++ b/.gitignore @@ -157,4 +157,7 @@ cython_debug/ # be found at https://github.com/github/gitignore/blob/main/Global/JetBrains.gitignore # and can be added to the global gitignore or merged into this file. For a more nuclear # option (not recommended) you can uncomment the following to ignore the entire idea folder. -#.idea/ \ No newline at end of file +#.idea/ + +# vscode project settings +.vscode \ No newline at end of file diff --git a/livekit/_proto/audio_frame_pb2.py b/livekit/_proto/audio_frame_pb2.py index 8bc55719..44599376 100644 --- a/livekit/_proto/audio_frame_pb2.py +++ b/livekit/_proto/audio_frame_pb2.py @@ -2,10 +2,10 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # source: audio_frame.proto """Generated protocol buffer code.""" +from google.protobuf.internal import builder as _builder from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -16,53 +16,52 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x11\x61udio_frame.proto\x12\rlivekit.proto\x1a\x0chandle.proto\"a\n\x17\x41llocAudioBufferRequest\x12\x13\n\x0bsample_rate\x18\x01 \x01(\r\x12\x14\n\x0cnum_channels\x18\x02 \x01(\r\x12\x1b\n\x13samples_per_channel\x18\x03 \x01(\r\"O\n\x18\x41llocAudioBufferResponse\x12\x33\n\x06\x62uffer\x18\x01 \x01(\x0b\x32#.livekit.proto.AudioFrameBufferInfo\"[\n\x15NewAudioStreamRequest\x12\x14\n\x0ctrack_handle\x18\x01 \x01(\x04\x12,\n\x04type\x18\x02 \x01(\x0e\x32\x1e.livekit.proto.AudioStreamType\"H\n\x16NewAudioStreamResponse\x12.\n\x06stream\x18\x01 \x01(\x0b\x32\x1e.livekit.proto.AudioStreamInfo\"\x8a\x01\n\x15NewAudioSourceRequest\x12,\n\x04type\x18\x01 \x01(\x0e\x32\x1e.livekit.proto.AudioSourceType\x12\x37\n\x07options\x18\x02 \x01(\x0b\x32!.livekit.proto.AudioSourceOptionsH\x00\x88\x01\x01\x42\n\n\x08_options\"H\n\x16NewAudioSourceResponse\x12.\n\x06source\x18\x01 \x01(\x0b\x32\x1e.livekit.proto.AudioSourceInfo\"H\n\x18\x43\x61ptureAudioFrameRequest\x12\x15\n\rsource_handle\x18\x01 \x01(\x04\x12\x15\n\rbuffer_handle\x18\x02 \x01(\x04\"\x1b\n\x19\x43\x61ptureAudioFrameResponse\"\x1a\n\x18NewAudioResamplerRequest\"Q\n\x19NewAudioResamplerResponse\x12\x34\n\tresampler\x18\x01 \x01(\x0b\x32!.livekit.proto.AudioResamplerInfo\"u\n\x17RemixAndResampleRequest\x12\x18\n\x10resampler_handle\x18\x01 \x01(\x04\x12\x15\n\rbuffer_handle\x18\x02 \x01(\x04\x12\x14\n\x0cnum_channels\x18\x03 \x01(\r\x12\x13\n\x0bsample_rate\x18\x04 \x01(\r\"O\n\x18RemixAndResampleResponse\x12\x33\n\x06\x62uffer\x18\x01 \x01(\x0b\x32#.livekit.proto.AudioFrameBufferInfo\"\x9f\x01\n\x14\x41udioFrameBufferInfo\x12-\n\x06handle\x18\x01 \x01(\x0b\x32\x1d.livekit.proto.FfiOwnedHandle\x12\x10\n\x08\x64\x61ta_ptr\x18\x02 \x01(\x04\x12\x14\n\x0cnum_channels\x18\x03 \x01(\r\x12\x13\n\x0bsample_rate\x18\x04 \x01(\r\x12\x1b\n\x13samples_per_channel\x18\x05 \x01(\r\"n\n\x0f\x41udioStreamInfo\x12-\n\x06handle\x18\x01 \x01(\x0b\x32\x1d.livekit.proto.FfiOwnedHandle\x12,\n\x04type\x18\x02 \x01(\x0e\x32\x1e.livekit.proto.AudioStreamType\"q\n\x10\x41udioStreamEvent\x12\x15\n\rsource_handle\x18\x01 \x01(\x04\x12;\n\x0e\x66rame_received\x18\x02 \x01(\x0b\x32!.livekit.proto.AudioFrameReceivedH\x00\x42\t\n\x07message\"H\n\x12\x41udioFrameReceived\x12\x32\n\x05\x66rame\x18\x01 \x01(\x0b\x32#.livekit.proto.AudioFrameBufferInfo\"e\n\x12\x41udioSourceOptions\x12\x19\n\x11\x65\x63ho_cancellation\x18\x01 \x01(\x08\x12\x19\n\x11noise_suppression\x18\x02 \x01(\x08\x12\x19\n\x11\x61uto_gain_control\x18\x03 \x01(\x08\"n\n\x0f\x41udioSourceInfo\x12-\n\x06handle\x18\x01 \x01(\x0b\x32\x1d.livekit.proto.FfiOwnedHandle\x12,\n\x04type\x18\x02 \x01(\x0e\x32\x1e.livekit.proto.AudioSourceType\"C\n\x12\x41udioResamplerInfo\x12-\n\x06handle\x18\x01 \x01(\x0b\x32\x1d.livekit.proto.FfiOwnedHandle*A\n\x0f\x41udioStreamType\x12\x17\n\x13\x41UDIO_STREAM_NATIVE\x10\x00\x12\x15\n\x11\x41UDIO_STREAM_HTML\x10\x01**\n\x0f\x41udioSourceType\x12\x17\n\x13\x41UDIO_SOURCE_NATIVE\x10\x00\x42\x10\xaa\x02\rLiveKit.Protob\x06proto3') -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'audio_frame_pb2', _globals) +_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals()) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'audio_frame_pb2', globals()) if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None DESCRIPTOR._serialized_options = b'\252\002\rLiveKit.Proto' - _globals['_AUDIOSTREAMTYPE']._serialized_start=1773 - _globals['_AUDIOSTREAMTYPE']._serialized_end=1838 - _globals['_AUDIOSOURCETYPE']._serialized_start=1840 - _globals['_AUDIOSOURCETYPE']._serialized_end=1882 - _globals['_ALLOCAUDIOBUFFERREQUEST']._serialized_start=50 - _globals['_ALLOCAUDIOBUFFERREQUEST']._serialized_end=147 - _globals['_ALLOCAUDIOBUFFERRESPONSE']._serialized_start=149 - _globals['_ALLOCAUDIOBUFFERRESPONSE']._serialized_end=228 - _globals['_NEWAUDIOSTREAMREQUEST']._serialized_start=230 - _globals['_NEWAUDIOSTREAMREQUEST']._serialized_end=321 - _globals['_NEWAUDIOSTREAMRESPONSE']._serialized_start=323 - _globals['_NEWAUDIOSTREAMRESPONSE']._serialized_end=395 - _globals['_NEWAUDIOSOURCEREQUEST']._serialized_start=398 - _globals['_NEWAUDIOSOURCEREQUEST']._serialized_end=536 - _globals['_NEWAUDIOSOURCERESPONSE']._serialized_start=538 - _globals['_NEWAUDIOSOURCERESPONSE']._serialized_end=610 - _globals['_CAPTUREAUDIOFRAMEREQUEST']._serialized_start=612 - _globals['_CAPTUREAUDIOFRAMEREQUEST']._serialized_end=684 - _globals['_CAPTUREAUDIOFRAMERESPONSE']._serialized_start=686 - _globals['_CAPTUREAUDIOFRAMERESPONSE']._serialized_end=713 - _globals['_NEWAUDIORESAMPLERREQUEST']._serialized_start=715 - _globals['_NEWAUDIORESAMPLERREQUEST']._serialized_end=741 - _globals['_NEWAUDIORESAMPLERRESPONSE']._serialized_start=743 - _globals['_NEWAUDIORESAMPLERRESPONSE']._serialized_end=824 - _globals['_REMIXANDRESAMPLEREQUEST']._serialized_start=826 - _globals['_REMIXANDRESAMPLEREQUEST']._serialized_end=943 - _globals['_REMIXANDRESAMPLERESPONSE']._serialized_start=945 - _globals['_REMIXANDRESAMPLERESPONSE']._serialized_end=1024 - _globals['_AUDIOFRAMEBUFFERINFO']._serialized_start=1027 - _globals['_AUDIOFRAMEBUFFERINFO']._serialized_end=1186 - _globals['_AUDIOSTREAMINFO']._serialized_start=1188 - _globals['_AUDIOSTREAMINFO']._serialized_end=1298 - _globals['_AUDIOSTREAMEVENT']._serialized_start=1300 - _globals['_AUDIOSTREAMEVENT']._serialized_end=1413 - _globals['_AUDIOFRAMERECEIVED']._serialized_start=1415 - _globals['_AUDIOFRAMERECEIVED']._serialized_end=1487 - _globals['_AUDIOSOURCEOPTIONS']._serialized_start=1489 - _globals['_AUDIOSOURCEOPTIONS']._serialized_end=1590 - _globals['_AUDIOSOURCEINFO']._serialized_start=1592 - _globals['_AUDIOSOURCEINFO']._serialized_end=1702 - _globals['_AUDIORESAMPLERINFO']._serialized_start=1704 - _globals['_AUDIORESAMPLERINFO']._serialized_end=1771 + _AUDIOSTREAMTYPE._serialized_start=1773 + _AUDIOSTREAMTYPE._serialized_end=1838 + _AUDIOSOURCETYPE._serialized_start=1840 + _AUDIOSOURCETYPE._serialized_end=1882 + _ALLOCAUDIOBUFFERREQUEST._serialized_start=50 + _ALLOCAUDIOBUFFERREQUEST._serialized_end=147 + _ALLOCAUDIOBUFFERRESPONSE._serialized_start=149 + _ALLOCAUDIOBUFFERRESPONSE._serialized_end=228 + _NEWAUDIOSTREAMREQUEST._serialized_start=230 + _NEWAUDIOSTREAMREQUEST._serialized_end=321 + _NEWAUDIOSTREAMRESPONSE._serialized_start=323 + _NEWAUDIOSTREAMRESPONSE._serialized_end=395 + _NEWAUDIOSOURCEREQUEST._serialized_start=398 + _NEWAUDIOSOURCEREQUEST._serialized_end=536 + _NEWAUDIOSOURCERESPONSE._serialized_start=538 + _NEWAUDIOSOURCERESPONSE._serialized_end=610 + _CAPTUREAUDIOFRAMEREQUEST._serialized_start=612 + _CAPTUREAUDIOFRAMEREQUEST._serialized_end=684 + _CAPTUREAUDIOFRAMERESPONSE._serialized_start=686 + _CAPTUREAUDIOFRAMERESPONSE._serialized_end=713 + _NEWAUDIORESAMPLERREQUEST._serialized_start=715 + _NEWAUDIORESAMPLERREQUEST._serialized_end=741 + _NEWAUDIORESAMPLERRESPONSE._serialized_start=743 + _NEWAUDIORESAMPLERRESPONSE._serialized_end=824 + _REMIXANDRESAMPLEREQUEST._serialized_start=826 + _REMIXANDRESAMPLEREQUEST._serialized_end=943 + _REMIXANDRESAMPLERESPONSE._serialized_start=945 + _REMIXANDRESAMPLERESPONSE._serialized_end=1024 + _AUDIOFRAMEBUFFERINFO._serialized_start=1027 + _AUDIOFRAMEBUFFERINFO._serialized_end=1186 + _AUDIOSTREAMINFO._serialized_start=1188 + _AUDIOSTREAMINFO._serialized_end=1298 + _AUDIOSTREAMEVENT._serialized_start=1300 + _AUDIOSTREAMEVENT._serialized_end=1413 + _AUDIOFRAMERECEIVED._serialized_start=1415 + _AUDIOFRAMERECEIVED._serialized_end=1487 + _AUDIOSOURCEOPTIONS._serialized_start=1489 + _AUDIOSOURCEOPTIONS._serialized_end=1590 + _AUDIOSOURCEINFO._serialized_start=1592 + _AUDIOSOURCEINFO._serialized_end=1702 + _AUDIORESAMPLERINFO._serialized_start=1704 + _AUDIORESAMPLERINFO._serialized_end=1771 # @@protoc_insertion_point(module_scope) diff --git a/livekit/_proto/ffi_pb2.py b/livekit/_proto/ffi_pb2.py index b4a82d20..f4adbe6c 100644 --- a/livekit/_proto/ffi_pb2.py +++ b/livekit/_proto/ffi_pb2.py @@ -2,10 +2,10 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # source: ffi.proto """Generated protocol buffer code.""" +from google.protobuf.internal import builder as _builder from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -19,27 +19,26 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\tffi.proto\x12\rlivekit.proto\x1a\x0btrack.proto\x1a\nroom.proto\x1a\x11video_frame.proto\x1a\x11\x61udio_frame.proto\"\x83\x0b\n\nFfiRequest\x12\x36\n\ninitialize\x18\x01 \x01(\x0b\x32 .livekit.proto.InitializeRequestH\x00\x12\x30\n\x07\x64ispose\x18\x02 \x01(\x0b\x32\x1d.livekit.proto.DisposeRequestH\x00\x12\x30\n\x07\x63onnect\x18\x03 \x01(\x0b\x32\x1d.livekit.proto.ConnectRequestH\x00\x12\x36\n\ndisconnect\x18\x04 \x01(\x0b\x32 .livekit.proto.DisconnectRequestH\x00\x12;\n\rpublish_track\x18\x05 \x01(\x0b\x32\".livekit.proto.PublishTrackRequestH\x00\x12?\n\x0funpublish_track\x18\x06 \x01(\x0b\x32$.livekit.proto.UnpublishTrackRequestH\x00\x12\x39\n\x0cpublish_data\x18\x07 \x01(\x0b\x32!.livekit.proto.PublishDataRequestH\x00\x12=\n\x0eset_subscribed\x18\x08 \x01(\x0b\x32#.livekit.proto.SetSubscribedRequestH\x00\x12\x44\n\x12\x63reate_video_track\x18\t \x01(\x0b\x32&.livekit.proto.CreateVideoTrackRequestH\x00\x12\x44\n\x12\x63reate_audio_track\x18\n \x01(\x0b\x32&.livekit.proto.CreateAudioTrackRequestH\x00\x12\x44\n\x12\x61lloc_video_buffer\x18\x0b \x01(\x0b\x32&.livekit.proto.AllocVideoBufferRequestH\x00\x12@\n\x10new_video_stream\x18\x0c \x01(\x0b\x32$.livekit.proto.NewVideoStreamRequestH\x00\x12@\n\x10new_video_source\x18\r \x01(\x0b\x32$.livekit.proto.NewVideoSourceRequestH\x00\x12\x46\n\x13\x63\x61pture_video_frame\x18\x0e \x01(\x0b\x32\'.livekit.proto.CaptureVideoFrameRequestH\x00\x12/\n\x07to_i420\x18\x0f \x01(\x0b\x32\x1c.livekit.proto.ToI420RequestH\x00\x12/\n\x07to_argb\x18\x10 \x01(\x0b\x32\x1c.livekit.proto.ToArgbRequestH\x00\x12\x44\n\x12\x61lloc_audio_buffer\x18\x11 \x01(\x0b\x32&.livekit.proto.AllocAudioBufferRequestH\x00\x12@\n\x10new_audio_stream\x18\x12 \x01(\x0b\x32$.livekit.proto.NewAudioStreamRequestH\x00\x12@\n\x10new_audio_source\x18\x13 \x01(\x0b\x32$.livekit.proto.NewAudioSourceRequestH\x00\x12\x46\n\x13\x63\x61pture_audio_frame\x18\x14 \x01(\x0b\x32\'.livekit.proto.CaptureAudioFrameRequestH\x00\x12\x46\n\x13new_audio_resampler\x18\x15 \x01(\x0b\x32\'.livekit.proto.NewAudioResamplerRequestH\x00\x12\x44\n\x12remix_and_resample\x18\x16 \x01(\x0b\x32&.livekit.proto.RemixAndResampleRequestH\x00\x42\t\n\x07message\"\x9a\x0b\n\x0b\x46\x66iResponse\x12\x37\n\ninitialize\x18\x01 \x01(\x0b\x32!.livekit.proto.InitializeResponseH\x00\x12\x31\n\x07\x64ispose\x18\x02 \x01(\x0b\x32\x1e.livekit.proto.DisposeResponseH\x00\x12\x31\n\x07\x63onnect\x18\x03 \x01(\x0b\x32\x1e.livekit.proto.ConnectResponseH\x00\x12\x37\n\ndisconnect\x18\x04 \x01(\x0b\x32!.livekit.proto.DisconnectResponseH\x00\x12<\n\rpublish_track\x18\x05 \x01(\x0b\x32#.livekit.proto.PublishTrackResponseH\x00\x12@\n\x0funpublish_track\x18\x06 \x01(\x0b\x32%.livekit.proto.UnpublishTrackResponseH\x00\x12:\n\x0cpublish_data\x18\x07 \x01(\x0b\x32\".livekit.proto.PublishDataResponseH\x00\x12>\n\x0eset_subscribed\x18\x08 \x01(\x0b\x32$.livekit.proto.SetSubscribedResponseH\x00\x12\x45\n\x12\x63reate_video_track\x18\t \x01(\x0b\x32\'.livekit.proto.CreateVideoTrackResponseH\x00\x12\x45\n\x12\x63reate_audio_track\x18\n \x01(\x0b\x32\'.livekit.proto.CreateAudioTrackResponseH\x00\x12\x45\n\x12\x61lloc_video_buffer\x18\x0b \x01(\x0b\x32\'.livekit.proto.AllocVideoBufferResponseH\x00\x12\x41\n\x10new_video_stream\x18\x0c \x01(\x0b\x32%.livekit.proto.NewVideoStreamResponseH\x00\x12\x41\n\x10new_video_source\x18\r \x01(\x0b\x32%.livekit.proto.NewVideoSourceResponseH\x00\x12G\n\x13\x63\x61pture_video_frame\x18\x0e \x01(\x0b\x32(.livekit.proto.CaptureVideoFrameResponseH\x00\x12\x30\n\x07to_i420\x18\x0f \x01(\x0b\x32\x1d.livekit.proto.ToI420ResponseH\x00\x12\x30\n\x07to_argb\x18\x10 \x01(\x0b\x32\x1d.livekit.proto.ToArgbResponseH\x00\x12\x45\n\x12\x61lloc_audio_buffer\x18\x11 \x01(\x0b\x32\'.livekit.proto.AllocAudioBufferResponseH\x00\x12\x41\n\x10new_audio_stream\x18\x12 \x01(\x0b\x32%.livekit.proto.NewAudioStreamResponseH\x00\x12\x41\n\x10new_audio_source\x18\x13 \x01(\x0b\x32%.livekit.proto.NewAudioSourceResponseH\x00\x12G\n\x13\x63\x61pture_audio_frame\x18\x14 \x01(\x0b\x32(.livekit.proto.CaptureAudioFrameResponseH\x00\x12G\n\x13new_audio_resampler\x18\x15 \x01(\x0b\x32(.livekit.proto.NewAudioResamplerResponseH\x00\x12\x45\n\x12remix_and_resample\x18\x16 \x01(\x0b\x32\'.livekit.proto.RemixAndResampleResponseH\x00\x42\t\n\x07message\"\xd0\x04\n\x08\x46\x66iEvent\x12.\n\nroom_event\x18\x01 \x01(\x0b\x32\x18.livekit.proto.RoomEventH\x00\x12\x30\n\x0btrack_event\x18\x02 \x01(\x0b\x32\x19.livekit.proto.TrackEventH\x00\x12=\n\x12video_stream_event\x18\x03 \x01(\x0b\x32\x1f.livekit.proto.VideoStreamEventH\x00\x12=\n\x12\x61udio_stream_event\x18\x04 \x01(\x0b\x32\x1f.livekit.proto.AudioStreamEventH\x00\x12\x31\n\x07\x63onnect\x18\x05 \x01(\x0b\x32\x1e.livekit.proto.ConnectCallbackH\x00\x12\x37\n\ndisconnect\x18\x06 \x01(\x0b\x32!.livekit.proto.DisconnectCallbackH\x00\x12\x31\n\x07\x64ispose\x18\x07 \x01(\x0b\x32\x1e.livekit.proto.DisposeCallbackH\x00\x12<\n\rpublish_track\x18\x08 \x01(\x0b\x32#.livekit.proto.PublishTrackCallbackH\x00\x12@\n\x0funpublish_track\x18\t \x01(\x0b\x32%.livekit.proto.UnpublishTrackCallbackH\x00\x12:\n\x0cpublish_data\x18\n \x01(\x0b\x32\".livekit.proto.PublishDataCallbackH\x00\x42\t\n\x07message\"/\n\x11InitializeRequest\x12\x1a\n\x12\x65vent_callback_ptr\x18\x01 \x01(\x04\"\x14\n\x12InitializeResponse\"\x1f\n\x0e\x44isposeRequest\x12\r\n\x05\x61sync\x18\x01 \x01(\x08\"5\n\x0f\x44isposeResponse\x12\x15\n\x08\x61sync_id\x18\x01 \x01(\x04H\x00\x88\x01\x01\x42\x0b\n\t_async_id\"#\n\x0f\x44isposeCallback\x12\x10\n\x08\x61sync_id\x18\x01 \x01(\x04\x42\x10\xaa\x02\rLiveKit.Protob\x06proto3') -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'ffi_pb2', _globals) +_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals()) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'ffi_pb2', globals()) if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None DESCRIPTOR._serialized_options = b'\252\002\rLiveKit.Proto' - _globals['_FFIREQUEST']._serialized_start=92 - _globals['_FFIREQUEST']._serialized_end=1503 - _globals['_FFIRESPONSE']._serialized_start=1506 - _globals['_FFIRESPONSE']._serialized_end=2940 - _globals['_FFIEVENT']._serialized_start=2943 - _globals['_FFIEVENT']._serialized_end=3535 - _globals['_INITIALIZEREQUEST']._serialized_start=3537 - _globals['_INITIALIZEREQUEST']._serialized_end=3584 - _globals['_INITIALIZERESPONSE']._serialized_start=3586 - _globals['_INITIALIZERESPONSE']._serialized_end=3606 - _globals['_DISPOSEREQUEST']._serialized_start=3608 - _globals['_DISPOSEREQUEST']._serialized_end=3639 - _globals['_DISPOSERESPONSE']._serialized_start=3641 - _globals['_DISPOSERESPONSE']._serialized_end=3694 - _globals['_DISPOSECALLBACK']._serialized_start=3696 - _globals['_DISPOSECALLBACK']._serialized_end=3731 + _FFIREQUEST._serialized_start=92 + _FFIREQUEST._serialized_end=1503 + _FFIRESPONSE._serialized_start=1506 + _FFIRESPONSE._serialized_end=2940 + _FFIEVENT._serialized_start=2943 + _FFIEVENT._serialized_end=3535 + _INITIALIZEREQUEST._serialized_start=3537 + _INITIALIZEREQUEST._serialized_end=3584 + _INITIALIZERESPONSE._serialized_start=3586 + _INITIALIZERESPONSE._serialized_end=3606 + _DISPOSEREQUEST._serialized_start=3608 + _DISPOSEREQUEST._serialized_end=3639 + _DISPOSERESPONSE._serialized_start=3641 + _DISPOSERESPONSE._serialized_end=3694 + _DISPOSECALLBACK._serialized_start=3696 + _DISPOSECALLBACK._serialized_end=3731 # @@protoc_insertion_point(module_scope) diff --git a/livekit/_proto/handle_pb2.py b/livekit/_proto/handle_pb2.py index c6b9f84c..95db00e2 100644 --- a/livekit/_proto/handle_pb2.py +++ b/livekit/_proto/handle_pb2.py @@ -2,10 +2,10 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # source: handle.proto """Generated protocol buffer code.""" +from google.protobuf.internal import builder as _builder from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -15,13 +15,12 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0chandle.proto\x12\rlivekit.proto\"\x1c\n\x0e\x46\x66iOwnedHandle\x12\n\n\x02id\x18\x01 \x01(\x04\x42\x10\xaa\x02\rLiveKit.Protob\x06proto3') -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'handle_pb2', _globals) +_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals()) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'handle_pb2', globals()) if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None DESCRIPTOR._serialized_options = b'\252\002\rLiveKit.Proto' - _globals['_FFIOWNEDHANDLE']._serialized_start=31 - _globals['_FFIOWNEDHANDLE']._serialized_end=59 + _FFIOWNEDHANDLE._serialized_start=31 + _FFIOWNEDHANDLE._serialized_end=59 # @@protoc_insertion_point(module_scope) diff --git a/livekit/_proto/participant_pb2.py b/livekit/_proto/participant_pb2.py index 33b80dc9..7b80c580 100644 --- a/livekit/_proto/participant_pb2.py +++ b/livekit/_proto/participant_pb2.py @@ -2,10 +2,10 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # source: participant.proto """Generated protocol buffer code.""" +from google.protobuf.internal import builder as _builder from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -16,13 +16,12 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x11participant.proto\x12\rlivekit.proto\x1a\x0chandle.proto\"\x7f\n\x0fParticipantInfo\x12-\n\x06handle\x18\x01 \x01(\x0b\x32\x1d.livekit.proto.FfiOwnedHandle\x12\x0b\n\x03sid\x18\x02 \x01(\t\x12\x0c\n\x04name\x18\x03 \x01(\t\x12\x10\n\x08identity\x18\x04 \x01(\t\x12\x10\n\x08metadata\x18\x05 \x01(\tB\x10\xaa\x02\rLiveKit.Protob\x06proto3') -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'participant_pb2', _globals) +_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals()) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'participant_pb2', globals()) if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None DESCRIPTOR._serialized_options = b'\252\002\rLiveKit.Proto' - _globals['_PARTICIPANTINFO']._serialized_start=50 - _globals['_PARTICIPANTINFO']._serialized_end=177 + _PARTICIPANTINFO._serialized_start=50 + _PARTICIPANTINFO._serialized_end=177 # @@protoc_insertion_point(module_scope) diff --git a/livekit/_proto/room_pb2.py b/livekit/_proto/room_pb2.py index 6b4c86c4..01bfd6cf 100644 --- a/livekit/_proto/room_pb2.py +++ b/livekit/_proto/room_pb2.py @@ -2,10 +2,10 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # source: room.proto """Generated protocol buffer code.""" +from google.protobuf.internal import builder as _builder from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -19,105 +19,104 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\nroom.proto\x12\rlivekit.proto\x1a\x0chandle.proto\x1a\x11participant.proto\x1a\x0btrack.proto\x1a\x11video_frame.proto\"Y\n\x0e\x43onnectRequest\x12\x0b\n\x03url\x18\x01 \x01(\t\x12\r\n\x05token\x18\x02 \x01(\t\x12+\n\x07options\x18\x03 \x01(\x0b\x32\x1a.livekit.proto.RoomOptions\"#\n\x0f\x43onnectResponse\x12\x10\n\x08\x61sync_id\x18\x01 \x01(\x04\"\xf9\x02\n\x0f\x43onnectCallback\x12\x10\n\x08\x61sync_id\x18\x01 \x01(\x04\x12\x12\n\x05\x65rror\x18\x02 \x01(\tH\x00\x88\x01\x01\x12%\n\x04room\x18\x03 \x01(\x0b\x32\x17.livekit.proto.RoomInfo\x12\x39\n\x11local_participant\x18\x04 \x01(\x0b\x32\x1e.livekit.proto.ParticipantInfo\x12J\n\x0cparticipants\x18\x05 \x03(\x0b\x32\x34.livekit.proto.ConnectCallback.ParticipantWithTracks\x1a\x87\x01\n\x15ParticipantWithTracks\x12\x33\n\x0bparticipant\x18\x01 \x01(\x0b\x32\x1e.livekit.proto.ParticipantInfo\x12\x39\n\x0cpublications\x18\x02 \x03(\x0b\x32#.livekit.proto.TrackPublicationInfoB\x08\n\x06_error\"(\n\x11\x44isconnectRequest\x12\x13\n\x0broom_handle\x18\x01 \x01(\x04\"&\n\x12\x44isconnectResponse\x12\x10\n\x08\x61sync_id\x18\x01 \x01(\x04\"&\n\x12\x44isconnectCallback\x12\x10\n\x08\x61sync_id\x18\x01 \x01(\x04\"\x82\x01\n\x13PublishTrackRequest\x12 \n\x18local_participant_handle\x18\x01 \x01(\x04\x12\x14\n\x0ctrack_handle\x18\x02 \x01(\x04\x12\x33\n\x07options\x18\x03 \x01(\x0b\x32\".livekit.proto.TrackPublishOptions\"(\n\x14PublishTrackResponse\x12\x10\n\x08\x61sync_id\x18\x01 \x01(\x04\"\x80\x01\n\x14PublishTrackCallback\x12\x10\n\x08\x61sync_id\x18\x01 \x01(\x04\x12\x12\n\x05\x65rror\x18\x02 \x01(\tH\x00\x88\x01\x01\x12\x38\n\x0bpublication\x18\x03 \x01(\x0b\x32#.livekit.proto.TrackPublicationInfoB\x08\n\x06_error\"g\n\x15UnpublishTrackRequest\x12 \n\x18local_participant_handle\x18\x01 \x01(\x04\x12\x11\n\ttrack_sid\x18\x02 \x01(\t\x12\x19\n\x11stop_on_unpublish\x18\x03 \x01(\x08\"*\n\x16UnpublishTrackResponse\x12\x10\n\x08\x61sync_id\x18\x01 \x01(\x04\"H\n\x16UnpublishTrackCallback\x12\x10\n\x08\x61sync_id\x18\x01 \x01(\x04\x12\x12\n\x05\x65rror\x18\x02 \x01(\tH\x00\x88\x01\x01\x42\x08\n\x06_error\"\xa1\x01\n\x12PublishDataRequest\x12 \n\x18local_participant_handle\x18\x01 \x01(\x04\x12\x10\n\x08\x64\x61ta_ptr\x18\x02 \x01(\x04\x12\x10\n\x08\x64\x61ta_len\x18\x03 \x01(\x04\x12+\n\x04kind\x18\x04 \x01(\x0e\x32\x1d.livekit.proto.DataPacketKind\x12\x18\n\x10\x64\x65stination_sids\x18\x05 \x03(\t\"\'\n\x13PublishDataResponse\x12\x10\n\x08\x61sync_id\x18\x01 \x01(\x04\"E\n\x13PublishDataCallback\x12\x10\n\x08\x61sync_id\x18\x01 \x01(\x04\x12\x12\n\x05\x65rror\x18\x02 \x01(\tH\x00\x88\x01\x01\x42\x08\n\x06_error\"E\n\x14SetSubscribedRequest\x12\x11\n\tsubscribe\x18\x01 \x01(\x08\x12\x1a\n\x12publication_handle\x18\x02 \x01(\x04\"\x17\n\x15SetSubscribedResponse\";\n\rVideoEncoding\x12\x13\n\x0bmax_bitrate\x18\x01 \x01(\x04\x12\x15\n\rmax_framerate\x18\x02 \x01(\x01\"$\n\rAudioEncoding\x12\x13\n\x0bmax_bitrate\x18\x01 \x01(\x04\"\x8a\x02\n\x13TrackPublishOptions\x12\x34\n\x0evideo_encoding\x18\x01 \x01(\x0b\x32\x1c.livekit.proto.VideoEncoding\x12\x34\n\x0e\x61udio_encoding\x18\x02 \x01(\x0b\x32\x1c.livekit.proto.AudioEncoding\x12.\n\x0bvideo_codec\x18\x03 \x01(\x0e\x32\x19.livekit.proto.VideoCodec\x12\x0b\n\x03\x64tx\x18\x04 \x01(\x08\x12\x0b\n\x03red\x18\x05 \x01(\x08\x12\x11\n\tsimulcast\x18\x06 \x01(\x08\x12*\n\x06source\x18\x07 \x01(\x0e\x32\x1a.livekit.proto.TrackSource\"P\n\x0bRoomOptions\x12\x16\n\x0e\x61uto_subscribe\x18\x01 \x01(\x08\x12\x17\n\x0f\x61\x64\x61ptive_stream\x18\x02 \x01(\x08\x12\x10\n\x08\x64ynacast\x18\x03 \x01(\x08\"_\n\nBufferInfo\x12-\n\x06handle\x18\x01 \x01(\x0b\x32\x1d.livekit.proto.FfiOwnedHandle\x12\x10\n\x08\x64\x61ta_ptr\x18\x02 \x01(\x04\x12\x10\n\x08\x64\x61ta_len\x18\x03 \x01(\x04\"\xd9\t\n\tRoomEvent\x12\x13\n\x0broom_handle\x18\x01 \x01(\x04\x12\x44\n\x15participant_connected\x18\x02 \x01(\x0b\x32#.livekit.proto.ParticipantConnectedH\x00\x12J\n\x18participant_disconnected\x18\x03 \x01(\x0b\x32&.livekit.proto.ParticipantDisconnectedH\x00\x12\x43\n\x15local_track_published\x18\x04 \x01(\x0b\x32\".livekit.proto.LocalTrackPublishedH\x00\x12G\n\x17local_track_unpublished\x18\x05 \x01(\x0b\x32$.livekit.proto.LocalTrackUnpublishedH\x00\x12\x38\n\x0ftrack_published\x18\x06 \x01(\x0b\x32\x1d.livekit.proto.TrackPublishedH\x00\x12<\n\x11track_unpublished\x18\x07 \x01(\x0b\x32\x1f.livekit.proto.TrackUnpublishedH\x00\x12:\n\x10track_subscribed\x18\x08 \x01(\x0b\x32\x1e.livekit.proto.TrackSubscribedH\x00\x12>\n\x12track_unsubscribed\x18\t \x01(\x0b\x32 .livekit.proto.TrackUnsubscribedH\x00\x12K\n\x19track_subscription_failed\x18\n \x01(\x0b\x32&.livekit.proto.TrackSubscriptionFailedH\x00\x12\x30\n\x0btrack_muted\x18\x0b \x01(\x0b\x32\x19.livekit.proto.TrackMutedH\x00\x12\x34\n\rtrack_unmuted\x18\x0c \x01(\x0b\x32\x1b.livekit.proto.TrackUnmutedH\x00\x12G\n\x17\x61\x63tive_speakers_changed\x18\r \x01(\x0b\x32$.livekit.proto.ActiveSpeakersChangedH\x00\x12M\n\x1a\x63onnection_quality_changed\x18\x0e \x01(\x0b\x32\'.livekit.proto.ConnectionQualityChangedH\x00\x12\x34\n\rdata_received\x18\x0f \x01(\x0b\x32\x1b.livekit.proto.DataReceivedH\x00\x12I\n\x18\x63onnection_state_changed\x18\x10 \x01(\x0b\x32%.livekit.proto.ConnectionStateChangedH\x00\x12-\n\tconnected\x18\x11 \x01(\x0b\x32\x18.livekit.proto.ConnectedH\x00\x12\x33\n\x0c\x64isconnected\x18\x12 \x01(\x0b\x32\x1b.livekit.proto.DisconnectedH\x00\x12\x33\n\x0creconnecting\x18\x13 \x01(\x0b\x32\x1b.livekit.proto.ReconnectingH\x00\x12\x31\n\x0breconnected\x18\x14 \x01(\x0b\x32\x1a.livekit.proto.ReconnectedH\x00\x42\t\n\x07message\"f\n\x08RoomInfo\x12-\n\x06handle\x18\x01 \x01(\x0b\x32\x1d.livekit.proto.FfiOwnedHandle\x12\x0b\n\x03sid\x18\x02 \x01(\t\x12\x0c\n\x04name\x18\x03 \x01(\t\x12\x10\n\x08metadata\x18\x04 \x01(\t\"D\n\x14ParticipantConnected\x12,\n\x04info\x18\x01 \x01(\x0b\x32\x1e.livekit.proto.ParticipantInfo\"2\n\x17ParticipantDisconnected\x12\x17\n\x0fparticipant_sid\x18\x01 \x01(\t\"(\n\x13LocalTrackPublished\x12\x11\n\ttrack_sid\x18\x01 \x01(\t\"0\n\x15LocalTrackUnpublished\x12\x17\n\x0fpublication_sid\x18\x01 \x01(\t\"c\n\x0eTrackPublished\x12\x17\n\x0fparticipant_sid\x18\x01 \x01(\t\x12\x38\n\x0bpublication\x18\x02 \x01(\x0b\x32#.livekit.proto.TrackPublicationInfo\"D\n\x10TrackUnpublished\x12\x17\n\x0fparticipant_sid\x18\x01 \x01(\t\x12\x17\n\x0fpublication_sid\x18\x02 \x01(\t\"S\n\x0fTrackSubscribed\x12\x17\n\x0fparticipant_sid\x18\x01 \x01(\t\x12\'\n\x05track\x18\x02 \x01(\x0b\x32\x18.livekit.proto.TrackInfo\"?\n\x11TrackUnsubscribed\x12\x17\n\x0fparticipant_sid\x18\x01 \x01(\t\x12\x11\n\ttrack_sid\x18\x02 \x01(\t\"T\n\x17TrackSubscriptionFailed\x12\x17\n\x0fparticipant_sid\x18\x01 \x01(\t\x12\x11\n\ttrack_sid\x18\x02 \x01(\t\x12\r\n\x05\x65rror\x18\x03 \x01(\t\"8\n\nTrackMuted\x12\x17\n\x0fparticipant_sid\x18\x01 \x01(\t\x12\x11\n\ttrack_sid\x18\x02 \x01(\t\":\n\x0cTrackUnmuted\x12\x17\n\x0fparticipant_sid\x18\x01 \x01(\t\x12\x11\n\ttrack_sid\x18\x02 \x01(\t\"1\n\x15\x41\x63tiveSpeakersChanged\x12\x18\n\x10participant_sids\x18\x01 \x03(\t\"f\n\x18\x43onnectionQualityChanged\x12\x17\n\x0fparticipant_sid\x18\x01 \x01(\t\x12\x31\n\x07quality\x18\x02 \x01(\x0e\x32 .livekit.proto.ConnectionQuality\"\x96\x01\n\x0c\x44\x61taReceived\x12\'\n\x04\x64\x61ta\x18\x01 \x01(\x0b\x32\x19.livekit.proto.BufferInfo\x12\x1c\n\x0fparticipant_sid\x18\x02 \x01(\tH\x00\x88\x01\x01\x12+\n\x04kind\x18\x03 \x01(\x0e\x32\x1d.livekit.proto.DataPacketKindB\x12\n\x10_participant_sid\"G\n\x16\x43onnectionStateChanged\x12-\n\x05state\x18\x01 \x01(\x0e\x32\x1e.livekit.proto.ConnectionState\"\x0b\n\tConnected\"\x0e\n\x0c\x44isconnected\"\x0e\n\x0cReconnecting\"\r\n\x0bReconnected*N\n\x11\x43onnectionQuality\x12\x10\n\x0cQUALITY_POOR\x10\x00\x12\x10\n\x0cQUALITY_GOOD\x10\x01\x12\x15\n\x11QUALITY_EXCELLENT\x10\x02*S\n\x0f\x43onnectionState\x12\x15\n\x11\x43ONN_DISCONNECTED\x10\x00\x12\x12\n\x0e\x43ONN_CONNECTED\x10\x01\x12\x15\n\x11\x43ONN_RECONNECTING\x10\x02*3\n\x0e\x44\x61taPacketKind\x12\x0e\n\nKIND_LOSSY\x10\x00\x12\x11\n\rKIND_RELIABLE\x10\x01\x42\x10\xaa\x02\rLiveKit.Protob\x06proto3') -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'room_pb2', _globals) +_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals()) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'room_pb2', globals()) if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None DESCRIPTOR._serialized_options = b'\252\002\rLiveKit.Proto' - _globals['_CONNECTIONQUALITY']._serialized_start=4700 - _globals['_CONNECTIONQUALITY']._serialized_end=4778 - _globals['_CONNECTIONSTATE']._serialized_start=4780 - _globals['_CONNECTIONSTATE']._serialized_end=4863 - _globals['_DATAPACKETKIND']._serialized_start=4865 - _globals['_DATAPACKETKIND']._serialized_end=4916 - _globals['_CONNECTREQUEST']._serialized_start=94 - _globals['_CONNECTREQUEST']._serialized_end=183 - _globals['_CONNECTRESPONSE']._serialized_start=185 - _globals['_CONNECTRESPONSE']._serialized_end=220 - _globals['_CONNECTCALLBACK']._serialized_start=223 - _globals['_CONNECTCALLBACK']._serialized_end=600 - _globals['_CONNECTCALLBACK_PARTICIPANTWITHTRACKS']._serialized_start=455 - _globals['_CONNECTCALLBACK_PARTICIPANTWITHTRACKS']._serialized_end=590 - _globals['_DISCONNECTREQUEST']._serialized_start=602 - _globals['_DISCONNECTREQUEST']._serialized_end=642 - _globals['_DISCONNECTRESPONSE']._serialized_start=644 - _globals['_DISCONNECTRESPONSE']._serialized_end=682 - _globals['_DISCONNECTCALLBACK']._serialized_start=684 - _globals['_DISCONNECTCALLBACK']._serialized_end=722 - _globals['_PUBLISHTRACKREQUEST']._serialized_start=725 - _globals['_PUBLISHTRACKREQUEST']._serialized_end=855 - _globals['_PUBLISHTRACKRESPONSE']._serialized_start=857 - _globals['_PUBLISHTRACKRESPONSE']._serialized_end=897 - _globals['_PUBLISHTRACKCALLBACK']._serialized_start=900 - _globals['_PUBLISHTRACKCALLBACK']._serialized_end=1028 - _globals['_UNPUBLISHTRACKREQUEST']._serialized_start=1030 - _globals['_UNPUBLISHTRACKREQUEST']._serialized_end=1133 - _globals['_UNPUBLISHTRACKRESPONSE']._serialized_start=1135 - _globals['_UNPUBLISHTRACKRESPONSE']._serialized_end=1177 - _globals['_UNPUBLISHTRACKCALLBACK']._serialized_start=1179 - _globals['_UNPUBLISHTRACKCALLBACK']._serialized_end=1251 - _globals['_PUBLISHDATAREQUEST']._serialized_start=1254 - _globals['_PUBLISHDATAREQUEST']._serialized_end=1415 - _globals['_PUBLISHDATARESPONSE']._serialized_start=1417 - _globals['_PUBLISHDATARESPONSE']._serialized_end=1456 - _globals['_PUBLISHDATACALLBACK']._serialized_start=1458 - _globals['_PUBLISHDATACALLBACK']._serialized_end=1527 - _globals['_SETSUBSCRIBEDREQUEST']._serialized_start=1529 - _globals['_SETSUBSCRIBEDREQUEST']._serialized_end=1598 - _globals['_SETSUBSCRIBEDRESPONSE']._serialized_start=1600 - _globals['_SETSUBSCRIBEDRESPONSE']._serialized_end=1623 - _globals['_VIDEOENCODING']._serialized_start=1625 - _globals['_VIDEOENCODING']._serialized_end=1684 - _globals['_AUDIOENCODING']._serialized_start=1686 - _globals['_AUDIOENCODING']._serialized_end=1722 - _globals['_TRACKPUBLISHOPTIONS']._serialized_start=1725 - _globals['_TRACKPUBLISHOPTIONS']._serialized_end=1991 - _globals['_ROOMOPTIONS']._serialized_start=1993 - _globals['_ROOMOPTIONS']._serialized_end=2073 - _globals['_BUFFERINFO']._serialized_start=2075 - _globals['_BUFFERINFO']._serialized_end=2170 - _globals['_ROOMEVENT']._serialized_start=2173 - _globals['_ROOMEVENT']._serialized_end=3414 - _globals['_ROOMINFO']._serialized_start=3416 - _globals['_ROOMINFO']._serialized_end=3518 - _globals['_PARTICIPANTCONNECTED']._serialized_start=3520 - _globals['_PARTICIPANTCONNECTED']._serialized_end=3588 - _globals['_PARTICIPANTDISCONNECTED']._serialized_start=3590 - _globals['_PARTICIPANTDISCONNECTED']._serialized_end=3640 - _globals['_LOCALTRACKPUBLISHED']._serialized_start=3642 - _globals['_LOCALTRACKPUBLISHED']._serialized_end=3682 - _globals['_LOCALTRACKUNPUBLISHED']._serialized_start=3684 - _globals['_LOCALTRACKUNPUBLISHED']._serialized_end=3732 - _globals['_TRACKPUBLISHED']._serialized_start=3734 - _globals['_TRACKPUBLISHED']._serialized_end=3833 - _globals['_TRACKUNPUBLISHED']._serialized_start=3835 - _globals['_TRACKUNPUBLISHED']._serialized_end=3903 - _globals['_TRACKSUBSCRIBED']._serialized_start=3905 - _globals['_TRACKSUBSCRIBED']._serialized_end=3988 - _globals['_TRACKUNSUBSCRIBED']._serialized_start=3990 - _globals['_TRACKUNSUBSCRIBED']._serialized_end=4053 - _globals['_TRACKSUBSCRIPTIONFAILED']._serialized_start=4055 - _globals['_TRACKSUBSCRIPTIONFAILED']._serialized_end=4139 - _globals['_TRACKMUTED']._serialized_start=4141 - _globals['_TRACKMUTED']._serialized_end=4197 - _globals['_TRACKUNMUTED']._serialized_start=4199 - _globals['_TRACKUNMUTED']._serialized_end=4257 - _globals['_ACTIVESPEAKERSCHANGED']._serialized_start=4259 - _globals['_ACTIVESPEAKERSCHANGED']._serialized_end=4308 - _globals['_CONNECTIONQUALITYCHANGED']._serialized_start=4310 - _globals['_CONNECTIONQUALITYCHANGED']._serialized_end=4412 - _globals['_DATARECEIVED']._serialized_start=4415 - _globals['_DATARECEIVED']._serialized_end=4565 - _globals['_CONNECTIONSTATECHANGED']._serialized_start=4567 - _globals['_CONNECTIONSTATECHANGED']._serialized_end=4638 - _globals['_CONNECTED']._serialized_start=4640 - _globals['_CONNECTED']._serialized_end=4651 - _globals['_DISCONNECTED']._serialized_start=4653 - _globals['_DISCONNECTED']._serialized_end=4667 - _globals['_RECONNECTING']._serialized_start=4669 - _globals['_RECONNECTING']._serialized_end=4683 - _globals['_RECONNECTED']._serialized_start=4685 - _globals['_RECONNECTED']._serialized_end=4698 + _CONNECTIONQUALITY._serialized_start=4700 + _CONNECTIONQUALITY._serialized_end=4778 + _CONNECTIONSTATE._serialized_start=4780 + _CONNECTIONSTATE._serialized_end=4863 + _DATAPACKETKIND._serialized_start=4865 + _DATAPACKETKIND._serialized_end=4916 + _CONNECTREQUEST._serialized_start=94 + _CONNECTREQUEST._serialized_end=183 + _CONNECTRESPONSE._serialized_start=185 + _CONNECTRESPONSE._serialized_end=220 + _CONNECTCALLBACK._serialized_start=223 + _CONNECTCALLBACK._serialized_end=600 + _CONNECTCALLBACK_PARTICIPANTWITHTRACKS._serialized_start=455 + _CONNECTCALLBACK_PARTICIPANTWITHTRACKS._serialized_end=590 + _DISCONNECTREQUEST._serialized_start=602 + _DISCONNECTREQUEST._serialized_end=642 + _DISCONNECTRESPONSE._serialized_start=644 + _DISCONNECTRESPONSE._serialized_end=682 + _DISCONNECTCALLBACK._serialized_start=684 + _DISCONNECTCALLBACK._serialized_end=722 + _PUBLISHTRACKREQUEST._serialized_start=725 + _PUBLISHTRACKREQUEST._serialized_end=855 + _PUBLISHTRACKRESPONSE._serialized_start=857 + _PUBLISHTRACKRESPONSE._serialized_end=897 + _PUBLISHTRACKCALLBACK._serialized_start=900 + _PUBLISHTRACKCALLBACK._serialized_end=1028 + _UNPUBLISHTRACKREQUEST._serialized_start=1030 + _UNPUBLISHTRACKREQUEST._serialized_end=1133 + _UNPUBLISHTRACKRESPONSE._serialized_start=1135 + _UNPUBLISHTRACKRESPONSE._serialized_end=1177 + _UNPUBLISHTRACKCALLBACK._serialized_start=1179 + _UNPUBLISHTRACKCALLBACK._serialized_end=1251 + _PUBLISHDATAREQUEST._serialized_start=1254 + _PUBLISHDATAREQUEST._serialized_end=1415 + _PUBLISHDATARESPONSE._serialized_start=1417 + _PUBLISHDATARESPONSE._serialized_end=1456 + _PUBLISHDATACALLBACK._serialized_start=1458 + _PUBLISHDATACALLBACK._serialized_end=1527 + _SETSUBSCRIBEDREQUEST._serialized_start=1529 + _SETSUBSCRIBEDREQUEST._serialized_end=1598 + _SETSUBSCRIBEDRESPONSE._serialized_start=1600 + _SETSUBSCRIBEDRESPONSE._serialized_end=1623 + _VIDEOENCODING._serialized_start=1625 + _VIDEOENCODING._serialized_end=1684 + _AUDIOENCODING._serialized_start=1686 + _AUDIOENCODING._serialized_end=1722 + _TRACKPUBLISHOPTIONS._serialized_start=1725 + _TRACKPUBLISHOPTIONS._serialized_end=1991 + _ROOMOPTIONS._serialized_start=1993 + _ROOMOPTIONS._serialized_end=2073 + _BUFFERINFO._serialized_start=2075 + _BUFFERINFO._serialized_end=2170 + _ROOMEVENT._serialized_start=2173 + _ROOMEVENT._serialized_end=3414 + _ROOMINFO._serialized_start=3416 + _ROOMINFO._serialized_end=3518 + _PARTICIPANTCONNECTED._serialized_start=3520 + _PARTICIPANTCONNECTED._serialized_end=3588 + _PARTICIPANTDISCONNECTED._serialized_start=3590 + _PARTICIPANTDISCONNECTED._serialized_end=3640 + _LOCALTRACKPUBLISHED._serialized_start=3642 + _LOCALTRACKPUBLISHED._serialized_end=3682 + _LOCALTRACKUNPUBLISHED._serialized_start=3684 + _LOCALTRACKUNPUBLISHED._serialized_end=3732 + _TRACKPUBLISHED._serialized_start=3734 + _TRACKPUBLISHED._serialized_end=3833 + _TRACKUNPUBLISHED._serialized_start=3835 + _TRACKUNPUBLISHED._serialized_end=3903 + _TRACKSUBSCRIBED._serialized_start=3905 + _TRACKSUBSCRIBED._serialized_end=3988 + _TRACKUNSUBSCRIBED._serialized_start=3990 + _TRACKUNSUBSCRIBED._serialized_end=4053 + _TRACKSUBSCRIPTIONFAILED._serialized_start=4055 + _TRACKSUBSCRIPTIONFAILED._serialized_end=4139 + _TRACKMUTED._serialized_start=4141 + _TRACKMUTED._serialized_end=4197 + _TRACKUNMUTED._serialized_start=4199 + _TRACKUNMUTED._serialized_end=4257 + _ACTIVESPEAKERSCHANGED._serialized_start=4259 + _ACTIVESPEAKERSCHANGED._serialized_end=4308 + _CONNECTIONQUALITYCHANGED._serialized_start=4310 + _CONNECTIONQUALITYCHANGED._serialized_end=4412 + _DATARECEIVED._serialized_start=4415 + _DATARECEIVED._serialized_end=4565 + _CONNECTIONSTATECHANGED._serialized_start=4567 + _CONNECTIONSTATECHANGED._serialized_end=4638 + _CONNECTED._serialized_start=4640 + _CONNECTED._serialized_end=4651 + _DISCONNECTED._serialized_start=4653 + _DISCONNECTED._serialized_end=4667 + _RECONNECTING._serialized_start=4669 + _RECONNECTING._serialized_end=4683 + _RECONNECTED._serialized_start=4685 + _RECONNECTED._serialized_end=4698 # @@protoc_insertion_point(module_scope) diff --git a/livekit/_proto/track_pb2.py b/livekit/_proto/track_pb2.py index 6191a4bd..37936d10 100644 --- a/livekit/_proto/track_pb2.py +++ b/livekit/_proto/track_pb2.py @@ -2,10 +2,10 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # source: track.proto """Generated protocol buffer code.""" +from google.protobuf.internal import builder as _builder from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -16,31 +16,30 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0btrack.proto\x12\rlivekit.proto\x1a\x0chandle.proto\">\n\x17\x43reateVideoTrackRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x15\n\rsource_handle\x18\x02 \x01(\x04\"C\n\x18\x43reateVideoTrackResponse\x12\'\n\x05track\x18\x01 \x01(\x0b\x32\x18.livekit.proto.TrackInfo\">\n\x17\x43reateAudioTrackRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x15\n\rsource_handle\x18\x02 \x01(\x04\"C\n\x18\x43reateAudioTrackResponse\x12\'\n\x05track\x18\x01 \x01(\x0b\x32\x18.livekit.proto.TrackInfo\"\x0c\n\nTrackEvent\"\x9a\x02\n\x14TrackPublicationInfo\x12-\n\x06handle\x18\x01 \x01(\x0b\x32\x1d.livekit.proto.FfiOwnedHandle\x12\x0b\n\x03sid\x18\x02 \x01(\t\x12\x0c\n\x04name\x18\x03 \x01(\t\x12&\n\x04kind\x18\x04 \x01(\x0e\x32\x18.livekit.proto.TrackKind\x12*\n\x06source\x18\x05 \x01(\x0e\x32\x1a.livekit.proto.TrackSource\x12\x13\n\x0bsimulcasted\x18\x06 \x01(\x08\x12\r\n\x05width\x18\x07 \x01(\r\x12\x0e\n\x06height\x18\x08 \x01(\r\x12\x11\n\tmime_type\x18\t \x01(\t\x12\r\n\x05muted\x18\n \x01(\x08\x12\x0e\n\x06remote\x18\x0b \x01(\x08\"\xce\x01\n\tTrackInfo\x12-\n\x06handle\x18\x01 \x01(\x0b\x32\x1d.livekit.proto.FfiOwnedHandle\x12\x0b\n\x03sid\x18\x02 \x01(\t\x12\x0c\n\x04name\x18\x03 \x01(\t\x12&\n\x04kind\x18\x04 \x01(\x0e\x32\x18.livekit.proto.TrackKind\x12\x30\n\x0cstream_state\x18\x05 \x01(\x0e\x32\x1a.livekit.proto.StreamState\x12\r\n\x05muted\x18\x06 \x01(\x08\x12\x0e\n\x06remote\x18\x07 \x01(\x08*=\n\tTrackKind\x12\x10\n\x0cKIND_UNKNOWN\x10\x00\x12\x0e\n\nKIND_AUDIO\x10\x01\x12\x0e\n\nKIND_VIDEO\x10\x02*\x81\x01\n\x0bTrackSource\x12\x12\n\x0eSOURCE_UNKNOWN\x10\x00\x12\x11\n\rSOURCE_CAMERA\x10\x01\x12\x15\n\x11SOURCE_MICROPHONE\x10\x02\x12\x16\n\x12SOURCE_SCREENSHARE\x10\x03\x12\x1c\n\x18SOURCE_SCREENSHARE_AUDIO\x10\x04*D\n\x0bStreamState\x12\x11\n\rSTATE_UNKNOWN\x10\x00\x12\x10\n\x0cSTATE_ACTIVE\x10\x01\x12\x10\n\x0cSTATE_PAUSED\x10\x02\x42\x10\xaa\x02\rLiveKit.Protob\x06proto3') -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'track_pb2', _globals) +_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals()) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'track_pb2', globals()) if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None DESCRIPTOR._serialized_options = b'\252\002\rLiveKit.Proto' - _globals['_TRACKKIND']._serialized_start=818 - _globals['_TRACKKIND']._serialized_end=879 - _globals['_TRACKSOURCE']._serialized_start=882 - _globals['_TRACKSOURCE']._serialized_end=1011 - _globals['_STREAMSTATE']._serialized_start=1013 - _globals['_STREAMSTATE']._serialized_end=1081 - _globals['_CREATEVIDEOTRACKREQUEST']._serialized_start=44 - _globals['_CREATEVIDEOTRACKREQUEST']._serialized_end=106 - _globals['_CREATEVIDEOTRACKRESPONSE']._serialized_start=108 - _globals['_CREATEVIDEOTRACKRESPONSE']._serialized_end=175 - _globals['_CREATEAUDIOTRACKREQUEST']._serialized_start=177 - _globals['_CREATEAUDIOTRACKREQUEST']._serialized_end=239 - _globals['_CREATEAUDIOTRACKRESPONSE']._serialized_start=241 - _globals['_CREATEAUDIOTRACKRESPONSE']._serialized_end=308 - _globals['_TRACKEVENT']._serialized_start=310 - _globals['_TRACKEVENT']._serialized_end=322 - _globals['_TRACKPUBLICATIONINFO']._serialized_start=325 - _globals['_TRACKPUBLICATIONINFO']._serialized_end=607 - _globals['_TRACKINFO']._serialized_start=610 - _globals['_TRACKINFO']._serialized_end=816 + _TRACKKIND._serialized_start=818 + _TRACKKIND._serialized_end=879 + _TRACKSOURCE._serialized_start=882 + _TRACKSOURCE._serialized_end=1011 + _STREAMSTATE._serialized_start=1013 + _STREAMSTATE._serialized_end=1081 + _CREATEVIDEOTRACKREQUEST._serialized_start=44 + _CREATEVIDEOTRACKREQUEST._serialized_end=106 + _CREATEVIDEOTRACKRESPONSE._serialized_start=108 + _CREATEVIDEOTRACKRESPONSE._serialized_end=175 + _CREATEAUDIOTRACKREQUEST._serialized_start=177 + _CREATEAUDIOTRACKREQUEST._serialized_end=239 + _CREATEAUDIOTRACKRESPONSE._serialized_start=241 + _CREATEAUDIOTRACKRESPONSE._serialized_end=308 + _TRACKEVENT._serialized_start=310 + _TRACKEVENT._serialized_end=322 + _TRACKPUBLICATIONINFO._serialized_start=325 + _TRACKPUBLICATIONINFO._serialized_end=607 + _TRACKINFO._serialized_start=610 + _TRACKINFO._serialized_end=816 # @@protoc_insertion_point(module_scope) diff --git a/livekit/_proto/video_frame_pb2.py b/livekit/_proto/video_frame_pb2.py index d7cf5401..95393295 100644 --- a/livekit/_proto/video_frame_pb2.py +++ b/livekit/_proto/video_frame_pb2.py @@ -2,10 +2,10 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! # source: video_frame.proto """Generated protocol buffer code.""" +from google.protobuf.internal import builder as _builder from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -16,71 +16,70 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x11video_frame.proto\x12\rlivekit.proto\x1a\x0chandle.proto\"k\n\x17\x41llocVideoBufferRequest\x12\x31\n\x04type\x18\x01 \x01(\x0e\x32#.livekit.proto.VideoFrameBufferType\x12\r\n\x05width\x18\x02 \x01(\r\x12\x0e\n\x06height\x18\x03 \x01(\r\"O\n\x18\x41llocVideoBufferResponse\x12\x33\n\x06\x62uffer\x18\x01 \x01(\x0b\x32#.livekit.proto.VideoFrameBufferInfo\"[\n\x15NewVideoStreamRequest\x12\x14\n\x0ctrack_handle\x18\x01 \x01(\x04\x12,\n\x04type\x18\x02 \x01(\x0e\x32\x1e.livekit.proto.VideoStreamType\"H\n\x16NewVideoStreamResponse\x12.\n\x06stream\x18\x01 \x01(\x0b\x32\x1e.livekit.proto.VideoStreamInfo\"\x93\x01\n\x15NewVideoSourceRequest\x12,\n\x04type\x18\x01 \x01(\x0e\x32\x1e.livekit.proto.VideoSourceType\x12=\n\nresolution\x18\x02 \x01(\x0b\x32$.livekit.proto.VideoSourceResolutionH\x00\x88\x01\x01\x42\r\n\x0b_resolution\"H\n\x16NewVideoSourceResponse\x12.\n\x06source\x18\x01 \x01(\x0b\x32\x1e.livekit.proto.VideoSourceInfo\"v\n\x18\x43\x61ptureVideoFrameRequest\x12\x15\n\rsource_handle\x18\x01 \x01(\x04\x12,\n\x05\x66rame\x18\x02 \x01(\x0b\x32\x1d.livekit.proto.VideoFrameInfo\x12\x15\n\rbuffer_handle\x18\x03 \x01(\x04\"\x1b\n\x19\x43\x61ptureVideoFrameResponse\"o\n\rToI420Request\x12\x0e\n\x06\x66lip_y\x18\x01 \x01(\x08\x12-\n\x04\x61rgb\x18\x02 \x01(\x0b\x32\x1d.livekit.proto.ARGBBufferInfoH\x00\x12\x17\n\rbuffer_handle\x18\x03 \x01(\x04H\x00\x42\x06\n\x04\x66rom\"E\n\x0eToI420Response\x12\x33\n\x06\x62uffer\x18\x01 \x01(\x0b\x32#.livekit.proto.VideoFrameBufferInfo\"\xb6\x01\n\rToArgbRequest\x12\x15\n\rbuffer_handle\x18\x01 \x01(\x04\x12\x0f\n\x07\x64st_ptr\x18\x02 \x01(\x04\x12\x32\n\ndst_format\x18\x03 \x01(\x0e\x32\x1e.livekit.proto.VideoFormatType\x12\x12\n\ndst_stride\x18\x04 \x01(\r\x12\x11\n\tdst_width\x18\x05 \x01(\r\x12\x12\n\ndst_height\x18\x06 \x01(\r\x12\x0e\n\x06\x66lip_y\x18\x07 \x01(\x08\"\x10\n\x0eToArgbResponse\"D\n\x0fVideoResolution\x12\r\n\x05width\x18\x01 \x01(\r\x12\x0e\n\x06height\x18\x02 \x01(\r\x12\x12\n\nframe_rate\x18\x03 \x01(\x01\"|\n\x0e\x41RGBBufferInfo\x12\x0b\n\x03ptr\x18\x01 \x01(\x04\x12.\n\x06\x66ormat\x18\x02 \x01(\x0e\x32\x1e.livekit.proto.VideoFormatType\x12\x0e\n\x06stride\x18\x03 \x01(\r\x12\r\n\x05width\x18\x04 \x01(\r\x12\x0e\n\x06height\x18\x05 \x01(\r\"V\n\x0eVideoFrameInfo\x12\x14\n\x0ctimestamp_us\x18\x01 \x01(\x03\x12.\n\x08rotation\x18\x02 \x01(\x0e\x32\x1c.livekit.proto.VideoRotation\"\xc6\x02\n\x14VideoFrameBufferInfo\x12-\n\x06handle\x18\x01 \x01(\x0b\x32\x1d.livekit.proto.FfiOwnedHandle\x12\x38\n\x0b\x62uffer_type\x18\x02 \x01(\x0e\x32#.livekit.proto.VideoFrameBufferType\x12\r\n\x05width\x18\x03 \x01(\r\x12\x0e\n\x06height\x18\x04 \x01(\r\x12\x31\n\x03yuv\x18\x05 \x01(\x0b\x32\".livekit.proto.PlanarYuvBufferInfoH\x00\x12\x36\n\x06\x62i_yuv\x18\x06 \x01(\x0b\x32$.livekit.proto.BiplanarYuvBufferInfoH\x00\x12\x31\n\x06native\x18\x07 \x01(\x0b\x32\x1f.livekit.proto.NativeBufferInfoH\x00\x42\x08\n\x06\x62uffer\"\xda\x01\n\x13PlanarYuvBufferInfo\x12\x14\n\x0c\x63hroma_width\x18\x01 \x01(\r\x12\x15\n\rchroma_height\x18\x02 \x01(\r\x12\x10\n\x08stride_y\x18\x03 \x01(\r\x12\x10\n\x08stride_u\x18\x04 \x01(\r\x12\x10\n\x08stride_v\x18\x05 \x01(\r\x12\x10\n\x08stride_a\x18\x06 \x01(\r\x12\x12\n\ndata_y_ptr\x18\x07 \x01(\x04\x12\x12\n\ndata_u_ptr\x18\x08 \x01(\x04\x12\x12\n\ndata_v_ptr\x18\t \x01(\x04\x12\x12\n\ndata_a_ptr\x18\n \x01(\x04\"\x92\x01\n\x15\x42iplanarYuvBufferInfo\x12\x14\n\x0c\x63hroma_width\x18\x01 \x01(\r\x12\x15\n\rchroma_height\x18\x02 \x01(\r\x12\x10\n\x08stride_y\x18\x03 \x01(\r\x12\x11\n\tstride_uv\x18\x04 \x01(\r\x12\x12\n\ndata_y_ptr\x18\x05 \x01(\x04\x12\x13\n\x0b\x64\x61ta_uv_ptr\x18\x06 \x01(\x04\"\x12\n\x10NativeBufferInfo\"n\n\x0fVideoStreamInfo\x12-\n\x06handle\x18\x01 \x01(\x0b\x32\x1d.livekit.proto.FfiOwnedHandle\x12,\n\x04type\x18\x02 \x01(\x0e\x32\x1e.livekit.proto.VideoStreamType\"q\n\x10VideoStreamEvent\x12\x15\n\rstream_handle\x18\x01 \x01(\x04\x12;\n\x0e\x66rame_received\x18\x02 \x01(\x0b\x32!.livekit.proto.VideoFrameReceivedH\x00\x42\t\n\x07message\"w\n\x12VideoFrameReceived\x12,\n\x05\x66rame\x18\x01 \x01(\x0b\x32\x1d.livekit.proto.VideoFrameInfo\x12\x33\n\x06\x62uffer\x18\x02 \x01(\x0b\x32#.livekit.proto.VideoFrameBufferInfo\"6\n\x15VideoSourceResolution\x12\r\n\x05width\x18\x01 \x01(\r\x12\x0e\n\x06height\x18\x02 \x01(\r\"n\n\x0fVideoSourceInfo\x12-\n\x06handle\x18\x01 \x01(\x0b\x32\x1d.livekit.proto.FfiOwnedHandle\x12,\n\x04type\x18\x02 \x01(\x0e\x32\x1e.livekit.proto.VideoSourceType*(\n\nVideoCodec\x12\x07\n\x03VP8\x10\x00\x12\x08\n\x04H264\x10\x01\x12\x07\n\x03\x41V1\x10\x02*l\n\rVideoRotation\x12\x14\n\x10VIDEO_ROTATION_0\x10\x00\x12\x15\n\x11VIDEO_ROTATION_90\x10\x01\x12\x16\n\x12VIDEO_ROTATION_180\x10\x02\x12\x16\n\x12VIDEO_ROTATION_270\x10\x03*U\n\x0fVideoFormatType\x12\x0f\n\x0b\x46ORMAT_ARGB\x10\x00\x12\x0f\n\x0b\x46ORMAT_BGRA\x10\x01\x12\x0f\n\x0b\x46ORMAT_ABGR\x10\x02\x12\x0f\n\x0b\x46ORMAT_RGBA\x10\x03*j\n\x14VideoFrameBufferType\x12\n\n\x06NATIVE\x10\x00\x12\x08\n\x04I420\x10\x01\x12\t\n\x05I420A\x10\x02\x12\x08\n\x04I422\x10\x03\x12\x08\n\x04I444\x10\x04\x12\x08\n\x04I010\x10\x05\x12\x08\n\x04NV12\x10\x06\x12\t\n\x05WEBGL\x10\x07*Y\n\x0fVideoStreamType\x12\x17\n\x13VIDEO_STREAM_NATIVE\x10\x00\x12\x16\n\x12VIDEO_STREAM_WEBGL\x10\x01\x12\x15\n\x11VIDEO_STREAM_HTML\x10\x02**\n\x0fVideoSourceType\x12\x17\n\x13VIDEO_SOURCE_NATIVE\x10\x00\x42\x10\xaa\x02\rLiveKit.Protob\x06proto3') -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'video_frame_pb2', _globals) +_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals()) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'video_frame_pb2', globals()) if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None DESCRIPTOR._serialized_options = b'\252\002\rLiveKit.Proto' - _globals['_VIDEOCODEC']._serialized_start=2686 - _globals['_VIDEOCODEC']._serialized_end=2726 - _globals['_VIDEOROTATION']._serialized_start=2728 - _globals['_VIDEOROTATION']._serialized_end=2836 - _globals['_VIDEOFORMATTYPE']._serialized_start=2838 - _globals['_VIDEOFORMATTYPE']._serialized_end=2923 - _globals['_VIDEOFRAMEBUFFERTYPE']._serialized_start=2925 - _globals['_VIDEOFRAMEBUFFERTYPE']._serialized_end=3031 - _globals['_VIDEOSTREAMTYPE']._serialized_start=3033 - _globals['_VIDEOSTREAMTYPE']._serialized_end=3122 - _globals['_VIDEOSOURCETYPE']._serialized_start=3124 - _globals['_VIDEOSOURCETYPE']._serialized_end=3166 - _globals['_ALLOCVIDEOBUFFERREQUEST']._serialized_start=50 - _globals['_ALLOCVIDEOBUFFERREQUEST']._serialized_end=157 - _globals['_ALLOCVIDEOBUFFERRESPONSE']._serialized_start=159 - _globals['_ALLOCVIDEOBUFFERRESPONSE']._serialized_end=238 - _globals['_NEWVIDEOSTREAMREQUEST']._serialized_start=240 - _globals['_NEWVIDEOSTREAMREQUEST']._serialized_end=331 - _globals['_NEWVIDEOSTREAMRESPONSE']._serialized_start=333 - _globals['_NEWVIDEOSTREAMRESPONSE']._serialized_end=405 - _globals['_NEWVIDEOSOURCEREQUEST']._serialized_start=408 - _globals['_NEWVIDEOSOURCEREQUEST']._serialized_end=555 - _globals['_NEWVIDEOSOURCERESPONSE']._serialized_start=557 - _globals['_NEWVIDEOSOURCERESPONSE']._serialized_end=629 - _globals['_CAPTUREVIDEOFRAMEREQUEST']._serialized_start=631 - _globals['_CAPTUREVIDEOFRAMEREQUEST']._serialized_end=749 - _globals['_CAPTUREVIDEOFRAMERESPONSE']._serialized_start=751 - _globals['_CAPTUREVIDEOFRAMERESPONSE']._serialized_end=778 - _globals['_TOI420REQUEST']._serialized_start=780 - _globals['_TOI420REQUEST']._serialized_end=891 - _globals['_TOI420RESPONSE']._serialized_start=893 - _globals['_TOI420RESPONSE']._serialized_end=962 - _globals['_TOARGBREQUEST']._serialized_start=965 - _globals['_TOARGBREQUEST']._serialized_end=1147 - _globals['_TOARGBRESPONSE']._serialized_start=1149 - _globals['_TOARGBRESPONSE']._serialized_end=1165 - _globals['_VIDEORESOLUTION']._serialized_start=1167 - _globals['_VIDEORESOLUTION']._serialized_end=1235 - _globals['_ARGBBUFFERINFO']._serialized_start=1237 - _globals['_ARGBBUFFERINFO']._serialized_end=1361 - _globals['_VIDEOFRAMEINFO']._serialized_start=1363 - _globals['_VIDEOFRAMEINFO']._serialized_end=1449 - _globals['_VIDEOFRAMEBUFFERINFO']._serialized_start=1452 - _globals['_VIDEOFRAMEBUFFERINFO']._serialized_end=1778 - _globals['_PLANARYUVBUFFERINFO']._serialized_start=1781 - _globals['_PLANARYUVBUFFERINFO']._serialized_end=1999 - _globals['_BIPLANARYUVBUFFERINFO']._serialized_start=2002 - _globals['_BIPLANARYUVBUFFERINFO']._serialized_end=2148 - _globals['_NATIVEBUFFERINFO']._serialized_start=2150 - _globals['_NATIVEBUFFERINFO']._serialized_end=2168 - _globals['_VIDEOSTREAMINFO']._serialized_start=2170 - _globals['_VIDEOSTREAMINFO']._serialized_end=2280 - _globals['_VIDEOSTREAMEVENT']._serialized_start=2282 - _globals['_VIDEOSTREAMEVENT']._serialized_end=2395 - _globals['_VIDEOFRAMERECEIVED']._serialized_start=2397 - _globals['_VIDEOFRAMERECEIVED']._serialized_end=2516 - _globals['_VIDEOSOURCERESOLUTION']._serialized_start=2518 - _globals['_VIDEOSOURCERESOLUTION']._serialized_end=2572 - _globals['_VIDEOSOURCEINFO']._serialized_start=2574 - _globals['_VIDEOSOURCEINFO']._serialized_end=2684 + _VIDEOCODEC._serialized_start=2686 + _VIDEOCODEC._serialized_end=2726 + _VIDEOROTATION._serialized_start=2728 + _VIDEOROTATION._serialized_end=2836 + _VIDEOFORMATTYPE._serialized_start=2838 + _VIDEOFORMATTYPE._serialized_end=2923 + _VIDEOFRAMEBUFFERTYPE._serialized_start=2925 + _VIDEOFRAMEBUFFERTYPE._serialized_end=3031 + _VIDEOSTREAMTYPE._serialized_start=3033 + _VIDEOSTREAMTYPE._serialized_end=3122 + _VIDEOSOURCETYPE._serialized_start=3124 + _VIDEOSOURCETYPE._serialized_end=3166 + _ALLOCVIDEOBUFFERREQUEST._serialized_start=50 + _ALLOCVIDEOBUFFERREQUEST._serialized_end=157 + _ALLOCVIDEOBUFFERRESPONSE._serialized_start=159 + _ALLOCVIDEOBUFFERRESPONSE._serialized_end=238 + _NEWVIDEOSTREAMREQUEST._serialized_start=240 + _NEWVIDEOSTREAMREQUEST._serialized_end=331 + _NEWVIDEOSTREAMRESPONSE._serialized_start=333 + _NEWVIDEOSTREAMRESPONSE._serialized_end=405 + _NEWVIDEOSOURCEREQUEST._serialized_start=408 + _NEWVIDEOSOURCEREQUEST._serialized_end=555 + _NEWVIDEOSOURCERESPONSE._serialized_start=557 + _NEWVIDEOSOURCERESPONSE._serialized_end=629 + _CAPTUREVIDEOFRAMEREQUEST._serialized_start=631 + _CAPTUREVIDEOFRAMEREQUEST._serialized_end=749 + _CAPTUREVIDEOFRAMERESPONSE._serialized_start=751 + _CAPTUREVIDEOFRAMERESPONSE._serialized_end=778 + _TOI420REQUEST._serialized_start=780 + _TOI420REQUEST._serialized_end=891 + _TOI420RESPONSE._serialized_start=893 + _TOI420RESPONSE._serialized_end=962 + _TOARGBREQUEST._serialized_start=965 + _TOARGBREQUEST._serialized_end=1147 + _TOARGBRESPONSE._serialized_start=1149 + _TOARGBRESPONSE._serialized_end=1165 + _VIDEORESOLUTION._serialized_start=1167 + _VIDEORESOLUTION._serialized_end=1235 + _ARGBBUFFERINFO._serialized_start=1237 + _ARGBBUFFERINFO._serialized_end=1361 + _VIDEOFRAMEINFO._serialized_start=1363 + _VIDEOFRAMEINFO._serialized_end=1449 + _VIDEOFRAMEBUFFERINFO._serialized_start=1452 + _VIDEOFRAMEBUFFERINFO._serialized_end=1778 + _PLANARYUVBUFFERINFO._serialized_start=1781 + _PLANARYUVBUFFERINFO._serialized_end=1999 + _BIPLANARYUVBUFFERINFO._serialized_start=2002 + _BIPLANARYUVBUFFERINFO._serialized_end=2148 + _NATIVEBUFFERINFO._serialized_start=2150 + _NATIVEBUFFERINFO._serialized_end=2168 + _VIDEOSTREAMINFO._serialized_start=2170 + _VIDEOSTREAMINFO._serialized_end=2280 + _VIDEOSTREAMEVENT._serialized_start=2282 + _VIDEOSTREAMEVENT._serialized_end=2395 + _VIDEOFRAMERECEIVED._serialized_start=2397 + _VIDEOFRAMERECEIVED._serialized_end=2516 + _VIDEOSOURCERESOLUTION._serialized_start=2518 + _VIDEOSOURCERESOLUTION._serialized_end=2572 + _VIDEOSOURCEINFO._serialized_start=2574 + _VIDEOSOURCEINFO._serialized_end=2684 # @@protoc_insertion_point(module_scope) diff --git a/livekit/room.py b/livekit/room.py index 6ed8b9aa..016ce14d 100644 --- a/livekit/room.py +++ b/livekit/room.py @@ -242,9 +242,10 @@ def _on_room_event(self, event: proto_room.RoomEvent): elif which == 'data_received': rparticipant = self.participants[event.data_received.participant_sid] buffer_info = event.data_received.data - data = ctypes.cast(buffer_info.data_ptr, - ctypes.POINTER(ctypes.c_byte - * buffer_info.data_len)).contents + native_data = ctypes.cast(buffer_info.data_ptr, + ctypes.POINTER(ctypes.c_byte + * buffer_info.data_len)).contents + data = bytearray(native_data) FfiHandle(buffer_info.handle.id) self.emit('data_received', data, event.data_received.kind, rparticipant)