api: stream: test profiles for test creator ids (#2152)

* api: stream: test profiles for test creator ids * todo * removing old hardcoded debug playback id * hardcode test profiles * update * Make streams from those creators unoverridable --------- Co-authored-by: Victor Elias <[email protected]>
livepeer · Apr 29, 2024 · 67decac · 67decac
1 parent 85bc74b
commit 67decac
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 4 deletions.
diff --git a/packages/api/src/controllers/playback.ts b/packages/api/src/controllers/playback.ts
@@ -345,10 +345,7 @@ app.get("/:id", async (req, res) => {
   let ingest = ingests[0].base;
   let { id } = req.params;
 
-  if (
-    (id === "1ba7nrr34rbjl4bb" || req.user?.directPlayback) &&
-    ingests[0].baseDirect
-  ) {
+  if (req.user?.directPlayback && ingests[0].baseDirect) {
     ingest = ingests[0].baseDirect;
   }
 

diff --git a/packages/api/src/controllers/stream.ts b/packages/api/src/controllers/stream.ts
@@ -1038,6 +1038,13 @@ const pullStreamKeyAccessors: Record<string, string[]> = {
   "pull.source": ["pull", "source"],
 };
 
+const testCreatorIds: string[] = [
+  "73846_104901225_104901225",
+  "73846_116005487_116003843",
+  "73846_116003843_116003843",
+  "73846_115939837_115939837",
+];
+
 app.put(
   "/pull",
   authorizer({}),
@@ -1139,6 +1146,9 @@ app.put(
         pullRegion,
         ...payload,
       };
+      if (testCreatorIds.includes(stream.creatorId?.value)) {
+        stream.profiles = oldStream.profiles;
+      }
       await db.stream.replace(stream);
       // read from DB again to keep exactly what got saved
       stream = await db.stream.get(stream.id, { useReplica: false });