Master

.gitignore

@@ -8,6 +8,3 @@
 *.jar
 *.war
 *.ear
-
-# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
-hs_err_pid*

ChatApp.iml

@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="JAVA_MODULE" version="4">
+  <component name="NewModuleRootManager" inherit-compiler-output="true">
+    <exclude-output />
+    <content url="file://$MODULE_DIR$">
+      <sourceFolder url="file://$MODULE_DIR$/src" isTestSource="false" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+    <orderEntry type="module-library" exported="">
+      <library>
+        <CLASSES>
+          <root url="jar://$MODULE_DIR$/mysql-connector-java-5.1.38/mysql-connector-java-5.1.38/mysql-connector-java-5.1.38-bin.jar!/" />
+        </CLASSES>
+        <JAVADOC />
+        <SOURCES />
+      </library>
+    </orderEntry>
+  </component>
+</module>

META-INF/MANIFEST.MF

@@ -0,0 +1,3 @@
+Manifest-Version: 1.0
+Main-Class: ChatWindow
+

src/BusyCommand.java

@@ -0,0 +1,30 @@
+
+public class BusyCommand extends Command {
+    private String nick;
+
+    public BusyCommand(CommandTypes type, String nick) {
+        super(type);
+        this.nick = nick;
+    }
+
+    public String intoString() {
+        String s = "User " + this.nick +" is busy at that moment" + "\n";
+        return s;
+    }
+
+    public CommandTypes getType() {
+        return commandTypes;
+    }
+
+    public void setType(CommandTypes type) {
+        this.commandTypes = type;
+    }
+
+    public String getNick() {
+        return nick;
+    }
+
+    public void setNick(String nick) {
+        this.nick = nick;
+    }
+}

src/CallListener.java

@@ -0,0 +1,29 @@
+import java.io.*;
+import java.net.*;
+
+public class CallListener {
+    private Boolean isBusy;
+    private ServerSocket serverSocket;
+
+    public CallListener(){
+        setStatus(false);
+    }
+
+    public Connection getConnection() throws IOException{
+        if (StatusBusy()){
+            return null;
+        }else{
+            serverSocket = new ServerSocket(Protocol.PORT);
+            return new Connection(serverSocket.accept());
+        }
+    }
+
+
+    public Boolean StatusBusy(){
+        return isBusy;
+    }
+
+    public void setStatus(Boolean statusBusy){
+        this.isBusy = statusBusy;
+    }
+}

src/CallListenerThread.java

@@ -0,0 +1,72 @@
+import java.io.*;
+import java.util.*;
+import java.net.*;
+
+public class CallListenerThread extends Observable implements Runnable {
+    private Socket socket;
+    private ServerSocket serverSocket;
+    private volatile boolean disconnected;
+    private Connection connection;
+    private boolean isBusy;
+    private CallListener callListener;
+
+    public CallListenerThread(){
+
+    }
+
+    public void start() {
+        this.disconnected = false;
+        Thread t = new Thread(this);
+        t.start();
+    }
+
+    public boolean isDisconnected() {
+        return disconnected;
+    }
+
+    public void stop() {
+        disconnected = true;
+    }
+
+    public Connection getConnection(){
+        if(socket!=null){
+            try {
+                return new Connection(socket);
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return null;
+    }
+
+    @Override
+    public  void run(){
+        try {
+            serverSocket = new ServerSocket(Protocol.PORT);
+            while (true){
+                socket = serverSocket.accept();
+                //IncomingConnection incomingConnection = new IncomingConnection();
+                //if(Protocol.statusBusy == true){
+                connection = new Connection(socket);
+                if (connection.getSocket()!=null) {
+                    CommandListenerThread clt = new CommandListenerThread(connection);
+                    clt.addObserver(ChatWindow.observer);
+                    clt.start();
+                    connection.sendNickHello(Protocol.localNick);
+                }
+                //}
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    public void setDisconnected(boolean b){
+        this.disconnected = b;
+    }
+
+    public void setBusy(Boolean isBusy){
+        this.isBusy = isBusy;
+        callListener.setStatus(isBusy);
+    }
+}

src/Caller.java

@@ -0,0 +1,19 @@
+import java.net.*;
+import java.io.*;
+
+public class Caller {
+    private Socket s;
+
+    public Caller() throws IOException{
+        s = new Socket(Protocol.IP,Protocol.PORT);
+    }
+
+    public Connection call() throws IOException {
+    	try {
+    		Class.forName("com.mysql.jdbc.Driver");
+    	} catch (ClassNotFoundException e) {}
+        Connection c = new Connection(s);
+        c.sendNickHello(Protocol.localNick);
+        return c;
+    }
+}