Skip to content

Commit 98df769

Browse files
authored
Add recording component (#32)
* Add recording component * Requested changes
1 parent bda24ad commit 98df769

25 files changed

+452
-73
lines changed

jellyfish/__init__.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,14 +14,17 @@
1414
ComponentOptionsFile,
1515
ComponentOptionsHLS,
1616
ComponentOptionsHLSSubscribeMode,
17+
ComponentOptionsRecording,
1718
ComponentOptionsRTSP,
1819
ComponentOptionsSIP,
1920
ComponentPropertiesFile,
2021
ComponentPropertiesHLS,
2122
ComponentPropertiesHLSSubscribeMode,
23+
ComponentPropertiesRecording,
2224
ComponentPropertiesRTSP,
2325
ComponentPropertiesSIP,
2426
ComponentPropertiesSIPSIPCredentials,
27+
ComponentRecording,
2528
ComponentRTSP,
2629
ComponentSIP,
2730
Peer,
@@ -30,6 +33,7 @@
3033
Room,
3134
RoomConfig,
3235
RoomConfigVideoCodec,
36+
S3Credentials,
3337
SIPCredentials,
3438
)
3539

@@ -69,5 +73,9 @@
6973
"events",
7074
"errors",
7175
"SIPCredentials",
76+
"ComponentRecording",
77+
"ComponentOptionsRecording",
78+
"ComponentPropertiesRecording",
79+
"S3Credentials",
7280
]
7381
__docformat__ = "restructuredtext"

