メッセージライフサイクルのリファクタリング

Documentation Index

Fetch the complete documentation index at: https://docs.openclaw.ai/llms.txt

Use this file to discover all available pages before exploring further.

• コア プリミティブは reply ではなく、receive と send であるべきです。
• 返信はアウトバウンド メッセージ上の関係にすぎません。
• ターンはインバウンド処理の便宜であり、配信の所有者ではありません。
• 送信はコンテキスト ベースである必要があります: begin、レンダー、プレビューまたはストリーム、最終送信、 コミット、失敗。
• 受信もコンテキスト ベースである必要があります: 正規化、重複排除、ルーティング、記録、 ディスパッチ、プラットフォーム ack、失敗。
• 公開 Plugin SDK は、小さなチャネル メッセージ サーフェス 1 つに集約するべきです。

​

問題

• シンプルなインバウンド アダプターは runtime.channel.turn.run を使います。
• 高機能なアダプターは runtime.channel.turn.runPrepared を使います。
• レガシー ヘルパーは dispatchInboundReplyWithBase、 recordInboundSessionAndDispatchReply、返信ペイロード ヘルパー、返信チャンク化、 返信参照、アウトバウンド ランタイム ヘルパーを使います。
• プレビュー ストリーミングはチャネル固有のディスパッチャーにあります。
• 最終配信の耐久性は、既存の返信ペイロード パスの周辺に追加されつつあります。

Telegram polling update acked
  -> assistant final text exists
  -> process restarts before sendMessage succeeds
  -> final response is lost

​

目標

• すべてのチャネル メッセージ受信および送信パスに対する、1 つのコア ライフサイクル。
• アダプターがリプレイ安全な挙動を宣言した後の、新しいメッセージ ライフサイクルにおける デフォルトで永続的な最終送信。
• 共有されたプレビュー、編集、ストリーム、ファイナライズ、リトライ、リカバリー、レシート セマンティクス。
• サードパーティ Plugin が学習し保守できる、小さな Plugin SDK サーフェス。
• 移行中の既存 channel.turn 呼び出し元との互換性。
• 新しいチャネル機能のための明確な拡張ポイント。
• コアにプラットフォーム固有の分岐を置かないこと。
• トークン差分のチャネル メッセージを置かないこと。チャネル ストリーミングは、メッセージ プレビュー、 編集、追記、または完了済みブロック配信のままです。
• 運用/システム出力のための構造化された OpenClaw 起源メタデータ。これにより、可視の Gateway 失敗が、共有の bot 有効ルームで新しいプロンプトとして再入力されません。

​

非目標

• 最初のフェーズで runtime.channel.turn.* を削除しないこと。
• すべてのチャネルに同じネイティブ トランスポート挙動を強制しないこと。
• コアに Telegram トピック、Slack ネイティブ ストリーム、Matrix リダクション、 Feishu カード、QQ 音声、または Teams アクティビティを教え込まないこと。
• すべての内部移行ヘルパーを安定版 SDK API として公開しないこと。
• リトライで完了済みの非冪等プラットフォーム操作をリプレイしないこと。

​

参照モデル

• Chat
• Thread
• Channel
• Message
• postMessage、editMessage、deleteMessage、 stream、startTyping、履歴取得などのアダプター メソッド
• 重複排除、ロック、キュー、永続化のための状態アダプター

• 直接トランスポート呼び出しの前の、永続的なアウトバウンド送信意図。
• begin、commit、fail を持つ明示的な送信コンテキスト。
• プラットフォーム ack ポリシーを知る受信コンテキスト。
• 再起動を生き残り、編集、削除、リカバリー、重複抑止を駆動できるレシート。
• より小さな公開 SDK。バンドル済み Plugin は内部ランタイム ヘルパーを使用できますが、 サードパーティ Plugin には一貫したメッセージ API 1 つを見せるべきです。
• エージェント固有の挙動: セッション、トランスクリプト、ブロック ストリーミング、ツール進行状況、 承認、メディア ディレクティブ、サイレント返信、グループ メンション履歴。

​

コア モデル

