Store ID in cache

client/src/proto/livepeer.proto

@@ -7,6 +7,7 @@ service Orchestrator {
 
   // Called by the broadcaster to request transcoder info from an orchestrator.
   rpc GetOrchestrator(OrchestratorRequest) returns (OrchestratorInfo);
+  rpc EndTranscodingSession(EndTranscodingSessionRequest) returns (EndTranscodingSessionResponse);
   rpc Ping(PingPong) returns (PingPong);
 }
 
@@ -23,6 +24,14 @@ message PingPong {
 
 }
 
+// sent by Broadcaster to Orchestrator to terminate the transcoding session and free resources (used for verification sessions)
+message EndTranscodingSessionRequest {
+  // Data for transcoding authentication
+  AuthToken auth_token   = 1;
+}
+
+message EndTranscodingSessionResponse {
+}
 
 // This request is sent by the broadcaster in `GetTranscoder` to request
 // information on which transcoder to use.
@@ -221,6 +230,9 @@ message SegData {
   // Transcoding parameters specific to this segment
   SegParameters segment_parameters = 37;
 
+  // Force HW Session Reinit
+  bool ForceSessionReinit = 38;
+
   // [EXPERIMENTAL]
   // Detector profiles to use
   repeated DetectorProfile detector_profiles = 36;
@@ -292,6 +304,7 @@ message VideoProfile {
     CHROMA_444 = 2;
   }
   ChromaSubsampling chromaFormat = 27;
+  uint32 quality = 28;
 }
 
 // Individual transcoded segment data.

master/src/routes/hodler.js

@@ -217,12 +217,14 @@ const onOrchUpdate = async function (id, obj, tag, region, livepeer_regions) {
   if (!newObj) {
     newObj = {
       name: ensDomain,
+      id: id.toLowerCase(),
       regionalStats: {},
       instances: {},
       leaderboardResults: { lastTime: now },
     };
   } else {
     newObj.name = ensDomain;
+    newObj.id = id.toLowerCase()
   }
   // Find region entry or init it
   let newRegion = newObj.regionalStats[tag];