Mesaj yaşam döngüsü yeniden düzenlemesi

Documentation Index

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

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

• Temel ilkel öğeler reply değil, receive ve send olmalıdır.
• Yanıt, yalnızca giden bir ileti üzerindeki ilişkidir.
• Turn, gelen işleme için bir kolaylıktır; teslimatın sahibi değildir.
• Gönderme bağlam tabanlı olmalıdır: begin, render, preview veya stream, final send, commit, fail.
• Alma da bağlam tabanlı olmalıdır: normalize, dedupe, route, record, dispatch, platform ack, fail.
• Herkese açık Plugin SDK tek, küçük bir kanal-ileti yüzeyine indirgenmelidir.

​

Sorunlar

• Basit gelen bağdaştırıcılar runtime.channel.turn.run kullanır.
• Zengin bağdaştırıcılar runtime.channel.turn.runPrepared kullanır.
• Eski yardımcılar dispatchInboundReplyWithBase, recordInboundSessionAndDispatchReply, yanıt yükü yardımcıları, yanıt parçalama, yanıt referansları ve giden çalışma zamanı yardımcılarını kullanır.
• Önizleme akışı kanala özgü dispatcher’larda yaşar.
• Nihai teslimat dayanıklılığı mevcut yanıt yükü yolları etrafında ekleniyor.

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

​

Hedefler

• Tüm kanal iletisi alma ve gönderme yolları için tek bir çekirdek yaşam döngüsü.
• Bir bağdaştırıcı yeniden oynatma açısından güvenli davranış bildirdikten sonra yeni ileti yaşam döngüsünde varsayılan olarak dayanıklı nihai gönderimler.
• Paylaşılan önizleme, düzenleme, akış, sonlandırma, yeniden deneme, kurtarma ve alındı semantikleri.
• Üçüncü taraf Plugin’lerin öğrenip sürdürebileceği küçük bir Plugin SDK yüzeyi.
• Geçiş sırasında mevcut channel.turn çağıranları için uyumluluk.
• Yeni kanal yetenekleri için net genişletme noktaları.
• Çekirdekte platforma özgü dallar yok.
• Token-delta kanal iletileri yok. Kanal akışı ileti önizlemesi, düzenleme, ekleme veya tamamlanmış blok teslimatı olarak kalır.
• Görünür Gateway hatalarının paylaşılan bot etkin odalara yeni prompt’lar olarak yeniden girmemesi için operasyonel/sistem çıktısına yönelik yapılandırılmış OpenClaw kaynak metadatası.

​

Hedef dışı kalanlar

• İlk aşamada runtime.channel.turn.* kaldırılmayacak.
• Her kanal aynı yerel aktarım davranışına zorlanmayacak.
• Çekirdeğe Telegram konuları, Slack yerel akışları, Matrix redaction’ları, Feishu kartları, QQ sesleri veya Teams etkinlikleri öğretilmeyecek.
• Tüm dahili geçiş yardımcıları kararlı SDK API olarak yayımlanmayacak.
• Yeniden denemeler tamamlanmış idempotent olmayan platform işlemlerini yeniden oynatmayacak.

​

Referans model

• Chat
• Thread
• Channel
• Message
• postMessage, editMessage, deleteMessage, stream, startTyping ve geçmiş getirmeleri gibi bağdaştırıcı yöntemleri
• dedupe, kilitler, kuyruklar ve kalıcılık için bir durum bağdaştırıcısı

• Doğrudan aktarım çağrılarından önce dayanıklı giden gönderim niyetleri.
• Begin, commit ve fail içeren açık gönderim bağlamları.
• Platform ack politikasını bilen alma bağlamları.
• Yeniden başlatmadan sağ çıkan ve düzenleme, silme, kurtarma ve kopya bastırmayı yönlendirebilen alındılar.
• Daha küçük bir herkese açık SDK. Birlikte gelen Plugin’ler dahili çalışma zamanı yardımcılarını kullanabilir, ancak üçüncü taraf Plugin’ler tek, tutarlı bir ileti API’si görmelidir.
• Ajana özgü davranış: oturumlar, transcript’ler, blok akışı, araç ilerlemesi, onaylar, medya yönergeleri, sessiz yanıtlar ve grup mention geçmişi.

