Skip to content

Commit

Permalink
Add recording component (#32)
Browse files Browse the repository at this point in the history
* Add recording component

* Requested changes
  • Loading branch information
Karolk99 authored Mar 15, 2024
1 parent bda24ad commit 98df769
Show file tree
Hide file tree
Showing 25 changed files with 452 additions and 73 deletions.
8 changes: 8 additions & 0 deletions jellyfish/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,14 +14,17 @@
ComponentOptionsFile,
ComponentOptionsHLS,
ComponentOptionsHLSSubscribeMode,
ComponentOptionsRecording,
ComponentOptionsRTSP,
ComponentOptionsSIP,
ComponentPropertiesFile,
ComponentPropertiesHLS,
ComponentPropertiesHLSSubscribeMode,
ComponentPropertiesRecording,
ComponentPropertiesRTSP,
ComponentPropertiesSIP,
ComponentPropertiesSIPSIPCredentials,
ComponentRecording,
ComponentRTSP,
ComponentSIP,
Peer,
Expand All @@ -30,6 +33,7 @@
Room,
RoomConfig,
RoomConfigVideoCodec,
S3Credentials,
SIPCredentials,
)

Expand Down Expand Up @@ -69,5 +73,9 @@
"events",
"errors",
"SIPCredentials",
"ComponentRecording",
"ComponentOptionsRecording",
"ComponentPropertiesRecording",
"S3Credentials",
]
__docformat__ = "restructuredtext"
8 changes: 4 additions & 4 deletions jellyfish/_openapi_client/api/health/healthcheck.py
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ def _build_response(

def sync_detailed(
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Response[Union[Error, HealthcheckResponse]]:
"""Describes the health of Jellyfish
Expand All @@ -70,7 +70,7 @@ def sync_detailed(

def sync(
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Optional[Union[Error, HealthcheckResponse]]:
"""Describes the health of Jellyfish
Expand All @@ -89,7 +89,7 @@ def sync(

async def asyncio_detailed(
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Response[Union[Error, HealthcheckResponse]]:
"""Describes the health of Jellyfish
Expand All @@ -110,7 +110,7 @@ async def asyncio_detailed(

async def asyncio(
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Optional[Union[Error, HealthcheckResponse]]:
"""Describes the health of Jellyfish
Expand Down
8 changes: 4 additions & 4 deletions jellyfish/_openapi_client/api/hls/subscribe_hls_to.py
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ def _build_response(
def sync_detailed(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: SubscriptionConfig,
) -> Response[Union[Any, Error]]:
"""Subscribe the HLS component to the tracks of peers or components
Expand Down Expand Up @@ -96,7 +96,7 @@ def sync_detailed(
def sync(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: SubscriptionConfig,
) -> Optional[Union[Any, Error]]:
"""Subscribe the HLS component to the tracks of peers or components
Expand All @@ -123,7 +123,7 @@ def sync(
async def asyncio_detailed(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: SubscriptionConfig,
) -> Response[Union[Any, Error]]:
"""Subscribe the HLS component to the tracks of peers or components
Expand Down Expand Up @@ -153,7 +153,7 @@ async def asyncio_detailed(
async def asyncio(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: SubscriptionConfig,
) -> Optional[Union[Any, Error]]:
"""Subscribe the HLS component to the tracks of peers or components
Expand Down
8 changes: 4 additions & 4 deletions jellyfish/_openapi_client/api/recording/delete_recording.py
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ def _build_response(
def sync_detailed(
recording_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Response[Union[Any, Error]]:
"""Deletes the recording
Expand Down Expand Up @@ -87,7 +87,7 @@ def sync_detailed(
def sync(
recording_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Optional[Union[Any, Error]]:
"""Deletes the recording
Expand All @@ -111,7 +111,7 @@ def sync(
async def asyncio_detailed(
recording_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Response[Union[Any, Error]]:
"""Deletes the recording
Expand All @@ -138,7 +138,7 @@ async def asyncio_detailed(
async def asyncio(
recording_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Optional[Union[Any, Error]]:
"""Deletes the recording
Expand Down
8 changes: 4 additions & 4 deletions jellyfish/_openapi_client/api/recording/get_recordings.py
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ def _build_response(

def sync_detailed(
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Response[Union[Error, RecordingListResponse]]:
"""Lists all available recordings
Expand All @@ -74,7 +74,7 @@ def sync_detailed(

def sync(
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Optional[Union[Error, RecordingListResponse]]:
"""Lists all available recordings
Expand All @@ -93,7 +93,7 @@ def sync(

async def asyncio_detailed(
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Response[Union[Error, RecordingListResponse]]:
"""Lists all available recordings
Expand All @@ -114,7 +114,7 @@ async def asyncio_detailed(

async def asyncio(
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Optional[Union[Error, RecordingListResponse]]:
"""Lists all available recordings
Expand Down
8 changes: 4 additions & 4 deletions jellyfish/_openapi_client/api/room/add_component.py
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ def _build_response(
def sync_detailed(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: AddComponentJsonBody,
) -> Response[Union[ComponentDetailsResponse, Error]]:
"""Creates the component and adds it to the room
Expand Down Expand Up @@ -98,7 +98,7 @@ def sync_detailed(
def sync(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: AddComponentJsonBody,
) -> Optional[Union[ComponentDetailsResponse, Error]]:
"""Creates the component and adds it to the room
Expand All @@ -125,7 +125,7 @@ def sync(
async def asyncio_detailed(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: AddComponentJsonBody,
) -> Response[Union[ComponentDetailsResponse, Error]]:
"""Creates the component and adds it to the room
Expand Down Expand Up @@ -155,7 +155,7 @@ async def asyncio_detailed(
async def asyncio(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: AddComponentJsonBody,
) -> Optional[Union[ComponentDetailsResponse, Error]]:
"""Creates the component and adds it to the room
Expand Down
8 changes: 4 additions & 4 deletions jellyfish/_openapi_client/api/room/add_peer.py
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ def _build_response(
def sync_detailed(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: AddPeerJsonBody,
) -> Response[Union[Error, PeerDetailsResponse]]:
"""Create peer
Expand Down Expand Up @@ -102,7 +102,7 @@ def sync_detailed(
def sync(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: AddPeerJsonBody,
) -> Optional[Union[Error, PeerDetailsResponse]]:
"""Create peer
Expand All @@ -129,7 +129,7 @@ def sync(
async def asyncio_detailed(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: AddPeerJsonBody,
) -> Response[Union[Error, PeerDetailsResponse]]:
"""Create peer
Expand Down Expand Up @@ -159,7 +159,7 @@ async def asyncio_detailed(
async def asyncio(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: AddPeerJsonBody,
) -> Optional[Union[Error, PeerDetailsResponse]]:
"""Create peer
Expand Down
8 changes: 4 additions & 4 deletions jellyfish/_openapi_client/api/room/create_room.py
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ def _build_response(

def sync_detailed(
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: RoomConfig,
) -> Response[Union[Error, RoomCreateDetailsResponse]]:
"""Creates a room
Expand Down Expand Up @@ -87,7 +87,7 @@ def sync_detailed(

def sync(
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: RoomConfig,
) -> Optional[Union[Error, RoomCreateDetailsResponse]]:
"""Creates a room
Expand All @@ -111,7 +111,7 @@ def sync(

async def asyncio_detailed(
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: RoomConfig,
) -> Response[Union[Error, RoomCreateDetailsResponse]]:
"""Creates a room
Expand All @@ -138,7 +138,7 @@ async def asyncio_detailed(

async def asyncio(
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
json_body: RoomConfig,
) -> Optional[Union[Error, RoomCreateDetailsResponse]]:
"""Creates a room
Expand Down
8 changes: 4 additions & 4 deletions jellyfish/_openapi_client/api/room/delete_component.py
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ def sync_detailed(
room_id: str,
id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Response[Union[Any, Error]]:
"""Delete the component from the room
Expand Down Expand Up @@ -89,7 +89,7 @@ def sync(
room_id: str,
id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Optional[Union[Any, Error]]:
"""Delete the component from the room
Expand All @@ -116,7 +116,7 @@ async def asyncio_detailed(
room_id: str,
id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Response[Union[Any, Error]]:
"""Delete the component from the room
Expand Down Expand Up @@ -146,7 +146,7 @@ async def asyncio(
room_id: str,
id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Optional[Union[Any, Error]]:
"""Delete the component from the room
Expand Down
8 changes: 4 additions & 4 deletions jellyfish/_openapi_client/api/room/delete_peer.py
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ def sync_detailed(
room_id: str,
id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Response[Union[Any, Error]]:
"""Delete peer
Expand Down Expand Up @@ -89,7 +89,7 @@ def sync(
room_id: str,
id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Optional[Union[Any, Error]]:
"""Delete peer
Expand All @@ -116,7 +116,7 @@ async def asyncio_detailed(
room_id: str,
id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Response[Union[Any, Error]]:
"""Delete peer
Expand Down Expand Up @@ -146,7 +146,7 @@ async def asyncio(
room_id: str,
id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Optional[Union[Any, Error]]:
"""Delete peer
Expand Down
8 changes: 4 additions & 4 deletions jellyfish/_openapi_client/api/room/delete_room.py
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ def _build_response(
def sync_detailed(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Response[Union[Any, Error]]:
"""Delete the room
Expand Down Expand Up @@ -83,7 +83,7 @@ def sync_detailed(
def sync(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Optional[Union[Any, Error]]:
"""Delete the room
Expand All @@ -107,7 +107,7 @@ def sync(
async def asyncio_detailed(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Response[Union[Any, Error]]:
"""Delete the room
Expand All @@ -134,7 +134,7 @@ async def asyncio_detailed(
async def asyncio(
room_id: str,
*,
client: Union[AuthenticatedClient, Client],
client: AuthenticatedClient,
) -> Optional[Union[Any, Error]]:
"""Delete the room
Expand Down
Loading

0 comments on commit 98df769

Please sign in to comment.