Video CSP

api/Dockerfile

@@ -5,7 +5,7 @@ EXPOSE 5000
 ENV HOME=/home/etl
 WORKDIR $HOME
 
-RUN apk add nodejs-current npm memcached python3 make bash g++ openssl postgresql-client
+RUN apk add nodejs-current npm memcached python3 make bash g++ openssl postgresql-client grep
 
 WORKDIR $HOME/api
 
@@ -27,8 +27,6 @@ RUN npm run lint \
     && npm run build
 
 COPY ./nginx.conf /etc/nginx/nginx.conf
+COPY ./start $HOME/api
 
-CMD memcached -d -u root \
-    && sed -i "s/API_URL/${API_URL}/g" /etc/nginx/nginx.conf \
-    && nginx \
-    && npm run prod
+CMD ["./start"]

api/lib/config.ts

@@ -122,7 +122,7 @@ export default class Config {
             SigningSecret = 'coe-wildland-fire';
             API_URL = 'http://localhost:5001';
             Bucket = process.env.ASSET_BUCKET;
-            PMTILES_URL = 'http://localhost:5001';
+            PMTILES_URL = process.env.PMTILES_URL || 'http://localhost:5001';
         } else {
             if (!process.env.StackName) throw new Error('StackName env must be set');
             if (!process.env.API_URL) throw new Error('API_URL env must be set');
@@ -133,7 +133,7 @@ export default class Config {
             const apiUrl = new URL(`http://${process.env.API_URL}`);
             if (apiUrl.hostname === 'localhost') {
                 API_URL = `http://${process.env.API_URL}`;
-                PMTILES_URL = 'http://localhost:5001'
+                PMTILES_URL = process.env.PMTILES_URL || 'http://localhost:5001'
             } else {
                 PMTILES_URL = `https://tiles.${process.env.API_URL}`;
                 API_URL = String(`https://${process.env.API_URL}`);

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);
@@ -272,6 +272,7 @@ export default class VideoServiceControl {
 
     async generate(opts: {
         name: string;
+        ephemeral: boolean;
         expiration: string;
         path: string;
         username: string;
@@ -286,6 +287,7 @@ export default class VideoServiceControl {
         const lease = await this.config.models.VideoLease.generate({
             name: opts.name,
             expiration: opts.expiration,
+            ephemeral: opts.ephemeral,
             path: opts.path,
             username: opts.username,
             proxy: opts.proxy
@@ -297,6 +299,29 @@ export default class VideoServiceControl {
         headers.append('Content-Type', 'application/json');
 
         if (lease.proxy) {
+            try {
+                const proxy = new URL(opts.proxy);
+
+                // Check for HLS Errors
+                if (['http:', 'https:'].includes(proxy.protocol)) {
+                    const res = await fetch(proxy);
+
+                    if (res.status === 404) {
+                        throw new Err(400, null, 'External Video Server reports Video Stream not found');
+                    } else if (!res.ok) {
+                        throw new Err(res.status, null, `External Video Server failed stream video - HTTP Error ${res.status}`);
+                    }
+                }
+            } catch (err) {
+                if (err instanceof Err) {
+                    throw err;
+                } else if (err instanceof TypeError && err.code === 'ERR_INVALID_URL') {
+                    throw new Err(400, null, 'Invalid Video Stream URL');
+                } else {
+                    throw new Err(500, err instanceof Error ? err : new Error(String(err)), 'Failed to generate proxy stream');
+                }
+            }
+
             const res = await fetch(url, {
                 method: 'POST',
                 headers,

api/lib/enums.ts

@@ -20,6 +20,7 @@ export class toEnum {
 
 export enum Basemap_Format {
     PNG = 'png',
+    JPEG = 'jpeg',
     MVT = 'mvt'
 }
 

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'),

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, {

api/migrations/0061_wide_bruce_banner.sql

@@ -0,0 +1 @@
+ALTER TABLE "video_lease" ADD COLUMN "ephemeral" boolean DEFAULT false NOT NULL;