core.messages.receive(...)
core.messages.send(...)
core.messages.live(...)
core.messages.state(...)

​

メッセージ用語

​

メッセージ

type ChannelMessage = {
  id: string;
  channel: string;
  accountId?: string;
  direction: "inbound" | "outbound";
  target: MessageTarget;
  sender?: MessageActor;
  body?: MessageBody;
  attachments?: MessageAttachment[];
  relation?: MessageRelation;
  origin?: MessageOrigin;
  timestamp?: number;
  raw?: unknown;
};

​

ターゲット

type MessageTarget = {
  kind: "direct" | "group" | "channel" | "thread";
  id: string;
  label?: string;
  spaceId?: string;
  parentId?: string;
  threadId?: string;
  nativeChannelId?: string;
};

​

関係

type MessageRelation =
  | {
      kind: "reply";
      inboundMessageId?: string;
      replyToId?: string;
      threadId?: string;
      quote?: MessageQuote;
    }
  | {
      kind: "followup";
      sessionKey?: string;
      previousMessageId?: string;
    }
  | {
      kind: "broadcast";
      reason?: string;
    }
  | {
      kind: "system";
      reason:
        | "approval"
        | "task"
        | "hook"
        | "cron"
        | "subagent"
        | "message_tool"
        | "cli"
        | "control_ui"
        | "automation"
        | "error";
    };

​

起源

type MessageOrigin =
  | {
      source: "openclaw";
      schemaVersion: 1;
      kind: "gateway_failure";
      code: "agent_failed_before_reply" | "missing_api_key" | "model_login_expired";
      echoPolicy: "drop_bot_room_echo";
    }
  | {
      source: "user" | "external_bot" | "platform" | "unknown";
    };

​

レシート

type MessageReceipt = {
  primaryPlatformMessageId?: string;
  platformMessageIds: string[];
  parts: MessageReceiptPart[];
  threadId?: string;
  replyToId?: string;
  editToken?: string;
  deleteToken?: string;
  url?: string;
  sentAt: number;
  raw?: unknown;
};

type MessageReceiptPart = {
  platformMessageId: string;
  kind: "text" | "media" | "voice" | "card" | "preview" | "unknown";
  index: number;
  threadId?: string;
  replyToId?: string;
  editToken?: string;
  deleteToken?: string;
  url?: string;
  raw?: unknown;
};

​

受信コンテキスト

type MessageReceiveContext = {
  id: string;
  channel: string;
  accountId?: string;
  input: ChannelMessage;
  ack: ReceiveAckController;
  route: MessageRouteController;
  session: MessageSessionController;
  log: MessageLifecycleLogger;

  dedupe(): Promise<ReceiveDedupeResult>;
  resolve(): Promise<ResolvedInboundMessage>;
  record(resolved: ResolvedInboundMessage): Promise<RecordResult>;
  dispatch(recorded: RecordResult): Promise<DispatchResult>;
  commit(result: DispatchResult): Promise<void>;
  fail(error: unknown): Promise<void>;
};

platform event
  -> begin receive context
  -> normalize
  -> classify
  -> dedupe and self-echo gate
  -> route and authorize
  -> record inbound session metadata
  -> dispatch agent run
  -> durable outbound sends happen through send context
  -> commit receive
  -> ack platform when policy allows

• トランスポート ack: OpenClaw がイベント エンベロープを受け入れたことを、プラットフォームの Webhook またはソケットへ伝えます。一部のプラットフォームではディスパッチ前にこれが必要です。
• ポーリング オフセット ack: 同じイベントが再取得されないようにカーソルを進めます。リカバリー不能な作業を越えて進めてはいけません。
• インバウンド記録 ack: OpenClaw が再配信の重複排除とルーティングに十分なインバウンド メタデータを永続化したことを確認します。
• ユーザー可視レシート: 任意の既読/ステータス/入力中挙動です。耐久性の境界にはなりません。

function shouldDropOpenClawEcho(params: {
  origin?: MessageOrigin;
  isBotAuthor: boolean;
  isRoomish: boolean;
}): boolean {
  return (
    params.isBotAuthor &&
    params.isRoomish &&
    params.origin?.source === "openclaw" &&
    params.origin.kind === "gateway_failure" &&
    params.origin.echoPolicy === "drop_bot_room_echo"
  );
}

