Add support for saving message history.

.gitignore

@@ -1,4 +1,5 @@
 *.js
+data.db
 
 config.json
 

index.ts

@@ -9,27 +9,24 @@ if (process.argv[3] == null) {
 const ip = process.argv[2];
 const port = Number(process.argv[3]);
 
-class Message {
-	readonly msg: string;
-	readonly time: Date;
-	readonly address: string;
-	constructor(msg: string, time: Date, address: string) {
-		this.msg = msg;
-		this.time = time;
-		this.address = address;
-	}
-	toString() {
-		let d = this.time
-		return "[" + d.getDate() + "." + (d.getMonth() + 1) + "." + d.getFullYear() + 
-			" " + d.getHours() + ":" + d.getMinutes() + 
-			"] {" + this.address + "} " 
-			+ this.msg.replace("/\n/g", "$");
-	}
+function msgToString(time: Date, address: string, msg: string) {
+	return "[" + time.getDate() + "." + (time.getMonth() + 1) + "." + time.getFullYear() + 
+		" " + time.getHours() + ":" + time.getMinutes() + 
+		"] {" + address + "} " 
+		+ msg;
 }
 
-let messages: Message[] = [];
 
-//const net = require('net');
+import * as sq from "sqlite3";
+const db = new sq.Database("data.db");
+db.run("CREATE TABLE IF NOT EXISTS messages (time INTEGER PRIMARY KEY, address TEXT NOT NULL, msg TEXT NOT NULL) STRICT");
+
+
+let msize = 0;
+db.each("SELECT time, address, msg FROM messages", (err: Error, m: {time: number; address: string; msg: string}) => {
+	msize += textEncoder.encode(msgToString(new Date(m.time), m.address, m.msg)).length
+});
+
 const textEncoder = new TextEncoder();
 import * as net from "net";
 let srv = net.createServer(function(socket: net.Socket) {
@@ -42,29 +39,26 @@ let srv = net.createServer(function(socket: net.Socket) {
 	socket.on('data', function(data: Buffer | string) {
 		switch (data[0]) {
 			case 0x30:
-				let msg = new Message(String(data.slice(1)), new Date, addr.address);
-				messages[messages.length] = msg;
-				console.log("Got message: " + msg.toString());
+				const store = db.prepare("INSERT INTO messages VALUES (?,?,?)");
+				let t = new Date;
+				let a = addr.address;
+				let m = String(data.slice(1)).replace("/\n/g", "\\n").replace("/\x1b/g", "\\x1b");
+				msize += textEncoder.encode(msgToString(t, a, m)).length
+				store.run(Number(t),a,m);
+				store.finalize();
 				socket.end()
 				return;
 			case 0x31:
-				let msize = 1
-				for (const i of messages) {
-					msize += textEncoder.encode(i.toString()).length;
-				}
 				socket.write(String(msize));
 				socket.end();
-				console.log(addr.address + ", got size request. " + msize);
 				return;
 			case 0x32:
-				console.log(addr.address + ", got messages request.");
 				let str = "";
-				for (const i of messages) {
-					str += i.toString();
-				}
-				str += "\n"
-				console.log("Sending " + str.length  + " to " + addr.address);
-				socket.write(str);
+				db.each("SELECT time, address, msg FROM messages", (err: Error, m: {time: number; address: string; msg: string}) => {
+					str += msgToString(new Date(m.time), m.address, m.msg);
+				}, () => {
+					socket.write(str);
+				});
 				return;
 		}
 		console.log(addr.address + "???" + data[0]);

package.json

@@ -2,5 +2,8 @@
   "devDependencies": {
     "@types/node": "^22.10.2",
     "typescript": "^5.7.2"
+  },
+  "dependencies": {
+    "sqlite3": "^5.1.7"
   }
 }