SlackSocketModeReceiverOptions,

"clientPingTimeout" | "serverPingTimeout" | "pingPongLoggingEnabled"

>;

type SlackSdkLogger = NonNullable<SlackSocketModeReceiverOptions["logger"]>;

type SlackSdkLogLevel = ReturnType<SlackSdkLogger["getLevel"]>;

const OPENCLAW_SLACK_CLIENT_PING_TIMEOUT_MS = 15_000;

const SLACK_SOCKET_PONG_TIMEOUT_WARNING_PREFIX = "A pong wasn't received from the server";

const SLACK_SOCKET_LOG_LEVEL_IGNORED_WARNING_RE =

/^The logLevel given to .+ was ignored as you also gave logger$/;

export type SlackBoltResolvedExports = {

App: SlackAppConstructor;

});

}

function isSlackSocketPongTimeoutWarning(args: readonly unknown[]) {

return (

typeof args[0] === "string" && args[0].startsWith(SLACK_SOCKET_PONG_TIMEOUT_WARNING_PREFIX)

);

}

function isSlackSocketSelfInflictedLoggerWarning(args: readonly unknown[]) {

return typeof args[0] === "string" && SLACK_SOCKET_LOG_LEVEL_IGNORED_WARNING_RE.test(args[0]);

}

export function createSlackSocketModeLogger(

sink: Pick<typeof console, "debug" | "info" | "warn" | "error"> = console,

): SlackSdkLogger {

let level = "info" as SlackSdkLogLevel;

let name = "socket-mode";

const prefix = () => `socket-mode:${name}`;

return {

debug: () => {},

info: () => {},

warn: (...args: unknown[]) => {

if (isSlackSocketPongTimeoutWarning(args) || isSlackSocketSelfInflictedLoggerWarning(args)) {

return;

}

sink.warn(prefix(), ...args);

},

error: (...args: unknown[]) => sink.error(prefix(), ...args),

setLevel: (nextLevel) => {

level = nextLevel;

},

getLevel: () => level,

setName: (nextName) => {

name = nextName;

},

};

}

function asRecord(value: unknown): Record<string, unknown> | undefined {

return value && typeof value === "object" && !Array.isArray(value)

? (value as Record<string, unknown>)

autoReconnectEnabled: false,

clientPingTimeout:

params.socketMode?.clientPingTimeout ?? OPENCLAW_SLACK_CLIENT_PING_TIMEOUT_MS,

logger: createSlackSocketModeLogger(),

installerOptions: {

clientOptions: params.clientOptions,

},