Initial commit

1 files changed, 106 insertions, 0 deletions

diff --git a/bot/index.ts b/bot/index.ts
new file mode 100644
index 0000000..e3a2c6a
--- /dev/null
+++ b/bot/index.ts
@@ -0,0 +1,106 @@
+import { Client, Events, GatewayIntentBits } from 'discord.js';
+import { Database } from "bun:sqlite";
+
+const client = new Client({ intents: [GatewayIntentBits.Guilds, GatewayIntentBits.GuildMembers, GatewayIntentBits.GuildMessages, GatewayIntentBits.MessageContent] });
+const db = new Database("../database.sqlite", { create: true });
+
+function parseMessage(content: string) {
+    const lines = content.split('\n');
+    const authorMatch = content.match(/\*from(?: the)? ([^*]+)\*/i);
+    const titleLine = lines.slice(0, 2).find(l => /^#+\s+.+|^.+\*\*[^*]+\*\*$/.test(l)) ?? null;
+
+    const author = authorMatch ? authorMatch[1].trim() : null;
+    const title = titleLine ? titleLine.replace(/^#+\s+/, '').replace(/\*\*/g, '').trim() : null;
+    const message = lines
+        .filter(l => l !== titleLine)
+        .join('\n')
+        .replace(/\*from(?: the)? [^*]+\*\n?/i, '')
+        .trimStart();
+
+    return { author, title, message };
+}
+
+client.on(Events.ClientReady, bot => {
+  console.log(`Logged in as ${bot.user.tag}!`);
+  client.user?.setStatus('invisible');
+
+  try {
+    db.run(`CREATE TABLE IF NOT EXISTS announcements (
+                    id INTEGER PRIMARY KEY,
+                    msg_id INTERGER,
+                    title TEXT,
+                    author TEXT,
+                    message TEXT,
+                    created_at INTEGER
+                )`);
+  } catch (e) {
+    console.error(e);
+  }
+});
+
+client.on(Events.MessageCreate, async (msg) => {
+  if (msg.author.bot) return;
+  if (msg.author.id === client.user!.id) return;
+  if (msg.channel.id !== process.env.ANNOUNCEMENT_CHANNEL) return;
+  if (!(msg.content.startsWith('# ') || msg.content.startsWith('*') || msg.content.match(/^:[a-z0-9_]+:/i) || msg.content.match(/^\p{Emoji}/u))) return;
+
+  const { title, author, message } = parseMessage(msg.content);
+
+  try {
+    const insert = db.prepare(`INSERT INTO announcements (title, msg_id, author, message, created_at) VALUES (($title), ($msg_id), ($author), ($message), ($created_at))`);
+    insert.run({
+        $title: title,
+        $msg_id: msg.id,
+        $author: author,
+        $message: message,
+        $created_at: msg.createdTimestamp.toString()
+    })
+  } catch (e) {
+    console.error(e);
+  }
+
+});
+
+client.on(Events.MessageUpdate, async (msg, msgnew) => {
+  if (!msg.author) return;
+  if (!msg.content) return;
+  if (msg.author.bot) return;
+  if (msg.author.id === client.user!.id) return;
+  if (msg.channel.id !== process.env.ANNOUNCEMENT_CHANNEL) return;
+  if (!(msgnew.content.startsWith('# ') || msgnew.content.startsWith('*') || msgnew.content.match(/^:[a-z0-9_]+:/i) || msgnew.content.match(/^\p{Emoji}/u))) return;
+
+  const { title, author, message } = parseMessage(msgnew.content);
+
+  try {
+    const update = db.prepare(`UPDATE announcements SET title = ($title), author = ($author), message = ($message) WHERE msg_id = ($msg_id)`);
+    update.run({
+        $title: title,
+        $author: author,
+        $message: message,
+        $msg_id: msg.id
+    })
+  } catch (e) {
+    console.error(e);
+  }
+
+});
+
+client.on(Events.MessageDelete, async (msg) => {
+  if (!msg.author) return;
+  if (!msg.content) return;
+  if (msg.author.bot) return;
+  if (msg.author.id === client.user!.id) return;
+  if (msg.channel.id !== process.env.ANNOUNCEMENT_CHANNEL) return;
+
+  try {
+    const deleteAnnouncement = db.prepare(`DELETE FROM announcements WHERE msg_id = ($msg_id)`);
+    deleteAnnouncement.run({
+        $msg_id: msg.id
+    })
+  } catch (e) {
+    console.error(e);
+  }
+
+});
+
+client.login(process.env.TOKEN);