прокси

Author: Manjago

src/main/java/com/temnenkov/mz/Main.java

@@ -12,7 +12,7 @@ public class Main {
     public static void main(String[] args) {
         try {
             final Config config = ConfigLoader.loadConfig(args[0]);
-            new TgInbound(config.getToken()).loop();
+            new TgInbound(config.getToken(), config.getProxyHost(), config.getProxyPort()).loop();
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
             logger.error("Interrupted", e);

src/main/java/com/temnenkov/mz/config/Config.java

@@ -2,9 +2,21 @@
 
 public class Config {
     private final String token;
+    private final String proxyHost;
+    private final Integer proxyPort;
 
-    public Config(String token) {
+    public Config(String token, String proxyHost, Integer proxyPort) {
         this.token = token;
+        this.proxyHost = proxyHost;
+        this.proxyPort = proxyPort;
+    }
+
+    public Integer getProxyPort() {
+        return proxyPort;
+    }
+
+    public String getProxyHost() {
+        return proxyHost;
     }
 
     public String getToken() {

src/main/java/com/temnenkov/mz/config/ConfigLoader.java

@@ -4,17 +4,24 @@
 import org.jetbrains.annotations.NotNull;
 
 import java.io.FileInputStream;
-import java.io.FileNotFoundException;
 import java.io.IOException;
 import java.util.Properties;
 
 public class ConfigLoader {
+
+    private ConfigLoader() {
+    }
+
     @Contract("_ -> new")
     public static @NotNull Config loadConfig(@NotNull String fileName) throws IOException {
         final Properties properties = new Properties();
         try (FileInputStream input = new FileInputStream(fileName)) {
             properties.load(input);
-            return new Config(properties.getProperty("token"));
+            return new Config(
+                    properties.getProperty("token"),
+                    properties.getProperty("proxy.host"),
+                    Integer.parseInt(properties.getProperty("proxy.port", "0"))
+            );
         }
     }
 }

src/main/java/com/temnenkov/mz/ports/tg/TgInbound.java

@@ -3,10 +3,13 @@
 import com.temnenkov.mz.Main;
 import com.temnenkov.mz.ports.tg.dto.GetUpdatesRequest;
 import com.temnenkov.mz.utils.JsonUtils;
+import org.jetbrains.annotations.Nullable;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
+import java.net.InetSocketAddress;
+import java.net.ProxySelector;
 import java.net.URI;
 import java.net.http.HttpClient;
 import java.net.http.HttpRequest;
@@ -17,12 +20,20 @@ public class TgInbound {
     private static final Logger logger = LoggerFactory.getLogger(TgInbound.class);
     private static final String CONTENT_TYPE_VALUE = "application/json";
     private static final String CONTENT_TYPE = "Content-Type";
-    private final HttpClient httpClient =
-            HttpClient.newBuilder().version(HttpClient.Version.HTTP_1_1).connectTimeout(Duration.ofSeconds(5L)).build();
+    private final HttpClient httpClient;
     private final String url;
 
-    public TgInbound(String token) {
-        url = "https://api.telegram.org/bot" + token + "/sendMessage";
+    public TgInbound(String token, @Nullable String proxyHost, int proxyPort) {
+
+        final HttpClient.Builder builder = HttpClient.newBuilder().version(HttpClient.Version.HTTP_1_1).connectTimeout(Duration.ofSeconds(5L));
+
+        if (proxyHost != null) {
+            builder.proxy(ProxySelector.of(new InetSocketAddress(proxyHost, proxyPort)));
+        }
+
+        httpClient = builder.build();
+
+        url = "https://api.telegram.org/bot" + token + "/getUpdates";
     }
 
     public void loop() throws IOException, InterruptedException {