5682ec37fa
* refactor: move Discord channel implementation to extensions/discord/src/ Move all Discord source files from src/discord/ to extensions/discord/src/, following the extension migration pattern. Source files in src/discord/ are replaced with re-export shims. Channel-plugin files from src/channels/plugins/*/discord* are similarly moved and shimmed. - Copy all .ts source files preserving subdirectory structure (monitor/, voice/) - Move channel-plugin files (actions, normalize, onboarding, outbound, status-issues) - Fix all relative imports to use correct paths from new location - Create re-export shims at original locations for backward compatibility - Delete test files from shim locations (tests live in extension now) - Update tsconfig.plugin-sdk.dts.json rootDir from "src" to "." to accommodate extension files outside src/ - Update write-plugin-sdk-entry-dts.ts to match new declaration output paths * fix: add importOriginal to thread-bindings session-meta mock for extensions test * style: fix formatting in thread-bindings lifecycle test
38 lines
1.4 KiB
TypeScript
38 lines
1.4 KiB
TypeScript
import type { GatewayPlugin } from "@buape/carbon/gateway";
|
|
|
|
/**
|
|
* Module-level registry of active Discord GatewayPlugin instances.
|
|
* Bridges the gap between agent tool handlers (which only have REST access)
|
|
* and the gateway WebSocket (needed for operations like updatePresence).
|
|
* Follows the same pattern as presence-cache.ts.
|
|
*/
|
|
const gatewayRegistry = new Map<string, GatewayPlugin>();
|
|
|
|
// Sentinel key for the default (unnamed) account. Uses a prefix that cannot
|
|
// collide with user-configured account IDs.
|
|
const DEFAULT_ACCOUNT_KEY = "\0__default__";
|
|
|
|
function resolveAccountKey(accountId?: string): string {
|
|
return accountId ?? DEFAULT_ACCOUNT_KEY;
|
|
}
|
|
|
|
/** Register a GatewayPlugin instance for an account. */
|
|
export function registerGateway(accountId: string | undefined, gateway: GatewayPlugin): void {
|
|
gatewayRegistry.set(resolveAccountKey(accountId), gateway);
|
|
}
|
|
|
|
/** Unregister a GatewayPlugin instance for an account. */
|
|
export function unregisterGateway(accountId?: string): void {
|
|
gatewayRegistry.delete(resolveAccountKey(accountId));
|
|
}
|
|
|
|
/** Get the GatewayPlugin for an account. Returns undefined if not registered. */
|
|
export function getGateway(accountId?: string): GatewayPlugin | undefined {
|
|
return gatewayRegistry.get(resolveAccountKey(accountId));
|
|
}
|
|
|
|
/** Clear all registered gateways (for testing). */
|
|
export function clearGateways(): void {
|
|
gatewayRegistry.clear();
|
|
}
|