wangjunxiao/nanoclaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(v2): support async channel adapter factories

Browse Source 
Channel adapter factories can now return a Promise, enabling adapters
that need async initialization like loading auth state from disk
(e.g. WhatsApp reading credentials via useMultiFileAuthState).
Existing sync factories are unaffected — await on a sync return is
a no-op. All current adapters remain synchronous.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
Gabi Simons
2026-04-13 11:09:00 +00:00
parent 3db0dceb1b
commit 8676c07448
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/channels/adapter.ts
View File

@@ -97,7 +97,7 @@ export interface ChannelAdapter {
} }
/** Factory function that creates a channel adapter (returns null if credentials missing). */ /** Factory function that creates a channel adapter (returns null if credentials missing). */
export type ChannelAdapterFactory = () => ChannelAdapter | null; export type ChannelAdapterFactory = () => ChannelAdapter | Promise<ChannelAdapter> | null;
/** Registration entry for a channel adapter. */ /** Registration entry for a channel adapter. */
export interface ChannelRegistration { export interface ChannelRegistration {

2
src/channels/channel-registry.ts
View File

@@ -47,7 +47,7 @@ export function getChannelContainerConfig(name: string): ChannelRegistration['co
export async function initChannelAdapters(setupFn: (adapter: ChannelAdapter) => ChannelSetup): Promise<void> { export async function initChannelAdapters(setupFn: (adapter: ChannelAdapter) => ChannelSetup): Promise<void> {
for (const [name, registration] of registry) { for (const [name, registration] of registry) {
try { try {
const adapter = registration.factory(); const adapter = await registration.factory();
if (!adapter) { if (!adapter) {
log.warn('Channel credentials missing, skipping', { channel: name }); log.warn('Channel credentials missing, skipping', { channel: name });
continue; continue;