update setupStream to return /process/stream urls

ad-astra-video · ad-astra-video · commit 354fbe19d117 · 2025-12-18T17:01:02.000-06:00
diff --git a/byoc/stream_gateway.go b/byoc/stream_gateway.go
@@ -493,19 +493,19 @@ func (bsg *BYOCGatewayServer) setupStream(ctx context.Context, r *http.Request,
 		dataURL string
 	)
 
-	updateURL := fmt.Sprintf("https://%s/ai/stream/%s/%s", bsg.node.GatewayHost, streamID, "update")
-	statusURL := fmt.Sprintf("https://%s/ai/stream/%s/%s", bsg.node.GatewayHost, streamID, "status")
-	stopURL := fmt.Sprintf("https://%s/ai/stream/%s/%s", bsg.node.GatewayHost, streamID, "stop")
+	updateURL := fmt.Sprintf("https://%s/process/stream/%s/%s", bsg.node.GatewayHost, streamID, "update")
+	statusURL := fmt.Sprintf("https://%s/process/stream/%s/%s", bsg.node.GatewayHost, streamID, "status")
+	stopURL := fmt.Sprintf("https://%s/process/stream/%s/%s", bsg.node.GatewayHost, streamID, "stop")
 
 	if job.Job.Params.EnableVideoIngress {
-		whipURL = fmt.Sprintf("https://%s/ai/stream/%s/%s", bsg.node.GatewayHost, streamID, "whip")
+		whipURL = fmt.Sprintf("https://%s/process/stream/%s/%s", bsg.node.GatewayHost, streamID, "whip")
 		rtmpURL = mediaMTXInputURL
 	}
 	if job.Job.Params.EnableVideoEgress {
 		whepURL = generateWhepUrl(streamID, requestID)
 	}
 	if job.Job.Params.EnableDataOutput {
-		dataURL = fmt.Sprintf("https://%s/ai/stream/%s/%s", bsg.node.GatewayHost, streamID, "data")
+		dataURL = fmt.Sprintf("https://%s/process/stream/%s/%s", bsg.node.GatewayHost, streamID, "data")
 	}
 
 	//if set this will overwrite settings above

Original file line number	Diff line number	Diff line change
`@@ -493,19 +493,19 @@ func (bsg BYOCGatewayServer) setupStream(ctx context.Context, r http.Request,`
`493`	`493`	`dataURL string`
`494`	`494`	`)`
`495`	`495`
`496`		`- updateURL := fmt.Sprintf("https://%s/ai/stream/%s/%s", bsg.node.GatewayHost, streamID, "update")`
`497`		`- statusURL := fmt.Sprintf("https://%s/ai/stream/%s/%s", bsg.node.GatewayHost, streamID, "status")`
`498`		`- stopURL := fmt.Sprintf("https://%s/ai/stream/%s/%s", bsg.node.GatewayHost, streamID, "stop")`
	`496`	`+ updateURL := fmt.Sprintf("https://%s/process/stream/%s/%s", bsg.node.GatewayHost, streamID, "update")`
	`497`	`+ statusURL := fmt.Sprintf("https://%s/process/stream/%s/%s", bsg.node.GatewayHost, streamID, "status")`
	`498`	`+ stopURL := fmt.Sprintf("https://%s/process/stream/%s/%s", bsg.node.GatewayHost, streamID, "stop")`
`499`	`499`
`500`	`500`	`if job.Job.Params.EnableVideoIngress {`
`501`		`- whipURL = fmt.Sprintf("https://%s/ai/stream/%s/%s", bsg.node.GatewayHost, streamID, "whip")`
	`501`	`+ whipURL = fmt.Sprintf("https://%s/process/stream/%s/%s", bsg.node.GatewayHost, streamID, "whip")`
`502`	`502`	`rtmpURL = mediaMTXInputURL`
`503`	`503`	`}`
`504`	`504`	`if job.Job.Params.EnableVideoEgress {`
`505`	`505`	`whepURL = generateWhepUrl(streamID, requestID)`
`506`	`506`	`}`
`507`	`507`	`if job.Job.Params.EnableDataOutput {`
`508`		`- dataURL = fmt.Sprintf("https://%s/ai/stream/%s/%s", bsg.node.GatewayHost, streamID, "data")`
	`508`	`+ dataURL = fmt.Sprintf("https://%s/process/stream/%s/%s", bsg.node.GatewayHost, streamID, "data")`
`509`	`509`	`}`
`510`	`510`
`511`	`511`	`//if set this will overwrite settings above`