asepharyana
9b3134d767
- Live Moderation Feed: gateway publishes discord:moderation:action (Redis) → backend WS emits moderation_action → public web shows realtime stream. - Toxic Topic Trends: backend moderation.trends aggregates categories/severity/action_type (read-only) → SVG bar + donut. - Channel Timeline: messages view gets Feed/Timeline toggle with date-grouped separators. - CSV Export: client-side downloadCsv for moderation actions (no backend write scope). - Activity Heatmap: backend messages.activity (per-hour volume by channel) → pure-SVG grid. User reputation deliberately excluded — no such feature exists in the codebase. All read-only / public-facing / fully automatic per project rules.
131 lines
6.2 KiB
TypeScript
131 lines
6.2 KiB
TypeScript
// ---------------------------------------------------------------------------
|
|
// Redis Channel Constants — single source of truth
|
|
//
|
|
// All Redis channel names, status keys, and command types used for
|
|
// inter-service communication between discord-gateway and backend.
|
|
// ---------------------------------------------------------------------------
|
|
|
|
// ---------------------------------------------------------------------------
|
|
// Event channels (discord-gateway -> backend via pub/sub)
|
|
// ---------------------------------------------------------------------------
|
|
|
|
export const DISCORD_MESSAGE_CREATED = "discord:message:created";
|
|
export const DISCORD_MESSAGE_UPDATED = "discord:message:updated";
|
|
export const DISCORD_MESSAGE_DELETED = "discord:message:deleted";
|
|
export const DISCORD_MESSAGE_ANALYZED = "discord:message:analyzed";
|
|
export const DISCORD_ATTACHMENT_CREATED = "discord:attachment:created";
|
|
export const DISCORD_ATTACHMENT_UPLOADED = "discord:attachment:uploaded";
|
|
export const DISCORD_VOICE_STARTED = "discord:voice:started";
|
|
export const DISCORD_VOICE_STOPPED = "discord:voice:stopped";
|
|
export const DISCORD_VOICE_UPLOADED = "discord:voice:uploaded";
|
|
export const DISCORD_VOICE_ACTIVE_USER = "discord:voice:active_user";
|
|
export const DISCORD_VOICE_PCM = "discord:voice:pcm";
|
|
export const DISCORD_ANALYSIS_QUEUE_STATUS = "discord:analysis:queue_status";
|
|
export const DISCORD_REACTION_ADDED = "discord:reaction:added";
|
|
export const DISCORD_REACTION_REMOVED = "discord:reaction:removed";
|
|
export const DISCORD_THREAD_CREATED = "discord:thread:created";
|
|
export const DISCORD_THREAD_DELETED = "discord:thread:deleted";
|
|
export const DISCORD_THREAD_UPDATED = "discord:thread:updated";
|
|
export const DISCORD_CHANNEL_TOPIC_UPDATED = "discord:channel:topic_updated";
|
|
export const DISCORD_PRESENCE_UPDATED = "discord:presence:updated";
|
|
export const DISCORD_GUILD_MEMBER_ADDED = "discord:guild_member:added";
|
|
export const DISCORD_GUILD_MEMBER_REMOVED = "discord:guild_member:removed";
|
|
export const DISCORD_MODERATION_ACTION = "discord:moderation:action";
|
|
|
|
// ---------------------------------------------------------------------------
|
|
// Command channels (backend -> discord-gateway)
|
|
// ---------------------------------------------------------------------------
|
|
|
|
export const BACKEND_COMMAND = "backend:command";
|
|
export const BACKEND_VOICE_TRANSMIT = "backend:voice:transmit";
|
|
export const BACKEND_COMMAND_REPLY_PREFIX = "backend:command:reply:";
|
|
|
|
// ---------------------------------------------------------------------------
|
|
// Status keys (set by discord-gateway, read by backend via Redis GET)
|
|
// ---------------------------------------------------------------------------
|
|
|
|
export const VOICE_STATUS_KEY = "voice:status";
|
|
export const MEDIA_STATUS_KEY = "media:status";
|
|
|
|
// ---------------------------------------------------------------------------
|
|
// Command types (used as the `type` field in CommandMessage envelopes)
|
|
// ---------------------------------------------------------------------------
|
|
|
|
export const COMMAND_VOICE_CONNECT = "voice:connect";
|
|
export const COMMAND_VOICE_DISCONNECT = "voice:disconnect";
|
|
export const COMMAND_VOICE_DISCONNECT_GUILD = "voice:disconnect:guild";
|
|
export const COMMAND_VOICE_CHANNELS = "voice:channels";
|
|
export const COMMAND_VOICE_TRANSMIT_START = "voice:transmit:start";
|
|
export const COMMAND_VOICE_TRANSMIT_STOP = "voice:transmit:stop";
|
|
export const COMMAND_GUILDS_LIST = "guilds:list";
|
|
export const COMMAND_GUILDS_TEXT_CHANNELS = "guilds:text-channels";
|
|
export const COMMAND_MEDIA_QUEUE = "media:queue";
|
|
export const COMMAND_MEDIA_SKIP = "media:skip";
|
|
export const COMMAND_MEDIA_STOP = "media:stop";
|
|
export const COMMAND_MEDIA_VOLUME = "media:volume";
|
|
export const COMMAND_MEDIA_LOOP = "media:loop";
|
|
export const COMMAND_MODERATION_ACTION = "moderation:action";
|
|
export const DISCORD_VOICE_ANALYZED = "discord:voice:analyzed";
|
|
|
|
// ---------------------------------------------------------------------------
|
|
// Event envelope — used by discord-gateway when publishing to Redis
|
|
// ---------------------------------------------------------------------------
|
|
|
|
export interface DiscordGatewayEvent {
|
|
type: string;
|
|
data: unknown;
|
|
timestamp: number;
|
|
source: string;
|
|
}
|
|
|
|
// ---------------------------------------------------------------------------
|
|
// Command envelope — used by backend when publishing to backend:command
|
|
// ---------------------------------------------------------------------------
|
|
|
|
export interface CommandMessage {
|
|
id: string;
|
|
type: string;
|
|
payload: Record<string, unknown>;
|
|
replyChannel: string;
|
|
}
|
|
|
|
export interface CommandReply<T = unknown> {
|
|
id: string;
|
|
success: boolean;
|
|
data?: T;
|
|
error?: string;
|
|
}
|
|
|
|
// ---------------------------------------------------------------------------
|
|
// Discord Redis channel → WebSocket event type mapping (single source of truth)
|
|
// ---------------------------------------------------------------------------
|
|
|
|
/**
|
|
* Maps each Discord Redis channel to its corresponding WebSocket event type.
|
|
* Used by the backend Redis bridge to dispatch events to frontend WS clients.
|
|
*/
|
|
export const DISCORD_CHANNEL_TO_WS_EVENT: Record<string, string> = {
|
|
[DISCORD_MESSAGE_CREATED]: "message_created",
|
|
[DISCORD_MESSAGE_UPDATED]: "message_updated",
|
|
[DISCORD_MESSAGE_DELETED]: "message_deleted",
|
|
[DISCORD_MESSAGE_ANALYZED]: "message_analyzed",
|
|
[DISCORD_ATTACHMENT_CREATED]: "attachment_created",
|
|
[DISCORD_ATTACHMENT_UPLOADED]: "attachment_uploaded",
|
|
[DISCORD_VOICE_STARTED]: "voice_recording_started",
|
|
[DISCORD_VOICE_STOPPED]: "voice_recording_stopped",
|
|
[DISCORD_VOICE_UPLOADED]: "voice_recording_uploaded",
|
|
[DISCORD_ANALYSIS_QUEUE_STATUS]: "analysis_queue_status",
|
|
[DISCORD_VOICE_ACTIVE_USER]: "voice_active_user",
|
|
[DISCORD_VOICE_PCM]: "voice_pcm_data",
|
|
[DISCORD_VOICE_ANALYZED]: "voice_analyzed",
|
|
[DISCORD_REACTION_ADDED]: "reaction_added",
|
|
[DISCORD_REACTION_REMOVED]: "reaction_removed",
|
|
[DISCORD_THREAD_CREATED]: "thread_created",
|
|
[DISCORD_THREAD_DELETED]: "thread_deleted",
|
|
[DISCORD_THREAD_UPDATED]: "thread_updated",
|
|
[DISCORD_CHANNEL_TOPIC_UPDATED]: "channel_topic_updated",
|
|
[DISCORD_PRESENCE_UPDATED]: "presence_updated",
|
|
[DISCORD_GUILD_MEMBER_ADDED]: "guild_member_added",
|
|
[DISCORD_GUILD_MEMBER_REMOVED]: "guild_member_removed",
|
|
};
|