From 660e49a9f6b87d7b946f2d1ff27394e5c84d0b97 Mon Sep 17 00:00:00 2001
From: NorbiPeti <szatmari.norbert.peter@gmail.com>
Date: Wed, 17 Aug 2016 14:31:29 +0200
Subject: [PATCH] Conversation adding added (buggy)

---
 pages/index.html                              |  4 ++
 pages/js/conversations.js                     | 11 ++++
 pages/js/index.js                             |  8 +++
 pages/js/receivemessage.js                    |  3 +
 pages/js/sendmessage.js                       |  1 +
 .../chat/server/db/domain/Conversation.java   | 17 ++++++
 .../server/page/ConversationsAjaxPage.java    | 58 +++++++++++++++++++
 .../norbipeti/chat/server/page/IndexPage.java | 17 +-----
 .../server/page/ReceiveMessageAjaxPage.java   |  6 +-
 9 files changed, 109 insertions(+), 16 deletions(-)
 create mode 100644 pages/js/conversations.js
 create mode 100644 src/io/github/norbipeti/chat/server/page/ConversationsAjaxPage.java
diff --git a/pages/index.html b/pages/index.html
index 446f905..146d694 100644
--- a/pages/index.html
+++ b/pages/index.html
@@ -12,12 +12,16 @@
     <script src="js/register.js"></script>
     <link rel="stylesheet" href="css/style.css" />
     <script src="js/index.js"></script>
+    <script src="js/conversations.js"></script>
 </head>
 
 <body>
     <div id="errormsg">
     </div>
     <div id="conversations">
+        <div id="addconv">
+            <a href="#" onclick="return addConversation();">Add conversation</a>
+        </div>
     </div>
     <div id="sidebar">
         <div id="userbox">
diff --git a/pages/js/conversations.js b/pages/js/conversations.js
new file mode 100644
index 0000000..0830fcf
--- /dev/null
+++ b/pages/js/conversations.js
@@ -0,0 +1,11 @@
+function addConversation() {
+    var json = JSON.stringify({ "action": "add" });
+    $.ajax({
+        url: "/conversations", data: json, method: "POST", success: function (result) {
+            document.getElementById("conversations").innerHTML += result;
+        }, error: function (result) {
+            showError(result.responseText);
+        }
+    });
+    return false;
+}
\ No newline at end of file
diff --git a/pages/js/index.js b/pages/js/index.js
index 121ccb3..0226a45 100644
--- a/pages/js/index.js
+++ b/pages/js/index.js
@@ -29,6 +29,14 @@ function changeConversation(convid) {
     var convidp = document.getElementById("convidp");
     if (convidp.innerText == convid + "")
         return;
+    if (!canswitchconversations)
+        return;
+    canswitchconversations = false;
+    stopPoll();
+    var chmsgse = document.getElementById("channelmessages");
+    var chmsgs = chmsgse.getElementsByClassName("chmessage");
+    for (var i = 0; i < chmsgs.length; i++)
+        chmsgse.removeChild(chmsgs[i]);
     convidp.innerText = convid;
     conversationChanged();
 }
diff --git a/pages/js/receivemessage.js b/pages/js/receivemessage.js
index 962e598..d481a9e 100644
--- a/pages/js/receivemessage.js
+++ b/pages/js/receivemessage.js
@@ -41,6 +41,7 @@ var resetUnread = function resetUnread() {
 };
 
 var shouldpoll = false;