type ReceiveAckPolicy =
  | { kind: "immediate"; reason: "webhook-timeout" | "platform-contract" }
  | { kind: "after-record" }
  | { kind: "after-durable-send" }
  | { kind: "manual" };

​

送信コンテキスト

type MessageSendContext = {
  id: string;
  channel: string;
  accountId?: string;
  message: ChannelMessage;
  intent: DurableSendIntent;
  attempt: number;
  signal: AbortSignal;
  previousReceipt?: MessageReceipt;
  preview?: LiveMessageState;
  log: MessageLifecycleLogger;

  render(): Promise<RenderedMessageBatch>;
  previewUpdate(rendered: RenderedMessageBatch): Promise<LiveMessageState>;
  send(rendered: RenderedMessageBatch): Promise<MessageReceipt>;
  edit(receipt: MessageReceipt, rendered: RenderedMessageBatch): Promise<MessageReceipt>;
  delete(receipt: MessageReceipt): Promise<void>;
  commit(receipt: MessageReceipt): Promise<void>;
  fail(error: unknown): Promise<void>;
};

await core.messages.withSendContext(message, async (ctx) => {
  const rendered = await ctx.render();

  if (ctx.preview?.canFinalizeInPlace) {
    return await ctx.edit(ctx.preview.receipt, rendered);
  }

  return await ctx.send(rendered);
});

begin durable intent
  -> render
  -> optional preview/edit/stream work
  -> mark sending
  -> final platform send or final edit
  -> mark committing with raw receipt
  -> commit receipt
  -> ack durable intent
  -> fail durable intent on classified failure

type MessageDurabilityPolicy = "required" | "best_effort" | "disabled";

type RenderedMessageBatch = {
  units: RenderedMessageUnit[];
  atomicity: "all_or_retry_remaining" | "best_effort_parts";
  idempotencyKey: string;
};

type RenderedMessageUnit = {
  index: number;
  kind: "text" | "media" | "voice" | "card" | "preview" | "unknown";
  payload: unknown;
  required: boolean;
};

​

ライブコンテキスト

type MessageLiveAdapter = {
  begin?(ctx: MessageSendContext): Promise<LiveMessageState>;
  update?(
    ctx: MessageSendContext,
    state: LiveMessageState,
    update: LiveMessageUpdate,
  ): Promise<LiveMessageState>;
  finalize?(
    ctx: MessageSendContext,
    state: LiveMessageState,
    final: RenderedMessageBatch,
  ): Promise<MessageReceipt>;
  cancel?(
    ctx: MessageSendContext,
    state: LiveMessageState,
    reason: LiveCancelReason,
  ): Promise<void>;
};

type LiveMessageState = {
  mode: "partial" | "block" | "progress" | "native";
  receipt?: MessageReceipt;
  visibleSince?: number;
  canFinalizeInPlace: boolean;
  lastRenderedHash?: string;
  staleAfterMs?: number;
};

• Telegram の送信とプレビュー編集、およびプレビューが古くなった後の新しい最終メッセージ。
• Discord の送信とプレビュー編集、およびメディア、エラー、明示的な reply 時のキャンセル。
• スレッド形状に応じた Slack のネイティブストリームまたはドラフトプレビュー。
• Mattermost のドラフト投稿の最終化。
• Matrix のドラフトイベント最終化、または不一致時の削除。
• Teams のネイティブ進行状況ストリーム。
• QQ Bot のストリームまたは蓄積型フォールバック。

​

アダプターサーフェス

import { defineChannelMessageAdapter } from "openclaw/plugin-sdk/channel-message";

type ChannelMessageAdapter = {
  receive?: MessageReceiveAdapter;
  send: MessageSendAdapter;
  live?: MessageLiveAdapter;
  origin?: MessageOriginAdapter;
  render?: MessageRenderAdapter;
  capabilities: MessageCapabilities;
};

