+
+ Discord moderation command center
+ Voice. Text. Image. One Watch Floor.
+Single-page watcher for live voice bridge, captured messages, and uploaded image evidence. Built for dense moderation review without jumping between pages.
+
+
+ WebSocketConnecting
+ Voice LinkNot connected
+ Active TabVoice
+
-
+
-
+ connectWebSocket();
+ loadGuilds().then(refreshStatus).catch((error) => showError(error.message));
+ setInterval(() => {
+ if (state.activeTab === 'text') fetchText().catch(() => {});
+ if (state.activeTab === 'images') fetchImages().catch(() => {});
+ }, 7000);
+
diff --git a/src/moderation/messageCapture.ts b/src/moderation/messageCapture.ts
index c046ffa..4e8ad43 100644
--- a/src/moderation/messageCapture.ts
+++ b/src/moderation/messageCapture.ts
@@ -8,29 +8,73 @@ import type { MessageRecord, AttachmentRecord } from "./types";
const logger = createChildLogger("message-capture");
+function getMessageLocation(message: Message): {
+ channelId: string;
+ threadId: string | null;
+ threadName: string | null;
+} {
+ const channel = message.channel as TextChannel | ThreadChannel;
+ if (!channel.isThread?.()) {
+ return { channelId: message.channelId, threadId: null, threadName: null };
+ }
+
+ return {
+ channelId: channel.parentId ?? message.channelId,
+ threadId: channel.id,
+ threadName: channel.name,
+ };
+}
+
+function getStickerMetadata(message: Message): Array<{
+ id: string;
+ name: string;
+ url: string;
+}> {
+ return Array.from(message.stickers.values()).map((sticker) => ({
+ id: sticker.id,
+ name: sticker.name,
+ url: sticker.url,
+ }));
+}
+
+function getDisplayContent(message: Message): string {
+ if (message.content.trim().length > 0) return message.content;
+
+ const stickers = getStickerMetadata(message);
+ if (stickers.length > 0) {
+ return stickers.map((sticker) => `[Sticker: ${sticker.name}]`).join(" ");
+ }
+
+ return "";
+}
+
async function captureMessage(
db: SqliteDatabase,
message: Message,
type: "text" | "edited" | "deleted",
): Promise {
- const channel = message.channel as TextChannel | ThreadChannel;
- const threadId = channel.isThread?.() ? channel.id : null;
+ const location = getMessageLocation(message);
+ const stickers = getStickerMetadata(message);
+ const metadata = {
+ stickers,
+ threadName: location.threadName,
+ };
const messageRecord: MessageRecord = {
id: message.id,
guild_id: message.guildId!,
- channel_id: message.channelId,
- thread_id: threadId,
+ channel_id: location.channelId,
+ thread_id: location.threadId,
user_id: message.author!.id,
username: message.author!.username,
avatar_url: message.author!.avatarURL() || null,
- content: message.content,
+ content: getDisplayContent(message),
edited_content: null,
created_at: message.createdTimestamp,
edited_at: null,
deleted_at: null,
type,
- metadata: null,
+ metadata: JSON.stringify(metadata),
};
insertMessage(db, messageRecord);
@@ -38,13 +82,7 @@ async function captureMessage(
const broadcaster = globalThis as any;
if (broadcaster.broadcastMessageCreated) {
broadcaster.broadcastMessageCreated({
- id: message.id,
- channel_id: message.channelId,
- user_id: message.author!.id,
- username: message.author!.username,
- avatar_url: message.author!.avatarURL() || null,
- content: message.content,
- created_at: message.createdTimestamp,
+ ...messageRecord,
type: "text",
});
}
@@ -55,7 +93,8 @@ async function captureMessage(
id: attachment.id,
message_id: message.id,
guild_id: message.guildId!,
- channel_id: message.channelId,
+ channel_id: location.channelId,
+ thread_id: location.threadId,
user_id: message.author!.id,
filename: attachment.name || "unknown",
size: attachment.size,
@@ -77,7 +116,7 @@ async function captureMessage(
id: attachment.id,
message_id: message.id,
filename: attachment.name || "unknown",
- channel_id: message.channelId,
+ channel_id: location.channelId,
created_at: Date.now(),
});
}
@@ -129,13 +168,13 @@ export function registerMessageCapture(client: Client, db: SqliteDatabase): void
if (existing) {
const editedAt = Date.now();
- updateMessageAsEdited(db, newMessage.id, newMessage.content || "", editedAt);
+ updateMessageAsEdited(db, newMessage.id, getDisplayContent(newMessage as Message), editedAt);
const broadcaster = globalThis as any;
if (broadcaster.broadcastMessageUpdated) {
broadcaster.broadcastMessageUpdated({
id: newMessage.id,
- edited_content: newMessage.content || "",
+ edited_content: getDisplayContent(newMessage as Message),
edited_at: editedAt,
});
}
diff --git a/src/moderation/messageStore.ts b/src/moderation/messageStore.ts
index 5b0b377..87adfc5 100644
--- a/src/moderation/messageStore.ts
+++ b/src/moderation/messageStore.ts
@@ -96,12 +96,12 @@ export function getMessagesByChannel(
try {
const stmt = db.prepare(`
SELECT * FROM messages
- WHERE channel_id = ?
+ WHERE channel_id = ? OR thread_id = ?
ORDER BY created_at DESC
LIMIT ? OFFSET ?
`);
- const rows = stmt.all(channelId, limit, offset) as MessageRecord[];
+ const rows = stmt.all(channelId, channelId, limit, offset) as MessageRecord[];
return rows;
} catch (error) {
logger.error(
@@ -116,9 +116,9 @@ export function insertAttachment(db: SqliteDatabase, attachment: AttachmentRecor
try {
const stmt = db.prepare(`
INSERT INTO attachments (
- id, message_id, guild_id, channel_id, user_id, filename, size, type,
+ id, message_id, guild_id, channel_id, thread_id, user_id, filename, size, type,
discord_url, uploaded_url, upload_status, upload_error, created_at, uploaded_at
- ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
+ ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
`);
stmt.run(
@@ -126,6 +126,7 @@ export function insertAttachment(db: SqliteDatabase, attachment: AttachmentRecor
attachment.message_id,
attachment.guild_id,
attachment.channel_id,
+ attachment.thread_id,
attachment.user_id,
attachment.filename,
attachment.size,
@@ -157,12 +158,12 @@ export function getAttachmentsByChannel(
try {
const stmt = db.prepare(`
SELECT * FROM attachments
- WHERE channel_id = ?
+ WHERE channel_id = ? OR thread_id = ?
ORDER BY created_at DESC
LIMIT ? OFFSET ?
`);
- const rows = stmt.all(channelId, limit, offset) as AttachmentRecord[];
+ const rows = stmt.all(channelId, channelId, limit, offset) as AttachmentRecord[];
return rows;
} catch (error) {
logger.error(
diff --git a/src/moderation/types.ts b/src/moderation/types.ts
index 9b49d61..f1003b6 100644
--- a/src/moderation/types.ts
+++ b/src/moderation/types.ts
@@ -20,6 +20,7 @@ export interface AttachmentRecord {
message_id: string;
guild_id: string;
channel_id: string;
+ thread_id: string | null;
user_id: string;
filename: string;
size: number;
diff --git a/src/muxer-queue.ts b/src/muxer-queue.ts
index b9d241e..6ba2e50 100644
--- a/src/muxer-queue.ts
+++ b/src/muxer-queue.ts
@@ -84,6 +84,7 @@ function initializeDatabase(): SqliteDatabase {
message_id TEXT NOT NULL,
guild_id TEXT NOT NULL,
channel_id TEXT NOT NULL,
+ thread_id TEXT,
user_id TEXT NOT NULL,
filename TEXT NOT NULL,
size INTEGER NOT NULL,
@@ -102,6 +103,12 @@ function initializeDatabase(): SqliteDatabase {
CREATE INDEX IF NOT EXISTS idx_attachments_status ON attachments(upload_status);
`);
+ try {
+ database.exec("ALTER TABLE attachments ADD COLUMN thread_id TEXT");
+ } catch {
+ // Column already exists on databases initialized after the moderation schema was added.
+ }
+
return database;
}
diff --git a/src/voiceController.ts b/src/voiceController.ts
index 7f3def1..8ff5b50 100644
--- a/src/voiceController.ts
+++ b/src/voiceController.ts
@@ -25,6 +25,12 @@ export interface VoiceChannelSummary {
name: string;
}
+export interface ChannelSummary {
+ id: string;
+ name: string;
+ type: string;
+}
+
export class VoiceController {
private activeGuildId: string | null = null;
private activeChannelId: string | null = null;
@@ -63,6 +69,27 @@ export class VoiceController {
.sort((a, b) => a.name.localeCompare(b.name));
}
+ async listWatchableChannels(guildId: string): Promise {
+ const guild = this.getGuild(guildId);
+ await guild.channels.fetch().catch(() => null);
+
+ return guild.channels.cache
+ .filter((channel) =>
+ ["GUILD_TEXT", "GUILD_PUBLIC_THREAD", "GUILD_PRIVATE_THREAD"].includes(
+ channel.type,
+ ),
+ )
+ .map((channel) => {
+ const parentName = channel.isThread?.() ? channel.parent?.name : null;
+ return {
+ id: channel.id,
+ name: parentName ? `${parentName} / ${channel.name}` : channel.name,
+ type: channel.type,
+ };
+ })
+ .sort((a, b) => a.name.localeCompare(b.name));
+ }
+
async connect(guildId: string, channelId: string): Promise {
if (!this.client.isReady()) {
throw new AppError(
diff --git a/src/webserver.ts b/src/webserver.ts
index 16a53f2..2e3c067 100644
--- a/src/webserver.ts
+++ b/src/webserver.ts
@@ -106,6 +106,14 @@ export function startWebserver(
}
});
+ app.get("/api/guilds/:guildId/channels", async (req, res, next) => {
+ try {
+ res.json(await voiceController.listWatchableChannels(req.params.guildId));
+ } catch (error) {
+ next(error);
+ }
+ });
+
app.post("/api/connect", async (req, res, next) => {
try {
const { guildId, channelId } = req.body as {
-
-
-
-
-
-
-
-
- Not connected
+
+
+
+
+
+
+
+
+
- Voice Control
bridge
+
+
+
+
+
+
+
+
+ Idle
-
-
-
- Connecting...
-
+
+
+
+ Live Audio
speaker off
-
-
-
-
- Speaker Off
+
+
-
- Participants
- -
+
+
+
+