@@ -50,30 +50,20 @@ func validateStreamOptions(requestID string, user utils.User, jsonMap map[string
5050 return nil
5151}
5252
53+ var defaultRoutingStrategy , defaultRoutingStrategyEnabled = utils .CheckEnvExists (EnvRoutingAlgorithm )
54+
5355// getRoutingStrategy retrieves the routing strategy from the headers or environment variable
5456// It returns the routing strategy value and whether custom routing strategy is enabled.
5557func getRoutingStrategy (headers []* configPb.HeaderValue ) (string , bool ) {
56- var routingStrategy string
57- routingStrategyEnabled := false
58-
5958 // Check headers for routing strategy
6059 for _ , header := range headers {
6160 if strings .ToLower (header .Key ) == HeaderRoutingStrategy {
62- routingStrategy = string (header .RawValue )
63- routingStrategyEnabled = true
64- break // Prioritize header value over environment variable
65- }
66- }
67-
68- // If header not set, check environment variable
69- if ! routingStrategyEnabled {
70- if value , exists := utils .CheckEnvExists (EnvRoutingAlgorithm ); exists {
71- routingStrategy = value
72- routingStrategyEnabled = true
61+ return string (header .RawValue ), true
7362 }
7463 }
7564
76- return routingStrategy , routingStrategyEnabled
65+ // If header not set, use default routing strategy from environment variable
66+ return defaultRoutingStrategy , defaultRoutingStrategyEnabled
7767}
7868
7969// getRequestMessage returns input request message field which has user prompt
0 commit comments