type MessageSendAdapter = {
  send(ctx: MessageSendContext, rendered: RenderedMessageBatch): Promise<MessageReceipt>;
  edit?(
    ctx: MessageSendContext,
    receipt: MessageReceipt,
    rendered: RenderedMessageBatch,
  ): Promise<MessageReceipt>;
  delete?(ctx: MessageSendContext, receipt: MessageReceipt): Promise<void>;
  classifyError?(ctx: MessageSendContext, error: unknown): DeliveryFailureKind;
  reconcileUnknownSend?(ctx: MessageSendContext): Promise<MessageReceipt | null>;
  afterSendSuccess?(ctx: MessageSendContext, receipt: MessageReceipt): Promise<void>;
  afterCommit?(ctx: MessageSendContext, receipt: MessageReceipt): Promise<void>;
};

type MessageReceiveAdapter<TRaw = unknown> = {
  normalize(raw: TRaw, ctx: MessageNormalizeContext): Promise<ChannelMessage>;
  classify?(message: ChannelMessage): Promise<MessageEventClass>;
  preflight?(message: ChannelMessage, event: MessageEventClass): Promise<MessagePreflightResult>;
  ackPolicy?(message: ChannelMessage, event: MessageEventClass): ReceiveAckPolicy;
};

type MessageOriginAdapter<TRaw = unknown, TNative = unknown> = {
  encode?(origin: MessageOrigin): TNative | undefined;
  decode?(raw: TRaw): MessageOrigin | undefined;
};

type MessageCapabilities = {
  text: { maxLength?: number; chunking?: boolean };
  attachments?: {
    upload: boolean;
    remoteUrl: boolean;
    voice?: boolean;
  };
  threads?: {
    reply: boolean;
    topic?: boolean;
    nativeThread?: boolean;
  };
  live?: {
    edit: boolean;
    delete: boolean;
    nativeStream?: boolean;
    progress?: boolean;
  };
  delivery?: {
    idempotencyKey?: boolean;
    retryAfter?: boolean;
    receiptRequired?: boolean;
  };
};

​

公開 SDK の整理

• reply-runtime
• reply-dispatch-runtime
• reply-reference
• reply-chunking
• reply-payload
• inbound-reply-dispatch
• channel-reply-pipeline
• outbound-runtime のほとんどの公開利用
• アドホックなドラフトストリームライフサイクルヘルパー

​

チャネルターンとの関係

channel.turn.run
  -> messages.receive context
  -> session dispatch
  -> messages.send context for visible output

channel-owned dispatcher
  -> messages.receive record/finalize bridge
  -> messages.live for preview/progress
  -> messages.send for final delivery

​

互換性のガードレール

• channel.turn.run と dispatchAssembledChannelTurn は、そのチャネルが監査済みの durable ポリシー/options オブジェクトを明示的に提供しない限り、チャネルの配信コールバックを使用する。
• channel.turn.runPrepared は、prepared ディスパッチャーが送信コンテキストを明示的に呼び出すまで、チャネル所有のままにする。
• recordInboundSessionAndDispatchReply、dispatchInboundReplyWithBase、direct-DM ヘルパーなどの公開互換ヘルパーは、呼び出し元が提供した deliver または reply コールバックより前に汎用 durable delivery を注入しない。

• 耐久的な最終配信は判別可能なステータスを返します。handled_visible と handled_no_send は終端状態です。unsupported と not_applicable は チャネル所有の配信へフォールバックできます。failed は送信失敗を伝播します。
• 汎用の耐久的な最終配信は、サイレント配信、返信先の保持、ネイティブ引用の保持、 メッセージ送信フックなどのアダプター機能で制御されます。同等性が欠けている場合は、 ユーザーに見える挙動を変える汎用送信ではなく、チャネル所有の配信を選ぶ必要があります。
• キューに支えられた耐久的送信は、配信意図の参照を公開します。既存の pendingFinalDelivery* セッションフィールドは、移行中に意図 ID を保持できます。 最終状態は、凍結された返信テキストと場当たり的なコンテキストフィールドではなく、 MessageSendIntent ストアです。