+var canswitchconversations = true;
 function poll() {
     setTimeout(function () {
         if (!shouldpoll)
@@ -51,10 +52,12 @@ function poll() {
                 msgs.innerHTML += data;
                 var msgelement = msgs.children[msgs.children.length - 1];
                 handlereceivedmessage(msgelement);
+                canswitchconversations = true;
                 if (justsentmsgread)
                     justsentmsgread = false;
                 else
                     addUnread();
+
             }, error: function (data) {
                 if (data.responseText) {
                     if (data.responseText.indexOf("ERROR") == -1)
diff --git a/pages/js/sendmessage.js b/pages/js/sendmessage.js
index 313961f..a58ec6f 100644
--- a/pages/js/sendmessage.js
+++ b/pages/js/sendmessage.js
@@ -1,4 +1,5 @@
 var sendmsg = function sendmsg(msginputta) {
+    window.convid = document.getElementById("convidp").innerText * 1;
     window.jsonobj = JSON.stringify({ "message": msginputta.value, "conversation": window.convid });
     $.ajax({
         url: "/sendmessage", data: window.jsonobj, method: "POST", success: respfunc, error: respfunc
diff --git a/src/io/github/norbipeti/chat/server/db/domain/Conversation.java b/src/io/github/norbipeti/chat/server/db/domain/Conversation.java
index ad98029..9e5c070 100644
--- a/src/io/github/norbipeti/chat/server/db/domain/Conversation.java
+++ b/src/io/github/norbipeti/chat/server/db/domain/Conversation.java
@@ -2,6 +2,8 @@ package io.github.norbipeti.chat.server.db.domain;
 
 import javax.persistence.*;
 
+import org.jsoup.nodes.Element;
+
 import io.github.norbipeti.chat.server.data.LoaderCollection;
 
 @Entity
@@ -56,4 +58,19 @@ public class Conversation extends SavedData {
 	@Override
 	protected void init() {
 	}
+
+	public Element getAsHtml(Element conversations) {
+		Element conversation = conversations.appendElement("div");
+		conversation.addClass("conversation");
+		String users = "";
+		StringBuilder sb = new StringBuilder();
+		for (User item : getUsers()) {
+			sb.append(item.getName()).append(", ");
+		}
+		if (sb.length() > 2)
+			sb.replace(sb.length() - 2, sb.length() - 1, "");
+		users = sb.toString();
+		conversation.appendElement("a").text(users).attr("href", "javascript:changeConversation(" + getId() + ")");
+		return conversation;
+	}
 }
diff --git a/src/io/github/norbipeti/chat/server/page/ConversationsAjaxPage.java b/src/io/github/norbipeti/chat/server/page/ConversationsAjaxPage.java
new file mode 100644
index 0000000..53b818a
--- /dev/null
+++ b/src/io/github/norbipeti/chat/server/page/ConversationsAjaxPage.java
@@ -0,0 +1,58 @@
+package io.github.norbipeti.chat.server.page;
+
+import java.io.IOException;
+
+import org.jsoup.nodes.Document;
+
+import com.google.gson.JsonObject;
+import com.sun.net.httpserver.HttpExchange;
+
+import io.github.norbipeti.chat.server.db.domain.Conversation;
+import io.github.norbipeti.chat.server.db.domain.ManagedData;
+import io.github.norbipeti.chat.server.db.domain.User;
+import io.github.norbipeti.chat.server.io.IOHelper;
+
+public class ConversationsAjaxPage extends Page {
+
+	@Override
+	public String GetName() {
+		return "conversations";
+	}
+
+	@Override
+	public void handlePage(HttpExchange exchange) throws IOException {
+		JsonObject post = IOHelper.GetPOSTJSON(exchange);
+		User user = IOHelper.GetLoggedInUser(exchange);
+		if (user == null) {
+			IOHelper.SendResponse(403, "<h1>403 Login required</h1>", exchange);
+			return;
+		}
+		if (post == null) {
+			IOHelper.SendResponse(400,
+					"<h1>400 Bad request</h1><p>Not a JSON string: " + IOHelper.GetPOST(exchange) + "</p>", exchange);
+			return;
+		}
+		if (!post.has("action")) {
+			IOHelper.SendResponse(400, "<h1>400 Bad request</h1><p>Action missing: " + post + "</p>", exchange);
+			return;
+		}
+		switch (post.get("action").getAsString()) {
+		case "add": {
+			Conversation conv = ManagedData.create(Conversation.class);
+			conv.getUsers().add(user); // TODO: Option to invite people
+			user.getConversations().add(conv);
+			Document doc = new Document("");
+			conv.getAsHtml(doc);
+			IOHelper.SendResponse(200, doc.toString(), exchange);
+			break;
+		}
+		default: {
+			IOHelper.SendResponse(400,
+					"<h1>400 Bad request</h1><p>Unknown action: " + post.get("action").getAsString() + "</p>",
+					exchange);
+			break;
+		}
+		}
+	}
+
+}
diff --git a/src/io/github/norbipeti/chat/server/page/IndexPage.java b/src/io/github/norbipeti/chat/server/page/IndexPage.java
index 30359d3..2be99f5 100644
--- a/src/io/github/norbipeti/chat/server/page/IndexPage.java
+++ b/src/io/github/norbipeti/chat/server/page/IndexPage.java
@@ -51,22 +51,11 @@ public class IndexPage extends Page {
 				cide.attr("id", "convidp");
 				cide.text(Long.toString(convid));
 				Element conversations = doc.getElementById("conversations");
-				for (Conversation conv : user.getConversations()) {
-					Element conversation = conversations.appendElement("div");
-					conversation.addClass("conversation");
-					String users = "";
-					StringBuilder sb = new StringBuilder();
-					for (User item : conv.getUsers()) {
-						sb.append(item.getName()).append(", ");
-					}
-					if (sb.length() > 2)
-						sb.replace(sb.length() - 2, sb.length() - 1, "");
-					users = sb.toString();
-					conversation.appendElement("a").text(users).attr("href",
-							"javascript:changeConversation(" + conv.getId() + ")");
-				}
+				for (Conversation conv : user.getConversations())
+					conv.getAsHtml(conversations);
 				return doc;
 			}, exchange);
+
 	} // TODO:
 		// Validation
 		// at
diff --git a/src/io/github/norbipeti/chat/server/page/ReceiveMessageAjaxPage.java b/src/io/github/norbipeti/chat/server/page/ReceiveMessageAjaxPage.java
index c4fdcf5..2d142fe 100644
--- a/src/io/github/norbipeti/chat/server/page/ReceiveMessageAjaxPage.java
+++ b/src/io/github/norbipeti/chat/server/page/ReceiveMessageAjaxPage.java
@@ -41,6 +41,7 @@ public class ReceiveMessageAjaxPage extends Page {
 		String post = IOHelper.GetPOST(exchange);
 		if (post.length() == 0) {
 			IOHelper.SendResponse(400, "ERROR: Empty string", exchange);
+			return;
 		}
 		long convid = Long.parseLong(post);
 		LoaderRef<Conversation> currentconversation = convid == -1 ? null : new LoaderRef<>(Conversation.class, convid);
@@ -91,8 +92,9 @@ public class ReceiveMessageAjaxPage extends Page {
 		LogManager.getLogger().debug("Attempting to send channel messages to user: " + user);
 		if (exmap.containsKey(user)) {
 			Document doc = new Document("");
-			for (Message msg : conv.getMesssageChunks().get(conv.getMesssageChunks().size() - 1).getMessages())
-				msg.getAsHTML(doc);
+			if (conv.getMesssageChunks().size() > 0)
+				for (Message msg : conv.getMesssageChunks().get(conv.getMesssageChunks().size() - 1).getMessages())
+					msg.getAsHTML(doc);
 			IOHelper.SendResponse(200, doc.toString(), exmap.get(user));
 			exmap.remove(user);
 		} else {
