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 <[email protected]>
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");