​

Çekirdek model

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

​

İleti terimleri

​

İleti

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;
};

​

Hedef

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

​

İlişki

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";
    };

​

Origin

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";
    };

​

Alındı

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;
};

​

Alma bağlamı

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

• Aktarım ack’i: platform webhook’una veya socket’ine OpenClaw’ın olay zarfını kabul ettiğini söyler. Bazı platformlar bunu dispatch’ten önce gerektirir.
• Polling offset ack’i: aynı olayın tekrar getirilmemesi için bir imleci ilerletir. Bu, kurtarılamayacak işin ötesine ilerlememelidir.
• Gelen kayıt ack’i: OpenClaw’ın bir yeniden teslimatı dedupe etmek ve yönlendirmek için yeterli gelen metadatasını kalıcılaştırdığını doğrular.
• Kullanıcıya görünür alındı: isteğe bağlı okundu/durum/yazıyor davranışı; asla dayanıklılık sınırı değildir.

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" };

​

Gönderim bağlamı

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;
};

​

Canlı bağlam

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 gönderimi ve düzenleme önizlemesi, bayat önizleme yaşından sonra taze nihai iletiyle.
• Discord gönderimi ve düzenleme önizlemesi, medya/hata/açık yanıt durumunda iptal.
• İş parçacığı şekline bağlı olarak Slack yerel stream’i veya taslak önizlemesi.
• Mattermost taslak gönderi sonlandırması.
• Matrix taslak olay sonlandırması veya uyumsuzlukta redaksiyon.
• Teams yerel ilerleme stream’i.
• QQ Bot stream’i veya biriktirilmiş geri dönüş.

​

Adaptör yüzeyi

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;
  };
};

​

Genel SDK sadeleştirmesi

• reply-runtime
• reply-dispatch-runtime
• reply-reference
• reply-chunking
• reply-payload
• inbound-reply-dispatch
• channel-reply-pipeline
• outbound-runtime genel kullanımlarının çoğu
• geçici taslak stream yaşam döngüsü yardımcıları

​

Kanal turu ile ilişki

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

​

Uyumluluk koruma sınırları

• channel.turn.run ve dispatchAssembledChannelTurn, ilgili kanal açıkça denetlenmiş bir kalıcılık ilkesi/seçenekler nesnesi sağlamadığı sürece kanalın teslimat callback’ini kullanır.
• channel.turn.runPrepared, hazırlanmış dağıtıcı gönderim bağlamını açıkça çağırana kadar kanal sahipliğinde kalır.
• recordInboundSessionAndDispatchReply, dispatchInboundReplyWithBase ve doğrudan DM yardımcıları gibi genel uyumluluk yardımcıları, çağıranın sağladığı deliver veya reply callback’inden önce asla genel kalıcı teslimat enjekte etmez.

• Dayanıklı nihai teslimat, ayrıştırılmış bir durum döndürür. handled_visible ve handled_no_send sonlandırıcıdır; unsupported ve not_applicable, kanalın sahip olduğu teslimata geri düşebilir; failed gönderme hatasını iletir.
• Genel dayanıklı nihai teslimat; sessiz teslimat, yanıt hedefini koruma, yerel alıntıyı koruma ve mesaj gönderme kancaları gibi adaptör yetenekleriyle sınırlandırılır. Eksik denklik, kullanıcıya görünen davranışı değiştiren genel bir gönderimi değil, kanalın sahip olduğu teslimatı seçmelidir.
• Kuyruk destekli dayanıklı gönderimler bir teslimat niyeti referansı sunar. Mevcut pendingFinalDelivery* oturum alanları geçiş sırasında niyet kimliğini taşıyabilir; son durum, donmuş yanıt metni artı geçici bağlam alanları yerine bir MessageSendIntent deposudur.

