This is an automated email from the ASF dual-hosted git repository. xiaoyu pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/shenyu.git
The following commit(s) were added to refs/heads/master by this push: new 7f50a51b37 [refactor] ai proxy plugin refactor (#5952) 7f50a51b37 is described below commit 7f50a51b37147c0d73beffe9ae3acbe5b75cceb9 Author: aias00 <liuhon...@apache.org> AuthorDate: Fri Mar 7 13:37:57 2025 +0800 [refactor] ai proxy plugin refactor (#5952) --- .../main/java/org/apache/shenyu/plugin/ai/proxy/AiProxyPlugin.java | 3 --- .../org/apache/shenyu/plugin/ai/proxy/strategy/openai/OpenAI.java | 4 +++- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/shenyu-plugin/shenyu-plugin-ai-proxy/src/main/java/org/apache/shenyu/plugin/ai/proxy/AiProxyPlugin.java b/shenyu-plugin/shenyu-plugin-ai-proxy/src/main/java/org/apache/shenyu/plugin/ai/proxy/AiProxyPlugin.java index d11f2939d7..c348af7440 100644 --- a/shenyu-plugin/shenyu-plugin-ai-proxy/src/main/java/org/apache/shenyu/plugin/ai/proxy/AiProxyPlugin.java +++ b/shenyu-plugin/shenyu-plugin-ai-proxy/src/main/java/org/apache/shenyu/plugin/ai/proxy/AiProxyPlugin.java @@ -88,9 +88,6 @@ public class AiProxyPlugin extends AbstractShenyuPlugin { exchange.getAttributes().put(Constants.CONTEXT, shenyuContext); // set domain - // TODO fix the domain - // String domain = aiProxyConfig.getBaseUrl() + realUrl; - exchange.getAttributes().put(Constants.HTTP_DOMAIN, aiProxyConfig.getBaseUrl()); // set the http timeout exchange.getAttributes().put(Constants.HTTP_TIME_OUT, 60 * 3000L); diff --git a/shenyu-plugin/shenyu-plugin-ai-proxy/src/main/java/org/apache/shenyu/plugin/ai/proxy/strategy/openai/OpenAI.java b/shenyu-plugin/shenyu-plugin-ai-proxy/src/main/java/org/apache/shenyu/plugin/ai/proxy/strategy/openai/OpenAI.java index a1c7b84e13..5320ebf15a 100644 --- a/shenyu-plugin/shenyu-plugin-ai-proxy/src/main/java/org/apache/shenyu/plugin/ai/proxy/strategy/openai/OpenAI.java +++ b/shenyu-plugin/shenyu-plugin-ai-proxy/src/main/java/org/apache/shenyu/plugin/ai/proxy/strategy/openai/OpenAI.java @@ -62,7 +62,9 @@ public class OpenAI implements AiModel { private static void convertHeader(final HttpHeaders httpHeaders, final AiProxyConfig aiProxyConfig) { - httpHeaders.add("Authorization", "Bearer " + aiProxyConfig.getApiKey()); + if (!httpHeaders.containsKey("Authorization")) { + httpHeaders.add("Authorization", "Bearer " + aiProxyConfig.getApiKey()); + } if (aiProxyConfig.getStream()) { httpHeaders.add(HttpHeaders.CONTENT_TYPE, MediaType.TEXT_EVENT_STREAM_VALUE); httpHeaders.add(HttpHeaders.CACHE_CONTROL, "no-cache");