summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rwxr-xr-x.classpath6
-rw-r--r--.gitignore171
-rwxr-xr-x.project17
-rwxr-xr-x.project (1)17
-rwxr-xr-xbin (1)/.project17
-rwxr-xr-xsrc/com/encrox/twitchbot/client/Client.java135
-rwxr-xr-xsrc/com/encrox/twitchbot/client/Core.java59
-rwxr-xr-xsrc/com/encrox/twitchbot/client/IRCMessage.java26
-rwxr-xr-xsrc/com/encrox/twitchbot/client/MessageTypes.java8
-rwxr-xr-xsrc/com/encrox/twitchbot/client/Plugin.java11
-rwxr-xr-xsrc/com/encrox/twitchbot/client/PluginHandler.java82
-rwxr-xr-xsrc/com/encrox/twitchbot/client/Utils.java48
-rwxr-xr-xsrc/com/encrox/twitchbot/client/messages/Login.java49
-rwxr-xr-xsrc/com/encrox/twitchbot/client/messages/Message.java9
14 files changed, 655 insertions, 0 deletions
diff --git a/.classpath b/.classpath
new file mode 100755
index 0000000..91ee9a5
--- /dev/null
+++ b/.classpath
@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+ <classpathentry kind="src" path="src"/>
+ <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.7"/>
+ <classpathentry kind="output" path="bin"/>
+</classpath>
diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..9d02df8
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,171 @@
+
+# Created by https://www.toptal.com/developers/gitignore/api/eclipse,java,windows,linux,macos
+# Edit at https://www.toptal.com/developers/gitignore?templates=eclipse,java,windows,linux,macos
+
+### Eclipse ###
+.metadata
+bin/
+tmp/
+*.tmp
+*.bak
+*.swp
+*~.nib
+local.properties
+.settings/
+.loadpath
+.recommenders
+
+# External tool builders
+.externalToolBuilders/
+
+# Locally stored "Eclipse launch configurations"
+*.launch
+
+# PyDev specific (Python IDE for Eclipse)
+*.pydevproject
+
+# CDT-specific (C/C++ Development Tooling)
+.cproject
+
+# CDT- autotools
+.autotools
+
+# Java annotation processor (APT)
+.factorypath
+
+# PDT-specific (PHP Development Tools)
+.buildpath
+
+# sbteclipse plugin
+.target
+
+# Tern plugin
+.tern-project
+
+# TeXlipse plugin
+.texlipse
+
+# STS (Spring Tool Suite)
+.springBeans
+
+# Code Recommenders
+.recommenders/
+
+# Annotation Processing
+.apt_generated/
+.apt_generated_test/
+
+# Scala IDE specific (Scala & Java development for Eclipse)
+.cache-main
+.scala_dependencies
+.worksheet
+
+# Uncomment this line if you wish to ignore the project description file.
+# Typically, this file would be tracked if it contains build/dependency configurations:
+#.project
+
+### Eclipse Patch ###
+# Spring Boot Tooling
+.sts4-cache/
+
+### Java ###
+# Compiled class file
+*.class
+
+# Log file
+*.log
+
+# BlueJ files
+*.ctxt
+
+# Mobile Tools for Java (J2ME)
+.mtj.tmp/
+
+# Package Files #
+*.jar
+*.war
+*.nar
+*.ear
+*.zip
+*.tar.gz
+*.rar
+
+# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
+hs_err_pid*
+replay_pid*
+
+### Linux ###
+*~
+
+# temporary files which can be created if a process still has a handle open of a deleted file
+.fuse_hidden*
+
+# KDE directory preferences
+.directory
+
+# Linux trash folder which might appear on any partition or disk
+.Trash-*
+
+# .nfs files are created when an open file is removed but is still being accessed
+.nfs*
+
+### macOS ###
+# General
+.DS_Store
+.AppleDouble
+.LSOverride
+
+# Icon must end with two \r
+Icon
+
+
+# Thumbnails
+._*
+
+# Files that might appear in the root of a volume
+.DocumentRevisions-V100
+.fseventsd
+.Spotlight-V100
+.TemporaryItems
+.Trashes
+.VolumeIcon.icns
+.com.apple.timemachine.donotpresent
+
+# Directories potentially created on remote AFP share
+.AppleDB
+.AppleDesktop
+Network Trash Folder
+Temporary Items
+.apdisk
+
+### macOS Patch ###
+# iCloud generated files
+*.icloud
+
+### Windows ###
+# Windows thumbnail cache files
+Thumbs.db
+Thumbs.db:encryptable
+ehthumbs.db
+ehthumbs_vista.db
+
+# Dump file
+*.stackdump
+
+# Folder config file
+[Dd]esktop.ini
+
+# Recycle Bin used on file shares
+$RECYCLE.BIN/
+
+# Windows Installer files
+*.cab
+*.msi
+*.msix
+*.msm
+*.msp
+
+# Windows shortcuts
+*.lnk
+
+# End of https://www.toptal.com/developers/gitignore/api/eclipse,java,windows,linux,macos
diff --git a/.project b/.project
new file mode 100755
index 0000000..e790f52
--- /dev/null
+++ b/.project
@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+ <name>Twitchbot-client</name>
+ <comment></comment>
+ <projects>
+ </projects>
+ <buildSpec>
+ <buildCommand>
+ <name>org.eclipse.jdt.core.javabuilder</name>
+ <arguments>
+ </arguments>
+ </buildCommand>
+ </buildSpec>
+ <natures>
+ <nature>org.eclipse.jdt.core.javanature</nature>
+ </natures>
+</projectDescription>
diff --git a/.project (1) b/.project (1)
new file mode 100755
index 0000000..e790f52
--- /dev/null
+++ b/.project (1)
@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+ <name>Twitchbot-client</name>
+ <comment></comment>
+ <projects>
+ </projects>
+ <buildSpec>
+ <buildCommand>
+ <name>org.eclipse.jdt.core.javabuilder</name>
+ <arguments>
+ </arguments>
+ </buildCommand>
+ </buildSpec>
+ <natures>
+ <nature>org.eclipse.jdt.core.javanature</nature>
+ </natures>
+</projectDescription>
diff --git a/bin (1)/.project b/bin (1)/.project
new file mode 100755
index 0000000..e790f52
--- /dev/null
+++ b/bin (1)/.project
@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+ <name>Twitchbot-client</name>
+ <comment></comment>
+ <projects>
+ </projects>
+ <buildSpec>
+ <buildCommand>
+ <name>org.eclipse.jdt.core.javabuilder</name>
+ <arguments>
+ </arguments>
+ </buildCommand>
+ </buildSpec>
+ <natures>
+ <nature>org.eclipse.jdt.core.javanature</nature>
+ </natures>
+</projectDescription>
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();
+ }
+ }
+
+}
diff --git a/src/com/encrox/twitchbot/client/Core.java b/src/com/encrox/twitchbot/client/Core.java
new file mode 100755
index 0000000..a872432
--- /dev/null
+++ b/src/com/encrox/twitchbot/client/Core.java
@@ -0,0 +1,59 @@
+package com.encrox.twitchbot.client;
+
+import java.io.BufferedReader;
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.UnsupportedEncodingException;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.net.URLClassLoader;
+import java.util.ArrayList;
+
+import com.encrox.twitchbot.client.Plugin;
+import com.encrox.twitchbot.client.messages.Login;
+
+public class Core {
+
+ public static String username, password;
+ private static BufferedReader br;
+ public static Client client;
+
+ public static void main(String[] args) {
+ br = new BufferedReader(new InputStreamReader(System.in));
+ System.out.println("Twitchbot-client build 201510042114");
+ System.out.println("Setting up...");
+ setup();
+ System.out.println("Connecting to the server...");
+ client = new Client();
+ if(client.connect() != MessageTypes.OK) {
+ System.out.println("Failed to connect to the server!");
+ return;
+ }
+ Login login = new Login();
+ do {
+ System.out.println("Encrox username: ");
+ try {
+ login.setUsername(br.readLine());
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ System.out.println("Encrox password: ");
+ try {
+ login.setPassword(br.readLine());
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ } while(client.send(login) != MessageTypes.OK);
+ client.login();
+ new PluginHandler(client);
+ }
+
+ public static void setup() {
+ File plugindir = new File("plugins/");
+ if(!plugindir.exists()) {
+ plugindir.mkdir();
+ }
+ }
+
+}
diff --git a/src/com/encrox/twitchbot/client/IRCMessage.java b/src/com/encrox/twitchbot/client/IRCMessage.java
new file mode 100755
index 0000000..69f8cd5
--- /dev/null
+++ b/src/com/encrox/twitchbot/client/IRCMessage.java
@@ -0,0 +1,26 @@
+package com.encrox.twitchbot.client;
+
+public class IRCMessage {
+
+ private String username, message;
+ private byte level;
+
+ public IRCMessage(String username, byte level, String message) {
+ this.username = username;
+ this.level = level;
+ this.message = message;
+ }
+
+ public String getUsername() {
+ return username;
+ }
+
+ public byte getLevel() {
+ return level;
+ }
+
+ public String getMessage() {
+ return message;
+ }
+
+}
diff --git a/src/com/encrox/twitchbot/client/MessageTypes.java b/src/com/encrox/twitchbot/client/MessageTypes.java
new file mode 100755
index 0000000..c70fa08
--- /dev/null
+++ b/src/com/encrox/twitchbot/client/MessageTypes.java
@@ -0,0 +1,8 @@
+package com.encrox.twitchbot.client;
+
+public class MessageTypes {
+
+ public static final int ERROR = 0;
+ public static final int OK = 1;
+
+}
diff --git a/src/com/encrox/twitchbot/client/Plugin.java b/src/com/encrox/twitchbot/client/Plugin.java
new file mode 100755
index 0000000..c70cd57
--- /dev/null
+++ b/src/com/encrox/twitchbot/client/Plugin.java
@@ -0,0 +1,11 @@
+package com.encrox.twitchbot.client;
+
+public abstract class Plugin {
+
+ public abstract void load(String locale);
+
+ public abstract String message(String user, byte level, String message);
+
+ public abstract String post();
+
+}
diff --git a/src/com/encrox/twitchbot/client/PluginHandler.java b/src/com/encrox/twitchbot/client/PluginHandler.java
new file mode 100755
index 0000000..7a759fb
--- /dev/null
+++ b/src/com/encrox/twitchbot/client/PluginHandler.java
@@ -0,0 +1,82 @@
+package com.encrox.twitchbot.client;
+
+import java.io.File;
+import java.io.UnsupportedEncodingException;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.net.URLClassLoader;
+import java.util.ArrayList;
+
+public class PluginHandler implements Runnable {
+
+ private Client client;
+ private ArrayList<Plugin> plugins = new ArrayList<Plugin>();
+
+ public PluginHandler(Client client) {
+ this.client = client;
+ File path = new File("plugins/");
+ URL[] urls;
+ ClassLoader cl;
+ try {
+ urls = new URL[] { path.toURI().toURL() };
+ cl = new URLClassLoader(urls);
+ File[] files = path.listFiles();
+ for (int i = 0; i < files.length; i++) {
+ String name = files[i].getName();
+ plugins.add((Plugin) cl.loadClass(name.substring(0, name.indexOf('.'))).newInstance());
+ plugins.get(i).load("en-GB");
+ }
+ } catch (MalformedURLException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ } catch (ClassNotFoundException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ } catch (InstantiationException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ } catch (IllegalAccessException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ new Thread(this).start();
+ String answer = null;
+ while(true) {
+ IRCMessage msg = client.getMessage();
+ if(msg != null) {
+ System.out.println("[" + msg.getUsername() + "][" + msg.getLevel() + "] " + msg.getMessage());
+ for(int i = 0, size = plugins.size(); i < size; i++) {
+ answer = plugins.get(i).message(msg.getUsername(), msg.getLevel(), msg.getMessage());
+ if(answer == null) {
+ client.write(Utils.int_to_ba(1));
+ client.write(new byte[] { (byte)0x00 });
+ } else {
+ client.write(Utils.int_to_ba(answer.length()));
+ try {
+ client.write(answer.getBytes("UTF-8"));
+ } catch (UnsupportedEncodingException e) {
+ e.printStackTrace();
+ }
+ System.out.println("Answer: " + answer);
+ }
+ }
+ } else {
+ return;
+ }
+ }
+ }
+
+ public void run() {
+ String post;
+ while(true) {
+ for(int i = 0, size = plugins.size(); i < size; i++) {
+ post = plugins.get(i).post();
+ if(post != null) {
+ client.post(post);
+ post = null;
+ }
+ }
+ }
+ }
+
+}
diff --git a/src/com/encrox/twitchbot/client/Utils.java b/src/com/encrox/twitchbot/client/Utils.java
new file mode 100755
index 0000000..dccb4ce
--- /dev/null
+++ b/src/com/encrox/twitchbot/client/Utils.java
@@ -0,0 +1,48 @@
+package com.encrox.twitchbot.client;
+
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+
+public class Utils {
+
+ public static int ba_to_int(byte[] arr) {
+ return ByteBuffer.wrap(arr).getInt();
+ }
+
+ public static byte[] int_to_ba(int integer) {
+ return ByteBuffer.allocate(4).putInt(integer).array();
+ }
+
+ public static short ba_to_short(byte[] arr) {
+ return ByteBuffer.wrap(arr).getShort();
+ }
+
+ public static byte[] short_to_ba(short s) {
+ return ByteBuffer.allocate(2).putShort(s).array();
+ }
+
+ public static byte[] fill(byte[] arr, int length) {
+ if(length <= arr.length)
+ return arr;
+ byte[] output = new byte[length];
+ for(int i = 0; i<arr.length; i++)
+ output[i] = arr[i];
+ for(int i = arr.length; i<length; i++)
+ output[i] = (byte) 0x00;
+ return output;
+ }
+
+ public static byte[] crop(byte[] arr) {
+ byte[] swap = new byte[arr.length];
+ for(int i = 0; i<swap.length; i++) {
+ if(arr[i] != (byte) 0x00)
+ swap[i] = arr[i];
+ else {
+ arr = Arrays.copyOfRange(swap, 0, i);
+ break;
+ }
+ }
+ return arr;
+ }
+
+}
diff --git a/src/com/encrox/twitchbot/client/messages/Login.java b/src/com/encrox/twitchbot/client/messages/Login.java
new file mode 100755
index 0000000..b439c99
--- /dev/null
+++ b/src/com/encrox/twitchbot/client/messages/Login.java
@@ -0,0 +1,49 @@
+package com.encrox.twitchbot.client.messages;
+
+import java.io.UnsupportedEncodingException;
+
+import com.encrox.twitchbot.client.Utils;
+
+public class Login extends Message {
+
+ private byte id = 1;
+ private String username, password;
+
+ public Login(String username, String password) {
+ this.username = username;
+ this.password = password;
+ }
+
+ public Login() {
+ username = null;
+ password = null;
+ }
+
+ public void setUsername(String username) {
+ this.username = username;
+ }
+
+ public void setPassword(String password) {
+ this.password = password;
+ }
+
+ public byte getID() {
+ return id;
+ }
+
+ public byte[] getData() {
+ byte[] output = new byte[160];
+ try {
+ byte[] user = Utils.fill(username.getBytes("UTF-8"), 32), pass = Utils.fill(password.getBytes("UTF-8"), 128);
+ for(int i = 0; i < 32; i++)
+ output[i] = user[i];
+ for(int i = 0; i < 128; i++)
+ output[32+i] = pass[i];
+ return output;
+ } catch (UnsupportedEncodingException e) {
+ e.printStackTrace();
+ return null;
+ }
+ }
+
+}
diff --git a/src/com/encrox/twitchbot/client/messages/Message.java b/src/com/encrox/twitchbot/client/messages/Message.java
new file mode 100755
index 0000000..aac9f38
--- /dev/null
+++ b/src/com/encrox/twitchbot/client/messages/Message.java
@@ -0,0 +1,9 @@
+package com.encrox.twitchbot.client.messages;
+
+public abstract class Message {
+
+ public abstract byte getID();
+
+ public abstract byte[] getData();
+
+}
generated by cgit v1.2.1 (git 2.18.0) at 2024-12-23 09:10:08 +0000