• Genel gönderim adaptörü, eski doğrudan yolla aynı işleme ve taşıma davranışını yürütür.
• Yerel gönderim sonrası yan etkiler gönderim bağlamı üzerinden korunur.
• Adaptör, tüm platform mesaj kimlikleriyle birlikte alındıları veya teslimat sonuçlarını döndürür.
• Hazırlanmış dispatcher yolları ya yeni gönderim bağlamını çağırır ya da dayanıklı garantinin dışında olarak belgelenmiş kalır.
• Geri dönüş teslimatı, yalnızca ilkini değil, öngörülen her yükü işler.
• Dayanıklı geri dönüş teslimatı, öngörülen yük dizisinin tamamını tek bir yeniden oynatılabilir niyet veya toplu plan olarak kaydeder.

• iMessage izleyici teslimatı, başarılı bir gönderimden sonra gönderilen mesajları bir yankı önbelleğine kaydeder. Dayanıklı nihai gönderimler yine de bu önbelleği doldurmalıdır; aksi takdirde OpenClaw kendi nihai yanıtlarını gelen kullanıcı mesajları olarak yeniden alabilir.
• Tlon isteğe bağlı bir model imzası ekler ve grup yanıtlarından sonra katılım sağlanan iş parçacıklarını kaydeder. Genel dayanıklı teslimat bu etkileri atlamamalıdır; bunları ya Tlon işleme/gönderme/sonlandırma adaptörlerine taşıyın ya da Tlon’u kanalın sahip olduğu yolda tutun.
• Discord ve diğer hazırlanmış dispatcher’lar zaten doğrudan teslimata ve önizleme davranışına sahiptir. Hazırlanmış dispatcher’ları nihai yanıtları gönderim bağlamı üzerinden açıkça yönlendirmedikçe, birleştirilmiş dönüş dayanıklı garantisi kapsamında değildirler.
• Telegram sessiz geri dönüş teslimatı, öngörülen yük dizisinin tamamını teslim etmelidir. Tek yük kısayolu, projeksiyondan sonra ek geri dönüş yüklerini düşürebilir.
• LINE, Zalo, Nostr ve diğer mevcut birleştirilmiş/yardımcı yollar; yanıt belirteci işleme, medya proxy’leme, gönderilen mesaj önbellekleri, yükleniyor/durum temizliği veya yalnızca geri çağrı hedeflerine sahip olabilir. Bu semantik gönderim adaptörü tarafından temsil edilip testlerle doğrulanana kadar kanalın sahip olduğu teslimatta kalırlar.
• Doğrudan-DM yardımcıları, tek doğru taşıma hedefi olan bir yanıt geri çağrısına sahip olabilir. Genel giden ileti, OriginatingTo veya To üzerinden tahminde bulunup bu geri çağrıyı atlamamalıdır.
• OpenClaw gateway hata çıktısı insanlar için görünür kalmalıdır, ancak etiketlenmiş bot tarafından yazılmış oda yankıları allowBots yetkilendirmesinden önce düşürülmelidir. Kanallar bunu, kısa süreli acil durdurma dışında görünür metin öneki filtreleriyle uygulamamalıdır; dayanıklı sözleşme yapılandırılmış kaynak meta verisidir.

​

Dahili depolama

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

​

Hata sınıfları

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

• transient ve rate_limit için yeniden deneyin.
• Bir işleme geri dönüşü yoksa invalid_payload için yeniden denemeyin.
• Yapılandırma değişene kadar auth veya permission için yeniden denemeyin.
• not_found için, kanal bunun güvenli olduğunu beyan ettiğinde canlı sonlandırmanın düzenlemeden yeni gönderime geri düşmesine izin verin.
• conflict için, mesajın zaten var olup olmadığına karar vermek üzere alındı/ idempotency kurallarını kullanın.
• Adaptör platform G/Ç’sini tamamlamış olabileceği halde alındı kaydından önce oluşan herhangi bir hata, adaptör platform işleminin gerçekleşmediğini kanıtlayamazsa unknown_after_send olur.

​

Kanal eşlemesi

​

Geçiş planı

​

Aşama 1: Dahili Mesaj Etki Alanı

