adding proxy configuration for azure openai

Author: csotiriou

model-providers/openai/azure-openai/runtime/src/main/java/io/quarkiverse/langchain4j/azure/openai/runtime/AzureOpenAiRecorder.java

@@ -2,6 +2,9 @@
 
 import static io.quarkiverse.langchain4j.runtime.OptionalUtil.firstOrDefault;
 
+import java.net.InetSocketAddress;
+import java.net.Proxy;
+import java.net.Proxy.Type;
 import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.time.Duration;
@@ -84,6 +87,11 @@ public Function<SyntheticCreationalContext<ChatModel>, ChatModel> chatModel(Stri
                     .frequencyPenalty(chatModelConfig.frequencyPenalty())
                     .responseFormat(chatModelConfig.responseFormat().orElse(null));
 
+            azureAiConfig.proxyHost().ifPresent(host -> {
+                builder.proxy(new Proxy(
+                    Type.valueOf(azureAiConfig.proxyType()),
+                    new InetSocketAddress(host, azureAiConfig.proxyPort())));
+            });
             if (chatModelConfig.maxTokens().isPresent()) {
                 builder.maxTokens(chatModelConfig.maxTokens().get());
             }
@@ -133,6 +141,12 @@ public Function<SyntheticCreationalContext<StreamingChatModel>, StreamingChatMod
                     .frequencyPenalty(chatModelConfig.frequencyPenalty())
                     .responseFormat(chatModelConfig.responseFormat().orElse(null));
 
+            azureAiConfig.proxyHost().ifPresent(host -> {
+                builder.proxy(new Proxy(
+                    Type.valueOf(azureAiConfig.proxyType()),
+                    new InetSocketAddress(host, azureAiConfig.proxyPort())));
+            });
+
             if (chatModelConfig.maxTokens().isPresent()) {
                 builder.maxTokens(chatModelConfig.maxTokens().get());
             }
@@ -176,6 +190,12 @@ public Function<SyntheticCreationalContext<EmbeddingModel>, EmbeddingModel> embe
                     .logRequests(firstOrDefault(false, embeddingModelConfig.logRequests(), azureAiConfig.logRequests()))
                     .logResponses(firstOrDefault(false, embeddingModelConfig.logResponses(), azureAiConfig.logResponses()));
 
+            azureAiConfig.proxyHost().ifPresent(host -> {
+                builder.proxy(new Proxy(
+                    Type.valueOf(azureAiConfig.proxyType()),
+                    new InetSocketAddress(host, azureAiConfig.proxyPort())));
+            });
+
             return new Function<>() {
                 @Override
                 public EmbeddingModel apply(SyntheticCreationalContext<EmbeddingModel> context) {

model-providers/openai/azure-openai/runtime/src/main/java/io/quarkiverse/langchain4j/azure/openai/runtime/config/LangChain4jAzureOpenAiConfig.java

@@ -136,6 +136,23 @@ interface AzureAiConfig {
         @WithDefault("true")
         Boolean enableIntegration();
 
+        /**
+         * The Proxy type
+         */
+        @WithDefault("HTTP")
+        String proxyType();
+
+        /**
+         * The Proxy host
+         */
+        Optional<String> proxyHost();
+
+        /**
+         * The Proxy port
+         */
+        @WithDefault("3128")
+        Integer proxyPort();
+
         /**
          * Chat model related settings
          */