From ca562e90c1a7cab57f63a5f19b15ff3e9da18e7f Mon Sep 17 00:00:00 2001
From: RoyceDa <admin@rosetta-im.com>
Date: Mon, 2 Feb 2026 00:37:31 +0200
Subject: [PATCH] init

---
 .vscode/settings.json                         |  14 ++
 pom.xml                                       |  28 +++
 src/main/java/com/rosetta/im/Main.java        |  20 ++
 .../java/com/rosetta/im/device/Device.java    |  39 ++++
 .../im/executors/Executor0Handshake.java      |  13 ++
 .../rosetta/im/packet/Packet0Handshake.java   |  83 ++++++++
 .../im/packet/enums/HandshakeStage.java       |  36 ++++
 .../java/com/rosetta/im/protocol/Client.java  |  46 +++++
 .../java/com/rosetta/im/protocol/Server.java  |  70 +++++++
 .../java/com/rosetta/im/protocol/Stream.java  | 179 ++++++++++++++++++
 .../rosetta/im/protocol/packet/Packet.java    |  31 +++
 .../im/protocol/packet/PacketExecutor.java    |   5 +
 .../im/protocol/packet/PacketManager.java     |  35 ++++
 .../rosetta/im/protocol/util/StringUtil.java  |  15 ++
 target/classes/com/rosetta/im/Main.class      | Bin 0 -> 996 bytes
 .../com/rosetta/im/device/Device.class        | Bin 0 -> 1064 bytes
 .../im/executors/Executor0Handshake.class     | Bin 0 -> 710 bytes
 .../rosetta/im/packet/Packet0Handshake.class  | Bin 0 -> 1832 bytes
 .../im/packet/enums/HandshakeStage.class      | Bin 0 -> 2092 bytes
 .../com/rosetta/im/protocol/Client.class      | Bin 0 -> 1783 bytes
 .../com/rosetta/im/protocol/Server.class      | Bin 0 -> 3828 bytes
 .../com/rosetta/im/protocol/Stream.class      | Bin 0 -> 5109 bytes
 .../rosetta/im/protocol/packet/Packet.class   | Bin 0 -> 511 bytes
 .../im/protocol/packet/PacketExecutor.class   | Bin 0 -> 275 bytes
 .../im/protocol/packet/PacketManager.class    | Bin 0 -> 2462 bytes
 .../rosetta/im/protocol/util/StringUtil.class | Bin 0 -> 956 bytes
 26 files changed, 614 insertions(+)
 create mode 100644 .vscode/settings.json
 create mode 100644 pom.xml
 create mode 100644 src/main/java/com/rosetta/im/Main.java
 create mode 100644 src/main/java/com/rosetta/im/device/Device.java
 create mode 100644 src/main/java/com/rosetta/im/executors/Executor0Handshake.java
 create mode 100644 src/main/java/com/rosetta/im/packet/Packet0Handshake.java
 create mode 100644 src/main/java/com/rosetta/im/packet/enums/HandshakeStage.java
 create mode 100644 src/main/java/com/rosetta/im/protocol/Client.java
 create mode 100644 src/main/java/com/rosetta/im/protocol/Server.java
 create mode 100644 src/main/java/com/rosetta/im/protocol/Stream.java
 create mode 100644 src/main/java/com/rosetta/im/protocol/packet/Packet.java
 create mode 100644 src/main/java/com/rosetta/im/protocol/packet/PacketExecutor.java
 create mode 100644 src/main/java/com/rosetta/im/protocol/packet/PacketManager.java
 create mode 100644 src/main/java/com/rosetta/im/protocol/util/StringUtil.java
 create mode 100644 target/classes/com/rosetta/im/Main.class
 create mode 100644 target/classes/com/rosetta/im/device/Device.class
 create mode 100644 target/classes/com/rosetta/im/executors/Executor0Handshake.class
 create mode 100644 target/classes/com/rosetta/im/packet/Packet0Handshake.class
 create mode 100644 target/classes/com/rosetta/im/packet/enums/HandshakeStage.class
 create mode 100644 target/classes/com/rosetta/im/protocol/Client.class
 create mode 100644 target/classes/com/rosetta/im/protocol/Server.class
 create mode 100644 target/classes/com/rosetta/im/protocol/Stream.class
 create mode 100644 target/classes/com/rosetta/im/protocol/packet/Packet.class
 create mode 100644 target/classes/com/rosetta/im/protocol/packet/PacketExecutor.class
 create mode 100644 target/classes/com/rosetta/im/protocol/packet/PacketManager.class
 create mode 100644 target/classes/com/rosetta/im/protocol/util/StringUtil.class

