From 38c8e07ef7d0e018d54aab61fcd4ffb9194a1d1e Mon Sep 17 00:00:00 2001
From: Royce59 <admin@rosetta.im>
Date: Sat, 21 Feb 2026 00:02:51 +0200
Subject: [PATCH] =?UTF-8?q?=D0=A3=D0=BB=D1=83=D1=87=D1=88=D0=B5=D0=BD?=
 =?UTF-8?q?=D0=BD=D0=BE=D0=B5=20=D0=BF=D0=BE=D0=BB=D1=83=D1=87=D0=B5=D0=BD?=
 =?UTF-8?q?=D0=B8=D0=B5=20IP=20=D0=B0=D0=B4=D1=80=D0=B5=D1=81=D0=B0=20?=
 =?UTF-8?q?=D0=B7=D0=B0=20nginx?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/io/orprotocol/Server.java       | 12 ++++++++++-
 .../java/io/orprotocol/client/Client.java     | 20 +++++++++++++++++++
 2 files changed, 31 insertions(+), 1 deletion(-)

diff --git a/src/main/java/io/orprotocol/Server.java b/src/main/java/io/orprotocol/Server.java
index 658e523..3ac0588 100644
--- a/src/main/java/io/orprotocol/Server.java
+++ b/src/main/java/io/orprotocol/Server.java
@@ -155,13 +155,23 @@ public class Server extends WebSocketServer {
     }    
 
     @Override
-    public void onOpen(WebSocket socket, ClientHandshake arg1) {
+    public void onOpen(WebSocket socket, ClientHandshake handshake) {
         /**
          * Создаем нового клиента при открытии соединения.
          * Передаем интервал heartbeat из настроек сервера.
          * Если клиент не отправляет heartbeat в указанный интервал, его можно отключить.
          */
         Client client = new Client(socket, this.settings.heartbeatInterval, this);
+        String ipAddress = handshake.getFieldValue("X-Forwarded-For");
+        if (ipAddress == null || ipAddress.isEmpty()) {
+            ipAddress = socket.getRemoteSocketAddress().getAddress().getHostAddress();
+        } else {
+            /**
+             * Берем первый IP адрес из списка разделенного запятой
+             */
+            ipAddress = ipAddress.split(",")[0].trim();
+        }        
+        client.setIpAddress(ipAddress);
         socket.setAttachment(client);
         if(this.listener == null){
             return;
diff --git a/src/main/java/io/orprotocol/client/Client.java b/src/main/java/io/orprotocol/client/Client.java
index e42cb45..2879b38 100644
--- a/src/main/java/io/orprotocol/client/Client.java
+++ b/src/main/java/io/orprotocol/client/Client.java
@@ -29,6 +29,10 @@ public class Client {
      * Интервал отправки heartbeat пакетов в миллисекундах.
      */
     public long heartbeatInterval = 0;
+    /**
+     * IP-адрес клиента
+     */
+    private String ipAddress;
     /**
      * Время последнего полученного heartbeat в миллисекундах.
      */
@@ -71,6 +75,22 @@ public class Client {
         this.lastHeartbeatTime = System.currentTimeMillis();
     }
 
+    /**
+     * Получает IP адрес клиента
+     * @return адрес
+     */
+    public String getIpAddress() {
+        return this.ipAddress;
+    }
+
+    /**
+     * Устанавливает IP адрес клиента
+     * @param ipAddress адрес
+     */
+    public void setIpAddress(String ipAddress){
+        this.ipAddress = ipAddress;
+    }
+
     /**
      * Получает уникальный идентификатор клиента.
      * @return Идентификатор клиента.