8.4 DEV 1

Changed JSON to SQLlite
Added Suggestion Forums
Added /suggestadmin

Structures/Database.js

@@ -0,0 +1,227 @@
+// SupportBot | Emerald Services
+// Database Structure
+
+const Database = require("better-sqlite3");
+const path = require("path");
+
+const db = new Database(path.join(__dirname, "../Data/supportbot.db"));
+
+// ----- Core tables -----
+db.prepare(`
+  CREATE TABLE IF NOT EXISTS suggestions (
+    thread_id TEXT PRIMARY KEY,
+    author_id TEXT,
+    text      TEXT,
+    status    TEXT DEFAULT 'Created'
+  )
+`).run();
+
+db.prepare(`
+  CREATE TABLE IF NOT EXISTS profiles (
+    user_id   TEXT PRIMARY KEY,
+    bio       TEXT,
+    timezone  TEXT,
+    clockedIn INTEGER DEFAULT 0
+  )
+`).run();
+
+db.prepare(`
+  CREATE TABLE IF NOT EXISTS tickets (
+    ticket_id      TEXT PRIMARY KEY,
+    user_id        TEXT,
+    status         TEXT DEFAULT 'open',
+    created_at     INTEGER,
+    updated_at     INTEGER,
+    subject        TEXT,
+    description    TEXT
+  )
+`).run();
+
+try {
+  db.prepare("ALTER TABLE tickets ADD COLUMN voiceChannelId TEXT").run();
+} catch (e) {
+  if (!String(e).includes("duplicate column name")) {
+    throw e;
+  }
+}
+
+db.prepare(`
+  CREATE TABLE IF NOT EXISTS ticket_panel (
+    id INTEGER PRIMARY KEY AUTOINCREMENT,
+    message_id TEXT,
+    channel_id TEXT,
+    created_at INTEGER
+  )
+`).run();
+
+db.prepare(`
+  CREATE TABLE IF NOT EXISTS ticket_users (
+    ticket_id TEXT,
+    user_id   TEXT,
+    PRIMARY KEY(ticket_id, user_id)
+  )
+`).run();
+
+/* ---- NEW table for global bot settings ---- */
+db.prepare(`
+  CREATE TABLE IF NOT EXISTS settings (
+    id   INTEGER PRIMARY KEY,
+    data TEXT
+  )
+`).run();
+
+module.exports = {
+  // ----- Suggestions -----
+  addSuggestion(threadId, authorId, text) {
+    db.prepare(`
+      INSERT INTO suggestions (thread_id, author_id, text)
+      VALUES (@threadId, @authorId, @text)
+      ON CONFLICT(thread_id) DO NOTHING
+    `).run({ threadId, authorId, text });
+  },
+
+  setSuggestionStatus(threadId, status) {
+    db.prepare(`
+      UPDATE suggestions SET status=@status WHERE thread_id=@threadId
+    `).run({ threadId, status });
+  },
+
+  getSuggestion(threadId) {
+    return db.prepare(`
+      SELECT * FROM suggestions WHERE thread_id=@threadId
+    `).get({ threadId });
+  },
+
+  // ----- Profiles -----
+  getProfile(userId) {
+    const row = db.prepare(`SELECT * FROM profiles WHERE user_id=?`).get(userId);
+    if (!row) {
+      db.prepare(`
+        INSERT INTO profiles (user_id, bio, timezone, clockedIn)
+        VALUES (?, '', '', 0)
+      `).run(userId);
+      return { user_id: userId, bio: "", timezone: "", clockedIn: 0 };
+    }
+    return row;
+  },
+
+  updateProfile(userId, data) {
+    const { bio = "", timezone = "", clockedIn = 0 } = data;
+    db.prepare(`
+      INSERT INTO profiles (user_id, bio, timezone, clockedIn)
+      VALUES (@userId, @bio, @timezone, @clockedIn)
+      ON CONFLICT(user_id) DO UPDATE SET
+        bio       = excluded.bio,
+        timezone  = excluded.timezone,
+        clockedIn = excluded.clockedIn
+    `).run({ userId, bio, timezone, clockedIn });
+  },
+
+  setClockedIn(userId, value) {
+    db.prepare(`UPDATE profiles SET clockedIn=? WHERE user_id=?`)
+      .run(value ? 1 : 0, userId);
+  },
+
+  // ----- Tickets -----
+  addTicket(ticket) {
+    const now = Date.now();
+    db.prepare(`
+      INSERT INTO tickets (ticket_id, user_id, subject, description, created_at, updated_at)
+      VALUES (@ticket_id, @user_id, @subject, @description, @created_at, @updated_at)
+      ON CONFLICT(ticket_id) DO NOTHING
+    `).run({
+      ticket_id: ticket.id,
+      user_id: ticket.user,
+      subject: ticket.reason || "",
+      description: ticket.description || "",
+      created_at: now,
+      updated_at: now
+    });
+  },
+
+  updateTicketVoice(ticketId, voiceChannelId) {
+    db.prepare(`
+      UPDATE tickets SET voiceChannelId=@voiceChannelId, updated_at=@updatedAt WHERE ticket_id=@ticketId
+    `).run({ ticketId, voiceChannelId, updatedAt: Date.now() });
+  },
+
+  getTicketVoice(ticketId) {
+    return db.prepare(`SELECT voiceChannelId FROM tickets WHERE ticket_id=?`).get(ticketId);
+  },
+
+  deleteTicketVoice(ticketId) {
+    db.prepare(`
+      UPDATE tickets SET voiceChannelId=NULL, updated_at=@updatedAt WHERE ticket_id=@ticketId
+    `).run({ ticketId, updatedAt: Date.now() });
+  },
+
+  updateTicketStatus(ticketId, status) {
+    db.prepare(`
+      UPDATE tickets SET status=@status, updated_at=@updatedAt WHERE ticket_id=@ticketId
+    `).run({ status, updatedAt: Date.now(), ticketId });
+  },
+
+  getTicket(ticketId) {
+    return db.prepare(`
+      SELECT * FROM tickets WHERE ticket_id=@ticketId
+    `).get({ ticketId });
+  },
+
+  getAllTickets() {
+    return db.prepare(`SELECT * FROM tickets`).all();
+  },
+
+  saveTicketPanel(messageId, channelId) {
+    db.prepare(`
+      INSERT INTO ticket_panel (message_id, channel_id, created_at)
+      VALUES (@messageId, @channelId, @createdAt)
+    `).run({ messageId, channelId, createdAt: Date.now() });
+  },
+
+  getTicketPanel() {
+    return db.prepare(`
+      SELECT * FROM ticket_panel ORDER BY id DESC LIMIT 1
+    `).get();
+  },
+
+  // ----- Ticket participants -----
+  addUserToTicket(ticketId, userId) {
+    db.prepare(`
+      INSERT INTO ticket_users (ticket_id, user_id)
+      VALUES (?, ?)
+      ON CONFLICT(ticket_id, user_id) DO NOTHING
+    `).run(ticketId, userId);
+  },
+
+  removeUserFromTicket(ticketId, userId) {
+    db.prepare(`
+      DELETE FROM ticket_users WHERE ticket_id=? AND user_id=?
+    `).run(ticketId, userId);
+  },
+
+  getTicketUsers(ticketId) {
+    return db.prepare(`
+      SELECT user_id FROM ticket_users WHERE ticket_id=?
+    `).all(ticketId).map(r => r.user_id);
+  },
+
+  // ----- Global Settings -----
+  getSettings() {
+    const row = db.prepare(`SELECT data FROM settings WHERE id=1`).get();
+    if (!row) return {};
+    try {
+      return JSON.parse(row.data);
+    } catch {
+      return {};
+    }
+  },
+
+  saveSettings(obj) {
+    const data = JSON.stringify(obj);
+    db.prepare(`
+      INSERT INTO settings (id, data)
+      VALUES (1, @data)
+      ON CONFLICT(id) DO UPDATE SET data = excluded.data
+    `).run({ data });
+  }
+};