github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-09 20:34:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(discord): dedupe reaction listener params

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-15 07:01:24 +00:00
parent 6e1b3ace4d
commit 913b137090
1 changed files with 12 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
src/discord/monitor/listeners.ts
View File

@@ -31,6 +31,15 @@ export type DiscordMessageHandler = (data: DiscordMessageEvent, client: Client)
type DiscordReactionEvent = Parameters<MessageReactionAddListener["handle"]>[0]; type DiscordReactionEvent = Parameters<MessageReactionAddListener["handle"]>[0];
type DiscordReactionListenerParams = {
cfg: LoadedConfig;
accountId: string;
runtime: RuntimeEnv;
botUserId?: string;
guildEntries?: Record<string, import("./allow-list.js").DiscordGuildEntryResolved>;
logger: Logger;
};
const DISCORD_SLOW_LISTENER_THRESHOLD_MS = 30_000; const DISCORD_SLOW_LISTENER_THRESHOLD_MS = 30_000;
const discordEventQueueLog = createSubsystemLogger("discord/event-queue"); const discordEventQueueLog = createSubsystemLogger("discord/event-queue");
@@ -94,16 +103,7 @@ export class DiscordMessageListener extends MessageCreateListener {
} }
export class DiscordReactionListener extends MessageReactionAddListener { export class DiscordReactionListener extends MessageReactionAddListener {
constructor( constructor(private params: DiscordReactionListenerParams) {
private params: {
cfg: LoadedConfig;
accountId: string;
runtime: RuntimeEnv;
botUserId?: string;
guildEntries?: Record<string, import("./allow-list.js").DiscordGuildEntryResolved>;
logger: Logger;
},
) {
super(); super();
} }
@@ -120,16 +120,7 @@ export class DiscordReactionListener extends MessageReactionAddListener {
} }
export class DiscordReactionRemoveListener extends MessageReactionRemoveListener { export class DiscordReactionRemoveListener extends MessageReactionRemoveListener {
constructor( constructor(private params: DiscordReactionListenerParams) {
private params: {
cfg: LoadedConfig;
accountId: string;
runtime: RuntimeEnv;
botUserId?: string;
guildEntries?: Record<string, import("./allow-list.js").DiscordGuildEntryResolved>;
logger: Logger;
},
) {
super(); super();
} }
@@ -149,14 +140,7 @@ async function runDiscordReactionHandler(params: {
data: DiscordReactionEvent; data: DiscordReactionEvent;
client: Client; client: Client;
action: "added" | "removed"; action: "added" | "removed";
handlerParams: { handlerParams: DiscordReactionListenerParams;
cfg: LoadedConfig;
accountId: string;
runtime: RuntimeEnv;
botUserId?: string;
guildEntries?: Record<string, import("./allow-list.js").DiscordGuildEntryResolved>;
logger: Logger;
};
listener: string; listener: string;
event: string; event: string;
}): Promise<void> { }): Promise<void> {