• 汎用送信アダプターが、古い直接パスと同じレンダリングおよびトランスポート挙動を実行する。
• ローカルの送信後副作用が送信コンテキストを通じて保持される。
• アダプターが、すべてのプラットフォームメッセージ ID を含む受領情報または配信結果を返す。
• 準備済みディスパッチャーパスが新しい送信コンテキストを呼び出すか、耐久保証の対象外として文書化されたままである。
• フォールバック配信が、最初の 1 件だけでなく、投影されたすべてのペイロードを処理する。
• 耐久的なフォールバック配信が、投影されたペイロード配列全体を、再生可能な 1 件の意図またはバッチ計画として記録する。

• iMessage モニター配信は、送信成功後に送信済みメッセージをエコーキャッシュへ記録します。耐久的な最終送信でもそのキャッシュを引き続き埋める必要があります。そうしないと、 OpenClaw が自分自身の最終返信を受信ユーザーメッセージとして再取り込みする可能性があります。
• Tlon は任意のモデル署名を追加し、グループ返信後に参加済みスレッドを記録します。汎用の耐久的配信がこれらの効果を迂回してはいけません。Tlon のレンダリング、送信、最終化アダプターへ移すか、Tlon をチャネル所有パスに残してください。
• Discord と他の準備済みディスパッチャーは、すでに直接配信とプレビュー挙動を所有しています。それらの準備済みディスパッチャーが最終出力を送信コンテキスト経由へ明示的にルーティングするまで、組み立て済みターンの耐久保証の対象にはなりません。
• Telegram のサイレントフォールバック配信は、投影されたペイロード配列全体を配信する必要があります。単一ペイロードの近道は、投影後に追加のフォールバックペイロードを落とす可能性があります。
• LINE、BlueBubbles、Zalo、Nostr、およびその他の既存の組み立て済み/ヘルパーパスには、返信トークン処理、メディアプロキシ、送信済みメッセージキャッシュ、読み込み/ステータスのクリーンアップ、またはコールバック専用ターゲットがある場合があります。これらの意味論が送信アダプターで表現され、テストで検証されるまで、チャネル所有の配信に残します。
• 直接 DM ヘルパーには、唯一の正しいトランスポートターゲットである返信コールバックがある場合があります。汎用アウトバウンドは OriginatingTo や To から推測して、そのコールバックを省略してはいけません。
• OpenClaw Gateway の失敗出力は人間に見える状態を保つ必要がありますが、タグ付けされたボット作成のルームエコーは、allowBots 認可より前に破棄する必要があります。チャネルは、短期の緊急回避策を除き、可視テキストのプレフィックスフィルターでこれを実装してはいけません。耐久契約は構造化された発信元メタデータです。

​

内部ストレージ

type DurableSendIntent = {
  id: string;
  idempotencyKey: string;
  channel: string;
  accountId?: string;
  message: ChannelMessage;
  batch?: RenderedMessageBatch;
  liveState?: LiveMessageState;
  status:
    | "pending"
    | "sending"
    | "committing"
    | "unknown_after_send"
    | "sent"
    | "failed"
    | "cancelled";
  attempt: number;
  nextAttemptAt?: number;
  receipt?: MessageReceipt;
  partialReceipt?: MessageReceipt;
  failure?: DeliveryFailure;
  createdAt: number;
  updatedAt: number;
};

load pending or sending intents
  -> acquire idempotency lock
  -> skip if receipt already committed
  -> reconstruct send context
  -> render if needed
  -> reconcile unknown_after_send if needed
  -> call adapter send/edit/finalize
  -> commit receipt, mark unknown_after_send, or schedule retry

​

失敗クラス

type DeliveryFailureKind =
  | "transient"
  | "rate_limit"
  | "auth"
  | "permission"
  | "not_found"
  | "invalid_payload"
  | "conflict"
  | "cancelled"
  | "unknown";

