feat: add transcoder tests

This commit adds some very basic tests for the transcoder so that we can
confirm that the transcoder is working correctly.

partially works on #86 point 2

frontend/player/.eslintignore

@@ -14,3 +14,4 @@ yarn.lock
 pkg/
 target/
 dist/
+demo-dist/

frontend/player/.prettierignore

@@ -16,4 +16,5 @@ yarn.lock
 wasm.d.ts
 target/
 dist/
-pkg/
+demo-dist/
+pkg/

video/ingest/src/ingest/connection.rs

@@ -312,7 +312,7 @@ impl Connection {
                 api_update_failed = true;
                 false
             }
-            event = self.transcoder_req_rx.recv() => self.on_transcoder_request(&update_channel, &global, event.expect("transcoder closed")).await,
+            event = self.transcoder_req_rx.recv() => self.on_grpc_request(&update_channel, &global, event.expect("transcoder closed")).await,
         } {}
 
         if let Some(transcoder) = self.current_transcoder.take() {
@@ -451,7 +451,7 @@ impl Connection {
         true
     }
 
-    async fn on_transcoder_request(
+    async fn on_grpc_request(
         &mut self,
         update_channel: &mpsc::Sender<Vec<Update>>,
         global: &Arc<GlobalState>,

video/transcoder/Cargo.toml

@@ -44,3 +44,5 @@ dotenvy = "0"
 portpicker = "0"
 serial_test = "2"
 tempfile = "3"
+transmuxer = { path = "../transmuxer" }
+flv = { path = "../container/flv" }

video/transcoder/src/tests/global.rs

@@ -41,6 +41,12 @@ pub async fn mock_global_state(config: AppConfig) -> (Arc<GlobalState>, Handler)
     )
     .expect("failed to create redis pool");
 
+    redis.connect();
+    redis
+        .wait_for_connect()
+        .await
+        .expect("failed to connect to redis");
+
     let global = Arc::new(GlobalState::new(config, ctx, rmq, redis));
 
     (global, handler)