message Archive

Author: TalkingPanda0

public/module.d.ts

@@ -47,8 +47,19 @@ declare module "botModule" {
     public permTitle: string | null;
   }
   export class Namespace {}
-  export class DB {}
+  export class DB {
+    public database: any;
 
+    public getOrSetConfig(key: string, defaultValue: string): string;
+
+    public setConfig(key: string, value: string): void;
+  }
+
+  export interface latestSub {
+    name: string;
+    pfpUrl: string;
+    time: Date;
+  }
   export class TalkingBot {
     /**
      * Will say message in every chat.
@@ -67,6 +78,7 @@ declare module "botModule" {
     public moduleManager: ModuleManager;
 
     public modtext: string;
+    public setLatestSub(sub: latestSub): void;
   }
   export interface MessageData {
     /**
@@ -101,6 +113,7 @@ declare module "botModule" {
     isCommand: boolean;
     rewardName?: string;
     isOld: boolean;
+    timestamp: Date;
     reply: (message: string, replyToUser: boolean) => void | Promise<void>;
     /*
      * if duration is null bans permanently.

src/app.ts

@@ -39,6 +39,19 @@ app.get("/soundEffects", async (_req, res) => {
   );
 });
 
+app.get("/messageArchive", async (_, res) => {
+  res.sendFile(__dirname + "/html/messagearchive.html");
+});
+
+app.get("/getMessages", async (req, res) => {
+  if (!req.query.date) {
+    res.sendStatus(400);
+    return;
+  }
+  const messages = bot.chatLogger.getMessages(req.query.date.toString());
+  res.send(messages);
+});
+
 app.use("/control", async (req, res) => {
   try {
     if (!bot.jwtSecret) {

src/botModule.ts

@@ -25,6 +25,7 @@ export interface MessageData {
   isOld: boolean;
   isAction?: boolean;
   isTestRun?: boolean;
+  timestamp: Date;
   reply: (message: string, replyToUser: boolean) => void | Promise<void>;
   banUser: (reason: string, duration?: number) => void | Promise<void>;
 }

src/chatLogger.ts

@@ -0,0 +1,74 @@
+import { MessageData } from "botModule";
+import { TalkingBot } from "./talkingbot";
+import { Database, Statement } from "bun:sqlite";
+interface SavedMessageData {
+  badges: string;
+  isUserMod: boolean;
+  isUserVip?: boolean;
+  isUserSub?: boolean;
+  message: string;
+  parsedMessage: string;
+  username: string;
+  sender: string;
+  senderId: string;
+  color: string;
+  id: string;
+  platform: string;
+  channelId: string;
+  isFirst: boolean;
+  replyTo?: string;
+  replyId?: string;
+  replyText?: string;
+  isCommand: boolean;
+  rewardName?: string;
+  isOld: boolean;
+  timestamp: Date;
+}
+
+function parseSaved(data: SavedMessageData): MessageData {
+  return {
+    ...data,
+    badges: JSON.parse(data.badges),
+    timestamp: new Date(data.timestamp),
+  } as MessageData;
+}
+
+export class ChatLogger {
+  private bot: TalkingBot;
+  private database: Database;
+  private insertMessage: CallableFunction;
+  private getMessagesQuery: Statement;
+
+  constructor(bot: TalkingBot) {
+    this.bot = bot;
+    this.database = this.bot.database.database;
+    this.database
+      .query(
+        "CREATE TABLE IF NOT EXISTS chat_messages (id TEXT PRIMARY KEY, username TEXT NOT NULL, sender TEXT, senderId TEXT, platform TEXT, channelId TEXT, message TEXT, parsedMessage TEXT, badges TEXT, isUserMod INTEGER, isUserVip INTEGER, isUserSub INTEGER, isFirst INTEGER, isCommand INTEGER, rewardName TEXT, replyTo TEXT, replyId TEXT, replyText TEXT,isOld INTEGER,color TEXT,timestamp DATETIME NOT NULL);",
+      )
+      .run();
+    const insertMessageQuery = this.database.prepare(
+      "INSERT OR REPLACE INTO chat_messages (id, username, sender, senderId, platform, channelId, message, parsedMessage, badges, isUserMod, isUserVip, isUserSub, isFirst, isCommand, rewardName, replyTo, replyId, replyText, isOld, color, timestamp) VALUES ( $id, $username, $sender, $senderId, $platform, $channelId, $message, $parsedMessage, $badges, $isUserMod, $isUserVip, $isUserSub, $isFirst, $isCommand, $rewardName, $replyTo, $replyId, $replyText, $isOld, $color, $timestamp);",
+    );
+    this.getMessagesQuery = this.database.prepare(
+      " SELECT * FROM chat_messages WHERE date(timestamp) = date(?1) ORDER BY timestamp ASC; `); ",
+    );
+    this.insertMessage = this.database.transaction((message) => {
+      insertMessageQuery.run(message);
+    });
+  }
+
+  // date like "2025-10-26"
+  public getMessages(date: string): MessageData[] {
+    const messages = this.getMessagesQuery.all(date) as SavedMessageData[];
+    return messages.map(parseSaved);
+  }
+
+  public recordMessage(message: MessageData) {
+    this.insertMessage({
+      ...message,
+      badges: JSON.stringify(message.badges),
+      timestamp: message.timestamp.toISOString(),
+    });
+  }
+}

src/commands.ts

@@ -1281,6 +1281,7 @@ export class MessageHandler {
 
   private sendToChatList(data: MessageData) {
     this.bot.iochat.emit("message", data);
+    this.bot.chatLogger.recordMessage(data);
   }
 
   public async handleMessage(data: MessageData) {

src/db.ts

@@ -1,3 +1,4 @@
+import { MessageData } from "botModule";
 import { Database, Statement } from "bun:sqlite";
 
 interface WatchTime {
@@ -23,7 +24,7 @@ export interface HapbooReaction {
 export class DB {
   public getHapbooReaction: Statement;
 
-  private database: Database;
+  public database: Database;
   private insertWatchTime: CallableFunction;
   private getWatchTimeQuery: Statement;
   private getTopWatchTimeQuery: Statement;

src/discord.ts

@@ -267,6 +267,7 @@ export class Discord {
         isAction: false,
         rewardName: "",
         username: message.author.username,
+        timestamp: new Date(message.createdTimestamp),
       };
 
       this.bot.commandHandler.handleCommand(data);