unpinMessageDiscord,

};

export async function resolveDiscordReactionTargetChannelId(params: {

async function resolveDiscordReactionTargetChannelId(params: {

target: string;

cfg: OpenClawConfig;

accountId?: string;

const IDENTIFY_WINDOW_MS = 5_000;

export class GatewayIdentifyLimiter {

class GatewayIdentifyLimiter {

private nextAllowedAtByKey = new Map<number, number>();

async wait(params: { shardId?: number; maxConcurrency?: number }): Promise<void> {

export const GATEWAY_SEND_LIMIT = 120;

export const GATEWAY_SEND_WINDOW_MS = 60_000;

const GATEWAY_SEND_LIMIT = 120;

const GATEWAY_SEND_WINDOW_MS = 60_000;

type QueuedGatewaySend = {

payload: string;

export type UpdatePresenceData = Omit<GatewayPresenceUpdateData, "status"> & {

status: "online" | "idle" | "dnd" | "invisible" | "offline";

};

export type UpdateVoiceStateData = GatewayVoiceStateUpdateData;

export type RequestGuildMembersData = {

type UpdateVoiceStateData = GatewayVoiceStateUpdateData;

type RequestGuildMembersData = {

guild_id: string;

query?: string;

limit: number;

| "deferred-update"

| "replied";

export type InteractionReplyAction = "initial" | "edit" | "follow-up";

type InteractionReplyAction = "initial" | "edit" | "follow-up";

export class InteractionResponseController {

state: InteractionResponseState = "unacknowledged";

import { createBucketKey, createRouteKey, readHeaderNumber, readResetAt } from "./rest-routes.js";

export type RequestQuery = Record<string, string | number | boolean>;

export type ScheduledRequest<TData> = {

type ScheduledRequest<TData> = {

method: string;

path: string;

data?: TData;

routeKeys: Set<string>;

};

export type RestSchedulerOptions = {

type RestSchedulerOptions = {

maxConcurrency: number;

maxRateLimitRetries: number;

maxQueueSize: number;