Add missing metrics

server/ai_mediaserver.go

@@ -705,6 +705,7 @@ func (ls *LivepeerServer) CreateWhip(server *media.WHIPServer) http.Handler {
 		// Others: auth, selection, job setup
 		// Run them in parallel
 
+		streamRequestTime := time.Now().UnixMilli()
 		corsHeaders(w, r.Method)
 
 		ctx := r.Context()
@@ -797,6 +798,27 @@ func (ls *LivepeerServer) CreateWhip(server *media.WHIPServer) http.Handler {
 				whipConn.Close()
 			}
 
+			clog.Info(ctx, "Received live video AI request", "pipelineParams", pipelineParams)
+
+			// Clear any previous gateway status
+			GatewayStatus.Clear(streamID)
+
+			monitor.SendQueueEventAsync("stream_trace", map[string]interface{}{
+				"type":        "gateway_receive_stream_request",
+				"timestamp":   streamRequestTime,
+				"stream_id":   streamID,
+				"pipeline_id": pipelineID,
+				"request_id":  requestID,
+				"orchestrator_info": map[string]interface{}{
+					"address": "",
+					"url":     "",
+				},
+			})
+
+			if monitor.Enabled {
+				monitor.AILiveVideoAttempt()
+			}
+
 			params := aiRequestParams{
 				node:        ls.LivepeerNode,
 				os:          drivers.NodeStorage.NewSession(requestID),