jellyfish/_openapi_client/api/health/healthcheck.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ def _build_response(
4747

4848
def sync_detailed(
4949
*,
50-
client: Union[AuthenticatedClient, Client],
50+
client: AuthenticatedClient,
5151
) -> Response[Union[Error, HealthcheckResponse]]:
5252
"""Describes the health of Jellyfish
5353
@@ -70,7 +70,7 @@ def sync_detailed(
7070

7171
def sync(
7272
*,
73-
client: Union[AuthenticatedClient, Client],
73+
client: AuthenticatedClient,
7474
) -> Optional[Union[Error, HealthcheckResponse]]:
7575
"""Describes the health of Jellyfish
7676
@@ -89,7 +89,7 @@ def sync(
8989

9090
async def asyncio_detailed(
9191
*,
92-
client: Union[AuthenticatedClient, Client],
92+
client: AuthenticatedClient,
9393
) -> Response[Union[Error, HealthcheckResponse]]:
9494
"""Describes the health of Jellyfish
9595
@@ -110,7 +110,7 @@ async def asyncio_detailed(
110110

111111
async def asyncio(
112112
*,
113-
client: Union[AuthenticatedClient, Client],
113+
client: AuthenticatedClient,
114114
) -> Optional[Union[Error, HealthcheckResponse]]:
115115
"""Describes the health of Jellyfish
116116

jellyfish/_openapi_client/api/hls/subscribe_hls_to.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ def _build_response(
6464
def sync_detailed(
6565
room_id: str,
6666
*,
67-
client: Union[AuthenticatedClient, Client],
67+
client: AuthenticatedClient,
6868
json_body: SubscriptionConfig,
6969
) -> Response[Union[Any, Error]]:
7070
"""Subscribe the HLS component to the tracks of peers or components
@@ -96,7 +96,7 @@ def sync_detailed(
9696
def sync(
9797
room_id: str,
9898
*,
99-
client: Union[AuthenticatedClient, Client],
99+
client: AuthenticatedClient,
100100
json_body: SubscriptionConfig,
101101
) -> Optional[Union[Any, Error]]:
102102
"""Subscribe the HLS component to the tracks of peers or components
@@ -123,7 +123,7 @@ def sync(
123123
async def asyncio_detailed(
124124
room_id: str,
125125
*,
126-
client: Union[AuthenticatedClient, Client],
126+
client: AuthenticatedClient,
127127
json_body: SubscriptionConfig,
128128
) -> Response[Union[Any, Error]]:
129129
"""Subscribe the HLS component to the tracks of peers or components
@@ -153,7 +153,7 @@ async def asyncio_detailed(
153153
async def asyncio(
154154
room_id: str,
155155
*,
156-
client: Union[AuthenticatedClient, Client],
156+
client: AuthenticatedClient,
157157
json_body: SubscriptionConfig,
158158
) -> Optional[Union[Any, Error]]:
159159
"""Subscribe the HLS component to the tracks of peers or components

jellyfish/_openapi_client/api/recording/delete_recording.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ def _build_response(
5858
def sync_detailed(
5959
recording_id: str,
6060
*,
61-
client: Union[AuthenticatedClient, Client],
61+
client: AuthenticatedClient,
6262
) -> Response[Union[Any, Error]]:
6363
"""Deletes the recording
6464
@@ -87,7 +87,7 @@ def sync_detailed(
8787
def sync(
8888
recording_id: str,
8989
*,
90-
client: Union[AuthenticatedClient, Client],
90+
client: AuthenticatedClient,
9191
) -> Optional[Union[Any, Error]]:
9292
"""Deletes the recording
9393
@@ -111,7 +111,7 @@ def sync(
111111
async def asyncio_detailed(
112112
recording_id: str,
113113
*,
114-
client: Union[AuthenticatedClient, Client],
114+
client: AuthenticatedClient,
115115
) -> Response[Union[Any, Error]]:
116116
"""Deletes the recording
117117
@@ -138,7 +138,7 @@ async def asyncio_detailed(
138138
async def asyncio(
139139
recording_id: str,
140140
*,
141-
client: Union[AuthenticatedClient, Client],
141+
client: AuthenticatedClient,
142142
) -> Optional[Union[Any, Error]]:
143143
"""Deletes the recording
144144

jellyfish/_openapi_client/api/recording/get_recordings.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ def _build_response(
5151

5252
def sync_detailed(
5353
*,
54-
client: Union[AuthenticatedClient, Client],
54+
client: AuthenticatedClient,
5555
) -> Response[Union[Error, RecordingListResponse]]:
5656
"""Lists all available recordings
5757
@@ -74,7 +74,7 @@ def sync_detailed(
7474

7575
def sync(
7676
*,
77-
client: Union[AuthenticatedClient, Client],
77+
client: AuthenticatedClient,
7878
) -> Optional[Union[Error, RecordingListResponse]]:
7979
"""Lists all available recordings
8080
@@ -93,7 +93,7 @@ def sync(
9393

9494
async def asyncio_detailed(
9595
*,
96-
client: Union[AuthenticatedClient, Client],
96+
client: AuthenticatedClient,
9797
) -> Response[Union[Error, RecordingListResponse]]:
9898
"""Lists all available recordings
9999
@@ -114,7 +114,7 @@ async def asyncio_detailed(
114114

115115
async def asyncio(
116116
*,
117-
client: Union[AuthenticatedClient, Client],
117+
client: AuthenticatedClient,
118118
) -> Optional[Union[Error, RecordingListResponse]]:
119119
"""Lists all available recordings
120120

jellyfish/_openapi_client/api/room/add_component.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ def _build_response(
6666
def sync_detailed(
6767
room_id: str,
6868
*,
69-
client: Union[AuthenticatedClient, Client],
69+
client: AuthenticatedClient,
7070
json_body: AddComponentJsonBody,
7171
) -> Response[Union[ComponentDetailsResponse, Error]]:
7272
"""Creates the component and adds it to the room
@@ -98,7 +98,7 @@ def sync_detailed(
9898
def sync(
9999
room_id: str,
100100
*,
101-
client: Union[AuthenticatedClient, Client],
101+
client: AuthenticatedClient,
102102
json_body: AddComponentJsonBody,
103103
) -> Optional[Union[ComponentDetailsResponse, Error]]:
104104
"""Creates the component and adds it to the room
@@ -125,7 +125,7 @@ def sync(
125125
async def asyncio_detailed(
126126
room_id: str,
127127
*,
128-
client: Union[AuthenticatedClient, Client],
128+
client: AuthenticatedClient,
129129
json_body: AddComponentJsonBody,
130130
) -> Response[Union[ComponentDetailsResponse, Error]]:
131131
"""Creates the component and adds it to the room
@@ -155,7 +155,7 @@ async def asyncio_detailed(
155155
async def asyncio(
156156
room_id: str,
157157
*,
158-
client: Union[AuthenticatedClient, Client],
158+
client: AuthenticatedClient,
159159
json_body: AddComponentJsonBody,
160160
) -> Optional[Union[ComponentDetailsResponse, Error]]:
161161
"""Creates the component and adds it to the room

jellyfish/_openapi_client/api/room/add_peer.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ def _build_response(
7070
def sync_detailed(
7171
room_id: str,
7272
*,
73-
client: Union[AuthenticatedClient, Client],
73+
client: AuthenticatedClient,
7474
json_body: AddPeerJsonBody,
7575
) -> Response[Union[Error, PeerDetailsResponse]]:
7676
"""Create peer
@@ -102,7 +102,7 @@ def sync_detailed(
102102
def sync(
103103
room_id: str,
104104
*,
105-
client: Union[AuthenticatedClient, Client],
105+
client: AuthenticatedClient,
106106
json_body: AddPeerJsonBody,
107107
) -> Optional[Union[Error, PeerDetailsResponse]]:
108108
"""Create peer
@@ -129,7 +129,7 @@ def sync(
129129
async def asyncio_detailed(
130130
room_id: str,
131131
*,
132-
client: Union[AuthenticatedClient, Client],
132+
client: AuthenticatedClient,
133133
json_body: AddPeerJsonBody,
134134
) -> Response[Union[Error, PeerDetailsResponse]]:
135135
"""Create peer
@@ -159,7 +159,7 @@ async def asyncio_detailed(
159159
async def asyncio(
160160
room_id: str,
161161
*,
162-
client: Union[AuthenticatedClient, Client],
162+
client: AuthenticatedClient,
163163
json_body: AddPeerJsonBody,
164164
) -> Optional[Union[Error, PeerDetailsResponse]]:
165165
"""Create peer

jellyfish/_openapi_client/api/room/create_room.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ def _build_response(
5858

5959
def sync_detailed(
6060
*,
61-
client: Union[AuthenticatedClient, Client],
61+
client: AuthenticatedClient,
6262
json_body: RoomConfig,
6363
) -> Response[Union[Error, RoomCreateDetailsResponse]]:
6464
"""Creates a room
@@ -87,7 +87,7 @@ def sync_detailed(
8787

8888
def sync(
8989
*,
90-
client: Union[AuthenticatedClient, Client],
90+
client: AuthenticatedClient,
9191
json_body: RoomConfig,
9292
) -> Optional[Union[Error, RoomCreateDetailsResponse]]:
9393
"""Creates a room
@@ -111,7 +111,7 @@ def sync(
111111

112112
async def asyncio_detailed(
113113
*,
114-
client: Union[AuthenticatedClient, Client],
114+
client: AuthenticatedClient,
115115
json_body: RoomConfig,
116116
) -> Response[Union[Error, RoomCreateDetailsResponse]]:
117117
"""Creates a room
@@ -138,7 +138,7 @@ async def asyncio_detailed(
138138

139139
async def asyncio(
140140
*,
141-
client: Union[AuthenticatedClient, Client],
141+
client: AuthenticatedClient,
142142
json_body: RoomConfig,
143143
) -> Optional[Union[Error, RoomCreateDetailsResponse]]:
144144
"""Creates a room

jellyfish/_openapi_client/api/room/delete_component.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ def sync_detailed(
5757
room_id: str,
5858
id: str,
5959
*,
60-
client: Union[AuthenticatedClient, Client],
60+
client: AuthenticatedClient,
6161
) -> Response[Union[Any, Error]]:
6262
"""Delete the component from the room
6363
@@ -89,7 +89,7 @@ def sync(
8989
room_id: str,
9090
id: str,
9191
*,
92-
client: Union[AuthenticatedClient, Client],
92+
client: AuthenticatedClient,
9393
) -> Optional[Union[Any, Error]]:
9494
"""Delete the component from the room
9595
@@ -116,7 +116,7 @@ async def asyncio_detailed(
116116
room_id: str,
117117
id: str,
118118
*,
119-
client: Union[AuthenticatedClient, Client],
119+
client: AuthenticatedClient,
120120
) -> Response[Union[Any, Error]]:
121121
"""Delete the component from the room
122122
@@ -146,7 +146,7 @@ async def asyncio(
146146
room_id: str,
147147
id: str,
148148
*,
149-
client: Union[AuthenticatedClient, Client],
149+
client: AuthenticatedClient,
150150
) -> Optional[Union[Any, Error]]:
151151
"""Delete the component from the room
152152

jellyfish/_openapi_client/api/room/delete_peer.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ def sync_detailed(
5757
room_id: str,
5858
id: str,
5959
*,
60-
client: Union[AuthenticatedClient, Client],
60+
client: AuthenticatedClient,
6161
) -> Response[Union[Any, Error]]:
6262
"""Delete peer
6363
@@ -89,7 +89,7 @@ def sync(
8989
room_id: str,
9090
id: str,
9191
*,
92-
client: Union[AuthenticatedClient, Client],
92+
client: AuthenticatedClient,
9393
) -> Optional[Union[Any, Error]]:
9494
"""Delete peer
9595
@@ -116,7 +116,7 @@ async def asyncio_detailed(
116116
room_id: str,
117117
id: str,
118118
*,
119-
client: Union[AuthenticatedClient, Client],
119+
client: AuthenticatedClient,
120120
) -> Response[Union[Any, Error]]:
121121
"""Delete peer
122122
@@ -146,7 +146,7 @@ async def asyncio(
146146
room_id: str,
147147
id: str,
148148
*,
149-
client: Union[AuthenticatedClient, Client],
149+
client: AuthenticatedClient,
150150
) -> Optional[Union[Any, Error]]:
151151
"""Delete peer
152152

0 commit comments

Comments
 (0)