From 07379beca1c5acc6ca10fd542a624b00c483920b Mon Sep 17 00:00:00 2001
From: RoyceDa <admin@rosetta-im.com>
Date: Mon, 2 Feb 2026 22:48:38 +0200
Subject: [PATCH] =?UTF-8?q?=D0=90=D0=B4=D0=B0=D0=BF=D1=82=D0=B5=D1=80=20?=
 =?UTF-8?q?=D1=81=D0=B5=D1=80=D0=B2=D0=B5=D1=80=D0=B0=20=D0=B8=20=D1=81?=
 =?UTF-8?q?=D0=BC=D0=B5=D0=BD=D0=B0=20=D0=BE=D1=80=D0=B5=D0=B8=D0=BD=D1=82?=
 =?UTF-8?q?=D0=B0=D1=86=D0=B8=D0=B8=20=D0=BE=D1=82=D0=BC=D0=B5=D0=BD=D1=8B?=
 =?UTF-8?q?=20=D1=81=D0=BE=D0=B1=D1=8B=D1=82=D0=B8=D0=B9=20(=D1=82=D0=B5?=
 =?UTF-8?q?=D0=BF=D0=B5=D1=80=D1=8C=20=D0=B0=D0=B4=D0=B0=D0=BF=D1=82=D0=B5?=
 =?UTF-8?q?=D1=80=20=D0=B4=D0=BE=D0=BB=D0=B6=D0=B5=D0=BD=20=D0=B2=D0=B5?=
 =?UTF-8?q?=D1=80=D0=BD=D1=83=D1=82=D1=8C=20true=20=D1=87=D1=82=D0=BE?=
 =?UTF-8?q?=D0=B1=D1=8B=20=D0=BF=D1=80=D0=BE=D0=B4=D0=BE=D0=BB=D0=B6=D0=B8?=
 =?UTF-8?q?=D1=82=D1=8C=20=D0=BE=D0=B1=D1=80=D0=B0=D0=B1=D0=BE=D1=82=D0=BA?=
 =?UTF-8?q?=D1=83=20=D0=BF=D0=B0=D0=BA=D0=B5=D1=82=D0=B0=20=D0=B8=20false?=
 =?UTF-8?q?=20=D0=B5=D1=81=D0=BB=D0=B8=20=D0=BF=D0=B0=D0=BA=D0=B5=D1=82=20?=
 =?UTF-8?q?=D0=BE=D0=B1=D1=80=D0=B0=D0=B1=D0=B0=D1=82=D1=8B=D0=B2=D0=B0?=
 =?UTF-8?q?=D1=82=D1=8C=20=D0=BD=D0=B5=20=D0=BD=D1=83=D0=B6=D0=BD=D0=BE)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/rosetta/im/ServerAdapter.java    | 36 +++++++++++++++++++
 src/main/java/io/orprotocol/Server.java       |  6 ++--
 .../java/io/orprotocol/ServerListener.java    | 24 ++++++-------
 3 files changed, 51 insertions(+), 15 deletions(-)
 create mode 100644 src/main/java/com/rosetta/im/ServerAdapter.java

diff --git a/src/main/java/com/rosetta/im/ServerAdapter.java b/src/main/java/com/rosetta/im/ServerAdapter.java
new file mode 100644
index 0000000..f0c546c
--- /dev/null
+++ b/src/main/java/com/rosetta/im/ServerAdapter.java
@@ -0,0 +1,36 @@
+package com.rosetta.im;
+
+import io.orprotocol.Server;
+import io.orprotocol.ServerListener;
+import io.orprotocol.client.Client;
+import io.orprotocol.packet.Packet;
+
+public class ServerAdapter implements ServerListener {
+
+    @Override
+    public void onServerStart(Server server) {}
+
+    @Override
+    public void onServerStop(Server server) {}
+
+    @Override
+    public boolean onClientConnect(Server server, Client client) {
+        
+        return true;
+    }
+
+    @Override
+    public void onClientDisconnect(Server server, Client client) {}
+
+    @Override
+    public void onError(Server server, Exception exception) {
+        System.out.println("Server error: " + exception.getMessage());
+    }
+
+    @Override
+    public boolean onPacketReceived(Server server, Client client, Packet packet) {
+        
+        return true;
+    }
+
+}
diff --git a/src/main/java/io/orprotocol/Server.java b/src/main/java/io/orprotocol/Server.java
index 25122ac..26dde38 100644
--- a/src/main/java/io/orprotocol/Server.java
+++ b/src/main/java/io/orprotocol/Server.java
@@ -130,9 +130,9 @@ public class Server extends WebSocketServer {
             PacketExecutor executor = executorClass.getConstructor().newInstance();
             executor.settings = this.settings;
             executor.context = this.context;
-            if(listener != null && listener.onPacketReceived(this, client, packet)) {
+            if(listener != null && !listener.onPacketReceived(this, client, packet)) {
                 /**
-                 * Если слушатель сервера вернул true, пакет не обрабатываем.
+                 * Если слушатель сервера вернул false, пакет не обрабатываем.
                  */
                 return;
             }
@@ -155,7 +155,7 @@ public class Server extends WebSocketServer {
         if(this.listener == null){
             return;
         }
-        if(this.listener.onClientConnect(this, client)) {
+        if(!this.listener.onClientConnect(this, client)) {
             client.disconnect(ServerFailures.SERVER_NOT_ACCEPT_CLIENT);
             return;
         }
diff --git a/src/main/java/io/orprotocol/ServerListener.java b/src/main/java/io/orprotocol/ServerListener.java
index bff82c4..6daacb1 100644
--- a/src/main/java/io/orprotocol/ServerListener.java
+++ b/src/main/java/io/orprotocol/ServerListener.java
@@ -6,19 +6,19 @@ import io.orprotocol.packet.Packet;
 public interface ServerListener {
     /**
      * Сервер запущен
-     * @param server
+     * @param server сервер
      */
     void onServerStart(Server server);
     /**
      * Сервер остановлен
-     * @param server
+     * @param server сервер
      */
     void onServerStop(Server server);
     /**
-     * Клиент подключился
-     * @param server
-     * @param client
-     * @return если возвращено true значит клиент не будет подключен к серверу выбросится
+     * Клиент подключился, вернуть false чтобы отклонить подключение
+     * @param server сервер
+     * @param client клиент
+     * @return если возвращено false значит клиент не будет подключен к серверу выбросится
      * ошибка SERVER_NOT_ACCEPT_CLIENT
      */
     boolean onClientConnect(Server server, Client client);
@@ -30,16 +30,16 @@ public interface ServerListener {
     void onClientDisconnect(Server server, Client client);
     /**
      * Произошла ошибка сервера
-     * @param server
-     * @param exception
+     * @param server сервер
+     * @param exception исключение
      */
     void onError(Server server, Exception exception);
     /**
      * Пакет получен от клиента
-     * @param server
-     * @param client
-     * @param packet
-     * @return если возвращено true значит пакет не будет обработан дальше
+     * @param server сервер
+     * @param client клиент
+     * @param packet пакет
+     * @return если возвращено false значит пакет не будет обработан дальше
      */
     boolean onPacketReceived(Server server, Client client, Packet packet);
 }