• transient と rate_limit は再試行する。
• レンダリングフォールバックが存在しない限り、invalid_payload は再試行しない。
• 設定が変更されるまで、auth または permission は再試行しない。
• not_found では、チャネルが安全と宣言している場合、ライブ最終化が編集から新規送信へフォールバックできるようにする。
• conflict では、受領情報/冪等性ルールを使用して、メッセージがすでに存在するかどうかを判断する。
• アダプターがプラットフォーム I/O を完了した可能性がある後、受領情報のコミット前に発生したエラーは、アダプターがプラットフォーム操作が発生しなかったことを証明できない限り、unknown_after_send になります。

​

チャネルマッピング

​

移行計画

​

フェーズ 1: 内部メッセージドメイン

• メッセージ、ターゲット、関係、 発信元、受領、機能、永続意図、受信コンテキスト、送信 コンテキスト、ライブコンテキスト、失敗クラス用の src/channels/message/* 型を追加する。
• 現在の返信配信で使われる移行ブリッジペイロード型に origin?: MessageOrigin を追加し、 その後、リファクターで返信ペイロードを置き換える際に、そのフィールドを ChannelMessage とレンダリング済み メッセージ型へ移動する。
• アダプターとテストで形状が証明されるまで、これは内部のままにする。
• 状態遷移とシリアライズ用の純粋な単体テストを追加する。

​

フェーズ 2: 永続送信コア

• 既存の送信キューを、返信ペイロードの永続性から永続的な メッセージ送信意図へ移動する。
• 永続送信意図には、1 つの返信ペイロードだけでなく、投影済みペイロード配列またはバッチ計画を 持たせる。
• 互換変換を通じて現在のキュー復旧動作を保持する。
• deliverOutboundPayloads が messages.send を呼び出すようにする。
• アダプターがリプレイ安全性を宣言した後、新しいメッセージライフサイクルで 永続意図を書き込めない場合は、最終送信の永続性をデフォルトにし、フェイルクローズする。既存の channel-turn と SDK 互換パスは、このフェーズ中はデフォルトで直接送信のままにする。
• 受領を一貫して記録する。
• 永続送信を終端的な副作用として扱うのではなく、受領と配信結果を元のディスパッチャー呼び出し元へ返す。
• 復旧、リプレイ、チャンク化送信が OpenClaw の運用上の来歴を保持できるように、永続送信意図を通じてメッセージ発信元を永続化する。

​

フェーズ 3: Channel Turn ブリッジ

• messages.receive と messages.send の上に channel.turn.run と dispatchAssembledChannelTurn を再実装する。
• 現在のファクト型を安定したままにする。
• デフォルトではレガシー動作を維持する。assembled-turn チャンネルは、そのアダプターがリプレイ安全な永続性ポリシーで明示的にオプトインした場合にのみ永続化される。
• ネイティブ編集を最終化してまだ安全にリプレイできないパス向けの互換エスケープハッチとして durable: false を残すが、未移行チャンネルを保護するために false マーカーへ依存しない。
• チャンネルマッピングにより、汎用送信パスが古いチャンネル配信セマンティクスを保持することが証明された後、新しいメッセージライフサイクルでのみ assembled-turn の永続性をデフォルトにする。

​

フェーズ 4: 準備済みディスパッチャーブリッジ

• deliverDurableInboundReplyPayload を send-context bridge に置き換える。
• 古いヘルパーはラッパーとして残す。
• Telegram、WhatsApp、Slack、Signal、iMessage、Discord を最初に移植する。これらは すでに durable-final 作業があるか、送信パスがより単純なため。
• 準備済み dispatcher は、send context へ明示的に opt-in するまで未対応として扱う。 ドキュメントと changelog エントリでは、すべての自動 final reply を主張するのではなく、 「組み立て済み channel turn」と言うか、移行済み channel パスを名指しする必要がある。
• recordInboundSessionAndDispatchReply、直接 DM ヘルパー、および同様の public 互換ヘルパーは、挙動を維持する。後で明示的な send-context opt-in を公開してもよいが、 caller-owned delivery callback より前に generic durable delivery を自動的に試みてはならない。

​

フェーズ 5: 統合 Live Lifecycle

• 2 つの proof adapter で messages.live を構築する。
  • Telegram は送信、編集、stale final send 用。
  • Matrix は draft finalization と redaction fallback 用。
• その後、Discord、Slack、Mattermost、Teams、QQ Bot、Feishu を移行する。
• 各 channel に parity test ができるまでは、重複した preview finalization コードを削除しない。

​

フェーズ 6: Public SDK

• openclaw/plugin-sdk/channel-message を追加する。
• それを推奨 channel Plugin API として文書化する。
• package export、entrypoint inventory、生成 API baseline、Plugin SDK ドキュメントを更新する。
• MessageOrigin、origin encode/decode hook、共有 shouldDropOpenClawEcho predicate を channel-message SDK surface に含める。
• 古い subpath 用の互換ラッパーを残す。
• バンドル Plugin の移行後、reply 名の SDK ヘルパーをドキュメントで deprecated として示す。

​

フェーズ 7: すべての Sender

• cron と heartbeat 通知
• task 完了
• hook 結果
• approval prompt と approval result
• message tool send
• subagent 完了アナウンス
• 明示的な CLI または Control UI 送信
• automation/broadcast パス

​

フェーズ 8: Turn を deprecated にする

• channel.turn は少なくとも 1 つの互換期間の間、ラッパーとして残す。
• migration note を公開する。
• 古い import に対して Plugin SDK 互換テストを実行する。
• バンドル Plugin が不要になり、third-party contract に安定した代替ができた後にのみ、 古い internal ヘルパーを削除または非表示にする。

​

テスト計画

• Durable send intent のシリアライズと復旧。
• idempotency key の再利用と duplicate suppression。
• receipt commit と replay skip。
• adapter が reconciliation をサポートする場合に、replay 前に reconcile する unknown_after_send recovery。
• failure classification policy。
• receive ack policy sequencing。
• reply、followup、system、broadcast send の relation mapping。
• Gateway-failure origin factory と shouldDropOpenClawEcho predicate。
• payload normalization、chunking、durable queue serialization、recovery を通した origin preservation。

• channel.turn.run の単純な adapter が、引き続き記録して送信する。
• legacy assembled-turn delivery は、channel が明示的に opt-in しない限り durable にならない。
• channel.turn.runPrepared bridge が、引き続き記録して finalize する。
• Public 互換ヘルパーはデフォルトで caller-owned delivery callback を呼び出し、 それらの callback より前に generic-send しない。
• Durable fallback delivery は再起動後に投影済み payload 配列全体を replay し、 早期 crash 後に後続 payload が未記録のまま残らない。
• Durable assembled-turn delivery は platform message id を buffered dispatcher に返す。
• custom delivery hook は、durable delivery が無効または利用不可の場合でも platform message id を返す。
• assistant completion と platform send の間の再起動後も final reply が残る。
• 許可されている場合、preview draft はその場で finalize される。
• media/error/reply-target mismatch により通常 delivery が必要な場合、 preview draft はキャンセルまたは redacted される。
• block streaming と preview streaming が同じ text を両方 delivery しない。
• 早期に streaming された media が final delivery で重複しない。

• Telegram topic reply は、polling ack を receive context の safe completed watermark まで遅延する。
• accepted-but-not-delivered update の Telegram polling recovery は、 永続化された safe-completed offset model でカバーされる。
• Telegram stale preview は新しい final を送信し、preview を clean up する。
• Telegram silent fallback はすべての投影済み fallback payload を送信する。
• Telegram silent fallback durability は、loop iteration ごとに単一 payload の durable intent を 1 つ作るのではなく、 投影済み fallback 配列全体を atomically に記録する。
• Discord preview は media/error/explicit reply で cancel する。
• Discord prepared dispatcher final は、ドキュメントまたは changelog が Discord final-reply durability を主張する前に、 send context 経由で route される。
• iMessage durable final send は monitor sent-message echo cache を populate する。
• LINE、BlueBubbles、Zalo、Nostr の legacy delivery path は、 adapter parity test が存在するまで generic durable send によって bypass されない。
• Direct-DM/Nostr callback delivery は、完全な message target と replay-safe send adapter に明示的に移行されない限り、 authoritative のままにする。
• Slack の tag 付き OpenClaw Gateway failure message は outbound で visible のままになり、 tag 付き bot-room echo は allowBots より前に drop され、 同じ visible text を持つ tag なし bot message は通常の bot authorization に従う。
• Slack native stream fallback to draft preview in top-level DM。
• Matrix preview finalization と redaction fallback。
• configured bot account からの Matrix tag 付き OpenClaw gateway-failure room echo は、 allowBots handling より前に drop される。
• Discord と Google Chat の shared-room gateway-failure cascade audit は、 そこで generic protection を主張する前に allowBots mode をカバーする。
• Mattermost draft finalization と fresh-send fallback。
• Teams native progress finalization。
• Feishu duplicate final suppression。
• QQ Bot accumulator timeout fallback。
• Tlon durable final send は model-signature rendering と participated thread tracking を維持する。
• WhatsApp、Signal、iMessage、Google Chat、LINE、IRC、Nostr、Nextcloud Talk、 Synology Chat、Tlon、Twitch、Zalo、Zalo Personal の単純な durable final send。

• 開発中の targeted Vitest file。
• 変更 surface 全体に対する Testbox での pnpm check:changed。
• 完全な refactor を landing する前、または public SDK/export 変更後の Testbox でのより広範な pnpm check。
• 互換ラッパーを削除する前に、少なくとも 1 つの編集可能 channel と 1 つの単純な send-only channel で live または qa-channel smoke。

​

未解決事項

• Telegram が最終的に grammY runner source を、OpenClaw の永続化された restart watermark だけでなく platform-level redelivery を制御できる完全な durable polling source に置き換えるべきか。
• durable live preview state を final send intent と同じ queue record に保存するべきか、 sibling live-state store に保存するべきか。
• plugin-sdk/channel-message の出荷後、互換ラッパーをどのくらいの期間ドキュメントに残すか。
• third-party Plugin は receive adapter を直接実装するべきか、それとも defineChannelMessageAdapter を通じて normalize/send/live hook のみを提供するべきか。
• public SDK に公開して安全な receipt field と internal runtime state の境界。
• self-echo cache や participated-thread marker などの side effect を、 send-context hook、adapter-owned finalize step、receipt subscriber のどれとして model 化するべきか。
• どの channel が native origin metadata を持ち、どれが persisted outbound registry を必要とし、 どれが reliable cross-bot echo suppression を提供できないか。

​

受け入れ基準

• すべてのバンドル message channel が final visible output を messages.send 経由で送信する。
• すべての inbound message channel が messages.receive または文書化された互換ラッパー経由で入る。
• すべての preview/edit/stream channel が draft state と finalization に messages.live を使う。
• channel.turn はラッパーだけになる。
• reply 名の SDK ヘルパーは互換 export であり、推奨パスではない。
• Durable recovery は、再起動後に pending final send を replay でき、 final response を失ったり、すでに committed の send を重複させたりしない。 platform outcome が不明な send は replay 前に reconcile されるか、 その adapter では at-least-once として文書化される。
• Durable final send は、caller が文書化された non-durable mode を明示的に選択していない限り、 durable intent を書き込めない場合に fail closed する。
• Legacy channel-turn と SDK 互換ヘルパーは、デフォルトで direct channel-owned delivery を使う。 generic durable send は明示的な opt-in のみ。
• receipt は multi-part delivery のすべての platform message id と、 threading/edit convenience 用の primary id を維持する。
• Durable ラッパーは、direct delivery callback を置き換える前に channel-local side effect を維持する。
• Prepared dispatcher は、final delivery path が明示的に send context を使うまで durable として数えない。
• Fallback delivery はすべての投影済み payload を扱う。
• Durable fallback delivery は、すべての投影済み payload を 1 つの replayable intent または batch plan に記録する。
• OpenClaw 起点の Gateway failure output は人間に visible だが、 origin contract のサポートを宣言する channel では、tag 付き bot-authored room echo は bot authorization より前に drop される。
• ドキュメントは send、receive、live、state、receipt、relation、failure policy、 migration、test coverage を説明する。

​

関連

• Messages
• Streaming and chunking
• Progress drafts
• Retry policy
• Channel turn kernel