diff --git a/.vscode/settings.json b/.vscode/settings.json
new file mode 100644
index 0000000..f8f0c7b
--- /dev/null
+++ b/.vscode/settings.json
@@ -0,0 +1,14 @@
+{
+    "files.exclude": {
+        "**/.git": true,
+        "**/.svn": true,
+        "**/.hg": true,
+        "**/.DS_Store": true,
+        "**/Thumbs.db": true,
+        ".DS_Store": true,
+        "._*": true,
+        "**/._*": true
+    },
+    "java.project.explorer.showNonJavaResources": false,
+    "java.configuration.updateBuildConfiguration": "interactive"
+}
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..19b9e3e
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,28 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.rosetta.im</groupId>
+    <artifactId>rosetta-server</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <properties>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+    </properties>
+
+
+
+    <dependencies>
+    
+
+        <dependency>
+            <groupId>org.java-websocket</groupId>
+            <artifactId>Java-WebSocket</artifactId>
+            <version>1.6.0</version>
+        </dependency>
+
+    </dependencies>
+</project>
\ No newline at end of file
diff --git a/src/main/java/com/rosetta/im/Main.java b/src/main/java/com/rosetta/im/Main.java
new file mode 100644
index 0000000..f09e66a
--- /dev/null
+++ b/src/main/java/com/rosetta/im/Main.java
@@ -0,0 +1,20 @@
+package com.rosetta.im;
+
+
+import com.rosetta.im.packet.Packet0Handshake;
+import com.rosetta.im.protocol.Server;
+import com.rosetta.im.protocol.packet.PacketManager;
+
+public class Main {
+    public static void main(String[] args) {
+        PacketManager manager = new PacketManager();
+        manager.registerPacket(0, Packet0Handshake.class);
+
+
+        Server server = new Server(8881, manager);
+        server.start();
+
+
+        System.out.println("Rosetta server started...");
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/com/rosetta/im/device/Device.java b/src/main/java/com/rosetta/im/device/Device.java
new file mode 100644
index 0000000..e3ebfb9
--- /dev/null
+++ b/src/main/java/com/rosetta/im/device/Device.java
@@ -0,0 +1,39 @@
+package com.rosetta.im.device;
+
+public class Device {
+    
+    public String deviceId;
+    public String deviceName;
+    public String deviceOs;
+
+    public Device(String deviceId, String deviceName, String deviceOs) {
+        this.deviceId = deviceId;
+        this.deviceName = deviceName;
+        this.deviceOs = deviceOs;
+    }
+
+    public String getDeviceId() {
+        return deviceId;
+    }
+
+    public String getDeviceName() {
+        return deviceName;
+    }
+
+    public String getDeviceOs() {
+        return deviceOs;
+    }
+
+    public void setDeviceId(String deviceId) {
+        this.deviceId = deviceId;
+    }
+
+    public void setDeviceName(String deviceName) {
+        this.deviceName = deviceName;
+    }
+
+    public void setDeviceOs(String deviceOs) {
+        this.deviceOs = deviceOs;
+    }
+
+}
diff --git a/src/main/java/com/rosetta/im/executors/Executor0Handshake.java b/src/main/java/com/rosetta/im/executors/Executor0Handshake.java
new file mode 100644
index 0000000..349fab1
--- /dev/null
+++ b/src/main/java/com/rosetta/im/executors/Executor0Handshake.java
@@ -0,0 +1,13 @@
+package com.rosetta.im.executors;
+
+import com.rosetta.im.protocol.packet.Packet;
+import com.rosetta.im.protocol.packet.PacketExecutor;
+
+public class Executor0Handshake implements PacketExecutor {
+
+    @Override
+    public void onPacketReceived(Class<? extends Packet> packet) {
+        
+    }
+
+}
diff --git a/src/main/java/com/rosetta/im/packet/Packet0Handshake.java b/src/main/java/com/rosetta/im/packet/Packet0Handshake.java
new file mode 100644
index 0000000..6389fce
--- /dev/null
+++ b/src/main/java/com/rosetta/im/packet/Packet0Handshake.java
@@ -0,0 +1,83 @@
+package com.rosetta.im.packet;
+
+import com.rosetta.im.device.Device;
+import com.rosetta.im.packet.enums.HandshakeStage;
+import com.rosetta.im.protocol.Stream;
+import com.rosetta.im.protocol.packet.Packet;
+
+/**
+ * Пакет хэндшейка между клиентом и сервером.
+ * Используется для установления соединения и подтверждения от сервера что клиент
+ * тот за кого себя выдает.
+ * 
+ * Протокол таблица:
+ * 0 - packetId (int16)
+ * 1 - privateKey (string)
+ * 2 - publicKey (string)
+ * 3 - protocolVersion (int8)
+ * 4 - heartbeatInterval (int8)
+ * 5 - deviceId (string)
+ * 6 - deviceName (string)
+ * 7 - deviceOs (string)
+ * 8 - handshakeStage (int8)
+ */
+public class Packet0Handshake extends Packet {
+    /**
+     * Публичный и приватный ключи клиента
+     */
+    private String publicKey;
+    private String privateKey;
+    /**
+     * Версия протокола клиента
+     */
+    private int protocolVersion = 1;
+
+    /**
+     * Интервал отправки heartbeat пакетов в секундах
+     */
+    private int heartbeatInterval = 15;
+
+    /**
+     * Минимальная информация об устройстве клиента
+     */
+    private Device device;
+
+    /**
+     * Стадия рукопожатия
+     * 0 - COMPLETED
+     * 1 - NEED_DEVICE_VERIFICATION
+     */
+    private HandshakeStage handshakeStage = HandshakeStage.COMPLETED;
+
+
+    @Override
+    public Stream write() {
+        Stream stream = new Stream();
+        stream.writeInt16(this.packetId);
+        stream.writeString(this.privateKey);
+        stream.writeString(this.publicKey);
+        stream.writeInt8(this.protocolVersion);
+        stream.writeInt8(this.heartbeatInterval);
+        stream.writeString(this.device.getDeviceId());
+        stream.writeString(this.device.getDeviceName());
+        stream.writeString(this.device.getDeviceOs());
+        stream.writeInt8(this.handshakeStage.getCode());
+        return stream;
+    }
+
+    @Override
+    public void read(Stream stream) {
+        this.privateKey = stream.readString();
+        this.publicKey = stream.readString();
+        this.protocolVersion = stream.readInt8();
+        this.heartbeatInterval = stream.readInt8();
+        String deviceId = stream.readString();
+        String deviceName = stream.readString();
+        String deviceOs = stream.readString();
+        this.device = new Device(deviceId, deviceName, deviceOs);
+        this.handshakeStage = HandshakeStage.fromCode(
+            stream.readInt8()
+        );
+    }
+
+}
diff --git a/src/main/java/com/rosetta/im/packet/enums/HandshakeStage.java b/src/main/java/com/rosetta/im/packet/enums/HandshakeStage.java
new file mode 100644
index 0000000..a581057
--- /dev/null
+++ b/src/main/java/com/rosetta/im/packet/enums/HandshakeStage.java
@@ -0,0 +1,36 @@
+package com.rosetta.im.packet.enums;
+
+/**
+ * Этапы хэндшейка между клиентом и сервером.
+ */
+public enum HandshakeStage {
+    /**
+     * Успешный хэндшейк
+     * Такой пользователь может авторизованно взаимодействовать с сервером
+     */
+    COMPLETED(0),
+    /**
+     * Необходима верификация устройства
+     * Такой пользователь должен подтвердить устройство (например, через код на другом устройстве)
+     */
+    NEED_DEVICE_VERIFICATION(1);
+
+    private final int code;
+
+    HandshakeStage(int code) {
+        this.code = code;
+    }
+
+    public int getCode() {
+        return code;
+    }
+
+    public static HandshakeStage fromCode(int code) {
+        for (HandshakeStage stage : HandshakeStage.values()) {
+            if (stage.getCode() == code) {
+                return stage;
+            }
+        }
+        throw new IllegalArgumentException("Invalid HandshakeStage code: " + code);
+    }
+}
diff --git a/src/main/java/com/rosetta/im/protocol/Client.java b/src/main/java/com/rosetta/im/protocol/Client.java
new file mode 100644
index 0000000..58b04a0
--- /dev/null
+++ b/src/main/java/com/rosetta/im/protocol/Client.java
@@ -0,0 +1,46 @@
+package com.rosetta.im.protocol;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.java_websocket.WebSocket;
+
+import com.rosetta.im.protocol.util.StringUtil;
+
+public class Client {
+
+    public WebSocket socket;
+    public String clientId;
+    public Map<String, Object> clientData;
+
+    public Client(WebSocket socket) {
+        this.socket = socket;
+        this.clientId = StringUtil.randomString(32);
+        this.clientData = new HashMap<>();
+    }
+
+    public String getClientId() {
+        return clientId;
+    }
+
+    public Map<String, Object> getClientData() {
+        return clientData;
+    }
+
+    public void setClientId(String clientId) {
+        this.clientId = clientId;
+    }
+
+    public void setData(String key, Object value) {
+        this.clientData.put(key, value);
+    }
+
+    public void setData(Map<String, Object> data) {
+        this.clientData = data;
+    }
+
+    public Object getData(String key) {
+        return this.clientData.get(key);
+    }
+
+}
diff --git a/src/main/java/com/rosetta/im/protocol/Server.java b/src/main/java/com/rosetta/im/protocol/Server.java
new file mode 100644
index 0000000..f1bfaf0
--- /dev/null
+++ b/src/main/java/com/rosetta/im/protocol/Server.java
@@ -0,0 +1,70 @@
+package com.rosetta.im.protocol;
+
+import java.net.InetSocketAddress;
+import java.nio.ByteBuffer;
+
+import org.java_websocket.WebSocket;
+import org.java_websocket.handshake.ClientHandshake;
+import org.java_websocket.server.WebSocketServer;
+
+import com.rosetta.im.protocol.packet.Packet;
+import com.rosetta.im.protocol.packet.PacketManager;
+
+public class Server extends WebSocketServer {
+
+    private PacketManager packetManager;
+
+    public Server(int port, PacketManager packetManager) {
+        super(new InetSocketAddress(port));
+        this.packetManager = packetManager;
+    }
+
+    @Override
+    public void onClose(WebSocket arg0, int arg1, String arg2, boolean arg3) {
+
+    }
+
+    @Override
+    public void onError(WebSocket arg0, Exception arg1) {
+
+    }
+
+    @Override
+    public void onMessage(WebSocket arg0, String arg1) {
+
+    }
+
+    @Override
+    public void onMessage(WebSocket socket, ByteBuffer byteBuffer) {
+        Client client = socket.getAttachment();
+        
+        byte[] bytes = byteBuffer.array();
+        Stream stream = new Stream(bytes);
+        int packetId = stream.readInt16();
+        Class<? extends Packet> packetClass = this.packetManager.getPacketClass(packetId);
+        if(packetClass == null){
+            System.out.println("Received unknown packet with id: " + packetId);
+            return;
+        }
+        try {
+            Packet packet = packetClass.getConstructor().newInstance();
+            packet.packetId = packetId;
+            packet.read(stream);
+            System.out.println("Received packet: " + packetClass.getSimpleName());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }    
+
+    @Override
+    public void onOpen(WebSocket socket, ClientHandshake arg1) {
+        Client client = new Client(socket);
+        socket.setAttachment(client);
+    }
+
+    @Override
+    public void onStart() {
+        
+    }
+
+}
diff --git a/src/main/java/com/rosetta/im/protocol/Stream.java b/src/main/java/com/rosetta/im/protocol/Stream.java
new file mode 100644
index 0000000..b54ee64
--- /dev/null
+++ b/src/main/java/com/rosetta/im/protocol/Stream.java
@@ -0,0 +1,179 @@
+package com.rosetta.im.protocol;
+
+public class Stream {
+    
+    private byte[] stream;
+    private int readPointer = 0;
+    private int writePointer = 0;
+
+    public Stream() {
+        this.stream = new byte[0];
+    }
+
+    public Stream(byte[] stream) {
+        this.stream = stream;
+    }
+
+    public byte[] getStream() {
+        return this.stream;
+    }
+
+    public void setStream(byte[] stream) {
+        this.stream = stream;
+    }
+
+    public void writeInt8(int value) {
+        int negationBit = value < 0 ? 1 : 0;
+        int int8Value = Math.abs(value) & 0xFF;
+        
+        ensureCapacity(writePointer >> 3);
+        stream[writePointer >> 3] |= (byte)(negationBit << (7 - (writePointer & 7)));
+        writePointer++;
+        
+        for (int i = 0; i < 8; i++) {
+            int bit = (int8Value >> (7 - i)) & 1;
+            ensureCapacity(writePointer >> 3);
+            stream[writePointer >> 3] |= (byte)(bit << (7 - (writePointer & 7)));
+            writePointer++;
+        }
+    }
+
+    public int readInt8() {
+        int value = 0;
+        int negationBit = (stream[readPointer >> 3] >> (7 - (readPointer & 7))) & 1;
+        readPointer++;
+        
+        for (int i = 0; i < 8; i++) {
+            int bit = (stream[readPointer >> 3] >> (7 - (readPointer & 7))) & 1;
+            value |= bit << (7 - i);
+            readPointer++;
+        }
+        
+        return negationBit == 1 ? -value : value;
+    }
+
+    public void writeBit(int value) {
+        int bit = value & 1;
+        ensureCapacity(writePointer >> 3);
+        stream[writePointer >> 3] |= (byte)(bit << (7 - (writePointer & 7)));
+        writePointer++;
+    }
+
+    public int readBit() {
+        int bit = (stream[readPointer >> 3] >> (7 - (readPointer & 7))) & 1;
+        readPointer++;
+        return bit;
+    }
+
+    public void writeBoolean(boolean value) {
+        writeBit(value ? 1 : 0);
+    }
+
+    public boolean readBoolean() {
+        return readBit() == 1;
+    }
+
+    public void writeInt16(int value) {
+        writeInt8(value >> 8);
+        writeInt8(value & 0xFF);
+    }
+
+    public int readInt16() {
+        int value = readInt8() << 8;
+        return value | readInt8();
+    }
+
+    public void writeInt32(int value) {
+        writeInt16(value >> 16);
+        writeInt16(value & 0xFFFF);
+    }
+
+    public int readInt32() {
+        int value = readInt16() << 16;
+        return value | readInt16();
+    }
+
+    public void writeInt64(long value) {
+        int high = (int)(value >> 32);
+        int low = (int)value;
+        writeInt32(high);
+        writeInt32(low);
+    }
+
+    public long readInt64() {
+        long high = readInt32();
+        long low = readInt32() & 0xFFFFFFFFL;
+        return (high << 32) | low;
+    }
+
+    public void writeFloat32(float value) {
+        int floatValue = Float.floatToIntBits(value);
+        writeInt32(floatValue);
+    }
+
+    public float readFloat32() {
+        int floatValue = readInt32();
+        return Float.intBitsToFloat(floatValue);
+    }
+
+    public void writeString(String value) {
+        int length = value.length();
+        writeInt32(length);
+        for (int i = 0; i < value.length(); i++) {
+            writeInt16(value.charAt(i));
+        }
+    }
+
+    public String readString() {
+        int length = readInt32();
+        
+        // Security fix for string length exceeding stream capacity
+        if (length < 0 || length > (stream.length - (readPointer >> 3))) {
+            System.out.println("Stream readString length invalid: " + length + ", stream length: " + stream.length + ", readPointer: " + readPointer);
+            return "";
+        }
+        
+        StringBuilder value = new StringBuilder();
+        for (int i = 0; i < length; i++) {
+            value.append((char)readInt16());
+        }
+        return value.toString();
+    }
+
+    public void writeBytes(byte[] value) {
+        writeInt32(value.length);
+        for (int i = 0; i < value.length; i++) {
+            writeInt8(value[i]);
+        }
+    }
+
+    public byte[] readBytes() {
+        int length = readInt32();
+        byte[] value = new byte[length];
+        for (int i = 0; i < length; i++) {
+            value[i] = (byte)readInt8();
+        }
+        return value;
+    }
+
+    public boolean isEmpty() {
+        return this.stream.length == 0;
+    }
+
+    public int length() {
+        return this.stream.length;
+    }
+
+    public byte[] getBuffer() {
+        return this.stream;
+    }
+
+    private void ensureCapacity(int byteIndex) {
+        if (byteIndex >= stream.length) {
+            byte[] newStream = new byte[byteIndex + 1];
+            System.arraycopy(stream, 0, newStream, 0, stream.length);
+            stream = newStream;
+        }
+    }
+
+}
diff --git a/src/main/java/com/rosetta/im/protocol/packet/Packet.java b/src/main/java/com/rosetta/im/protocol/packet/Packet.java
new file mode 100644
index 0000000..bb74db9
--- /dev/null
+++ b/src/main/java/com/rosetta/im/protocol/packet/Packet.java
@@ -0,0 +1,31 @@
+package com.rosetta.im.protocol.packet;
+
+import com.rosetta.im.protocol.Stream;
+
+/**
+ * Представляет собой абстрактный класс для всех пакетов, используемых в протоколе.
+ */
+public abstract class Packet {
+
+    public int packetId;
+    public PacketManager packetManager;
+
+    public Packet() {
+
+    }
+
+    /**
+     * Записывает данные пакета в поток. Исползуется при отправке
+     * 
+     * @return Поток с записанными данными пакета.
+     */
+    public abstract Stream write();
+
+    /**
+     * Читает данные пакета из потока. Используется при получении
+     * 
+     * @param stream Поток с данными пакета.
+     */
+    public abstract void read(Stream stream);
+
+}
diff --git a/src/main/java/com/rosetta/im/protocol/packet/PacketExecutor.java b/src/main/java/com/rosetta/im/protocol/packet/PacketExecutor.java
new file mode 100644
index 0000000..bca1a0a
--- /dev/null
+++ b/src/main/java/com/rosetta/im/protocol/packet/PacketExecutor.java
@@ -0,0 +1,5 @@
+package com.rosetta.im.protocol.packet;
+
+public interface PacketExecutor {
+    public void onPacketReceived(Class <? extends Packet> packet);
+}
diff --git a/src/main/java/com/rosetta/im/protocol/packet/PacketManager.java b/src/main/java/com/rosetta/im/protocol/packet/PacketManager.java
new file mode 100644
index 0000000..cabd5dd
--- /dev/null
+++ b/src/main/java/com/rosetta/im/protocol/packet/PacketManager.java
@@ -0,0 +1,35 @@
+package com.rosetta.im.protocol.packet;
+
+import java.util.HashMap;
+
+public class PacketManager {
+
+    private HashMap<Integer, Class<? extends Packet>> packets;
+
+    public PacketManager() {
+        this.packets = new HashMap<>();
+    }
+
+    public void registerPacket(int packetId, Class<? extends Packet> packet) {
+        this.packets.put(packetId, packet);
+    }
+
+    public boolean isPacketRegistred(Packet packet) {
+        return this.packets.containsValue(packet.getClass());
+    }
+
+    public Integer getPacketIdByClass(Class<? extends Packet> packetClass) {
+        for (var entry : this.packets.entrySet()) {
+            if (entry.getValue().equals(packetClass)) {
+                return entry.getKey();
+            }
+        }
+        return null;
+    }
+
+    public Class<? extends Packet> getPacketClass(int packetId) {
+        return this.packets.get(packetId);
+    }
+
+
+}
diff --git a/src/main/java/com/rosetta/im/protocol/util/StringUtil.java b/src/main/java/com/rosetta/im/protocol/util/StringUtil.java
new file mode 100644
index 0000000..877f270
--- /dev/null
+++ b/src/main/java/com/rosetta/im/protocol/util/StringUtil.java
@@ -0,0 +1,15 @@
+package com.rosetta.im.protocol.util;
+
+public class StringUtil {
+    
+    public static String randomString(int length) {
+        StringBuilder sb = new StringBuilder();
+        String characters = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789";
+        for (int i = 0; i < length; i++) {
+            int index = (int) (Math.random() * characters.length());
+            sb.append(characters.charAt(index));
+        }
+        return sb.toString();
+    }
+
+}
diff --git a/target/classes/com/rosetta/im/Main.class b/target/classes/com/rosetta/im/Main.class
new file mode 100644
index 0000000000000000000000000000000000000000..33955d8f21ce53ba53052ecf16f68be8b5e93ec1
GIT binary patch
literal 996
zcmb7DU2hUW6g|U77uK~<kSax6TD66OyS08jpuRLQnt(Q9NE)ApWkR>z53)Nn(SKDR
zAhC%*z#nD2yQ`KG`rymlot?Soo_o%npTEBU0PqSg6eJjmrso*G7YHf2VL3*JTdsl>
zL;i%Hal_{B(D=|l5vF8VdTF_qe9e%o)q4!718*QyB$3sS#u7uWZMow8*y#)Z6YtxC
zq0shBZuhuvh5J80Q}Wmf7)tF0rCS8+5Cw+S+UNEqg|751ci5`;6s#~b=Q2mWCq2`%
zjS)9bg)|PM(BUp03SUJYSp~Nkw&&AkZ|}Y3?jShkr_@p&s~T?O4#To9hE^bjA43xB
z+PfKA2R09ah}9ay`aJw!R$bwrg*?i*8!B~=VV_X0yS=CfDiNk{XsCulrvu4-nZ*_!
zD7b&ctL_(K>u7k0ZSu(*lWnD#u;m$tB%&lK1$SB*)ELSiW9O?uM6nv-ih-`{Dt6IS
z(4Yy4T)3L8;SqEOWfTJ1<W{LRqsl+C$V~1J$?M_*FDc!L9b(Y`PYoKym@q^2+RRvW
z8Ys2vjeS$RvBHVWh6ApLEnyR+5IqGTL0>e%v?{bSC^Cxa-6=BX(XmQvcnoB4gH|oR
zK=CH+vRFor{)EY2k%~ZT7sww?=>as7h2jLI3zUymw$2+<R65NG*1uu1uropZ5`T><
u0BTerM~D@|+&}?4C`L7_F)q>Dqk9>egvZ#Ysukk!1W%(Tp3zAH&wm4p#r2~A

literal 0
HcmV?d00001

diff --git a/target/classes/com/rosetta/im/device/Device.class b/target/classes/com/rosetta/im/device/Device.class
new file mode 100644
index 0000000000000000000000000000000000000000..f6959d71e2900d19f8842a0dc40d2fb6fe4e3b31
GIT binary patch
literal 1064
zcma)3+fLg+5Ivh1hd2%)7bvvhl3t|56#QJZ<)sx;r3fCV^6ogRbWsvZ#_(N5BC6B}
zKA<0knAx?QDj3Ae&SmGEnK|?C{_h=tuXtBNL7*K*Q$LO_Ws(HGn))MotwQO4*QNwZ
zVErPv4*W?l8~bO&3mGN?tETG5NTAVQe4i(=nvFjTIOhK}n98j9>{7t~qGl>N7WmYC
z40}nYHxRJCMI-5;h^mV+)&z>(-k=N`)Wr&H_8Klq#%sA)g)LC)tC>8#nhs_BGZ;>2
ztVTZygUKL>6~}4PN`5JtbGQGTDzso_EE6LUYtZWU9uF^2&5Dc=3lM8jA;}jM8##jT
zvem3A<;Y^@aL%KvIFu)f7pfSxBfbYZq(YI-TqH}PkSACYZAlQaCCZfH&|9Hsf&whE
zE$<Ip?_iFa_i>K8cQ{A$hVlh$(7Q=oAe2S8GU3+XqKPWy0ngy^3R@HrlkO|D$DIq>
z<K8^eHeRQleX?A&;@zV5n;g^1*2#5E?V5s=THsACxV{W-<$~L};N~)TD;K<jU7Cdj
zJEl2#C0mQNkjT;5HZ8xS88%H-CX1cQBCwawRbS@XCq(B7E*6&M+t26v?{sFa_r&$#
O2`)Yjb9M9$-aY`B$)xlE

literal 0
HcmV?d00001

diff --git a/target/classes/com/rosetta/im/executors/Executor0Handshake.class b/target/classes/com/rosetta/im/executors/Executor0Handshake.class
new file mode 100644
index 0000000000000000000000000000000000000000..1b3aeadec4f12064f7e93fb468c3c9ee1484aa2e
GIT binary patch
literal 710
zcmb7C%TB^T6g|VE$U_lCP<QT7qT?Q9LwqcV8ZqpLGJ%28A?-l)vs{_D@B{oP<82Ee
zf-!N?`#5vw+<WHs^XvTsz$K1Sh%wY`J>j1Ar7?o5375~(o*C`={Av+h+zPkv55-uf
zkYLyyiMim8a0mRpH<GqV!D2XDqnUczXj?mcD(tZ|{2_EpN(QT;TxFUJ@#;yJA<@!(
znL!-c98%a~$hVa%?`D&p^qxe|kqpJQwuRFbo(l2>m@q@-Q}^~-`@dAwNrQHyfgYtT
z)m-)&O4asCSj!Q<Uk?ULchtZYX6DfZ&5e>qZN2gDy6er5%!(d^p|H`5q5M<d%XF!+
zzFz!~t_+!uo_V&sR>2!qmJ3+z^gK|FW6&n(OVXbaBTqXZo2HDDXXKNoZ^*oc$2qcA
z2wK>tI2RRQ2YJfqbx|OaVpzKulH7zbodpDOy09e3h6H6Q4=zRoK~%y%*)pLKd4N<1
KVK^WxhQn{P*s+2D

literal 0
HcmV?d00001

diff --git a/target/classes/com/rosetta/im/packet/Packet0Handshake.class b/target/classes/com/rosetta/im/packet/Packet0Handshake.class
new file mode 100644
index 0000000000000000000000000000000000000000..20b0d02a2d155039ecf7a9cb72e94b58b32c8374
GIT binary patch
literal 1832
zcmah}YgZdp6x}yT^XhGBDNVsXtW_`xl%d!M5a>f5B_$*v7)5J!l8i7m57uPB<-byw
z30>`4e%Bx6a-W%@t|V5!+;i@|=dsT@``$nQdi^_qB~)SvDNIyb4Z~@*E!Q;-yI~xf
z)t8oQY<Xg4-E7v{2j)vFhKRy=zpc}9Th&&**GVC9cvPv|)eY+>h2g>v=CNti&E~$b
z<2rV8Kc|p9bnIi(wLFWV!yruAa@uyQsi5)-7Y{7caVwVT=9{kN9Gi88Xw5pdtCqrz
zLLU<U!dUU{nc)1vDexWF+^5G>zeiA~)jVpnjkjfb*7T1q+D+Sis1QzP$_kO?R?SKx
zj7u6rxR8LtWsNuzqFvEQiZ+I;F}$ac?ZfsTnKZ89Jo~j=+T1Fv?yjy#yc-(l<aDTD
zH?87PqhdL`W~I&|h6}B#SudN8E&Jdw;vU#-h4ecL>>nhHJM*Jsy9{?Lof&XCohV0T
znT=cw69m*>P_I!E<G3WiGa6YW6ykox`I_8JY23y%NA4x%EbrWBKhyb4SzKl`Vu*^}
zti~s}t8mt{^O?dfrw8fdd*0VL<9p6&%u9yEX@)t8oYOc9og~j6#lS&c>noy%F&dBY
zgt_-E*QZdvrZB?x3~*NhE^Dla`MI~|MYBPAEMZOKX>XuXJ4s^XHJ)KZAx00OlE*8O
zJlgi!tZ?)H2Em?jAVl@y;GlcQk;{~&pW7Or36!L``R$bBU5(ELNnDOOjX8n+g|PZd
zh53K!_FxMJPbA|QzS8&_&l&oAr`7PQG&tvh%KQ)J9S<+=&qey5^i}CCgZi5inV#Hf
z9XVBN&6X!|xu4(DGBSKX288*`MG+F3PzwpsJjrM4Nj_Rnk|v(yqoWMdlTV!MMeerg
zrzo#vPcWQ~bTE>=Fw{XR`zuB}xc-ah_&(PZ(*UE0Fm(bG3^B{IQQYLI_CxUI7Iz#W
zJ_^FWX7~`#UcABh-U&V~OlE&Wx{FDXMi+NP-V5YN7Y}5g3gki;i@_DuPybO@1NC|r
z>tg#eGlU>0r}-v;2mHC_SmHeKEf8T2X)I!fM9ASG*6@gBKgM%B@zAGygaP_E$|zuy
z_!WvM1$F$v)=K>w*~u=pIxqrxPvnkt&6g>;-jt;%%R(gk21|QWx5pwUD0i^nnZ3eZ
zPitqr`K%H2Q-WS6=sbZvBbhh&-xLUZlaPyqT;jVd@@Crue%FT-04KNr_&CS&jmL~E
W?_N*~GsabXOD)2JzGERFn12I&2df$Y

literal 0
HcmV?d00001

diff --git a/target/classes/com/rosetta/im/packet/enums/HandshakeStage.class b/target/classes/com/rosetta/im/packet/enums/HandshakeStage.class
new file mode 100644
index 0000000000000000000000000000000000000000..4bec1d760256b66c4e04b7625c499fcae58beeb2
GIT binary patch
literal 2092
zcmb7EQBxaL6#g!oWRtK3Od&KBT12W4pxdIY3KXGXk+lib2GYs&p<b44*s|Hp>~0u&
z_t|G3^~o0>Dz(D2Bl_%b@i$n{-9)oY(Gh0C?!Eh+@0{;D=icA{e0c)k4j#(rV#phA
zUG-ew3<9oNb+y5bJu^^Er&;&aHSX;AyL`_q2fSv=h%xj$<@;Q<xl>a$!Z4%?8>Rb2
zZBtuem@fW*wt0q2>zcOmctxw|1?_P~d!VoCh2>3sW1S&pxH~2T(;2$8^{vu)Wx2Se
zl^JFpoi9gn!LTjI3KkipiOC8v7l=8Dcp40EDaha=Lt>!~8Js9~^pyk8a%%IsK3Pc-
zctAlMi6msPxTHWvLc9$rNTZvfw`e)$db7T5dYgRPrs6Y2*Wh-AdzM&-n`ub6B9dNZ
z$exv}mFjH;Nu;ROVAt{)<eC|XszV9nNb-s2)>|9ugg$v5Lxk!H1(V2=>V0lEP2yK4
zCeP)nAemP14#s6%XBg{PrrWkz<My&wYt~IC(7rUxMqs&4h9>TYf}5CS7_8Gk6<o*Q
z!9y$9r8hs|PC#`G2r(V9w*P6&-~-{=ErEFRyJ%{hC~D--1sYUiuf!Xn+cLV-n8Sh$
z8n(U&@qr(hb%o9VO+|`(9zQVL#sM9MDE-FvQ_~3M^+?9Qw`d}$E1`WGPZ*Y>VeP8V
z*%b+Q6?}pM!>uS;!REd{AF1FU_Kq5H3`t+Q>^42aT(!jLT|9kquM0FuEn78*2ThL<
zixE=6uyCF!S`>cXb=|-ZJl-go!LGaGr|}tzGVU>qcZ#!|eRt1PTV=PJzRHcj^$x@|
zlo-B=%59@tghGOC`r}2{-D@_^Fd?GgRN&@8!#o52D1vV{GCFN-iUPOovK5%~y$R?^
z+-JC=JJe}wXY{nEqvD2|8)XcN?l`6ww#xKnlo_tQVZd3EWNZ=pe?#e%w)8LEq(djs
zF^Vna#61Mildd4z$%xAW=o=Cj5v>!nR&asvJ+%6Q(BkjLE3j&&SCWp<_Z<D<DjSQ1
ztHJm$^ieuQf4Lev#9;Y3az9c`7cSHPY{(!}wr*lnFn~S`Q<mWnAy9OQwzI8KjWOC+
z@>9b{7|D;kz-Wi5Csfc+u>-`F4H>c&Pk4-lTEv@BBM~3nFKt$po{UiO{7)GDAxtX@
zON5)bkVa_%+B7L#!@IO24EUPJgaxz5c&|DaJ6V+Oe2;-#Y<RXf^)sf1zD0cM*;id`
zc;vg+f4ss>b?7Bj;0W*kN>Nh8f)NsW1w*(>8AqtNv50`#Ruc%3#_h1O4=FkW={0pC
zPUSNh9|1jGB#v(1c5Sz*GSSrRA#&AwQvRg6AUaW!E+6CL>1Xt%)q<8%7UmOnrRc6$
xYIEcXBg{!>SpFExzk&UGTnsBAr-s$=`6<@unWXr2`fcEI!9#Bku!#zCe*w9z??eCq

literal 0
HcmV?d00001

diff --git a/target/classes/com/rosetta/im/protocol/Client.class b/target/classes/com/rosetta/im/protocol/Client.class
new file mode 100644
index 0000000000000000000000000000000000000000..0a642fbc8c791ab6797f18df97b5b592d8983c8b
GIT binary patch
literal 1783
zcma)7Yfl<M6g>k73QGliwWT6fD=+KzWwmOxt){67txae#{nRY5!Bt?%ve@{q+N8$X
zCj9~ZQBCj6EU+RrhJ=~9bLY&t=iGrme}Dc4@Ekh<co-68v#wfZOSf%JHR@{9GHtVL
z*3|8qp*QRRd<>C8?O0Q5TBEA&l@9f?&ERjD<s+RYiM(l5Ri5zqi(ZmZbzd(P#Qr+N
za9IHDRv2RW9#Fxyj7F9AgK~dIvo(fMnbEe5n)+62()LKfs5UgaZRrfl7k4)<!?_}o
z>G~#N_&1D(VQ(_brvJ}2Q)KXMn-x6>FQN*<h%tE6nc@f-#uW^~AH*bX1~A2tx=K00
zUe@=K3Q=$iw;2>mYgEj-j5AE6cQY=wjvV}+I|>3A4j{o06?zH0H(Kj}6bWJ)QJyuc
zU<5&~n9<PRwd*C_`k<9+q*5$zmbF?@vkbm=f<F7eXfY)7SCN)>lUSjuZp#I?Y&<=H
zB}2HIBz=o^(p=81^vAC4SBSc?M`0p;Sto8(fU@N6sR0?TGfpRDiXl9}qW~Tf|DLcU
zs)EOOLPj^+)X=MLFz4t1u*)F=IMPoThK{vbTlmoHb_a*danQRu@k%;Zc7oRwN_1;Q
zyqn33o}V;3z6Z!CDbj+wE~nkx-Z~VyMq3JA;3d^VhZ!y$>}WZt{9wUsTV?&V!MiXd
z4P4?HV3r!zOFueZ8tDzujO@d(7^#bC6{5KZyz|K%+@SAKij?SthsH$q43TW^6l2*)
z@&_hP5zqd@^rth-oFe&6oV`omlY|aL;6s#NM~psW^j^j>C-wvq=5dc!gejOXx@iF^
z=RTE2Mteiq?}&e;i3c3kFM?A7Mv(~)3_}_j%98Z6g0veX*$)yQ2$I7h!SaeX35@gf
z^J?S0%7P*~L!6VYYW&@5{6bI8{yvr*tUXeXs~)CmlDWlms9x;%L(Y-t^8zv{le>^%
zER#iCjxe5Lg$Qu)RT^cr&jjK3wC)lXR(OSGl5mO$r>`KqCX8Pve5t7)YhuQ*LH|xt
fjx7g0BuY5PrU(6s=3MZhF8Po{p5YZ;;KBAkIp})!

literal 0
HcmV?d00001

diff --git a/target/classes/com/rosetta/im/protocol/Server.class b/target/classes/com/rosetta/im/protocol/Server.class
new file mode 100644
index 0000000000000000000000000000000000000000..ca113bb4a161398c4df983d06c2136df9fa0a937
GIT binary patch
literal 3828
zcmb7H`&S#s75;{Y7R1^ZY?3N&65`mg1emR{V;W@R7-BbS0lSfnW0N*rqyg4QyXtBM
zrVl4=-tY9CzTZjO-<*@+6Z<45zvZ0#QEk83S;Wc#On+dtJ9FpGcfb4HJHr?Mx%nx8
z6Zp4*CV~43UfJ@!stf|#a>`c4_X4lrm8`t<m!xl?MIht(^VSu6$$olS&Q`s`q71BR
zIBi{&v-xm9n+xoy*lK>#cI|oT3k*(dwt+UZ&c*Gs0*T{}>ja|$L+RZAw>C2^&@%27
zrGXBCdlX>HCDa@r8sw>B(U;X~5=rbZVPGd0q;r|+B$}~H4Ri_IpPtx!Wi~V24uRb!
zT9FXwoN!z@RV&X*|GYh0k^<cmUcoL++rFc|qrsM7!Kn)LZW@jzkHNQ8JU<W+IRV3S
z$4ktMz{BZ@4H8giKAY2kOSU_2<pbYw=d+hXE^L4PYs~Q0tGOxd4(p#G6+sw&+?$>|
zLR^<aT&I2CV``7x0awh?>8k}<2^`NQfdV}n&Iq)7?j+Mg;RqbrzVj$%<#~IMT*tG<
zRsuOzo12q9A$6b+0|xp9zPc6DCJtec5}%jBDV9rNp)6fyYfm~83+U|Z6<G+f1{C$1
zX@9)raA^`lIBI~z?$(lPz-8iL9201@ecxVT3euUGF#})U!Yhf8b~%Y*j3_ZvPp#>h
zF(vO|oG>wpljN8t#he=)rt9W(CYQu1j2jpe7}yN#MulqPF`O3INh)*!kC*H!HNJ=C
z6eA-X&9>tk$QgKCU{_3AE7d@jO?(sIA`-7gA|qXpg>zJKpu@>_vs+D?n8I0syUX^X
z9QWLU9b9yR1-?}S+YPvJPvgdsCX)Cz@&=w*W4O_^iSxKXMOV~rC099#VXw=|z(tn&
zI`S~6B&Ko6#AVEA7D6a~tq`cnIFg=;InpG=Y4PP;i6XILizt}yH1MN!l*H4p4SY}F
z-gN*QEH^QWf<T8WmvbQ}1=i5P1{jer<2dSCrSXAnrN13T%$rz1N}x>(BUemv@QR5=
zlqgfBFM$Wsn>V{qrK~zdp=-iJMb}i`DOXBz$}SU4V@*Y==w|Enl@gfmhc-%8jP$wy
zYFIX~v?hSCt<}4ciK}2~b%p}Sv!WNz`?g|^mBDV3&}W@Ma<<+r>MFghiO{+b7WGzr
zUYEV9OXZMJG|jN^64j8AtrjvGRyG%QXwIW*>xu=eRYq^xg4y3R1KJ`wdFfOz;=39T
zu9eE#;g!98kK_H@bUaGeJ3>|`?MiqQ8hDlfJ@;%yvf9qxsl{*5ix+ISSY2Qfur!yC
zuYHGlvhbE_d~XXpa0lPI=l|TqFYrsE<n<@s(Hr`}THR0(gBu;Cn?ni@OA?@t^km+v
z`2~5#QMZH+ec%tOl4jA5d0s#b*p*2cEO<rUPkxU-8u)|2{`I1F+$E1;YhCLWc*a)k
zW<^!Rp9J2CS43p39V(Javbul5^A>BBctW+e_(;RT^OQk+GBTfuNn(wi*ihtR+%A>!
zP9U?L3H+`Ne-+sGge*vBNfvu+?xO20yS-Y8z02(7y-snYSG3{pyn@v2^gPD}%$(~=
zKUBG_8hDo->r3Qp6t02yd1P*FN>OTV@Bmv(GY=e=rn=(s&EUI%Ha^?=^(0!t`R=}3
zNM71|1Lh5M_6>Z5?(3Xw!X7?%Y73ayjV_M#aI7~Py9;;o3+TpIkfKlZruJ##`#snj
z?ULtsEC0m0(?n>T3Y{I*lUQ@cYYXlT=NT#8HmRk!KiZVVfPI9`ri}f3sxVISFAVec
z4epDfWmAaIHg0erMEej9-pSd6+i=z!IZJD2;u>)&gxC5%Mn>Q>SW^S5I6TsF3&WRE
zEjRGUNNcKf6~~Vy`aVQ=Phu61ju<K9b98-xGd+o$m;hFB?t02-{shyjc#=O)t>U|%
zp*Yf(YU@dSgt=6ka^Y}6%2-ADCcYo8c@IftvWnn3(L9POmQW*eDygIB<nti^bI4#9
zuZw%pPgVzbBRs@g+#ngXxMBzwa0E}`C<?s2RdI|5%rJh8M?xm%xSEmGX}yLYM0vZ0
zAL2)3B8h<3ii2Hn@eH2j?tAI$C-^CIzK@=H@=`8`c&~X5&r_HenDH0zA_aPt7BArd
z-(Kb}CL_>Ruh8mMj_gPCe+jXTf;P}+V90=F;57ro{GJAC25L%Wuj37!3)sZb!j)aO
zU|s6Jfj6i64}FZEHDO&fTI(m6vQa`l8HU-X7uCb;s)yM{u)kuM?F6aA6!<k(qV4**
ym8ys@ss6Fht%^t)Xi+xfH~ebCJNPYsck=Deocl}o{2Ttku_V9$iTCg?r2Yq8O56qj

literal 0
HcmV?d00001

diff --git a/target/classes/com/rosetta/im/protocol/Stream.class b/target/classes/com/rosetta/im/protocol/Stream.class
new file mode 100644
index 0000000000000000000000000000000000000000..b023c77f22cb396ee5e433f5170e9dee72ed233c
GIT binary patch
literal 5109
zcma)A?{`$y72S7cl9?or%p?#}oJ67q4U^O;V2UIJOe8XtAWGz?T3==!$-rdZbmj#J
zRKyxAT7LkwRn)f9+G1O^+Et^=TK<5pe(FEc)#bM?CEe%Vmzft5UH!nD`|i7UpMCZ@
z_nb@qapUvr0Jh>!QG^t3&A3y&CAaK&p52?9>MfRB&&{~`-hE!lv8SSlC?t;AC+yz5
zU6|;7c>I`?@f2#y`m;jl$dEz<muC06xq|1E6jWNlI$6qjPGzcgAXmtFg9_oU_4^ef
z!*158M;MJ3>d{aK+OQBsOh(NX>da`Bg&Nc<#CPWk&YtP1ai=t9kLMk(+3jZR{C>NX
zlXrhI;!Wnt3LU$@-KBnonyw>5!lQ1&@r<A3)U{q*siP7LQ+3*jbivy!pVRC2*P{cs
zM{%1%V^xw-+ncm-2RiAUJx&6$G+j?m?zC_hZslU9P@XP1!*<cm<h&W$KVj#m=|)4r
znXtW_TNuhw(>m(6dB6Fhazq=K*%kXdJ9B*0F8W@^L~Fx|Vp8guW~mXP@=cG7{zI;t
zckF^tIxOrJ?z3=@P*R8es8yB_?69oZV&Pu&D%3AHe{Y{mZ?(`a8|!@YW_G)UyB96q
zxIq>VTj<BFVPJl~y2E^W$im>F9etaG-Y!G$`xYM1^mcJ_GB+_v74q)MDu}Em(_Lca
zQ42fJTf=0g9kFDb9?845w{e4@jtJ^O9FF1;v#1&}y~M&1JkH=8mGxsTC8csYd?O;O
z8leXIn;#OL<P~s|7!mAo3mIey!{EvOF;_1U>*@7`XwWh;qjH4_g_f?}RTgHlUpP+U
zSQHF-;G~(a7LJQrwRxv7;Z4fIDGLR-oXSkvr3aWGVrW>7#1dpWAkkVdzN%~e(lvGP
za3YH7#kOb4o<l<?af))g)3nlJw&vX4y>!JtBK^(O{<MWN_>n^ElzrS8b_*HXJCO4x
zIVyX0K@@H6N~hDy*sjM}oQvWag_WB7VsH!3;;2HjDE9J&7@kvLjW|!dn>`(x&gHXC
zsUEXvl*a`NFW^OLWEYE0fzfH}8eVGO-_<WWUb65qSi54LyCBz^C1NdXSU4O*GoC~D
z^pVixs8p+HuDoNaD92pN%h2@Eqr%L?&n^4{uXENemF$^}TjYvVFds~9?N0~nE=;lZ
zaN{`br3+byL8&V^CrOkQnq>C5)1{0vl9S5VU}o<Yi5OEJZ?Ei??Bb~7O}g1~J${9E
zqWHB!XH~>p;e>nKk&4eGH4z-KGoD+Tk<eaMcq2&DUu^()+J$W1DR=I6-Q&~6{s47@
z7MxkMacrjO1V8%Aj|32W=YxUsA%^XIejocwf4mmIjNx5{9o$bbI;#2JVUA1(x7hhy
zc1wrq=_s2;=8K+@^?sM)J4;BqP;g4adAnS8%28ZXShqx{<vfq#5A3DizLfcBWWsH%
zUaXG%7m^OgQAoO<{$=mu?=4)x&d8_5x4rz%<j3mNr&y5+e}cF?no{8}VxM5;$9i9j
zd?y;%JtM@dBVr>lT8Ofmvz9?XE55@wL0{veA0&E+bE|Gb?_LIbMF6`ID-qY&tId8N
zn@HL#)=>J9^sV&rSA3{R{S_-e;vht7AW@lY4p6MAP;9GE9P}yHrWTW`*M`OI)&P;(
z3X$3h5jHPFM5QQ<NPaQ-HlmShh=jK$Kf~H4%%2@hkz7;l={c+umgeR0jctjj3=`3_
z*;AL!T^dUr;#=e?Mj+frfT8w8v?Y=~9XZ=qvphgc%{L;<MpR2A5xYA7cL`%yYqCKH
z{T7BONr~H~@#220#V`{mjoUHC+s2dV<k?(@^PGE?*9-~qpz*8X{Y7*!nIzQDV?9S9
zqCJfiM`4T*shgt+(e6bLM>Y5^F)T!4+tm$hQ%VhTFWbA(4PSDtq}Nn<z!xW8dwQdG
zEH2W}|E;1-T$G822d`n%H?8Z7B<XatJ$vfhKy}M(Shb51|7?rAgILmIXp-+&M7fh0
z4U!L$c9MkGky?u69^{2)4_!FOcN?3u5St89Ux*NUs1YKGM|~mg!WQj*nEO|0_aoZ<
zMnrBPMc?oFFXG!JV|iWj1$d5$Bd7Mhq<CtQ<NwZ-n-A$`s(C*T=oUKBPuc^Tc!x1i
ziQs)c@rWNIDFeKn`Gjm@$iZDm)+O->h^v(}N3KyD*~Y`Qor&~7;NYzD4X<GuNJ@zR
z8?dor&eVy<RPu^{a^|q9nzrUJ?!XErm!zYq3XK(K8tF_Qu_Vn}5K2d(<~a=Um;aB@
zPlfMcvu|!2eUsW?rRH!yGomK)ez=+rrf#IQAye8c-;ltEq2z|hOQ;XFhf^X|b1IpL
z@q7=Yl5*fVs0PO9GD^Sqpa~BLd}yxt(Ci09$t~8$eu&6|9VgLkiP))uqzujpS0lI)
z=1~Ig3xLLb&=}Loq^FY0uMaxv6K*2m1PKqNlFbj2@6gSB4-obs5;zoqZmRHYszCFq
zybRxwM8fbLS;F^m0zVM|U5@WgRuR*p3gj!*VfETX$C(R*YcKRgQtfltm1>FbStV^+
zl+8*t&bpLg1IaQO9Bn7Xe3rB^ElNgR*iHOex+h@?bBD#?NYzpd&|cs66MPrjt<?RI
z^V{`v74|(dL@qP8J^Mi=5GKNt1k4fgm^NyTT&r)imXROTMiUIn9*&qwcnte}Q;#sD
zQUe<9_zVZOrrH+yX5b6t;*x1G0N+sYsewK{K`?3iPtp^~@gLwRAAX3xl1laB!vNco
z{b7Z?$)YlMdK%druX-Q3hVz0aN7lhnAMX{C6-_(4=P+UDN@0$tx*3~1vq@^Me7idT
z@9IImh1`HsM4X`?rx~L&yfmC<v3OcrHgW2#_|!?CinLh69(7#%Bxg~&OIROvdigct
zO38KRhbZ~n{zYcO?J?u)TUeQtesP@-7P9QSNd5)o>eS~XgE>6i{Ns=QhS@`(;`vc=
zCDFs}BbVp!lLO*Q^6LD5dgky`xnP)PYWl`Gl6#I7Z<bx+JWJ>W7T*_mhF`=^{_e#~
z0mmMzNV-?Mqqw$>F22Ih^fOtjj>QrA3TssB*RZ0PRZ@put=w5ol7OU2TdMmy(<Hq0
z8t-o1Z5vs0W<#p2`})=SFRPlHb8(T%U*d)BGH*ne*ydgf<WO5hZy_V~FUEc@WI|eH
z{yFC>G${EK%Eij9>t#|9kvojYU&OR%jXmvr-*#!tm+Z@)s$M4euT!r#*m1A0MZHN9
zS6G<d4rtU-(J1L_RL2>i6(W5@%LKmxp&MvaQC!j``EsDXn+u_(qyFZy_5B@f@*C?r
z|8Goh<%WC@f2CQ}YOreQHErVE0L;SWP~m44l>|k0FMBtAFR*#xZW`i^YoSt~p;Qv*
zPLr!w(VmPvMWKaBxF@U$eTLUkJ^pptq@{`X`;_<tp05vy_Gg~2kF_mRl7i>!4Mv%N
p!QfTpik8^#ad*)0n=~E5TZ|6$qTg`gZ}B_6NeBEr-oqcU=6~4ybY=hm

literal 0
HcmV?d00001

diff --git a/target/classes/com/rosetta/im/protocol/packet/Packet.class b/target/classes/com/rosetta/im/protocol/packet/Packet.class
new file mode 100644
index 0000000000000000000000000000000000000000..d6c377d4effd030d22d4d3e610e2537e5e0a43b4
GIT binary patch
literal 511
zcma)(OHTqZ5Xb+sEDskD#OGCw5j@a?M;{jx6O#3jV7Pae28+8}Qi^^qPbMDx0DdUr
zEX&nMn#^ye{dcC*`TqI*0&s<cDm=nTY*Jy(TsbF&PQ}a`XJV6xnT%hQ6OT(&;S<_Z
z`6@*svx#_!rYd%XTA><@2{a%yi||fna-uAuAFh>srN1ClE_J5eHKEk)jR^jY8LI##
zG#l7JKxl<JQ}>HBQuawki6V4D6U$^It<K}srthBhoN&5cd9GW2v)XaCqi*ldJ40uc
zOj+zRx#8pPf6}~#U}zRLR<}BTY`yr+e*TgEA-GMRgvTtS!XBZD8neV6x68K9(K(Zt
q<+Beo-r4c6$u?jDP55Z>0vd$~ZEPW*RtMWl?qHWs343fk?EeC5<$c5e

literal 0
HcmV?d00001

diff --git a/target/classes/com/rosetta/im/protocol/packet/PacketExecutor.class b/target/classes/com/rosetta/im/protocol/packet/PacketExecutor.class
new file mode 100644
index 0000000000000000000000000000000000000000..a4c2f31a87640ec9317fce5f4839f00db066516e
GIT binary patch
literal 275
zcma)%%?`mp6ot?DE47jE5JZ><DBTFFCWOR(jGLxaon|_1Je!3F@K9pZLd3@Eo^x|@
z?sxBx>kYshT?aLWiBxB<RZhkT9-Vonl~Gb9JQMOnhHt8|ypSx6(heF7y;zijCn62`
z`Vf;ecBRsHa7&V+l8y|6VerW<5|QWLXwT5uMPVvTp^3r&iOj~qUp$^)mAN}rXi2Lm
gv2Fct)amPbi-DnT-vyW@Z=z+rV_gkxt2&i(pP;8stN;K2

literal 0
HcmV?d00001

diff --git a/target/classes/com/rosetta/im/protocol/packet/PacketManager.class b/target/classes/com/rosetta/im/protocol/packet/PacketManager.class
new file mode 100644
index 0000000000000000000000000000000000000000..972ceaf987670aaad7f653c8027760d24c679e85
GIT binary patch
literal 2462
zcmcIlZBrXn6n<_9EQC$MTTwx6Yimh>5?`uTL!lB|iRH~wsm0eN+=iuLgS(rK{1p8I
ze(^({sZ?~vamH`{0Dq44x%cjdMfw3gIGNeaJ@?$_Jm)#*p8e~eUw;R14G%1&1SV_E
zos!=SWEeUncc--LH^XMF*(mKgwFfdRt?1XH<2iNdTSyD^Z95O0Qp54;rR9xnSqlX$
z;~WSKF6iA>=r&68PO!D;?3M+3R^7Vige_kR)Q)>h8<U2tdZA>ba>7(;I6*Kyv2Y@$
z<r)42x~5&v4QB*83dJ>nbfvi|Gw49pMh`L;@&f(Gm}Zbewg&<OHagKIkY8{;xzyU(
zkp3NKqe1oq3(cC-SaW<=ts`SP+;W-w)X5k|T9RbWmvuJ?rEf$QI8&(pH}A5dKYQGM
z3O$Nz8I0m33oph=CzZDGGS0Gu51mF!F5edzE>w#N7I8t8IOlD=f(sONx5cVoEhOAb
zD<sPnS&~?hNub*_Om$O0R9P*vB)tTpE<05kJ}UX%ZY+B;*lBx&q1?d8ep?s8m*g^D
zI9UnH#dXz8mu*a;#BAy^)CAc7g=D@a1*P2UHr~LS0@+&A3mw-B)|A|;;)#r7#nuJJ
zPDq3u$>1iD>gL>DMB`Et*04zOifbyca?J5Gjg{aYL#kxowecQUxo+u&{@$u&uk^>d
z=*d7+xtAko)&j3+_V6Nd!^U;I&$BM?g%dV?)sPW)eYP6e2~fce3m;H|Lx6bK#!Y<4
zd+*6_8GR^5NKCD=1$N%x;ZcsNi#HVEUd-c`jRgguN~=p{VTtoVdutFas%nB28y~C6
zcFAvAP9so<S8d!;hr4+AmLy&UYc}rUQ(m(zCs@*)IG9-HUeoze**djg><S~S&bLjA
zg34#v|A*<BT@5+*895qoxpt35M2C*f2-9H#GtV%eqMuanY}lxQSFwX31&;J_d_59f
z*B&UD)n?1D$(ybo(&j!ygLX<4O~9^tp7b?S8CY<S^c_<b=+xE6d42#o_=OZmsjmRv
z7FQ{BbHz^?GJN*ZGDk1Lci;FE*yFz;ckc=Men$UK+Ix`CoW|)vnrHGnGenzh&fpA&
zxe|B|&lB53ctPWC@RW+58-I-c(O)n!xsP*q6>0|*YKHy_J4;N3c+Pl7h-&8|Ue!@@
zxP&o!7wBc;Doc?Tjyg>6sq(nawL-L2yor4<+-pB_ozl@%{=k5aG;I9Zk!+$};l99I
zc$<4Bi+42YpIoPTa#o@4<LUvX1(trm*yRJv3H*Wi#mNJFr2Z{3=<;{Sa(!E^M<3DW
z6M^ra{w*F6BCUxGQ+`mi5lS{r(XR0SHGbC)C75j!o5ejQF6cXgb$muDN&-V)?G@X5
zpL6dE?hPUJ6n#ir5Ed4hNd>q-uP^acJF%~IVim5HT=}>>`*4_pBAQg}Y(lYon^-=o
UO$t)`-$$Kq)lu`<!gg2BzoTkmng9R*

literal 0
HcmV?d00001

diff --git a/target/classes/com/rosetta/im/protocol/util/StringUtil.class b/target/classes/com/rosetta/im/protocol/util/StringUtil.class
new file mode 100644
index 0000000000000000000000000000000000000000..14ca2b2f0d6e2a8890c8cb1f880a32162845f9e6
GIT binary patch
literal 956
zcma)4%~BIV5dJ1v*krSTh#-Q1f<Gh>S$+a&p;SQ-jV7Q5f_R&3)?{I`8#fa~&sKT!
z9XxrJOR%)c2k<$34zxE5MQJWpO?CJ5-+c3R|2+Bj1HgSO$_Oxw>rPd3ow^|e*UYL`
za~<L6j-@q(X=!=kns#}cOc@eGY>yvs&Ej@h+br%Gx?t$MXWFJ%W(dX;1qLbYlnezy
zgjIB)lc76n+QvqsS~T1(UbGB`o~)yDtH52;yPrBGQ8DWbiR^#ESz=IKZkL>@50RlS
zo=IfS@%ip085bD(|8=i6OsizL3StO{(95vAvYK9du>SB-=JAtkZe#Q5v*-D(?ZVEB
z-Iu(mmyB2Cin+IMRc)vC+O3Pm!JEUk@1|#F=Th?vi+AoSxP;3x`Wd>;pUQDjQ89o)
zBFTr^B56&*5JqGS|3#+{SH)Faqjbx#%c9as&v@x$Dz4)O1@sDcSBQ0qKAZO7-%>G-
zI7N7^X4oZ$p?JEThSUEpc@+~XCXr+a3FnNu-gtWn5zI0SfqIc)ppDnFh75`aiR;2}
zX?#6xiC!C%p~JLG#vwyAFSx#+<F(VVD|x5k>c+b1Ek?JG$J@3kk4B7wD4<;h0%XxT
zk(BACk!GYjCXNw0YK0Y&UKmsmA*uQaq@#2TqYK^S@rsWiQ7a(z9kJbGg4}a47hL{~
z;jidRHgV;{{>KGrGTA3JG1|n<o%caDJoxGNugNA7U#Kn!@2!zmuTF$WM@Z5l(VP?-
zMu_04Eet9D9h&KFst6&8sTTAI5}3veeJYAE%u+N+wGqsbB_Tz*Q3Os9lf5&<1_<~(
IIRjYu1He7iw*UYD

literal 0
HcmV?d00001