Add port to RTMP & ephemeral flag

dfpc-coe · Sep 18, 2024 · 3900d14 · 3900d14
1 parent 6a9ff47
commit 3900d14
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 1 deletion.
diff --git a/api/lib/control/video-service.ts b/api/lib/control/video-service.ts
@@ -234,7 +234,7 @@ export default class VideoServiceControl {
         if (c.config && c.config.rtmp) {
             // Format: rtmp://localhost/mystream
             const url = new URL(`/${lease.path}`, c.url.replace(/^http(s)?:/, 'rtmp:'))
-            url.port = '';
+            url.port = c.config.rtmpAddress.replace(':', '');
 
             if (lease.stream_user) url.searchParams.append('user', lease.stream_user);
             if (lease.stream_pass) url.searchParams.append('pass', lease.stream_pass);

diff --git a/api/lib/schema.ts b/api/lib/schema.ts
@@ -64,6 +64,7 @@ export const VideoLease = pgTable('video_lease', {
     updated: timestamp('updated', { withTimezone: true, mode: 'string' }).notNull().default(sql`Now()`),
     username: text('username').notNull().references(() => Profile.username),
 
+    ephemeral: boolean('ephemeral').notNull().default(false),
     expiration: timestamp('expiration', { withTimezone: true, mode: 'string' }).notNull().default(sql`Now() + INTERVAL 1 HOUR;`),
     path: text('path').notNull(),
     stream_user: text('stream_user'),

diff --git a/api/lib/types.ts b/api/lib/types.ts
@@ -61,6 +61,7 @@ export const ProfileResponse = Type.Object({
 
 export const VideoLeaseResponse = createSelectSchema(schemas.VideoLease, {
     id: Type.Integer(),
+    ephemeral: Type.Boolean()
 });
 
 export const OverlayResponse = createSelectSchema(schemas.Overlay, {