From 319e82391bfb8822fd75684f17ae28b26c1e3b0c Mon Sep 17 00:00:00 2001
From: Leonard Kugis <leonard@kug.is>
Date: Mon, 25 Apr 2022 18:49:40 +0200
Subject: Initial commit

---
 src/com/encrox/twitchbot/client/Client.java | 135 ++++++++++++++++++++++++++++
 1 file changed, 135 insertions(+)
 create mode 100755 src/com/encrox/twitchbot/client/Client.java

(limited to 'src/com/encrox/twitchbot/client/Client.java')

diff --git a/src/com/encrox/twitchbot/client/Client.java b/src/com/encrox/twitchbot/client/Client.java
new file mode 100755
index 0000000..557517e
--- /dev/null
+++ b/src/com/encrox/twitchbot/client/Client.java
@@ -0,0 +1,135 @@
+package com.encrox.twitchbot.client;
+
+import java.io.BufferedInputStream;
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.io.UnsupportedEncodingException;
+import java.net.Socket;
+import java.net.UnknownHostException;
+
+import com.encrox.twitchbot.client.messages.Message;
+
+public class Client implements Runnable {
+	
+	private volatile Socket socket, iSocket;
+	private volatile BufferedInputStream bis = null;
+	private volatile DataOutputStream dos = null;
+	private volatile DataOutputStream iDos = null;
+	
+	public int connect() {
+		try {
+			socket = new Socket("encrox.com", 5424);
+			bis = new BufferedInputStream(socket.getInputStream());
+			dos = new DataOutputStream(socket.getOutputStream());
+		} catch (UnknownHostException e) {
+			e.printStackTrace();
+			return MessageTypes.ERROR;
+		} catch (IOException e) {
+			e.printStackTrace();
+			return MessageTypes.ERROR;
+		}
+		Runtime.getRuntime().addShutdownHook(new Thread(this));
+		return MessageTypes.OK;
+	}
+	
+	public void login() {
+		try {
+			iSocket = new Socket("encrox.com", 5425);
+			iDos = new DataOutputStream(iSocket.getOutputStream());
+		} catch (UnknownHostException e) {
+			e.printStackTrace();
+		} catch (IOException e) {
+			e.printStackTrace();
+		}
+	}
+	
+	public void post(String message) {
+		try {
+			iDos.writeInt(message.length());
+			iDos.write(message.getBytes("UTF-8"));
+		} catch (IOException e) {
+			e.printStackTrace();
+		}
+	}
+	
+	public void write(byte[] data) {
+		try {
+			dos.write(data);
+		} catch (UnsupportedEncodingException e) {
+			e.printStackTrace();
+		} catch (IOException e) {
+			e.printStackTrace();
+		}
+	}
+	
+	public int send(Message message) {
+		try {
+			dos.write(message.getID());
+			dos.write(message.getData());
+			byte[] res = new byte[4];
+			bis.read(res);
+			System.out.println(Utils.ba_to_int(res));
+			return Utils.ba_to_int(res);
+		} catch (IOException e) {
+			e.printStackTrace();
+			return MessageTypes.ERROR;
+		}
+	}
+	
+	public IRCMessage getMessage() {
+		byte[] user = new byte[32];
+		byte level;
+		byte[] message;
+		byte[] buffer;
+		try {
+			bis.read(user);
+			buffer = new byte[1];
+			bis.read(buffer);
+			level = buffer[0];
+			buffer = new byte[4];
+			bis.read(buffer);
+			message = new byte [Utils.ba_to_int(buffer)];
+			bis.read(message);
+			return new IRCMessage(new String(Utils.crop(user), "UTF-8"), level, new String(message, "UTF-8"));
+		} catch (IOException e) {
+			e.printStackTrace();
+			return null;
+		}
+	}
+
+	@Override
+	public void run() {
+		try {
+			bis.close();
+		} catch (IOException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		try {
+			dos.close();
+		} catch (IOException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		try {
+			iDos.close();
+		} catch (IOException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		try {
+			socket.close();
+		} catch (IOException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		try {
+			iSocket.close();
+		} catch (IOException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+	}
+
+}
-- 
cgit v1.2.1