WIP: Create Chat MicroService

pom.xml

@@ -1,70 +1,70 @@
 <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>
+         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>net.cryptic_game.microservice</groupId>
-	<artifactId>chat</artifactId>
-	<version>0.0.3-SNAPSHOT</version>
-	<packaging>jar</packaging>
+    <groupId>net.cryptic_game.microservice</groupId>
+    <artifactId>chat</artifactId>
+    <version>0.0.3-SNAPSHOT</version>
+    <packaging>jar</packaging>
 
-	<name>cryptic-game-chat</name>
-	<description>offical chat microservice of cryptic-game</description>
-	<url>https://cryptic-game.net</url>
+    <name>cryptic-game-chat</name>
+    <description>offical chat microservice of cryptic-game</description>
+    <url>https://cryptic-game.net</url>
 
-	<build>
-		<plugins>
-			<plugin>
-				<artifactId>maven-assembly-plugin</artifactId>
-				<version>3.1.0</version>
-				<configuration>
-					<archive>
-						<manifest>
-							<mainClass>net.cryptic_game.microservice.chat.App</mainClass>
-						</manifest>
-					</archive>
-					<descriptorRefs>
-						<descriptorRef>jar-with-dependencies</descriptorRef>
-					</descriptorRefs>
-				</configuration>
-				<executions>
-					<execution>
-						<id>make-assembly</id>
-						<phase>package</phase>
-						<goals>
-							<goal>single</goal>
-						</goals>
-					</execution>
-				</executions>
-			</plugin>
-			<plugin>
-				<groupId>org.apache.maven.plugins</groupId>
-				<artifactId>maven-compiler-plugin</artifactId>
-				<version>3.8.0</version>
-				<configuration>
-					<source>1.8</source>
-					<target>1.8</target>
-				</configuration>
-			</plugin>
-		</plugins>
-	</build>
+    <build>
+        <plugins>
+            <plugin>
+                <artifactId>maven-assembly-plugin</artifactId>
+                <version>3.1.0</version>
+                <configuration>
+                    <archive>
+                        <manifest>
+                            <mainClass>net.cryptic_game.microservice.chat.App</mainClass>
+                        </manifest>
+                    </archive>
+                    <descriptorRefs>
+                        <descriptorRef>jar-with-dependencies</descriptorRef>
+                    </descriptorRefs>
+                </configuration>
+                <executions>
+                    <execution>
+                        <id>make-assembly</id>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>single</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.8.0</version>
+                <configuration>
+                    <source>1.8</source>
+                    <target>1.8</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
 
-	<properties>
-		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-	</properties>
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
 
-	<repositories>
-		<repository>
-		    <id>jitpack.io</id>
-		    <url>https://jitpack.io</url>
-		</repository>
-	</repositories>
+    <repositories>
+        <repository>
+            <id>jitpack.io</id>
+            <url>https://jitpack.io</url>
+        </repository>
+    </repositories>
 
-	<dependencies>
-		<dependency>
-			<groupId>com.github.cryptic-game</groupId>
-			<artifactId>java-lib</artifactId>
-			<version>master-SNAPSHOT</version>
-		</dependency>
-	</dependencies>
+    <dependencies>
+        <dependency>
+            <groupId>com.github.cryptic-game</groupId>
+            <artifactId>java-lib</artifactId>
+            <version>experimental-SNAPSHOT</version>
+        </dependency>
+    </dependencies>
 </project>

src/main/java/net/cryptic_game/microservice/chat/App.java

@@ -1,19 +1,27 @@
 package net.cryptic_game.microservice.chat;
 
-import org.apache.log4j.BasicConfigurator;
-
 import net.cryptic_game.microservice.MicroService;
+import net.cryptic_game.microservice.chat.channel.ChannelHandler;
+import org.apache.log4j.BasicConfigurator;
 
 public class App extends MicroService {
 
-	public App() {
-		super("chat");
-	}
+    private static ChannelHandler channelHandler;
+
+    private App() {
+        super("chat");
+    }
+
+    public static void main(String[] args) {
+        BasicConfigurator.configure();
 
-	public static void main(String[] args) {
-		BasicConfigurator.configure();
+        channelHandler = new ChannelHandler();
+        channelHandler.addChanel("global");
 
-		new App();
-	}
+        new App();
+    }
 
+    public static ChannelHandler getChannelHandler() {
+        return channelHandler;
+    }
 }

src/main/java/net/cryptic_game/microservice/chat/channel/Channel.java

