packages/channels/base/README.md
Base infrastructure for building Qwen Code channel adapters. Provides the abstract base class, access control, session routing, and the adapter-facing bridge interface used to communicate with the agent.
If you're building a channel plugin, this is your only dependency.
npm install @qwen-code/channel-base
Subclass ChannelBase and implement three methods:
import { ChannelBase } from '@qwen-code/channel-base';
import type {
ChannelAgentBridge,
ChannelBaseOptions,
ChannelConfig,
Envelope,
} from '@qwen-code/channel-base';
class MyChannel extends ChannelBase {
constructor(
name: string,
config: ChannelConfig,
bridge: ChannelAgentBridge,
options?: ChannelBaseOptions,
) {
super(name, config, bridge, options);
}
async connect(): Promise<void> {
// Connect to platform API, register message handlers.
// When a message arrives, build an Envelope and call:
// this.handleInbound(envelope)
}
async sendMessage(chatId: string, text: string): Promise<void> {
// Deliver the agent's response to the platform.
}
disconnect(): void {
// Clean up connections on shutdown.
}
}
Export a ChannelPlugin object so the extension loader can discover it:
import type { ChannelPlugin } from '@qwen-code/channel-base';
export const plugin: ChannelPlugin = {
channelType: 'my-platform',
displayName: 'My Platform',
requiredConfigFields: ['apiKey'],
createChannel: (name, config, bridge, options) =>
new MyChannel(name, config, bridge, options),
};
For a complete working example, see @qwen-code/channel-plugin-example.
Migration note for existing TypeScript plugins: if your adapter constructor or factory explicitly types bridge as AcpBridge, change that annotation to ChannelAgentBridge and keep using only the methods exposed by that contract. JavaScript plugins are unaffected at runtime, and standalone qwen channel start still passes the current AcpBridge implementation.
Channel adapters can run in two host modes:
qwen channel start [name] is the standalone service. It uses AcpBridge over a qwen-code --acp child process and remains the default channel command.qwen serve --channel <name> and qwen serve --channel all are experimental daemon-managed modes. qwen serve starts one out-of-process channel worker, the worker connects back to the daemon through the SDK, and adapters receive a DaemonChannelBridge-backed ChannelAgentBridge facade.In daemon-managed mode, one daemon is bound to one workspace. Every selected channel's cwd must resolve to that same workspace. The optional shellCommand method is exposed to adapters only when the daemon advertises the session_shell_command capability.
Inbound: Platform message
→ Envelope (with attachments)
→ GroupGate (group policy + mention gating)
→ SenderGate (allowlist / pairing / open)
→ Slash commands (/clear, /help, /status)
→ SessionRouter (resolve or create agent session)
→ Resolve attachments (images → bridge, files → prompt text)
→ ChannelAgentBridge.prompt() → agent
Outbound: Agent response
→ BlockStreamer (if enabled: split into blocks at paragraph boundaries)
→ sendMessage() → platform
Everything between handleInbound() and sendMessage() is handled by the base class — your adapter only deals with platform I/O.
| Class | Purpose |
|---|---|
ChannelBase | Abstract base class — extend this to build a channel adapter |
AcpBridge | Current standalone qwen channel start bridge implementation over qwen-code --acp |
BlockStreamer | Progressive multi-message delivery for block streaming |
SessionRouter | Maps senders to agent sessions with configurable scoping |
SenderGate | DM access control (allowlist / pairing / open) |
GroupGate | Group chat policy and @mention gating |
PairingStore | Pairing code generation, approval, and allowlist persistence |
| Type | Description |
|---|---|
Attachment | Structured file/image/audio/video attachment |
AvailableCommand | Agent command advertised through the bridge |
ChannelAgentBridge | Adapter-facing bridge contract used by ChannelBase and SessionRouter |
ChannelConfig | Channel configuration from settings.json |
ChannelPlugin | Plugin factory interface (what you export) |
Envelope | Normalized inbound message format |
SenderPolicy | 'allowlist' | 'pairing' | 'open' |
GroupPolicy | 'disabled' | 'allowlist' | 'open' |
SessionScope | 'user' | 'thread' | 'single' |
GroupConfig | Per-group settings (e.g. requireMention) |
SessionTarget | Maps a session back to its channel/sender/chat |
ToolCallEvent | Agent tool-call event delivered to adapters |
constructor(name: string, config: ChannelConfig, bridge: ChannelAgentBridge, options?: ChannelBaseOptions)
Abstract methods (you must implement):
| Method | Signature |
|---|---|
connect() | () => Promise<void> — Connect to the platform and start receiving messages |
sendMessage() | (chatId: string, text: string) => Promise<void> — Deliver agent response |
disconnect() | () => void — Clean up on shutdown |
Provided methods:
| Method | Description |
|---|---|
handleInbound(envelope) | Route an inbound message through the full pipeline (gate checks, commands, session, prompt). Call this from your message handler. |
setBridge(bridge) | Replace the agent bridge after crash recovery |
registerCommand(name, handler) | Register a custom slash command (e.g. /mycommand) |
onToolCall(chatId, event) | Hook called on agent tool invocations — override to show indicators |
onResponseChunk(chatId, chunk, sessionId) | Hook called per streaming text chunk — override for progressive display (default: no-op) |
onResponseComplete(chatId, fullText, sessionId) | Hook called when full response is ready — override to customize delivery (default: sendMessage()) |
Block streaming: When blockStreaming: "on" is set in the channel config, the base class automatically splits the agent's streaming response into multiple messages at paragraph boundaries. See Block Streaming below.
Built-in slash commands: /clear (/reset, /new), /help, /status
ChannelBaseOptions:
| Option | Description |
|---|---|
router | Optional SessionRouter. Omit for the default standalone router. |
proxy | Optional proxy URL made available to adapters. |
registerBridgeEvents | Set only when the adapter owns a supplied router and ChannelBase should consume bridge events directly. Leave unset for routers supplied by the gateway. |
ChannelAgentBridge is the adapter-facing contract. Channel adapters, channel plugins, ChannelBase, and SessionRouter should depend on this type instead of a concrete bridge implementation.
shellCommand is optional. Adapters should check for it before enabling !cmd-style features because daemon-managed hosts expose it only when the connected daemon supports shell execution.
interface ChannelAgentBridge {
readonly availableCommands: AvailableCommand[];
on(eventName: 'toolCall', listener: (event: ToolCallEvent) => void): unknown;
on(
eventName: 'textChunk',
listener: (sessionId: string, chunk: string) => void,
): unknown;
on(
eventName: 'sessionDied',
listener: (event: { sessionId: string; reason?: string }) => void,
): unknown;
off(eventName: 'toolCall', listener: (event: ToolCallEvent) => void): unknown;
off(
eventName: 'textChunk',
listener: (sessionId: string, chunk: string) => void,
): unknown;
off(
eventName: 'sessionDied',
listener: (event: { sessionId: string; reason?: string }) => void,
): unknown;
newSession(cwd: string): Promise<string>;
loadSession(sessionId: string, cwd: string): Promise<string>;
prompt(
sessionId: string,
text: string,
options?: { imageBase64?: string; imageMimeType?: string },
): Promise<string>;
cancelSession(sessionId: string): Promise<void>;
shellCommand?(
sessionId: string,
command: string,
signal?: AbortSignal,
): Promise<{ exitCode: number | null; output: string; aborted: boolean }>;
}
AcpBridge is the current implementation used by standalone qwen channel start. It manages the qwen-code --acp child process and implements ChannelAgentBridge.
constructor(options: { cliEntryPath: string; cwd: string; model?: string })
| Method | Description |
|---|---|
start() | Spawn the agent process |
stop() | Kill the agent process |
newSession(cwd) | Create a new ACP session, returns sessionId |
loadSession(sessionId, cwd) | Restore an existing session |
prompt(sessionId, text, options?) | Send a message to the agent, returns the full response text. Supports optional imageBase64 and imageMimeType. |
isConnected | Whether the agent process is alive |
Events (EventEmitter):
| Event | Payload | Description |
|---|---|---|
textChunk | (sessionId, chunk) | Streaming response chunk |
toolCall | (event: ToolCallEvent) | Agent invoked a tool |
disconnected | (code, signal) | Agent process exited |
Maps senders to agent sessions based on the configured scope.
constructor(bridge: ChannelAgentBridge, defaultCwd: string, scope?: SessionScope, persistPath?: string)
Routing keys by scope:
| Scope | Key format | Effect |
|---|---|---|
user (default) | channel:senderId:chatId | Each user gets their own session per chat |
thread | channel:threadId | One session per thread |
single | channel:__single__ | One shared session for the entire channel |
| Method | Description |
|---|---|
resolve(channelName, senderId, chatId, threadId?, cwd?) | Get or create a session for the given sender |
removeSession(channelName, senderId, chatId?, threadId?) | Remove session(s) — used by /clear |
removeSessionId(sessionId) | Remove all routing state for a bridge session ID |
restoreSessions() | Reload sessions from disk after bridge restart |
clearAll() | Clear all sessions and delete persist file (clean shutdown) |
constructor(policy: SenderPolicy, allowedUsers?: string[], pairingStore?: PairingStore)
| Method | Description |
|---|---|
check(senderId, senderName?) | Returns { allowed: boolean, pairingCode?: string | null } |
Policy behavior:
| Policy | Behavior |
|---|---|
open | Everyone allowed |
allowlist | Only allowedUsers allowed |
pairing | Check allowlist, then approved pairings, then generate a pairing code (8-char, 1hr expiry, max 3 pending) |
constructor(policy?: GroupPolicy, groups?: Record<string, GroupConfig>)
| Method | Description |
|---|---|
check(envelope) | Returns { allowed: boolean, reason?: 'disabled' | 'not_allowlisted' | 'mention_required' } |
Policy behavior:
| Policy | Behavior |
|---|---|
disabled | All group messages rejected |
allowlist | Only groups listed in config are allowed |
open | All groups allowed |
When requireMention is true (default), group messages are only processed if the bot is @mentioned or the message is a reply to the bot.
constructor(channelName: string)
Persists pairing state to ~/.qwen/channels/{channelName}-pairing.json and {channelName}-allowlist.json.
| Method | Description |
|---|---|
createRequest(senderId, senderName) | Generate an 8-char pairing code (or return existing). Returns null if 3 pending requests already exist. |
approve(code) | Approve a pairing request, adds sender to allowlist. Returns the request or null. |
isApproved(senderId) | Check if sender is in the approved allowlist |
listPending() | Get active (non-expired) pending requests |
The normalized message format your adapter must construct:
interface Envelope {
channelName: string; // your channel instance name
senderId: string; // stable, unique sender ID
senderName: string; // display name
chatId: string; // distinguishes DMs from groups
text: string; // message text (@mentions stripped)
messageId?: string; // platform message ID
threadId?: string; // for thread-scoped sessions
isGroup: boolean; // true for group chats
isMentioned: boolean; // true if bot was @mentioned
isReplyToBot: boolean; // true if replying to bot's message
referencedText?: string; // quoted message text
imageBase64?: string; // base64-encoded image (legacy — prefer attachments)
imageMimeType?: string; // e.g. 'image/jpeg' (legacy — prefer attachments)
attachments?: Attachment[]; // structured file/image/audio/video attachments
}
interface Attachment {
type: 'image' | 'file' | 'audio' | 'video';
data?: string; // base64-encoded data (images, small files)
filePath?: string; // absolute path to local file (large files)
mimeType: string; // e.g. 'application/pdf', 'image/jpeg'
fileName?: string; // original file name from the platform
}
handleInbound() automatically resolves attachments: images with data are sent to the model as vision input, files with filePath get their path appended to the prompt text so the agent can read them with its tools.
When blockStreaming: "on" is set in a channel's config, the agent's response is delivered as multiple separate messages instead of one large wall of text. The BlockStreamer accumulates streaming chunks and emits completed blocks based on paragraph boundaries and size heuristics.
Config fields (on ChannelConfig):
| Field | Type | Default | Description |
|---|---|---|---|
blockStreaming | 'on' | 'off' | 'off' | Enable/disable block streaming |
blockStreamingChunk | { minChars, maxChars } | { 400, 1000 } | minChars: don't emit until this size. maxChars: force-emit at this size |
blockStreamingCoalesce | { idleMs } | { 1500 } | Emit buffered text after this many ms of silence from the agent |
How it works:
minChars and hits a paragraph break (\n\n), that block is sent as a separate messagemaxChars without a paragraph break, it force-splits at the best break point (newline > space)idleMs, the buffer is flushed (as long as it's past minChars)minCharsBlock streaming and onResponseChunk work independently — plugins can override onResponseChunk for their own purposes while block streaming handles delivery.
@qwen-code/channel-plugin-example — working reference implementation