• Mesajlar, hedefler, ilişkiler, kökenler, alındılar, yetenekler, dayanıklı niyetler, alma bağlamı, gönderim bağlamı, canlı bağlam ve hata sınıfları için src/channels/message/* türleri ekleyin.
• Mevcut yanıt teslimi tarafından kullanılan geçiş köprüsü yük türüne origin?: MessageOrigin ekleyin, ardından yeniden düzenleme yanıt yüklerinin yerini aldıkça bu alanı ChannelMessage ve işlenmiş mesaj türlerine taşıyın.
• Adaptörler ve testler şekli kanıtlayana kadar bunu dahili tutun.
• Durum geçişleri ve serileştirme için saf birim testleri ekleyin.

​

Aşama 2: Dayanıklı Gönderim Çekirdeği

• Mevcut çıkış kuyruğunu yanıt-yükü dayanıklılığından dayanıklı mesaj gönderim niyetlerine taşıyın.
• Dayanıklı gönderim niyetinin yalnızca tek bir yanıt yükü değil, öngörülen bir yük dizisi veya toplu iş planı taşımasına izin verin.
• Uyumluluk dönüştürmesi yoluyla mevcut kuyruk kurtarma davranışını koruyun.
• deliverOutboundPayloads işlevinin messages.send çağırmasını sağlayın.
• Adaptör yeniden oynatma güvenliğini bildirdikten sonra, yeni mesaj yaşam döngüsünde dayanıklı niyet yazılamadığında nihai gönderim dayanıklılığını varsayılan yapın ve kapalı şekilde hata verin. Mevcut kanal turu ve SDK uyumluluk yolları bu aşamada varsayılan olarak doğrudan gönderim olarak kalır.
• Alındıları tutarlı şekilde kaydedin.
• Dayanıklı gönderimi terminal bir yan etki olarak ele almak yerine, alındıları ve teslim sonuçlarını özgün dağıtıcı çağırana döndürün.
• Kurtarma, yeniden oynatma ve parçalı gönderimler OpenClaw operasyonel kökenini korusun diye mesaj kökenini dayanıklı gönderim niyetleri üzerinden kalıcı hale getirin.

​

Aşama 3: Kanal Turu Köprüsü

• channel.turn.run ve dispatchAssembledChannelTurn işlevlerini messages.receive ve messages.send üzerine yeniden uygulayın.
• Mevcut olgu türlerini kararlı tutun.
• Eski davranışı varsayılan olarak koruyun. Birleştirilmiş tur kanalı yalnızca adaptörü yeniden oynatma açısından güvenli bir dayanıklılık ilkesiyle açıkça katıldığında dayanıklı hale gelir.
• Yerel düzenlemeleri nihai hale getiren ve henüz güvenli şekilde yeniden oynatamayan yollar için uyumluluk kaçış noktası olarak durable: false değerini koruyun, ancak taşınmamış kanalları korumak için false işaretlerine güvenmeyin.
• Birleştirilmiş tur dayanıklılığını yalnızca yeni mesaj yaşam döngüsünde, kanal eşlemesi genel gönderim yolunun eski kanal teslim semantiklerini koruduğunu kanıtladıktan sonra varsayılan yapın.

​

Aşama 4: Hazırlanmış Dağıtıcı Köprüsü

• deliverDurableInboundReplyPayload yerine bir gönderim bağlamı köprüsü koyun.
• Eski yardımcıyı bir sarmalayıcı olarak tutun.
• Önce Telegram, WhatsApp, Slack, Signal, iMessage ve Discord’u taşıyın; çünkü bunlarda zaten dayanıklı final çalışması veya daha basit gönderim yolları var.
• Açıkça gönderim bağlamına katılana kadar her hazırlanmış dağıtıcıyı kapsam dışı kabul edin. Dokümantasyon ve changelog girdileri, tüm otomatik final yanıtlarını iddia etmek yerine “assembled channel turns” demeli veya taşınan kanal yollarını adlandırmalıdır.
• recordInboundSessionAndDispatchReply, doğrudan DM yardımcıları ve benzer genel uyumluluk yardımcılarının davranışını koruyun. Daha sonra açık bir gönderim bağlamı katılımı sunabilirler, ancak çağıranın sahip olduğu teslim geri çağrısından önce otomatik olarak genel dayanıklı teslimat denememelidirler.

​

Aşama 5: Birleşik Canlı Yaşam Döngüsü

• messages.live öğesini iki kanıt bağdaştırıcısıyla oluşturun:
  • Gönderim, düzenleme ve eski final gönderimi için Telegram.
  • Taslak finalizasyonu ve düzeltme yedeği için Matrix.
• Ardından Discord, Slack, Mattermost, Teams, QQ Bot ve Feishu’yu taşıyın.
• Yinelenen önizleme finalizasyon kodunu yalnızca her kanalın eşdeğerlik testleri olduktan sonra silin.

​

Aşama 6: Genel SDK

• openclaw/plugin-sdk/channel-message ekleyin.
• Bunu tercih edilen kanal Plugin API’si olarak belgeleyin.
• Paket dışa aktarımlarını, giriş noktası envanterini, üretilen API temellerini ve Plugin SDK dokümantasyonunu güncelleyin.
• Kanal-ileti SDK yüzeyine MessageOrigin, origin kodlama/kod çözme hook’ları ve paylaşılan shouldDropOpenClawEcho predicate’ini dahil edin.
• Eski alt yollar için uyumluluk sarmalayıcılarını tutun.
• Paketli Plugin’ler taşındıktan sonra yanıta göre adlandırılmış SDK yardımcılarını dokümantasyonda kullanımdan kaldırılmış olarak işaretleyin.

​

Aşama 7: Tüm Göndericiler

• Cron ve Heartbeat bildirimleri
• görev tamamlamaları
• hook sonuçları
• onay istemleri ve onay sonuçları
• ileti aracı gönderimleri
• alt ajan tamamlanma duyuruları
• açık CLI veya Control UI gönderimleri
• otomasyon/yayın yolları

​

Aşama 8: Turn’ü Kullanımdan Kaldırma

• channel.turn öğesini en az bir uyumluluk penceresi boyunca sarmalayıcı olarak tutun.
• Geçiş notlarını yayımlayın.
• Eski içe aktarımlara karşı Plugin SDK uyumluluk testlerini çalıştırın.
• Eski dahili yardımcıları yalnızca hiçbir paketli Plugin bunlara ihtiyaç duymadığında ve üçüncü taraf sözleşmelerin kararlı bir ikamesi olduğunda kaldırın veya gizleyin.

​

Test planı

• Dayanıklı gönderim amacı serileştirme ve kurtarma.
• Idempotency anahtarı yeniden kullanımı ve yineleme baskılama.
• Alındı kaydı commit’i ve yeniden oynatma atlama.
• Bir bağdaştırıcı uzlaştırmayı desteklediğinde yeniden oynatmadan önce uzlaştıran unknown_after_send kurtarması.
• Hata sınıflandırma politikası.
• Alma onayı politikası sıralaması.
• Yanıt, takip, sistem ve yayın gönderimleri için ilişki eşlemesi.
• Gateway hatası origin fabrikası ve shouldDropOpenClawEcho predicate’i.
• Yük normalizasyonu, parçalama, dayanıklı kuyruk serileştirmesi ve kurtarma boyunca origin koruması.

• channel.turn.run basit bağdaştırıcısı hâlâ kaydeder ve gönderir.
• Eski assembled-turn teslimatı, kanal açıkça katılmadıkça dayanıklı hale gelmez.
• channel.turn.runPrepared köprüsü hâlâ kaydeder ve finalize eder.
• Genel uyumluluk yardımcıları varsayılan olarak çağıranın sahip olduğu teslim geri çağrılarını çağırır ve bu geri çağrılardan önce genel gönderim yapmaz.
• Dayanıklı yedek teslimat, yeniden başlatmadan sonra tüm projeksiyonu yapılan yük dizisini yeniden oynatır ve erken bir çökmeden sonra sonraki yüklerin kaydedilmeden kalmasına izin veremez.
• Dayanıklı assembled-turn teslimatı, platform ileti kimliklerini tamponlanmış dağıtıcıya döndürür.
• Özel teslim hook’ları, dayanıklı teslimat devre dışı veya kullanılamazken de platform ileti kimliklerini döndürür.
• Final yanıtı, asistan tamamlaması ile platform gönderimi arasındaki yeniden başlatmadan sağ çıkar.
• Önizleme taslağı izin verildiğinde yerinde finalize edilir.
• Medya/hata/yanıt-hedefi uyuşmazlığı normal teslimat gerektirdiğinde önizleme taslağı iptal edilir veya düzeltilir.
• Blok akışı ve önizleme akışı aynı metni ikisi birden teslim etmez.
• Erken akışla gönderilen medya final teslimatta yinelenmez.

• Telegram konu yanıtında polling onayı, alma bağlamının güvenli tamamlanmış watermark’ına kadar geciktirilir.
• Kabul edilmiş ancak teslim edilmemiş güncellemeler için Telegram polling kurtarması, kalıcı güvenli-tamamlanmış offset modeliyle kapsanır.
• Telegram eski önizlemesi yeni final gönderir ve önizlemeyi temizler.
• Telegram sessiz yedeği, projeksiyonu yapılan her yedek yükü gönderir.
• Telegram sessiz yedek dayanıklılığı, tam projeksiyonu yapılan yedek dizisini her döngü yinelemesi için tek bir tek-yük dayanıklı amacı olarak değil, atomik olarak kaydeder.
• Medya/hata/açık yanıt durumunda Discord önizleme iptali.
• Discord hazırlanmış dağıtıcı finalleri, dokümanlar veya changelog Discord final-yanıt dayanıklılığı iddia etmeden önce gönderim bağlamından geçer.
• iMessage dayanıklı final gönderimleri, izleyici gönderilen-ileti yankı önbelleğini doldurur.
• LINE, Zalo ve Nostr eski teslimat yolları, bağdaştırıcı eşdeğerlik testleri var olana kadar genel dayanıklı gönderim tarafından atlanmaz.
• Direct-DM/Nostr geri çağrılı teslimat, açıkça eksiksiz bir ileti hedefine ve yeniden oynatma güvenli gönderim bağdaştırıcısına taşınmadıkça yetkili kalır.
• Slack etiketli OpenClaw Gateway hatası iletileri giden tarafta görünür kalır, etiketli bot-odası yankıları allowBots öncesinde düşer ve aynı görünür metne sahip etiketsiz bot iletileri normal bot yetkilendirmesini izlemeye devam eder.
• Üst düzey DM’lerde Slack yerel akış yedeği taslak önizlemeye düşer.
• Matrix önizleme finalizasyonu ve düzeltme yedeği.
• Yapılandırılmış bot hesaplarından gelen Matrix etiketli OpenClaw Gateway hatası oda yankıları, allowBots işlenmeden önce düşer.
• Discord ve Google Chat paylaşımlı oda Gateway hatası cascade denetimleri, orada genel koruma iddia etmeden önce allowBots modlarını kapsar.
• Mattermost taslak finalizasyonu ve yeni-gönderim yedeği.
• Teams yerel ilerleme finalizasyonu.
• Feishu yinelenen final baskılaması.
• QQ Bot biriktirici zaman aşımı yedeği.
• Tlon dayanıklı final gönderimleri model-imzası görüntülemesini ve katılım sağlanan konu izlemeyi korur.
• WhatsApp, Signal, iMessage, Google Chat, LINE, IRC, Nostr, Nextcloud Talk, Synology Chat, Tlon, Twitch, Zalo ve Zalo Personal basit dayanıklı final gönderimleri.

• Geliştirme sırasında hedeflenmiş Vitest dosyaları.
• Tam değişen yüzey için Testbox içinde pnpm check:changed.
• Tam refactor indirilmeden veya genel SDK/dışa aktarım değişikliklerinden önce Testbox içinde daha geniş pnpm check.
• Uyumluluk sarmalayıcıları kaldırmadan önce en az bir düzenleme yetenekli kanal ve bir basit yalnızca-gönderim kanalı için canlı veya qa-channel smoke.

​

Açık sorular

• Telegram’ın sonunda grammY runner kaynağını, yalnızca OpenClaw’ın kalıcı yeniden başlatma watermark’ını değil, platform düzeyinde yeniden teslimatı kontrol edebilen tamamen dayanıklı bir polling kaynağıyla değiştirip değiştirmemesi gerektiği.
• Dayanıklı canlı önizleme durumunun final gönderim amacıyla aynı kuyruk kaydında mı yoksa kardeş bir canlı-durum deposunda mı saklanması gerektiği.
• plugin-sdk/channel-message yayımlandıktan sonra uyumluluk sarmalayıcılarının ne kadar süre belgeli kalacağı.
• Üçüncü taraf Plugin’lerin alma bağdaştırıcılarını doğrudan mı uygulaması gerektiği, yoksa defineChannelMessageAdapter üzerinden yalnızca normalize/send/live hook’ları mı sağlaması gerektiği.
• Hangi alındı alanlarının genel SDK’da, hangilerinin dahili çalışma zamanı durumunda açığa çıkarılmasının güvenli olduğu.
• Öz-yankı önbellekleri ve katılım sağlanan konu işaretçileri gibi yan etkilerin gönderim bağlamı hook’ları, bağdaştırıcıya ait finalize adımları veya alındı aboneleri olarak modellenip modellenmemesi gerektiği.
• Hangi kanalların yerel origin meta verisine sahip olduğu, hangilerinin kalıcı giden kayıt defterlerine ihtiyaç duyduğu ve hangilerinin güvenilir botlar arası yankı baskılama sunamayacağı.

​

Kabul kriterleri

• Her paketli ileti kanalı, final görünür çıktıyı messages.send üzerinden gönderir.
• Her gelen ileti kanalı messages.receive veya belgeli bir uyumluluk sarmalayıcısı üzerinden girer.
• Her önizleme/düzenleme/akış kanalı, taslak durumu ve finalizasyon için messages.live kullanır.
• channel.turn yalnızca bir sarmalayıcıdır.
• Yanıta göre adlandırılmış SDK yardımcıları, önerilen yol değil, uyumluluk dışa aktarımlarıdır.
• Dayanıklı kurtarma, yeniden başlatmadan sonra bekleyen final gönderimleri final yanıtı kaybetmeden veya zaten commit edilmiş gönderimleri yinelemeden yeniden oynatabilir; platform sonucu bilinmeyen gönderimler yeniden oynatmadan önce uzlaştırılır veya o bağdaştırıcı için at-least-once olarak belgelenir.
• Dayanıklı final gönderimleri, dayanıklı amaç yazılamadığında kapalı hata verir; yalnızca çağıran açıkça belgeli bir dayanıklı olmayan mod seçtiyse bu geçerli değildir.
• Eski channel-turn ve SDK uyumluluk yardımcıları varsayılan olarak doğrudan kanalın sahip olduğu teslimatı kullanır; genel dayanıklı gönderim yalnızca açık katılımdır.
• Alındılar, çok parçalı teslimatlar için tüm platform ileti kimliklerini ve konu/düzenleme kolaylığı için birincil kimliği korur.
• Dayanıklı sarmalayıcılar, doğrudan teslim geri çağrılarını değiştirmeden önce kanal-yerel yan etkileri korur.
• Hazırlanmış dağıtıcılar, final teslimat yolları açıkça gönderim bağlamını kullanana kadar dayanıklı sayılmaz.
• Yedek teslimat, projeksiyonu yapılan her yükü işler.
• Dayanıklı yedek teslimat, projeksiyonu yapılan her yükü tek bir yeniden oynatılabilir amaç veya toplu plan içinde kaydeder.
• OpenClaw kaynaklı Gateway hatası çıktısı insanlar tarafından görünürdür, ancak etiketli bot yazarlı oda yankıları, origin sözleşmesi desteğini bildiren kanallarda bot yetkilendirmesinden önce düşürülür.
• Dokümanlar gönderim, alma, canlı, durum, alındılar, ilişkiler, hata politikası, geçiş ve test kapsamını açıklar.

​

İlgili

• İletiler
• Akış ve parçalama
• İlerleme taslakları
• Yeniden deneme politikası
• Kanal turn çekirdeği