@@ -0,0 +1,55 @@
+package net.cryptic_game.microservice.chat.channel;
+
+import net.cryptic_game.microservice.wrapper.User;
+
+import java.util.ArrayList;
+import java.util.UUID;
+
+public class Channel {
+
+    private final UUID uuid;
+    private final ArrayList<User> users;
+    private String name;
+
+    Channel(final String name) {
+        this.uuid = UUID.randomUUID();
+        this.name = name;
+        this.users = new ArrayList<>();
+    }
+
+    public UUID getUuid() {
+        return this.uuid;
+    }
+
+    public String getName() {
+        return this.name;
+    }
+
+    public void setName(final String name) {
+        this.name = name;
+    }
+
+    public ArrayList<User> getUsers() {
+        return this.users;
+    }
+
+    public boolean addUser(final User user) {
+        for (User u : users) {
+            if (u.getUUID().equals(user.getUUID())) {
+                return false;
+            }
+        }
+        this.users.add(user);
+        return true;
+    }
+
+    public boolean removeUser(final User user) {
+        for (User u : users) {
+            if (u.getUUID().equals(user.getUUID())) {
+                this.users.remove(user);
+                return true;
+            }
+        }
+        return false;
+    }
+}

src/main/java/net/cryptic_game/microservice/chat/channel/ChannelHandler.java

@@ -0,0 +1,75 @@
+package net.cryptic_game.microservice.chat.channel;
+
+import net.cryptic_game.microservice.MicroService;
+import net.cryptic_game.microservice.utils.JSONBuilder;
+import net.cryptic_game.microservice.wrapper.User;
+import org.json.simple.JSONObject;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.UUID;
+
+import static net.cryptic_game.microservice.utils.JSONBuilder.anJSON;
+
+public class ChannelHandler {
+
+    private final ArrayList<Channel> channels;
+
+    public ChannelHandler() {
+        this.channels = new ArrayList<>();
+    }
+
+    public Channel addChanel(final String name) {
+        final Channel channel = new Channel(name);
+        this.channels.add(channel);
+        return channel;
+    }
+
+    public Channel getChannelByUUID(final UUID uuid) {
+        for (final Channel channel : this.channels) if (channel.getUuid().equals(uuid)) return channel;
+        return null;
+    }
+
+    public ArrayList<Channel> getChannels() {
+        return this.channels;
+    }
+
+    public void notifyUser(final User user, final ChatAction action, final Channel channel, final UUID target) {
+        this.notifyUsers(new ArrayList<>(Collections.singletonList(user)), action, channel, target);
+    }
+
+    public void notifyUser(final User user, final ChatAction action, final Channel channel, final UUID target, final JSONObject content) {
+        this.notifyUsers(new ArrayList<>(Collections.singletonList(user)), action, channel, target, content);
+    }
+
+    public void notifyUsers(final ArrayList<User> users, final ChatAction action, final Channel channel, final UUID target) {
+        this.notifyUsers(users, action, channel, target, null);
+    }
+
+    public void notifyAllChannelUsers(final ChatAction action, final Channel channel, final UUID target) {
+        this.notifyUsers(channel.getUsers(), action, channel, target, null);
+    }
+
+    public void notifyAllChannelUsers(final ChatAction action, final Channel channel, final UUID target, final JSONObject content) {
+        this.notifyUsers(channel.getUsers(), action, channel, target, content);
+    }
+
+    public void notifyUsers(final ArrayList<User> users, ChatAction action, final Channel channel, final UUID target, final JSONObject content) {
+        final JSONBuilder data = anJSON()
+                .add("action", action.getValue())
+                .add("channel", channel.getUuid().toString())
+                .add("user", target.toString());
+
+        if (content != null) {
+            data.add("content", content);
+        }
+
+        final JSONObject json = anJSON()
+                .add("notify-id", "chat-update")
+                .add("origin", "chat")
+                .add("data", data.build()
+                ).build();
+
+        users.forEach(user -> MicroService.getInstance().sendToUser(user.getUUID(), json));
+    }
+}

src/main/java/net/cryptic_game/microservice/chat/channel/ChatAction.java

@@ -0,0 +1,19 @@
+package net.cryptic_game.microservice.chat.channel;
+
+public enum ChatAction {
+    MEMBER_JOIN("member-join"),
+    MEMBER_LEAVE("member-leave"),
+
+    SEND_MESSAGE("send-message"),
+    WHISPER_MESSAGE("whisper-message");
+
+    final String value;
+
+    ChatAction(final String value) {
+        this.value = value;
+    }
+
+    public String getValue() {
+        return this.value;
+    }
+}