From 7ca3afd60e16c492bdcb6bc3cd3a59b13ce02d82 Mon Sep 17 00:00:00 2001
From: Alex <alex@roese.dev>
Date: Fri, 24 Dec 2021 22:25:06 +0100
Subject: [PATCH] init

---
 pom.xml                                       |  75 +++++++++++
 .../java/earth/krakatao/KraSocketClient.java  |  29 +++++
 .../earth/krakatao/KraSocketClientConfig.java |  15 +++
 .../java/earth/krakatao/SocketClient.java     |  55 ++++++++
 .../events/KraSocketClientEventInitiater.java |  33 +++++
 .../events/KraSocketClientEventInterface.java |  13 ++
 .../protocol/KraSocketClientProtocol.java     | 120 ++++++++++++++++++
 .../KraSocketClientProtocolMessage.java       |  24 ++++
 .../KraSocketClientProtocolStatus.java        |  21 +++
 .../earth/krakatao/KraSocketClient.class      | Bin 0 -> 2422 bytes
 .../krakatao/KraSocketClientConfig.class      | Bin 0 -> 3647 bytes
 .../classes/earth/krakatao/SocketClient.class | Bin 0 -> 2865 bytes
 .../KraSocketClientEventInitiater.class       | Bin 0 -> 1994 bytes
 .../KraSocketClientEventInterface.class       | Bin 0 -> 401 bytes
 .../earth/krakatao/protocol/KraProtocol.class | Bin 0 -> 4174 bytes
 .../protocol/KraProtocolMessage.class         | Bin 0 -> 1217 bytes
 .../protocol/KraProtocolMessageHandler.class  | Bin 0 -> 348 bytes
 .../krakatao/protocol/KraProtocolStatus.class | Bin 0 -> 1567 bytes
 .../protocol/KraSocketClientProtocol.class    | Bin 0 -> 4282 bytes
 .../KraSocketClientProtocolMessage.class      | Bin 0 -> 1253 bytes
 .../KraSocketClientProtocolStatus.class       | Bin 0 -> 1651 bytes
 .../earth/krakatao/test/TestInitiater.class   | Bin 0 -> 1254 bytes
 .../earth/krakatao/test/TestListener.class    | Bin 0 -> 155 bytes
 .../earth/krakatao/test/TestResponder.class   | Bin 0 -> 576 bytes
 target/maven-archiver/pom.properties          |   5 +
 .../compile/default-compile/createdFiles.lst  |   7 +
 .../compile/default-compile/inputFiles.lst    |   8 ++
 .../default-testCompile/inputFiles.lst        |   0
 28 files changed, 405 insertions(+)
 create mode 100644 pom.xml
 create mode 100644 src/main/java/earth/krakatao/KraSocketClient.java
 create mode 100644 src/main/java/earth/krakatao/KraSocketClientConfig.java
 create mode 100644 src/main/java/earth/krakatao/SocketClient.java
 create mode 100644 src/main/java/earth/krakatao/events/KraSocketClientEventInitiater.java
 create mode 100644 src/main/java/earth/krakatao/events/KraSocketClientEventInterface.java
 create mode 100644 src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java
 create mode 100644 src/main/java/earth/krakatao/protocol/KraSocketClientProtocolMessage.java
 create mode 100644 src/main/java/earth/krakatao/protocol/KraSocketClientProtocolStatus.java
 create mode 100644 target/classes/earth/krakatao/KraSocketClient.class
 create mode 100644 target/classes/earth/krakatao/KraSocketClientConfig.class
 create mode 100644 target/classes/earth/krakatao/SocketClient.class
 create mode 100644 target/classes/earth/krakatao/events/KraSocketClientEventInitiater.class
 create mode 100644 target/classes/earth/krakatao/events/KraSocketClientEventInterface.class
 create mode 100644 target/classes/earth/krakatao/protocol/KraProtocol.class
 create mode 100644 target/classes/earth/krakatao/protocol/KraProtocolMessage.class
 create mode 100644 target/classes/earth/krakatao/protocol/KraProtocolMessageHandler.class
 create mode 100644 target/classes/earth/krakatao/protocol/KraProtocolStatus.class
 create mode 100644 target/classes/earth/krakatao/protocol/KraSocketClientProtocol.class
 create mode 100644 target/classes/earth/krakatao/protocol/KraSocketClientProtocolMessage.class
 create mode 100644 target/classes/earth/krakatao/protocol/KraSocketClientProtocolStatus.class
 create mode 100644 target/classes/earth/krakatao/test/TestInitiater.class
 create mode 100644 target/classes/earth/krakatao/test/TestListener.class
 create mode 100644 target/classes/earth/krakatao/test/TestResponder.class
 create mode 100644 target/maven-archiver/pom.properties
 create mode 100644 target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst
 create mode 100644 target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst
 create mode 100644 target/maven-status/maven-compiler-plugin/testCompile/default-testCompile/inputFiles.lst

diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..ea4878d
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,75 @@
+<?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>earth.krakatoa</groupId>
+  <artifactId>KraSocketClient</artifactId>
+  <version>1.0-SNAPSHOT</version>
+
+  <properties>
+    <maven.compiler.source>14</maven.compiler.source>
+    <maven.compiler.target>14</maven.compiler.target>
+  </properties>
+
+  <build>
+    <defaultGoal>clean install</defaultGoal>
+    <plugins>
+      <plugin>
+        <artifactId>maven-assembly-plugin</artifactId>
+        <configuration>
+          <descriptorRefs>
+            <descriptorRef>jar-with-dependencies</descriptorRef>
+          </descriptorRefs>
+        </configuration>
+        <executions>
+          <execution>
+            <goals>
+              <goal>single</goal>
+            </goals>
+            <id>make-assembly</id>
+            <phase>package</phase>
+          </execution>
+        </executions>
+      </plugin>
+      <plugin>
+        <artifactId>maven-compiler-plugin</artifactId>
+        <configuration>
+          <source>9</source>
+          <target>9</target>
+        </configuration>
+        <groupId>org.apache.maven.plugins</groupId>
+      </plugin>
+    </plugins>
+  </build>
+
+  <dependencies>
+    <dependency>
+      <artifactId>lombok</artifactId>
+      <groupId>org.projectlombok</groupId>
+      <scope>provided</scope>
+      <version>1.18.22</version>
+    </dependency>
+    <dependency>
+      <artifactId>Java-WebSocket</artifactId>
+      <groupId>org.java-websocket</groupId>
+      <version>1.5.2</version> <!-- 1.5.1 -->
+    </dependency>
+  </dependencies>
+
+  <repositories>
+    <!-- https://github.com/TooTallNate/Java-WebSocket -->
+    <repository>
+      <id>sonatype-nexus-snapshots</id>
+      <releases>
+        <enabled>false</enabled>
+      </releases>
+      <snapshots>
+        <enabled>true</enabled>
+      </snapshots>
+      <url>https://oss.sonatype.org/content/repositories/snapshots</url>
+    </repository>
+  </repositories>
+
+</project>
\ No newline at end of file
diff --git a/src/main/java/earth/krakatao/KraSocketClient.java b/src/main/java/earth/krakatao/KraSocketClient.java
new file mode 100644
index 0000000..e9c66dc
--- /dev/null
+++ b/src/main/java/earth/krakatao/KraSocketClient.java
@@ -0,0 +1,29 @@
+package earth.krakatao;
+
+import earth.krakatao.events.KraSocketClientEventInitiater;
+import earth.krakatao.events.KraSocketClientEventInterface;
+import earth.krakatao.protocol.KraSocketClientProtocol;
+import earth.krakatao.protocol.KraSocketClientProtocolMessage;
+import java.net.URI;
+import java.net.URISyntaxException;
+
+public class KraSocketClient {
+
+  private KraSocketClientConfig kraSocketClientConfig;
+  private final SocketClient socketClient;
+  private KraSocketClientEventInitiater kraSocketClientEventInitiater;
+
+  public KraSocketClient(KraSocketClientConfig kraSocketClientConfig, KraSocketClientEventInterface kraSocketClientEventInterface, KraSocketClientProtocol kraSocketClientProtocol) throws URISyntaxException {
+    this.kraSocketClientConfig = kraSocketClientConfig;
+
+    this.kraSocketClientEventInitiater = new KraSocketClientEventInitiater();
+    this.kraSocketClientEventInitiater.addListener(kraSocketClientEventInterface);
+
+    this.socketClient = new SocketClient(new URI(this.kraSocketClientConfig.getWebSocketProtocol() +"://" + this.kraSocketClientConfig.getWebSocketHost() + ":" + this.kraSocketClientConfig.getWebSocketPort() + "/ws?t=" + this.kraSocketClientConfig.getWebSocketToken() + "&s="+ this.kraSocketClientConfig.getWebSocketServerName()), kraSocketClientEventInitiater, kraSocketClientProtocol);
+  }
+
+  public void sendMsg(KraSocketClientProtocolMessage kraProtocolMessage) {
+    this.socketClient.send("");
+  }
+
+}
diff --git a/src/main/java/earth/krakatao/KraSocketClientConfig.java b/src/main/java/earth/krakatao/KraSocketClientConfig.java
new file mode 100644
index 0000000..253f511
--- /dev/null
+++ b/src/main/java/earth/krakatao/KraSocketClientConfig.java
@@ -0,0 +1,15 @@
+package earth.krakatao;
+
+import lombok.Data;
+
+@Data
+public class KraSocketClientConfig {
+
+  private final String WebSocketProtocol;
+  private final String WebSocketHost;
+  private final int WebSocketPort;
+  private final String WebSocketToken;
+  private final String WebSocketAccessKey;
+  private final String WebSocketServerName;
+
+}
diff --git a/src/main/java/earth/krakatao/SocketClient.java b/src/main/java/earth/krakatao/SocketClient.java
new file mode 100644
index 0000000..8b31f9e
--- /dev/null
+++ b/src/main/java/earth/krakatao/SocketClient.java
@@ -0,0 +1,55 @@
+package earth.krakatao;
+
+import earth.krakatao.protocol.KraSocketClientProtocol;
+import earth.krakatao.protocol.KraSocketClientProtocolMessage;
+import earth.krakatao.events.KraSocketClientEventInitiater;
+import java.net.URI;
+import java.nio.ByteBuffer;
+import org.java_websocket.client.WebSocketClient;
+import org.java_websocket.handshake.ServerHandshake;
+
+public class SocketClient extends WebSocketClient {
+
+  private final KraSocketClientProtocol kraProtocol;
+  private final KraSocketClientEventInitiater kraSocketClientEventInitiater;
+
+  public SocketClient(URI serverUri, KraSocketClientEventInitiater kraSocketClientEventInitiater, KraSocketClientProtocol kraProtocol) {
+    super(serverUri);
+
+    this.kraSocketClientEventInitiater = kraSocketClientEventInitiater;
+    this.kraProtocol = kraProtocol;
+  }
+
+  public void SendMessage(KraSocketClientProtocolMessage kraProtocolMessage) {
+    if (isOpen()) {
+      send(this.kraProtocol.EncodeMessage(kraProtocolMessage));
+    }
+  }
+
+  @Override
+  public void onOpen(ServerHandshake serverHandshake) {
+    this.kraSocketClientEventInitiater.callOnOpen(serverHandshake);
+  }
+
+  @Override
+  public void onMessage(String s) {
+
+  }
+
+  @Override
+  public void onMessage(ByteBuffer byteBuffer) {
+    KraSocketClientProtocolMessage kraProtocolMessage = new KraSocketClientProtocol().DecodeMessage(byteBuffer.array());
+
+    this.kraSocketClientEventInitiater.callOnMessage(kraProtocolMessage);
+  }
+
+  @Override
+  public void onClose(int code, String reason, boolean remote) {
+    this.kraSocketClientEventInitiater.callOnClose(code, reason, remote);
+  }
+
+  @Override
+  public void onError(Exception e) {
+    System.out.println("Error: " + e);
+  }
+}
diff --git a/src/main/java/earth/krakatao/events/KraSocketClientEventInitiater.java b/src/main/java/earth/krakatao/events/KraSocketClientEventInitiater.java
new file mode 100644
index 0000000..8fc5819
--- /dev/null
+++ b/src/main/java/earth/krakatao/events/KraSocketClientEventInitiater.java
@@ -0,0 +1,33 @@
+package earth.krakatao.events;
+
+import earth.krakatao.protocol.KraSocketClientProtocolMessage;
+import java.util.ArrayList;
+import java.util.List;
+import org.java_websocket.handshake.ServerHandshake;
+
+public class KraSocketClientEventInitiater {
+
+  private final List<KraSocketClientEventInterface> listenerList = new ArrayList<>();
+
+  public void addListener(KraSocketClientEventInterface testListener) {
+    listenerList.add(testListener);
+  }
+
+  public void callOnOpen(ServerHandshake serverHandshake) {
+    for (KraSocketClientEventInterface testListener : listenerList) {
+      testListener.kraSocketClientOnOpen(serverHandshake);
+    }
+  }
+
+  public void callOnMessage(KraSocketClientProtocolMessage kraProtocolMessage) {
+    for (KraSocketClientEventInterface testListener : listenerList) {
+      testListener.kraSocketClientOnMessage(kraProtocolMessage);
+    }
+  }
+
+  public void callOnClose(int code, String reason, boolean remote) {
+    for (KraSocketClientEventInterface testListener : listenerList) {
+      testListener.kraSocketClientOnClose(code, reason, remote);
+    }
+  }
+}
diff --git a/src/main/java/earth/krakatao/events/KraSocketClientEventInterface.java b/src/main/java/earth/krakatao/events/KraSocketClientEventInterface.java
new file mode 100644
index 0000000..c8f25ba
--- /dev/null
+++ b/src/main/java/earth/krakatao/events/KraSocketClientEventInterface.java
@@ -0,0 +1,13 @@
+package earth.krakatao.events;
+
+import earth.krakatao.protocol.KraSocketClientProtocolMessage;
+import org.java_websocket.handshake.ServerHandshake;
+
+public interface KraSocketClientEventInterface {
+
+  void kraSocketClientOnMessage(KraSocketClientProtocolMessage kraProtocolMessage);
+
+  void kraSocketClientOnOpen(ServerHandshake serverHandshake);
+
+  void kraSocketClientOnClose(int code, String reason, boolean remote);
+}
diff --git a/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java b/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java
new file mode 100644
index 0000000..f1e4d90
--- /dev/null
+++ b/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java
@@ -0,0 +1,120 @@
+package earth.krakatao.protocol;
+
+import java.nio.charset.StandardCharsets;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.function.Consumer;
+import lombok.Getter;
+
+public class KraSocketClientProtocol {
+
+  @Getter
+  //ArrayList<Integer> cmdIDs = Lists.newArrayList();
+  ArrayList<Integer> cmdIDs = new ArrayList<>();
+
+  @Getter
+  HashMap<Integer, Consumer<KraSocketClientProtocolMessage>> consumerHashMap = new HashMap<>();
+
+  public int getCmdID() {
+    if (cmdIDs.isEmpty()) {
+      cmdIDs.add(10);
+      return 10;
+    }
+
+    int cmdID = cmdIDs.get(cmdIDs.size() - 1) + 1;
+
+    cmdIDs.add(cmdID);
+
+    // TODO: check max int value 2^32
+
+    return cmdID;
+  }
+
+  public byte[] EncodeMessage(KraSocketClientProtocolMessage kraProtocolMessage) {
+    return EncodeMessage(kraProtocolMessage.getStatus(), kraProtocolMessage.getCmdID(),
+        kraProtocolMessage.getDest(), kraProtocolMessage.getUuid(),
+        kraProtocolMessage.getCmdNumber(), kraProtocolMessage.getArgs());
+  }
+
+  public byte[] EncodeMessage(int status, int cmdID, int dest, String uuid, int cmdNumber,
+      String args) {
+    System.out.println("sendMessage: " + status + " " + cmdID + " " + dest + " " + cmdNumber);
+
+    int argLen = args.length();
+
+    byte[] raw = new byte[40 + argLen];
+
+    raw[0] = (byte) status;
+
+    raw[1] = (byte) cmdID;
+    raw[2] = (byte) (cmdID >> 8);
+    raw[3] = (byte) (cmdID >> 16);
+    raw[4] = (byte) (cmdID >> 24);
+
+    raw[5] = (byte) dest;
+
+    byte[] uuidBytes = uuid.getBytes();
+
+    /* for (int i = 0; i < 32; i++) {
+      raw[6 + i] = uuidBytes[i];
+    }*/
+
+    System.arraycopy(uuidBytes, 0, raw, 6, 32);
+
+    raw[38] = (byte) cmdNumber;
+    raw[39] = (byte) (cmdNumber >> 8);
+
+    if (argLen > 0) {
+      for (int i = 0; i < argLen; i++) {
+        raw[40 + i] = (byte) args.charAt(i);
+      }
+    }
+
+    return raw;
+    //ProxySystem.getInstance().getSocketClient().SendMessage(raw);
+  }
+
+  public KraSocketClientProtocolMessage DecodeMessage(byte[] data) {
+    System.out.println("start decode");
+
+    byte status = data[0];
+
+    int cmdID = Byte.toUnsignedInt(data[1]);
+
+    cmdID += Byte.toUnsignedInt(data[2]) * 256;
+    cmdID += Byte.toUnsignedInt(data[3]) * 256 * 256;
+    cmdID += Byte.toUnsignedInt(data[4]) * 256 * 256 * 256;
+
+    int dest = Byte.toUnsignedInt(data[5]);
+
+    byte[] playerUuidBytes = new byte[32];
+
+    System.arraycopy(data, 6, playerUuidBytes, 0, 32);
+
+    /* for (int i = 0; i < 32; i++) {
+      playerUuidBytes[i] = data[6 + i];
+    } */
+
+    String playerUuid = new String(playerUuidBytes, StandardCharsets.UTF_8);
+
+    short cmdNumber = (short) (Byte.toUnsignedInt(data[38]) + (Byte.toUnsignedInt(data[39]) * 256));
+
+    int argLen = data.length - 40;
+    byte[] argsBytes = new byte[argLen];
+
+    /* for (int i = 0; i < argLen; i++) {
+      argsBytes[i] = data[40 + i];
+    } */
+
+    System.arraycopy(data, 40, argsBytes, 0, argLen);
+
+    String args = new String(argsBytes, StandardCharsets.UTF_8);
+
+    System.out.println(
+        "decoded message " + status + " " + cmdID + " " + dest + " " + playerUuid + " "
+            + cmdNumber + " " + args + " ");
+
+    return new KraSocketClientProtocolMessage(status, cmdID, dest, playerUuid, cmdNumber, args);
+  }
+
+}
diff --git a/src/main/java/earth/krakatao/protocol/KraSocketClientProtocolMessage.java b/src/main/java/earth/krakatao/protocol/KraSocketClientProtocolMessage.java
new file mode 100644
index 0000000..9d2fffe
--- /dev/null
+++ b/src/main/java/earth/krakatao/protocol/KraSocketClientProtocolMessage.java
@@ -0,0 +1,24 @@
+package earth.krakatao.protocol;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@AllArgsConstructor
+@Getter
+public class KraSocketClientProtocolMessage {
+
+  private final byte status;
+  private final int cmdID; // long
+  private final int dest;
+  private final String uuid;
+  private final short cmdNumber;
+  private final String args;
+
+  public int getStatus() {
+    return Byte.toUnsignedInt(status);
+  }
+
+  public int getCmdNumber() {
+    return Short.toUnsignedInt(cmdNumber);
+  }
+}
diff --git a/src/main/java/earth/krakatao/protocol/KraSocketClientProtocolStatus.java b/src/main/java/earth/krakatao/protocol/KraSocketClientProtocolStatus.java
new file mode 100644
index 0000000..05eb398
--- /dev/null
+++ b/src/main/java/earth/krakatao/protocol/KraSocketClientProtocolStatus.java
@@ -0,0 +1,21 @@
+package earth.krakatao.protocol;
+
+import lombok.Getter;
+
+public enum KraSocketClientProtocolStatus {
+
+  SEND(10),
+  GET(11),
+  MESSAGE_ALREADY_IN_QUEUE(12),
+  ERROR_NO_PERMS(13),
+  ERROR_TRY_AGAIN(14),
+  ERROR_ARG_LEN_TOO_BIG(15),
+  REPLY(16);
+
+  @Getter
+  private final int status;
+
+  KraSocketClientProtocolStatus(int status) {
+    this.status = status;
+  }
+}
diff --git a/target/classes/earth/krakatao/KraSocketClient.class b/target/classes/earth/krakatao/KraSocketClient.class
new file mode 100644
index 0000000000000000000000000000000000000000..ca4b5ba53ce45910747ffedeec19c0cf2ed67a82
GIT binary patch
literal 2422
zcmb7Ge^(nt6um<t3+YxuOreERTcwz!Kh|2&mMvBrL9l^hLxTuaC!1;5ChX?y4zzp<
z|MhElj)12<#}D9#^7tm3lw~*4ayZ%9dGqGIclX`7!$1GN`WwJBYAN&~p&_Z`J@hlA
zpYvUAG`UkZ9#x+UOEUD|vmIN0#gNG5D}xxopoWx=Gte0>3GT@)qv7!em)tcTdc5pf
z4Izt7TR61&94&<{Mb~*|*BPctC+`gWObzcd+>W@4T?*|-bImF1B2{X0DZCWUBB6>M
z){(&n3=@$;j=M8VM+<tFET&3xPR9sF8P4!ptz`RBIKpGNlRH&FD)||=gqg2sxWF(T
zfgJvX8pav)cAp#}jVF&6Q<%Ud4Ik>bj4KS2k<F2&bX$<E3%Mq$LFg6Fm9FJB8M3*2
z>4*en>Df-5a8BT39g`}2I=pYe^`%;z((ws$k;N6)BMK00+7%XbTvPjp!~0j=hHzAX
z8#->P)sgUOS$Mm`Tjtv$Lu~z2$1QxuFuKhff>2mouGw;n-h9c45e!dr@zUd##keVM
z>G=`H@VPoC)5Pl@nevqs&f`nvafjhW$D`9D^Hg-`usF7<)oD|d{N45ue-!CwbeOnD
zEb)&W#))VRVOp63pfe5y;cFe=D3D2CI5mdfVpQ(Qs93Qlo}ez_qb0oqLMp82)&#>)
z$#%r@&URIJtGwDIOQz&nyjkI%t>ztLQf}Eqj?2+h5ftYCibSW@(~3kFA~7~1KHYXP
z+=>?UR{RX9xtEq`Nt<}DVVT4ttOeygNAj0%JQy_9#3i3J*NpY?ZON8|@AJA+CHl04
zp<8#yPAYfW^1BfUMcLi)EHQ7ZzGWl5xTzqKnmlk_=}V8dmW14LYyMC_)>8Np>l%Ji
zYOq0ScO+J}vrBSf1ez5H#5}j8>+Lc89zL)g#~|necWO=HPnKM_vC}f+QV_Bn+qk;d
z5<T2ELjJ)WYKFz66QanQ&9W^89lNLWaoLPvuo-5&@bAl6Hs#MUI=zbyT_wdP_kBT~
z{*~cs3~Mh48me?NpX^H4dVm*KNH6+GT@&=AJDuJ#N<3)nQ#WUOWF%=1XkMh*UnCJp
z8aE4vV1;Y@&<d|{cKr}T`$!l5MEd#xvSd2H{u*QJWY7+9F&I7yhO5Dl4~FZnU;u}>
zP1E#^LwvE1yMMH^eoN0W^wTp<8HX`Q)nw`KBHgze7{wf|6oOhXkMC$kRkbmYj?vo!
z7Td@+@jV_Az7koJU|6ExBdpL<;Ze90{uJfEo0&bp{iE#apCeVnAjaF-Mgq?_*;4oc
gk10+9W%BF8DxT0dK$Z&qHu1BHOK-n`!@`CC03wRTivR!s

literal 0
HcmV?d00001

diff --git a/target/classes/earth/krakatao/KraSocketClientConfig.class b/target/classes/earth/krakatao/KraSocketClientConfig.class
new file mode 100644
index 0000000000000000000000000000000000000000..ad9b573cc0a7b8b9cd370cddae84cbc519e3a48a
GIT binary patch
literal 3647
zcmcIm&2Jl35dS@U*SmH$U(Q#zEun=pBu-L8Ae7n-(1wPDCTVCw3N4gwoNesd^@jDP
zQZ67QPQal;LP8wig6O44AV`sVKp><dIKUr4&-?|HGPAo`uboxt1u5${Z{|1i=IhPN
zZ~xr-0l)+*DZ~(0AZd`15a_sUTs5*4qq?3wy?WU!I0A`drE1A}Rv<n!ypn{9q=J-&
z7H9$kreQn9Y}q!-hGSUSQ?{{W70RYFRVkTOXUeKxDy<82o;6oJ{-SL;R>7(Wr042K
zEjf0nx}Im_Z5rCya%-S6W7Qm%bZSVWD=b;GZ1PXcvb0A-FYC1hddpVXtg>j22AxIe
zKy<uNFl)6_<`#?hY1q%=u0XtG+E-0`!MI|kNZzmEVH^-p3r6+iTbo8jpl2xLyqBl^
z@HqxQqTx{tP#)J!C$Q)FN$Hzq$e@PDFeK33015KaJv1CL?q`Opl+iH4ek4qGqQ<7i
zG#qAA4X1IwSopYxCs^1SKF3W8OP|#66ia);(jYI4cv`~|M)Zae;nc)%R6~xVRf|Tg
zIAyJwX=<ut8YV&Q(s#uuo74dX!#P`WNL;NsM%AeaSmE^f5$=w8b~o!mI1$+sxbVN8
zxFR5N^aAa3rK-8Gd1ckKmyOj5anf^E!Kkblc8T{sQ*w$W%ERE?gIu3HwYb%IU;LI6
zkS(WZ+EgPpI8bl6pqu(!K$IlisKQ-Ccc2OGa~q*<4^jU%VSRRABRFU&fjvzMVNs(}
zy~_mjCatinb;&Ub<#}Vn&#Sz6W_JE0T@l-?ZB{6rbX4SRb*2|zd!6A2(N*V!yzH)X
z!(OP4<u$QDYRTHP3+8l*OTRaA8Xo4cM_2ZQWjQs+Ha6x>r)aI!+7oy)g^Ms0tnv*i
z&~&X&$WrwxjkBzGj(4f1je=v@TLPbio7)F^MrVxbTE(ml%vn}>b0dG>>(ijPytQFQ
zz|V&)?2Nq-%QrD)R4Pj)$IPpsEPN1|g`r)&Iw?jE1Wc|=1A|9s1H&y;11Bg{1GiqN
zNii&-%~q?XJykJkHM6FmC~#<3lB05`;Icsf{h`!%UZQc3#%GL1VS-*PdMAlW^Q-2r
z^oF@By;kl@Pm{aS8$@dh=u+c3`hA{uACeV?*1^p85Sfu}D4Ef1v}PXKMn^`Mw$Yu@
z<!$t3^u#vyenZF@j?-^~^g(t`(C>_A0aJK^c4W)-h~<N>PweL)zpRM66#FH)6niGS
z6#K?D>D}@@%hKwek@*hF*8~b5thxtl9>70X@Jkh;+}f<1j8vvaHA1=LM$^fuNM(8k
zBb2+FPi~1+rdKjTxvyDSi&UluG(vfAvvO;sGQIYmviP0S+e)F{8OeMJS-LUu6Vy*3
z$8U`M2z7oma}y7_TOtmQ()T&bXme<Rc87A(*e__&rQ7Jd4sA@AZen-`KAMvWGMY>1
zGGh|Ak-m;rUDgvJP&TI!D4SDtg+ZzhQgk&08qXyOG@eW8Nd~2SP*P8YKohwZ0!`#J
zy@f%V4<c#@BymaOySn&2FaDs5@8Be+DLXy*120l%$LN2ZZ>iU(N%si8!Yok|mT?U)
z5hdds-p47T64*i+b3`e42PWo;Qt=u6F3^|67j*AV6P3cxbc+{>YQeAAhnI=caE5$4
zfi6Y;8*K_y?Jjy1#OO~Icd^GKlmAVUXY?PX-xx<}<vS>IQJeeOyTZL5AP8QjkU4n4
z|9yF8#9xF_$;`(c`D4=L{*HW+o8jW5+XcL(9#A_*u0t8SiDz8?Xij2*F8LCbJHr!Y
zbFwR<rf`*1UEUFm=Mt_c5s0W&JgteG;)<wCd@aQl?T@bM8P8!qtT;Zx5=|kVf7hsT
zT@+9^-o+~vY8+!IVudJ)YCMm#M9C;%9Iq0Uz}x7<YeXq-h5kh99u-egpb9}nfe`n|
zM13D)Mi1m2zz#-gWcjc}2v$cnbA7PV2(IHJ1ip&8OQo(AEh9xr)45=_%(%lD=;vb7
z#{=OYeOda(>6^HPJkUIJyx#JrbbnBU^VCBzypA_$Rq2!q^sV6%?NUUoqeRz7{}(%r
B2Ydhk

literal 0
HcmV?d00001

diff --git a/target/classes/earth/krakatao/SocketClient.class b/target/classes/earth/krakatao/SocketClient.class
new file mode 100644
index 0000000000000000000000000000000000000000..32316e775dd8f0610dacd413d7c42d74edf43139
GIT binary patch
literal 2865
zcmbVO?N$?46x|n)Az=^*A7UwrEw)KOBehsH)>a}`Y7lD_Dzw^3xRNnpZaOod^hw&s
zXqU#d>{@+*K2%rtotcCrxcvH&%)RHHv(M+gGyneg>K_0L_$`hubQ|a~aRj{rDdlcw
zo>+U<qo=aysZvGynNro3j-OeV#X=y+1$%+sE4E|%R|STXd2Nz$sC@tKayGRVLmy%W
z;wJiG3QS7N^~;%xYgH`YQkiy~Dau<VOM7&;OlaHkr7N(I?=Y8I!OPrwlUY`WaMZ*g
zh6MWQ;f||(RZ>-f`A)oAbkvF1Fv-S=l`t`aQD$v>t2OBebSG0Aag5`bfe91G@sU8L
zBha@23k)ndCAB42q~}@NQs7GReS?ckv#HHR9p=X-rf@=_$CJ*Mz>(zUVrngpX`C|f
ziHT1!BXGVW%y+4$K)hsCtE*0!{CqP1nn@{J&X!lUDl$`$?w)jSHuf9|U8>LYlzkqQ
zj{6kS24+pn;f%mYI6=0`EbjYqarg0K-TEVz>stHFCK;qRj*N+Om}lLt%Z|D+&krq~
zF3))rUt)p4VV2E?WIwziLD|1DaS@j|f+23Msyw#&SaLa}Ox1F>GX>wZo$c&~=1mq?
z418_kD!vgI3W^fy?0df4Vd>PaFEAEbvs!m(>Jva(JJ|#&ea*xoa`dpnHsq93vix=1
zFLUMj7Fk1zM{EsXm!6em&9{}4O&ty>jwReM@STa9SZ=ha-KT(2(-Bljh_P1SD5un#
zz|)TFp|efzGJe@kqqk9u6UVX1ky`?TdE1e<cXx`?y=N7xlqB+s{aCYHTkj)bk6*S~
zpQ%n)t#?yaAm#<Lec!bOj<#QXY;%FMYYtDM<=$xuFLvU;EtLktIh+OGDpgjjS`=}w
zis(2P#?<7Sz}ffXC(}|+Gep5MBo5Dmz(k{!Z9ENX9WS=<HkwbTU5&${oQMHEn!W;p
zbJfe?^%Mt)iyh@_=|-Ts<hqKNK*MS0z_P)D%8{>*Q{Gnvwd<DT4O=&SxV4FAHLb|5
zMWuYtcdgor^vi0?8|=kS91fI$nx@gO0y75;w4FVrZ?=G}A+v5+C11I`pMGy0{YWtc
z)h($?Zziu)Ww(|+T+|jxo8i6vntYA=W{du6@rf+?ZOn}za=fYwwlA}NU@QBALSCL0
z0_L*gNH<rtJWqNC_5@BJ%J6l88+ayg;?1gTV3;LN@kP|d%cu(p{Q~AHp+5xpG{8$8
z-}C<#cU#ox;d3ZG`w}8O_X0-x%nJ<sNm&>2{7(eu!?YPe9HT@V!wTi;&<?k;${i7K
z2R{&1ue2xaeJJqVP3c{J>4Y91pgTAlP1iB}2L{vW=NOo+W2}xz?X^4bdX!IKg3%tQ
z-^sw^cxc!3IEn)95%qpxB}TYh!%XDn8kKbjF~S>!KY5Um{@?;mvO?1>xUnW~4D0xj
zFai&-9KkKnLR*Ogm|h+Mr&}OI6GC7En-RoM5yV3R1WEmk@dqz)nn5M&IJ=?)oU7xD
z1LQFI6pJ^DV|+R5a!*GEX_R{cKjR^h2N4U((8cv5T#9_HvpKr0{Th67ZmNz82k>G3
z=h)5p06Oese>3=g`~r(WG)IwX=)C(;;;iUSN<5C7Eb&C24g7`6v#;<iP{;L7Hwzqv
o3oSJoXu27|Hp+zRhE0$zJVAxeK1!<mx$wD*bG3`7*vIkz0k$UJzyJUM

literal 0
HcmV?d00001

diff --git a/target/classes/earth/krakatao/events/KraSocketClientEventInitiater.class b/target/classes/earth/krakatao/events/KraSocketClientEventInitiater.class
new file mode 100644
index 0000000000000000000000000000000000000000..ce32d1a6874c3ec607ecc1717f703eec3e9e3ba7
GIT binary patch
literal 1994
zcmb7FT~ixX7=BI?SV)$ShL(>)T0q)v_*$_=D?!>yzajygiGw3I&LJF=ZPHz4cR{`O
zS9s&C*Usp4&>6>Te}z~62&bbyXS0D2Itn+NbKZT=^E~Hy-+lA@-#`BfU>TcfB#<<a
zGSP)@fx#E@NZJkQR_*P*7pf8pbgw$D6Rrs)t^AIG9)Y1K=`eH}_9NeyUzeO9Ov6C3
z7a5oa`b_j=K;W*Deps{XzO2hodbT=JZW!1bzASr{x(e4D4g*hgv`7j^hRPQ(8-!D?
z@--|Kl}_1oq>#ZCWDN|NxQc56{byfOrrh5bxMnrawOyr<-_>VFOpIbopvNJd3_Vf~
zTlqGYVjL&aI3^6_Ox(atf$S+$D@DMl$zV%;MWM8Z_~V!|F^#tbQf?H!+QM#EV&K*#
z?V+YGWJP5#gF7ZH<atFJ+iv8xyM3TsfhDWt`Bhu1{rpR{7erp$HR<jLHCb17S@}oG
zf8N>`@;e%J&cr+x1V+!HZmJ-VRV7fcN*xtF@V(Hhc#Y1QejLZ+qcMeT;%zL^?sF9D
z4KE<Uh*fN>S~>I`w_4cE?+EmkovJItL!VjC+G?dcVzpD%fA(2yWMQqq60Ljt1RN+i
zuG%_$xu^V3<X(f3Y{{$0#*XwIy^n*bu;v5;%a@{y+nQt<_NA7qTU+4%IWI4yT6<xJ
zDhN-JE~lq;eStJ@*l6|4KybDx1QsvXL;`)~P*&=j@*uXWuZe%sJy}-0qc3Pfr<oV+
zDEisNk6R~IiApJo99X`RfyWOad%l^Xw=cbrH5R+{pzIy`74_87MW5a{`#qf<OpE$^
z!W1W5f|HZrddBhh9qtmi%ke4n2<7u0BWp-<1q{x<f|&gU#%Hh4`xDYXMA^%H>cI>2
zAjQ?YT$#;$yodYT3A~S$80#@Jb*?%4Bhqun7);>PPMkjK>W^@So4GNL#w}o#NCF=q
zA0vLloD>l)jd+Y<fzA12To?EjBV0@h{DzsW1#;a^;QN36)ND!qTY$IL=dK{f)eMGk
zheKGapXB=-{{l2ul6&if-=Y@}$or5{diNS>1LJ>Tf}uxP;8WXmaY3_h6f{EeQ3@KP
zpzHrD=tHc(S<quF#e%-$J-aE)K5=LzHI|A!n$WAs$fT97v99s?+%XnYH0qB|qjGGR
z8<@jQEYc!v)IB!I6icp+>e2)!M%j3Rr=-`hXLuf!(MAy;(a?vCM&@NA^QM`$!B7IF
Fe*r98=;Z(a

literal 0
HcmV?d00001

diff --git a/target/classes/earth/krakatao/events/KraSocketClientEventInterface.class b/target/classes/earth/krakatao/events/KraSocketClientEventInterface.class
new file mode 100644
index 0000000000000000000000000000000000000000..122150690fcc90da76514d191f52ef464e4af26c
GIT binary patch
literal 401
zcmaKo%}T^D6opS_bgH9*8-LcW>c$}As>?xfuu`Gm!j0UC*S6D=3`wl-=E4W?p~SR|
zC^O(DAt$-tIXRzS?;ijzu@_+=aKU7KDQinLc`}k)*51imOSw@s`$<y;;i^-o+OvHj
z#Su0H_UF`+Y)BU}o6T8yf#X2=JC*4>c8&@bNaA$GXkm>v$~3E1_e*^_nw&le9ISz}
z1#5xxI5oDAU6Q9ap1D4;EJ;7Rl4_PY+m`Lk&$(wEuCXSKaUtSSJWYT9lzUt0B6;lW
v$GLg6im$6CJUjWfnzN2D5)c@Ml7V4pY7--LjYZh%_ic>BjlfP=2iW}vd<T2x

literal 0
HcmV?d00001

diff --git a/target/classes/earth/krakatao/protocol/KraProtocol.class b/target/classes/earth/krakatao/protocol/KraProtocol.class
new file mode 100644
index 0000000000000000000000000000000000000000..1700a7a182ea4c2bbfd1916c16563b27f3c9fccd
GIT binary patch
literal 4174
zcmb_fYj+dZ72RV!MjB7Bun{0Xh<OBLi$oANF0~zkZ7?XYfyNJlNs7nPAPdVg%FKwy
zByAd?ZIV7oXiMUjw&^3KrENlkO(A9VLqGLXeno#oKQ!HUW@O8tbUABvY0b>N=bpRI
zxo4ky?$tm4bLSp_C-AX?Is{|{RfG_h5Id`#)6zxF$fu7@pVhODgm7QMC^-8i1d<&S
zG9nV1T&1#8D5m=@OPe1q*p31jfhg*s%6Le{Iy6Ywu4|Svlb*G-S<TVRbjdOuGiw&p
z&sf@VzfJt?TrP9amJlDVf!ix%y@d5EBS$oQW<)C~h<WxlsEA{ugodnX*yTCh@)hW2
z6`n8b6>e@;kwCKqxnLifD>?J-$|e=GqD{sY6%V7mV$lsm#&Gn!ZgIjntytENosqCH
znd$J*t2JEoZ7Q~72Qjr=j%!L*sd*9Y?Vv3gJ5}sLQbN!!oY!3!GD6&`B8A=T=XJ(D
zzS@otAY6S+MOsXc6bxrVxTRn(9+%Oj;tN9FxrW$}=(erpX*^0}qmJg3ZGqCQ;)^ac
zrGtVSA^ehx9wC$|Jg5u4_o7e5lVD;9*?76Y<!(q;hh@~U3Pzq$*^2`z`o(nB!#rA^
zo7OEcFsR~S1*6}}(}8*nsW^-y5*|8aWX+tu?B?!dCX=a(r;lGl)NyJcil_06jA0cc
zIJzpaN9S!vpJRy4vIwyUSTNJa=`F)x>DpXxBX`Gf6<@})5;o0gv-+TEWHskR!I@#p
zb~M9b#%>l4t;&SuC68fT#)OI!c&@TxR-0hhO2S~#xGzh5h>i&blQ<>gc@-~+&{b_s
zPla2js2h1_Mkt<EF$InJzyJ@-J374!CK(2WVaTe;LC~y;-I_H^O!>|liCG;;Kh?N8
z*N?o485G23ozbj*hAqg<9E@O=lrkEY)1K1>R|@7}$S_ru@S=ouE9FEuMM@oW+^`FI
zL(g$r37CP7OcXX88D$mc@Kp(0-AM++C5+j+lV)xjInBxqdVQ`fG(I+TdY^=5kG*PT
zUx{fqiFr}h&P#YWd1~OZH9IC6A>kE4_tzx!B?oF{+316b_ZhkVsxbNu38}RMO^}>X
zMul6@Vw5^PTdON<UzG!lohV7Y`+FtWRmy&utEF0{b*5}&oq}nkMJkJu**CoQYC)UA
zYH*Njv+52P4Bgw!W7>3)lEz^(s}(0St04NmFzCz_$l4=ou|x2Xdn8DZGRzo~pPgmJ
z_o4PA*8<|#j9%^ly2KNxa^9>Ilg|S~S48qN(^(_A_#7)BKV`S*HC7ShZ(h>LC3tb6
zp2ot)>HG}q-0lHOW180q*P;T#-LEpPa<K>9U9{}v9_DSw=W{fe<5^383EogDYV*1!
zO0!=Qlobh8M%|K-xBWqJ3b^&2zHX`%^3^#=Zg$rmsg-gfPZ|a2{U>vL6-MQ3mQb!G
zuZ8@7PG)7)EL&N9s2~zJR&_ghOq3#u229hj9ZM^X=+2Cpvm3(rqk=!-&oVv`W#dB$
zJ61|v!8m8m>a1Gg`11~qAua2e7VGZS>bmPIdZ0&G<BGbyW7srj%cb52ld4LxYU0>@
zNw1-Ps!G3d^QaQ}5QAE=I9hP@-U$A}^V`;qoS%I??UMJ4;Fg3|ufFHn=e$cpWzhRV
z%@~Gm4Hh-q)@>QLxz`_vN3CVbxFcc9|5oMB@nV9lyd2a4?!y}<i}q`7?*iYv1TOb4
z@*>45f-v8gI5vU+TR=<a5~R+%kWVfldJ77hF*X}-q3J^x=$m}6qcRXhkj5JL`xbku
zHyz)`>+DJ5e&j>HMQ!0yf9FR~7P09aG>KMBxs8@ZY&{WEZiv1&`baRhh>pLbbrFvS
zr}~7j#n)@OL68811I_dsXo7+b*u-@;V>7z=ehOP$XEu5UeP_Dp@EdrO?tI5Zkeb;%
zjPLsXy}(ci|JpiJi`c{G2|oMy^zwO%&%h!MeL#ge*LEY94Q!+B?P$afUX-_0*=+M|
z5)R+P_h~|yI^vm<t}x>DoV{=pnU>bJc<2s}0gD(-gcotLTaG2;^3=zXo=74RXt_L=
zhy+{3JJcGBoEMF7Yb@qA<kr|`w-IThJh+Ij^h6WUKq3+g$J%dWnvI?DkeCwN6%V<y
z<MK6Z4|FSWB`&{*1V@r_WhxPllan)-$1W+-`=9<R5fKaZg8Vd>2XydXM2bOv6z#lD
z@8o@SHy-ETqAu*`HTp2RnL7J0#@-YT@CMY+o5~<w;+6FR4&g0+uOj0HsKlke%&`1`
zR45_{%b{Ap4_$hMOb{j5SiohrM4l}W<!v|U3%EjA$d&zwvM~L+gdbBT)4P}P6WWT<
zm&166t*A@)R@8mUp?Vqhk|fEP^q+TSyvv0DH~%O|H1SiPp=$&X41Gd|8qboMRG{n0
zRIuwdiu>DAA@Sv(t(hry!j(=%AXf`KVJaeI-N9HpSq-IP;Y29l5_A`nCljHYu$J&r
zPdF9ZDfCjYT@{F_x4Y%ky;w5W9f?OcH=2qiNpL(ua^1O6f38ADnMpwsDJPUWT&l>Y
zyV!ejMY@EqujKC#)^mMFxz6L<w9j%EjWKxRBz6Krc#b2Jlsu2qnC4A2hl@DF0Ov{3
z9OGo-I$p#*l$R-Gtd@!V1V3ZodEv!BsDF(_HsNnBr2*nza48KE{T2M2dLbfa@e7y8
zi%g>{_$7&alU@i)BSbiW_go^c^N*k)Tp{+a@N43Vnw4gc6e1+5#L5CiNdrk-sY)T=
z!Ph9S!*4kLTfAQbr0IT;>e99v<abQX>n_~y@dtj_5$*<oZ@TY~$N^k$m+)8IMdH88
Cr4Z8q

literal 0
HcmV?d00001

diff --git a/target/classes/earth/krakatao/protocol/KraProtocolMessage.class b/target/classes/earth/krakatao/protocol/KraProtocolMessage.class
new file mode 100644
index 0000000000000000000000000000000000000000..eab4ca46d35215de771e4ad8b6f50d9d8fe7c189
GIT binary patch
literal 1217
zcma)4+int36kUhQ4A7xe>_u8?TdNeNwd1YcYD}b!aUx!lvAiE(0@KnNGaO9(2S3FJ
zO(Zrx_yK;Dai0Sz1m?k)v-jEAYp=7`*?<22`VHU!Pt%AYt|MU}35~&Yc_=#8S;)`0
z;DPlq3`Ecjy4LHEzaQmq++L5jT?VZuxajv7ST%zb(mFB*=3p?)pYl)K>T<trRX+=A
z&5Gc}?|E(CZP~tHNR+D;TXN4E$YFsY-8^r-?VmT?kj6O~<Z)HUq8zuxkQ<M4Izg!L
zPQ}h(1=n;G46I^}VPV|$u5s!%sZD$4`JQ;r5HDBil5X9=b!;#siOxPID)oph12<$f
z(Q<o2w%s&v3neP_`(BG7UmK5hMCkeLL)ld}P*GhxY?BM=wkw>GBgAJD{3vLV_*~8N
z-J!S-ywRmfz7{ljx6VUP-bclR=y)_{ulE0caL8Z~>(SV|-E!5oXP@iLmMV3I)DSG4
z&?!A8`NQl)>0T^XW^u!Y7fN!*3Ho8ved$S2E3-SYFMY!nd9_08rqQp`mQj|Mzn~)d
zt|Hm3A}xc8WGqD;w367RbB}KKC^CvE^9R@k^ski1aGOp|)$`b=+!*%2!X3IX+>OL%
zFK}fVzZ{8QRlJh_3$f`GOXg23n`;9wvp7J}TpwW5EF=clHkXnEWX*y$z|ME-oP3?8
zroS3a7`={WDMzHLlJX>`GU-ZOWzv^~%A_+%l}T@;;`^7%EV{`VNphw*Eo*K<R`Sx8
q2a({-X|NFqKEOlblb%d6Z-1l0q~vTQ_)#QyXBwP~1V2_3PyPW`b;eTw

literal 0
HcmV?d00001

diff --git a/target/classes/earth/krakatao/protocol/KraProtocolMessageHandler.class b/target/classes/earth/krakatao/protocol/KraProtocolMessageHandler.class
new file mode 100644
index 0000000000000000000000000000000000000000..ebdeea13c386c6f88c1fdf345bf1b6ef32d491da
GIT binary patch
literal 348
zcmb7A%Sr=55Uk!uR@Z1kK0xrM9vnnGDP9B-+^C@B-n$u+NyZ(So%mm#1P^|IA0_sL
zTs_zg)m_!lukWAFF97ElmPn8m$ok09BMcY(#>#R#QxEk*H-XT*G_46&g!J%eQeca4
zs@aFRT6$h`V5eTa3$Afi-Fbf8<YV1+Jkz(_PObKY?AlE=VNjV?->+V3?Vq`}qKqon
zu${0sk#EE-%uPo)tNuOdf>1uWm2dQoiS76Q-038qiUSn#foLQyKM>p&rq&$Dk3T@~
ZA|xmUV;M-XBiLW(xx`&zggwCogI@<~R?7eY

literal 0
HcmV?d00001

diff --git a/target/classes/earth/krakatao/protocol/KraProtocolStatus.class b/target/classes/earth/krakatao/protocol/KraProtocolStatus.class
new file mode 100644
index 0000000000000000000000000000000000000000..bc6e9f118eeb3a4c419ec4f38aa28a5b96552c86
GIT binary patch
literal 1567
zcmb7EU2_si6g@q_Fpx<YQSn>X7!^niekAG&#$YnCY(|JolB&^%sR?2v60jzNKgVC-
zgNyEJX=(ZFqd&;<-e$JM(g(u>ch0@1Pxt-k{`~dbM*#D%5>OC{BdQ|?RUp^${NQon
ziSIq}0<Twi>i2?Pv)3uC_}*&xZ3kY^-xY{YZIrEb(-xR{VEy*GViFn>ai}_y7!!y!
zJH2j8;6OHKZF|qWLdWZF73!PYt!6;naZJRK(qUkqz{Gcg+3oMp5uSOSeyjdSU_Lvt
zda2{>?iNQJcHp<WTgA~GSU~FU*Kq&`1=Lcz+YS~4GNV%A%4%+dD|JZ6VH_duZde0R
z)o@H8YMZs?BoR)q*hzsyztRXr{?Ks@rv;|>P&5r^1R@o4jZbk_#~GZ~a9-f>UDLM9
z71J$S4YR!LxYe3_Z{1usnU~XXo_W($IkVBIH{4p?T{RnbZH`{hG0o9}Kx!CWYdCJX
zQm)oGd`U-v!&d|j4#VX}#kI_uyH>Bex2qK<&Fi?rq-)g2hPi4v?EF*5HO^0!&7nb=
z&F1zpAXLt!-a{IRl-2IGYW<zfmcQn0cF1$<7iG=up^O4)tJm~88=l{0#ZWfd^>#=-
z{qw}oS%SxH${}I5x4Ja<KJlVi>Lj_gTEYK!A(G8i1+-GL6AlqMh;nm8kq54{hqEpe
z1(J5J?>Ad_+MImmr#m>y_hIo8)qI?8b7Jub4;Da{=0jTQzqHh8X{n{sQrD!VM$yVN
zPc>j1<wt;U3<=yo5dtMblVtgq96<bs_$O#D2~l$NugVzn4J^<%^XH&QZ!)dq-$MTc
zh55=4{9EMFhb%0jEaP->h{XzjA%Z9~^3%uPAe}$)FEal~4(~ZZQ9iSZ{TQR`##$L#
z$%?mSKK#WQMX*F(1<SOPi96x>3S>E>SpGFKFC^i6Dk&*9JX$Q2(@>!!4U_vq#o^!c
z_fVYl(TI_JgX6DoO2WygF(%=Zgy&+0E@4)}ylRX~I3wX~+?bH?qJ)<<BPHRSgjWsK
zFeJWi#6QqpkpWKGPIQ1N+ldX3wH<YU8QX~uaM5<O0p@JSAlG&K6$BS+*q}*zZ2@{h
h$)2P(U7%ODL}go{65Xe<*`|DyuuN6_O<V;l-vI49N>Km+

literal 0
HcmV?d00001

diff --git a/target/classes/earth/krakatao/protocol/KraSocketClientProtocol.class b/target/classes/earth/krakatao/protocol/KraSocketClientProtocol.class
new file mode 100644
index 0000000000000000000000000000000000000000..9c6d892fd8bb5f4dd319971ef0d30838185c3f28
GIT binary patch
literal 4282
zcmcInYj+dZ72RV!MjB7Bun{0^6Y~hj7K!S(ajESPY=c3Gc{DaAn51}+26?bNqs)wG
zOwy)2+9v6fgtjEKv`rr=Eo~DTYzir>ANr}E@+<ly`l0E*Gb39D(N$QhOKWECJ@?#w
z&OQ6wbFcpK?^|~OJcUmbG$14+tRjM_gv3ehl$I@NW-)u<_(?tQN{9{^rs3|85K4DW
z$cRa3@sujAQOXY5wl+6vIIaR2p*R|$%6LS@3N%T`>YD9NXJ>3}MsqbQTedCN%3G!E
zbG9~S<!5wvxMb+2doYmGR(`gS+vP||j@Gf!FJq;Il}jUgHD`LCR#uSkZLd<1#A*pm
zdCPPvv$`E9(B&GuK-e!_UaKO7brNL5**#l!=e$);DriHyjP)uWMMu@57nGdo>P6k=
zgi~6nq8~URVRbs!>7&<bc<38dY{F(@YJ~#Vl&(?pqubv}TQat&*ow4-uw$IoJr{C9
z+@&IeZR{6y@{n9^CjbzxKA|EjrpFA^oe*v*=*E*WdQ^N~$a^1<hkd%^Xhk{_r{OVI
zb1RNO>{amv&kUu*f+r#TqKZBtlquY$i#+JYfQqNVgb}hs6@yD(m97oZm}?tmkrC>~
zP8EY<y6R)@ugo6TZ80#cVpkPo&@R$}MvSP~gS`?S*=^>ng1+eHwsbC+tBGxZUq{q=
zbSREz@tllN75lJ%S;CLaIj%m-a9b4-ZXeLFvIprc!(i*$Y=1L%%|R7k!t)Z=%xW|G
zuw~{o_psqkv*oy&=`wrQ3Wt_u#p063aY)95io<xJx{;QfVA#sSV9C5IV*-fI2?dil
zD&s{JFNx6AY*}B0+o+_QMR!^#9#b&|jk&=956!tcy$h!q28ChBt0+LwtchKmx5`Za
zt~yCt8^|E-xH`{|qKau4V&hJ0_8`L+W|j`eFhfci4cqM~=z=Q+voK{?D$00S!iuFb
zBb*|ou64+CjH0O*xWxp_P-iX<2d<2Yic|QCgbm&#li?D^9No<_H_d`(7l!>l*A_W6
zK5}fkgmpf9waS4K({2)TqTHR9@M!wz(ET+#Cz>JQH9_}RB@Cp8>Sfv3y@_|9Tz_2{
z{knwA{|+=ka>f`HZb6$->hf(Zue<{_4ls72JoWGBm+*Rxa!~T>sn%$nsF-=zu*|GT
zWl=r{Mjx(n(7x~>JWS?UjYkbr_jmTVcDzJM^Qe{AN)wuGh<+dpyVC|4?0!(2G!*fU
z4GB_?nZ%^X&+t?TU<c9<3K-Ote(n;w%G0ZQJ}nlU?GFn{7sY1b&R|VtfC{Xb{8YRm
z*<3?pu-QpJm*&TgdKwEMr}Hzavpj@sjoYF@xEU7^-u{+xi9y)q?Yc#W2bkxb5ASri
z!1J5F(@;~nq|NEJDC<EvQI;fB8S~0X(Fq2{3F4g<^m|S95LlkS<ZoO3k$UMW@~T;Y
z-hIL+mtj=TcnN3f$?GBiA2)(BW>xIGK4OUEZ@bU!=Lu2XSk8wm%XM5^EAP|YX{+Eg
zMezp(f5e|;d?-rMM-nzKl~2PwWzFcUgyKl`52Fz+?^-r%`K8)g9w_>tds#P2y0dxI
zvSupf{(BRzMzU<;_*_}9qkgnTzk0K&5d{##TB$T<xO#sKf99RQ(al1Tp?w{a|BK-U
zBjleMg^pSOB2pdnzfg0gsoTRP&2e-`#!U&2-4l;`%an0T!utQN%H8G11RHqaXaKy2
zw^<$pXT087zIn-9?4RRBjTHz{zRz=PA3|&atz8R{x^6>0vViyvC~PL!Y`%e(k367n
z@V$b{KpbHjYvS*l?5X~Ad<$=|Cy6^(0R1+#g-e57A48ePns?D6S_$PQTIaFha6-8z
z`u^x+;leyR|Aw}CJRY7J5W?0#uk{*1LJ$tDqu)Ra6s*D;u4^6EqKEHiu-<cKwQn$R
zriTu{iMQy^w><=D9h-aboxs1B7z*KEdsk*2pX2ispY445`8>mCXdb&iq(XydyP3-d
zHq!PcG-ER_;u~vhwg)x|hwtKhG$Bmw^-W0^8SzHWzI+|I*0%O!<Q5J9^B7A-=W(Q0
zPNb9a)F-jNSSl83y)d4Nh1<kC(w2yw7L90IBH=aUw!~Vm5o@PBJdZE;#Z&Q6Dwc>Q
zI&R`P8(WeQF(t7z8S!Q(<tx|}>Q$0TQhpyPj-->yR4SSzCnqk9pI4+0KKo}XCKl=k
z`B^Rx=;XhY41@eQI(S{*!aMFZJjuUcJ=no(`X2N$b+%)iy(#SEt!j|BpJBYhYw%g@
z#@qZ}Le2|NnM;3_Vfj9(P(%<GLv<NH@aPdTL6l(QGA^(s^6WBE-tmHd85b#wc(NZ-
z7NuY3@gvG)diN@ROj|MfvIp<775C`gfQHXF)F`7-k|Y_E!SkMs_n7ei;vW%-CVmny
zbcFzdp-;(B^GPz33H3ak3HRJYX-9h|BEI}HH$BBpwA!f(<XV9*%*2GOH=O7otC371
znu>%xf^K8-NGft2_5xn%i)IpAgkC1GwF)uyPOqG~lSmhOW62oj#xsdD2~NgHt~WOx
z%vI<pGbv0W<&<)ZOBMNa8{J2iqzm}kQvQx$CD*r~>paL!`#g8iID>bH#7<xYFK}d%
zk{59d$9elL;2cgcz(rCt%Q#uMikEQ*l|@P!t3@I|#ZMV{UZU}L>R%y|E%>WPX^6OI
zJxaqwe+@sQUWABw{M;k*9Mk9`enBGNq8EbF7!h{jeUHei{G%xdSBU*f{EE1uW@XtU
zg@}kMv9v%@(m)cIs!}9y@C@Y*_%+9WgAeL}wA>9+TiTX`{FbSC)r0#Te$Vd;!d)Zq
Sb?^N#Ie_Qw0{(*ANc{)hqC7_c

literal 0
HcmV?d00001

diff --git a/target/classes/earth/krakatao/protocol/KraSocketClientProtocolMessage.class b/target/classes/earth/krakatao/protocol/KraSocketClientProtocolMessage.class
new file mode 100644
index 0000000000000000000000000000000000000000..b37667217e2419029b2b9eed29f99ce9607bbcc0
GIT binary patch
literal 1253
zcmbVKU2hUW6g|_zF3_b^?1%KjwxSfa+V!ioT4N$K#*O%qtmS=x4Q!#iW*JQU5B?M%
zG?Cc&;1BRe8Sf0F5W4Zfm$`Rt?z!ilGxPh;&tCxc@g#{E%<704h(lvIaCs=&Rwv{g
zE_h&l2m=u`g0A%{<WA7&xT4baTwlB!)nB{49&fn}T2FA%?=i4)3JD~2qzuf#V3<GU
zAGy`#e#<I<64aU&!HM7VTE5$~eZdebmP@wWW8Odp3k=D|S@TW*tnP+1&PgGQt2!3t
zxFv?nc%0J?LWOrqb_y%FrXy!y6>AI&<F2>$Q@25F+EdT>#50E3VyPzSHVj<HCPSR)
z>|>%*OKcmsA*->b+Y_?wrh!{1P@&)Vnhe?Mc(fxz&u<;cuA+gG>f&LGTu8QD;fx$1
zKAYf`ph@C0RnK>a;@<Ommnzw6(BRz~4?TGw6=S09(U`;P|Gmc%gFzcq#y;*A%eH-a
zb?0)aRAWdC!O|6-(qpn>n4KsO7K^3JxM9O{B|qf^{jlM_@T9=}zyHpj^b_0U;R=08
zjb596B4t_mIx5n8s7TMCB7G7S$#9A~7)<Qad7EzcDKd%)^E=o%^e>dp;0~Rds%NoB
zxiRd4g}ZcPxEF~}pX16jemN4qs(2;;XJXSS7R(=5HrEDV=K28Z=EeY9W-c~B-du_g
zkT!GL06X8Pb8<UPO@BF@Fxrl0DMzHLg7RcWWzv;dl}TS>DwEE{RVKZWiXU7kv*;#g
z#L1cUX<2g<vf>xEJd6ZyO@oa{@IDTRPkJ)Roc~INNy+I*@S{lZ&NMg^2|iR5kN*N)
C*woJe

literal 0
HcmV?d00001

diff --git a/target/classes/earth/krakatao/protocol/KraSocketClientProtocolStatus.class b/target/classes/earth/krakatao/protocol/KraSocketClientProtocolStatus.class
new file mode 100644
index 0000000000000000000000000000000000000000..95841818cb429b8233b6745a4086833683b09da5
GIT binary patch
literal 1651
zcmbVMTXWk~5dMyA%d(@y!fn(0Ee+Im+Pb9)3AG7v6V;fgcCeDn2p%+w5vdYKVjQ_Y
zhhM-0xIh^gm_GNBAH=YGtWM3);lY0J>f8O!p1q#efB*I;fE8FdC`e_I){%iKu;P1z
z_*wOM;2nFh7gfI<L~+!M`qk}$XGgtbKi=#Iei-j0dOP;w;i*7&alc{hnYO^%SJqTM
zYI$hLWufZGV@4p;>qnt4aJE#oj=bkyweN+8)y~0@-;0Smi@7WcIt;ugF!z>VhQkvI
z=egG(`kikmq0+?Z&AxYfTANVV@gN8fYm+yy1L^;aj<Yx?pw@#hh}Q+?CtW2cTjhPO
z;CUSvaFMvDNj*eM!)1ZAZML`aM7YY%t_hrfmyg8B4IP(pQ($$<0&2J=kZPK{9MSta
zZsDee+X5G!nzr3&nr_4DnvE^TZMEGm_RKw#d1W29nYTn$G`rnS*KK#)9kct?X6s!Y
zOKhzQ6vo!wuH!bEjaHk@4|G)7{7~TB*xcwgUCV5{yPb~vxYcCRijId&TBV+L%^k~O
z<;OZ!IagISiU#OWsXXoAP?<NQuW3{YRuKB_;mLtN*!2$jq}hH)xyw_QSD<J`J+Hs-
z4FdL_T#*jF6S}GR->IUw;%5Qnma~JykoIIiymX1WO{zmbezQBNQn@9d)qDM9&`3d)
z)`UkM%KDUXuh#_fb~GIH{3ihyW#NB!`5y1m#slinEWHr9jf*^#07;rBDQRA$q{)zy
zMnFpHvXs<VI$7k60E|ogun^85hexPEpiXFkB>(awh+mL>1?>ky0-w;oDs9X+uuk91
zUxp&J`Jz(!75XbE%vb)!|CBWPn1u~Aq@9+ISnT05q>yGtW$DUG6f0MM#{7?x!*|Y+
zm19<M1~as(>}#G*vd70VAO7NuQrIM|f-Snq#FHexDoM^LQ~3$=-%G;VR0`7FIJ8XS
zPD7JI8YlM`6^DP{{SL(`UP>AHm$>o**Ckv?8#59vO87y>&?PKMSW%5x3GYaFFKf(6
zcwfQ~HKQQmvV<QQs$odHW@P`MyHX=ux1IC|i?)*)p=3Mi2zP8JJHmb2(MDLd9fMSB
u_6rCu*0@0n^il)#{F1yzZMsV@cAd($O(pu0#^#9fQIayX@Huf6Z2tqN5NsU)

literal 0
HcmV?d00001

diff --git a/target/classes/earth/krakatao/test/TestInitiater.class b/target/classes/earth/krakatao/test/TestInitiater.class
new file mode 100644
index 0000000000000000000000000000000000000000..6f2a99192e935b463d762f75a3fb0477d13ee583
GIT binary patch
literal 1254
zcmah}TTc@~6#k~IY%j~j0`-EI7DU^EtRi?@1Q8^X6f`Np$lFjRWuUuDcBjU^`zQPb
zK5JBhCdOy~i2uPD^-M3&k`P{IXHL)g&Ue0ZPJjOW`W?VDmf{E@Y#?Id47wQlcKB;<
zRk&NWo^S4ml49tZk*-v;4B>2U-9VI~zwT63vSQ8qKCcyIpyDtPjv)clK(~n=^fF`w
z_tmzw>+@Z%xMwL5C~J+5Wdf9337^5NP_S@?uR$n(;Rst>>;%ptX`tW400tR)I)5fo
zd~1tgFx!Z0BW~w5VmOEM1}>Pmh@p<!iZx2=P_$R2q=SuM=~*v)>8hgg1$XQyE>o$`
zgfG%ENISK(BZ7dJMJA4`NE^tQ7{*9Tjm}^OV^2d>++*AbTe@XCx323NHE|s`7^0G-
z;L0O8QrTRa0?SQ1sgOh7z?g|~++;`|snBwvjN3d|6>q2>YSe~~uuR;-ZH9<jHxIP1
z+f_1fhar7ZqjU>&a}t=uw28ZVM7o`t?%_&94Te}zmR+u@zF?SYBd=p;3a264vo;Z2
z@U|$rw;)}yT6H#szs5H!WJwmh60fXtU+Q<$7*X3YU>G?O`*6GnIzjW%s)AuOdty+_
ziF!j*sYkVCVHiF=iga*lhnjR36))|s@VzGGc+so+C9x#yMRlyegzhCWv^gQ#NGe(H
z4t?*@D}?(9)16k6&Ie?ft-pc3{61Lz8;n=`h<!%<L*4r!oqC}`{t-lB)6Jwv^2ZDw
z(U%dzToY@NJhiWx|AhG10s2CCc^oI9H@c3KYWOyBH11=}6B5IdLw0Y;CrpUeN2HRM
zzTk>RKEO4G0^w&F-XTSo35Fk-Tp2&W6vO*}zjV?tH2D;j3MxOUw}Ye@Lq8^H^K~Jb
gz$m5CX*F%DNo9fVB;FtWH<9~|A!4*hrVyU~2WGM-4FCWD

literal 0
HcmV?d00001

diff --git a/target/classes/earth/krakatao/test/TestListener.class b/target/classes/earth/krakatao/test/TestListener.class
new file mode 100644
index 0000000000000000000000000000000000000000..505a0918b3d0b3f8b3de591c6b5c2f40b377dfb2
GIT binary patch
literal 155
zcmX^0Z`VEs1_o0GPId++Mh1n{#G;Z6{p_N|?8K79eEpKt;u8H3AmNi)T#}lXTEx!4
z!pI<yl~|UjpOcuEuJ50em6}|_$iSOh2~y^pT3no%p32C;tf3jk$iNkxUs{x$>Xw-U
k6cR)>M-OBK8zTcyCD3{X21cN<tPE@*76UtwWMbd|03>WDNdN!<

literal 0
HcmV?d00001

diff --git a/target/classes/earth/krakatao/test/TestResponder.class b/target/classes/earth/krakatao/test/TestResponder.class
new file mode 100644
index 0000000000000000000000000000000000000000..28781d74acc8a783ff03a88f803f062230a93aac
GIT binary patch
literal 576
zcmZ{i$xZ@65QhI|8wLkK5cdV*1w1$>;{oHv#M8J$2=@j$&@c<>X-s%5J!s;=2k@bc
zHG@G(<WiN|zW%$bKfm5T0Gy+iLjp+yDGO<27>XnQ#BG=R1N*)^5<Sh3xs<-tR}9H|
zqhlfq(?HI`8my)E)-2S*qpn~|Llq|m$-sV4($_7m1oxU*tTW`iS=AF^$Oj^aA~p<^
zER?ayQ2u9z!I(q@*C%LwPL1UeQu>2tqhnx;p(eP}Lwl_Fm}?%`T7=qelX(>3B=Gw}
z8Q5W{u4;26srQ9qNL>eg!BB9dFYcyZSEx4cx|At7L65r~u4EMdBvX1QLxvM)6?k!e
zlOgZTB1yON%hOA=f~o3>8yVx5)Sg98ff_2b9)@k&Rpe<!WOpgD$usil(>Ji^xV%R;
wDg#OEleOjzIKUxA3`dLMix>u&FEC2^R}_8$(RTn0+H&>}#9Tm*shU9b8;lTv+W-In

literal 0
HcmV?d00001

diff --git a/target/maven-archiver/pom.properties b/target/maven-archiver/pom.properties
new file mode 100644
index 0000000..56e9bb7
--- /dev/null
+++ b/target/maven-archiver/pom.properties
@@ -0,0 +1,5 @@
+#Generated by Maven
+#Fri Dec 17 19:53:24 CET 2021
+groupId=earth.krakatoa
+artifactId=KraSocketClient
+version=1.0-SNAPSHOT
diff --git a/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst b/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst
new file mode 100644
index 0000000..1ff5c4d
--- /dev/null
+++ b/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst
@@ -0,0 +1,7 @@
+earth/krakatao/KraSocketClientConfig.class
+earth/krakatao/protocol/KraSocketClientProtocolStatus.class
+earth/krakatao/protocol/KraSocketClientProtocolMessage.class
+earth/krakatao/SocketClient.class
+earth/krakatao/events/KraSocketClientEventInitiater.class
+earth/krakatao/protocol/KraSocketClientProtocol.class
+earth/krakatao/events/KraSocketClientEventInterface.class
diff --git a/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst b/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst
new file mode 100644
index 0000000..b6d5275
--- /dev/null
+++ b/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst
@@ -0,0 +1,8 @@
+/home/alex/IdeaProjects/KraSocketClient/src/main/java/earth/krakatao/KraSocketClient.java
+/home/alex/IdeaProjects/KraSocketClient/src/main/java/earth/krakatao/SocketClient.java
+/home/alex/IdeaProjects/KraSocketClient/src/main/java/earth/krakatao/events/KraSocketClientEventInterface.java
+/home/alex/IdeaProjects/KraSocketClient/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java
+/home/alex/IdeaProjects/KraSocketClient/src/main/java/earth/krakatao/protocol/KraSocketClientProtocolStatus.java
+/home/alex/IdeaProjects/KraSocketClient/src/main/java/earth/krakatao/KraSocketClientConfig.java
+/home/alex/IdeaProjects/KraSocketClient/src/main/java/earth/krakatao/protocol/KraSocketClientProtocolMessage.java
+/home/alex/IdeaProjects/KraSocketClient/src/main/java/earth/krakatao/events/KraSocketClientEventInitiater.java
diff --git a/target/maven-status/maven-compiler-plugin/testCompile/default-testCompile/inputFiles.lst b/target/maven-status/maven-compiler-plugin/testCompile/default-testCompile/inputFiles.lst
new file mode 100644
index 0000000..e69de29