chookspace/chookchat
1
1
Fork 2
Code Issues Pull Requests Actions Packages Projects Releases 4 Wiki Activity

JSON-based message history

Browse Source
This commit is contained in:
Maxwell
2025-06-07 10:06:46 +10:00
parent 82d18ac74d
commit 02f9460fd3
2 changed files with 87 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
client-web/index.js
View File

@@ -678,7 +678,7 @@ function handleRoomChange(message) {
} }
// Handle file messages // Handle file messages
function handleFileMessage(message) { function handleFileMessage(message, isHistory = false) {
// Only show file if it's for current room // Only show file if it's for current room
if (message.room && message.room !== currentRoom) { if (message.room && message.room !== currentRoom) {
highlightRoom(message.room); highlightRoom(message.room);
@@ -690,6 +690,7 @@ function handleFileMessage(message) {
const messageWrapper = document.createElement('div'); const messageWrapper = document.createElement('div');
messageWrapper.className = 'message'; messageWrapper.className = 'message';
if (isHistory) messageWrapper.classList.add('history-message');
// Create avatar // Create avatar
const avatar = document.createElement('div'); const avatar = document.createElement('div');
@@ -711,7 +712,7 @@ function handleFileMessage(message) {
const timestampSpan = document.createElement('span'); const timestampSpan = document.createElement('span');
timestampSpan.className = 'message-timestamp'; timestampSpan.className = 'message-timestamp';
timestampSpan.textContent = new Date().toLocaleTimeString(); timestampSpan.textContent = isHistory ? 'History' : new Date().toLocaleTimeString();
headerDiv.appendChild(authorSpan); headerDiv.appendChild(authorSpan);
headerDiv.appendChild(timestampSpan); headerDiv.appendChild(timestampSpan);
@@ -1183,8 +1184,34 @@ function clearMessages() {
async function loadRoomHistory(roomName) { async function loadRoomHistory(roomName) {
try { try {
const history = await getRoomHistory(roomName); const history = await getRoomHistory(roomName);
const jHistory = JSON.parse(history);
if (history) { if (history) {
const messagebox = document.getElementById('messagebox'); const messagebox = document.getElementById('messagebox');
jHistory.forEach(function (message, index) {
// Handle file messages
if (message.type == "file") {
handleFileMessage(message, true);
return;
}
// Handle call messages
else if (message.type == "call") {
handleCallMessage(message);
return;
}
// Handle regular messages
else if (message.type == "message") {
if (message.room && message.room !== currentRoom) {
// Highlight room with unread message
highlightRoom(message.room);
return;
}
addChatMessage(message.username, message.content, true);
}
});
/*
const lines = history.split('\n'); const lines = history.split('\n');
lines.forEach(line => { lines.forEach(line => {
@@ -1205,7 +1232,7 @@ async function loadRoomHistory(roomName) {
addSystemMessage(line, true); addSystemMessage(line, true);
} }
} }
}); });*/
messagebox.scrollTop = messagebox.scrollHeight; messagebox.scrollTop = messagebox.scrollHeight;
} }

81
server/src/main/kotlin/Main.kt
View File

@@ -27,6 +27,16 @@ fun md5(input:String): String {
return BigInteger(1, md.digest(input.toByteArray())).toString(16).padStart(32, '0') return BigInteger(1, md.digest(input.toByteArray())).toString(16).padStart(32, '0')
} }
fun log(input: String) {
val logFile = File("chookchat.log")
try {
logFile.appendText(input)
} catch (e: Exception) {
println("Something went wrong with logging to chookchat.log. Here's the error: " + e.toString())
println("And here's what actually went wrong: " + input)
}
}
object config { object config {
var address = "" var address = ""
var port = "" var port = ""
@@ -67,7 +77,7 @@ object config {
} }
} }
} catch (e: Exception) { } catch (e: Exception) {
println("Something went wrong :/ Here's the error: $e") log("Something went wrong :/ Here's the error: $e")
} }
} }
} }
@@ -168,7 +178,7 @@ object WsSessionManager {
deadSessions.add(ctx) deadSessions.add(ctx)
} }
} catch (e: Exception) { } catch (e: Exception) {
println("Error broadcasting to session: ${e.message}") log("Error broadcasting to session: ${e.message}")
deadSessions.add(ctx) deadSessions.add(ctx)
} }
} }
@@ -200,7 +210,7 @@ object WsSessionManager {
sessionIds.remove(sessionId) sessionIds.remove(sessionId)
} }
} catch (e: Exception) { } catch (e: Exception) {
println("Error removing session without broadcast: ${e.message}") log("Error removing session without broadcast: ${e.message}")
} }
} }
@@ -225,7 +235,7 @@ object WsSessionManager {
deadSessions.add(ctx) deadSessions.add(ctx)
} }
} catch (e: Exception) { } catch (e: Exception) {
println("Error sending ping: ${e.message}") log("Error sending ping: ${e.message}")
deadSessions.add(ctx) deadSessions.add(ctx)
} }
} }
@@ -239,7 +249,7 @@ object WsSessionManager {
sessions[ctx] = sessionId sessions[ctx] = sessionId
sessionIds[sessionId] = ctx sessionIds[sessionId] = ctx
} catch (e: Exception) { } catch (e: Exception) {
println("Error adding session: ${e.message}") log("Error adding session: ${e.message}")
} }
} }
@@ -267,7 +277,7 @@ object WsSessionManager {
broadcastOnlineUsers() broadcastOnlineUsers()
} }
} catch (e: Exception) { } catch (e: Exception) {
println("Error removing session: ${e.message}") log("Error removing session: ${e.message}")
} }
} }
@@ -289,7 +299,7 @@ object WsSessionManager {
deadSessions.add(ctx) deadSessions.add(ctx)
} }
} catch (e: Exception) { } catch (e: Exception) {
println("Error broadcasting to session: ${e.message}") log("Error broadcasting to session: ${e.message}")
deadSessions.add(ctx) deadSessions.add(ctx)
} }
} }
@@ -426,7 +436,7 @@ fun extractMessageContent(inputData: String, ctx: WsContext): String {
} }
fun handleSentMessage(inputData: String): String { fun handleSentMessage(inputData: String): String {
println("API request received: $inputData") log("API request received: $inputData")
var jsonInputData: JSONObject var jsonInputData: JSONObject
try { try {
jsonInputData = JSONObject(inputData) jsonInputData = JSONObject(inputData)
@@ -549,9 +559,7 @@ fun handleSentMessage(inputData: String): String {
} }
if (content != "") { if (content != "") {
if (type != "message") { if (type == "typing") return "Success"
return "Success"
}
val room = WsSessionManager.getUserRoom(username) ?: "general" val room = WsSessionManager.getUserRoom(username) ?: "general"
val roomDirectory = File("roomChats") val roomDirectory = File("roomChats")
@@ -560,10 +568,18 @@ fun handleSentMessage(inputData: String): String {
} }
val roomChatHistory = File("roomChats/$room.txt") val roomChatHistory = File("roomChats/$room.txt")
roomChatHistory.appendText("$username: $content ${System.lineSeparator()}") if (!roomChatHistory.exists()) {
roomChatHistory.appendText("[" + JSONObject().apply {
val chatHistory = File("chatHistory") put("type", "beginning")
chatHistory.appendText("$username: $content [Room: $room] ${System.lineSeparator()}") put("username", "system")
put("content", "")
})
}
roomChatHistory.appendText("," + JSONObject().apply {
put("type", type)
put("username", username)
put("content", content)
})
return "Success" return "Success"
} else { } else {
@@ -574,7 +590,7 @@ fun handleSentMessage(inputData: String): String {
fun getRoomChatHistory(roomName: String): String { fun getRoomChatHistory(roomName: String): String {
val roomChatFile = File("roomChats/$roomName.txt") val roomChatFile = File("roomChats/$roomName.txt")
if (roomChatFile.exists()) { if (roomChatFile.exists()) {
return roomChatFile.readText() return roomChatFile.readText() + "]"
} }
return "" return ""
} }
@@ -611,7 +627,7 @@ fun buildHTML(): String {
return(editedhtml) return(editedhtml)
} catch (e: Exception) { } catch (e: Exception) {
println(e) log(e.toString())
return("There was an error! If you're the server's admin, here are the details: $e") return("There was an error! If you're the server's admin, here are the details: $e")
} }
return("dingus") return("dingus")
@@ -646,7 +662,7 @@ fun buildJS(): String {
} }
return(editedJS) return(editedJS)
} catch (e: Exception) { } catch (e: Exception) {
println(e) log(e.toString())
return("console.log(`There was an error! If you're the server's admin, here are the details: $e`)") return("console.log(`There was an error! If you're the server's admin, here are the details: $e`)")
} }
return("dingus") return("dingus")
@@ -669,7 +685,6 @@ fun handleServerCommand(command: String): String {
} }
fun createAccount(inputData: String): String { fun createAccount(inputData: String): String {
println("Account creation request recieved: $inputData")
var username = "" var username = ""
var token = "" var token = ""
var message = "" var message = ""
@@ -832,6 +847,24 @@ fun main(args: Array<String>) {
} else { } else {
WsSessionManager.broadcast(processedData2.toString()) WsSessionManager.broadcast(processedData2.toString())
} }
val roomDirectory = File("roomChats")
if (!roomDirectory.exists()) {
roomDirectory.mkdir()
}
val roomChatHistory = File("roomChats/$room.txt")
if (!roomChatHistory.exists()) {
roomChatHistory.appendText("[" + JSONObject().apply {
put("type", "beginning")
put("username", "system")
put("content", "")
})
}
roomChatHistory.appendText("," + JSONObject().apply {
put("type", "file")
put("username", username)
put("content", "https://maxwellj.xyz/chookchat/uploads/$newFilename")
})
} }
.ws("/api/websocket") { ws -> .ws("/api/websocket") { ws ->
ws.onConnect { ctx -> ws.onConnect { ctx ->
@@ -844,13 +877,13 @@ fun main(args: Array<String>) {
when (ctx.message()) { when (ctx.message()) {
"pong" -> {} "pong" -> {}
else -> { else -> {
println(ctx.message()) log(ctx.message())
val successState = handleSentMessage(ctx.message()) val successState = handleSentMessage(ctx.message())
if (successState != "Success") { if (successState != "Success") {
try { try {
ctx.send(successState) ctx.send(successState)
} catch (e: Exception) { } catch (e: Exception) {
println("Error sending error message: ${e.message}") log("Error sending error message: ${e.message}")
} }
} else { } else {
val messageContent = extractMessageContent(ctx.message(), ctx) val messageContent = extractMessageContent(ctx.message(), ctx)
@@ -869,7 +902,7 @@ fun main(args: Array<String>) {
WsSessionManager.broadcastToRoom("general", messageContent) WsSessionManager.broadcastToRoom("general", messageContent)
} }
} catch (e: Exception) { } catch (e: Exception) {
println("Error in broadcasting message: ${e.message}") log("Error in broadcasting message: ${e.message}")
WsSessionManager.broadcastToRoom("general", messageContent) WsSessionManager.broadcastToRoom("general", messageContent)
} }
} }
@@ -881,9 +914,9 @@ fun main(args: Array<String>) {
try { try {
if (args[0] == "-i") { if (args[0] == "-i") {
println("Type a command for the server") log("Type a command for the server")
while (1 == 1) { while (1 == 1) {
println(handleServerCommand(readln())) log(handleServerCommand(readln()))
} }
} else { } else {
println("Interactive mode disabled, add -i to enable") println("Interactive mode disabled, add -i to enable")