Mesaj yaşam döngüsü refaktörü

• Temel ilkeller reply değil, receive ve send olmalıdır.
• Yanıt, yalnızca giden ileti üzerindeki bir ilişkidir.
• Turn, gelen ileti işleme kolaylığıdır; teslimatın sahibi değildir.
• Gönderme bağlam tabanlı olmalıdır: begin, render, önizleme veya akış, son gönderim, commit, fail.
• Alma da bağlam tabanlı olmalıdır: normalleştir, tekilleştir, yönlendir, kaydet, gönder, platform onayı, fail.
• Herkese açık Plugin SDK, tek ve küçük bir kanal-giden yüzeyine indirgenmelidir.

​

Sorunlar

• Basit gelen bağdaştırıcıları runtime.channel.inbound.run kullanır.
• Zengin bağdaştırıcılar runtime.channel.inbound.runPreparedReply kullanır.
• Eski yardımcılar dispatchInboundReplyWithBase, recordInboundSessionAndDispatchReply, yanıt yükü yardımcıları, yanıt parçalama, yanıt referansları ve giden runtime yardımcıları kullanır.
• Önizleme akışı kanala özgü göndericilerde yaşar.
• Son teslimat dayanıklılığı, mevcut yanıt yükü yollarının etrafına 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 core 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ı son 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 gelen yanıt uyumluluğu çağırıcıları için uyumluluk.
• Yeni kanal yetenekleri için net genişletme noktaları.
• Core içinde platforma özgü dallar yok.
• Token-delta kanal iletileri yok. Kanal akışı ileti önizlemesi, düzenleme, ekleme veya tamamlanmış blok teslimatı olarak kalır.
• Operasyonel/sistem çıktısı için yapılandırılmış OpenClaw-kökenli metadata; böylece görünür Gateway hataları paylaşılan bot etkin odalara yeni prompt’lar olarak yeniden girmez.

​

Hedef olmayanlar

• İlk aşamada her mevcut kanalı dayanıklı ileti teslimatına zorlamayın.
• Her kanalı aynı yerel taşıma davranışına zorlamayın.
• Core’a Telegram konuları, Slack yerel akışları, Matrix redaction’ları, Feishu kartları, QQ ses veya Teams etkinliklerini öğretmeyin.
• Tüm iç geçiş yardımcılarını kararlı SDK API olarak yayımlamayın.
• Yeniden denemelerin tamamlanmış idempotent olmayan platform işlemlerini yeniden oynatmasını sağlamayın.

​

Referans model

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

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

​

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

​

Köken

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

• Taşıma onayı: Platform webhook’una veya soketine OpenClaw’un olay zarfını kabul ettiğini söyler. Bazı platformlar bunu gönderimden önce gerektirir.
• Polling offset onayı: Aynı olayın yeniden getirilmemesi için bir imleci ilerletir. Bu, kurtarılamayacak işin ötesine geçmemelidir.
• Gelen kayıt onayı: OpenClaw’un bir yeniden teslimatı tekilleştirmek ve yönlendirmek için yeterli gelen metadata’yı kalıcılaştırdığını doğrular.
• Kullanıcıya görünür alındı: İsteğ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önderme 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 önizlemeyi düzenleme; bayat önizleme yaşından sonra yeni nihai mesaj.
• Discord gönderimi ve önizlemeyi düzenleme; medya/hata/açık yanıt durumunda iptal.
• İleti dizisi şekline bağlı olarak Slack yerel akışı veya taslak önizlemesi.
• Mattermost taslak gönderi sonlandırması.
• Matrix taslak olay sonlandırması veya uyuşmazlıkta redaksiyon.
• Teams yerel ilerleme akışı.
• QQ Bot akışı veya birikimli fallback.

​

Bağdaştırıcı yüzeyi

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

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 azaltımı

• 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
• ad hoc taslak akış yaşam döngüsü yardımcıları

​

Kanal gelen ile ilişki

channel.inbound.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.inbound.run ve dispatchChannelInboundReply, o kanal açıkça denetlenmiş bir dayanıklı ilke/seçenek nesnesi sağlamadıkça kanalın teslimat callback’ini kullanır.
• channel.inbound.runPreparedReply, hazırlanmış dağıtıcı gönderme bağlamını açıkça çağırana kadar kanalın 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 dayanıklı teslimat enjekte etmez.

• Dayanıklı nihai teslim, ayrıştırılmış bir durum döndürür. handled_visible ve handled_no_send terminaldir; unsupported ve not_applicable kanalın sahip olduğu teslime geri dönebilir; failed gönderim hatasını iletir.
• Genel dayanıklı nihai teslim, sessiz teslim, yanıt hedefini koruma, yerel alıntıyı koruma ve ileti gönderme kancaları gibi bağdaştırıcı yetenekleriyle sınırlandırılır. Eşdeğerlik eksikse, kullanıcıya görünür davranışı değiştiren genel bir gönderim değil, kanalın sahip olduğu teslim seçilmelidir.
• Kuyruk destekli dayanıklı gönderimler bir teslim amacı başvurusu sunar. Mevcut pendingFinalDelivery* oturum alanları geçiş sırasında amaç kimliğini taşıyabilir; son durum, dondurulmuş yanıt metni ve geçici bağlam alanları yerine bir MessageSendIntent deposudur.

• Genel gönderim bağdaştırıcısı, 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.
• Bağdaştırıcı, tüm platform ileti kimlikleriyle birlikte alındı bilgileri veya teslim sonuçları döndürür.
• Hazırlanmış dağıtıcı yolları ya yeni gönderim bağlamını çağırır ya da dayanıklılık garantisinin dışında olarak belgelenmiş kalır.
• Geri dönüş teslimi, yalnızca ilkini değil yansıtılan her yükü işler.
• Dayanıklı geri dönüş teslimi, yansıtılan yük dizisinin tamamını tek bir yeniden oynatılabilir amaç veya toplu plan olarak kaydeder.

• iMessage izleyici teslimi, başarılı bir gönderimden sonra gönderilen iletileri bir yankı önbelleğine kaydeder. Dayanıklı nihai gönderimler bu önbelleği yine de doldurmalıdır; aksi halde OpenClaw kendi nihai yanıtlarını gelen kullanıcı iletileri olarak yeniden içe alabilir.
• Tlon, isteğe bağlı bir model imzası ekler ve grup yanıtlarından sonra katılım sağlanan ileti dizilerini kaydeder. Genel dayanıklı teslim bu etkileri atlamamalıdır; bunları Tlon işleme/gönderim/sonlandırma bağdaştırıcılarına taşıyın ya da Tlon’u kanalın sahip olduğu yolda tutun.
• Discord ve diğer hazırlanmış dağıtıcılar zaten doğrudan teslim ve önizleme davranışına sahiptir. Hazırlanmış dağıtıcıları nihai iletileri açıkça gönderim bağlamı üzerinden yönlendirmedikçe, birleştirilmiş tur dayanıklılık garantisi kapsamında değildirler.
• Telegram sessiz geri dönüş teslimi, yansıtılan yük dizisinin tamamını teslim etmelidir. Tek yük kısayolu, yansıtmadan sonra ek geri dönüş yüklerini düşürebilir.
• LINE, Zalo, Nostr ve diğer mevcut birleştirilmiş/yardımcı yolların yanıt belirteci işleme, medya vekilleme, gönderilen ileti önbellekleri, yükleme/durum temizliği veya yalnızca geri çağrı hedefleri olabilir. Bu anlamlar gönderim bağdaştırıcısı tarafından temsil edilip testlerle doğrulanana kadar kanalın sahip olduğu teslimde kalırlar.
• Doğrudan DM yardımcılarında, tek doğru taşıma hedefi olan bir yanıt geri çağrısı bulunabilir. Genel giden yol, OriginatingTo veya To üzerinden tahminde bulunup bu geri çağrıyı atlamamalıdır.
• OpenClaw Gateway hata çıktısı insanlar tarafından 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 bir acil durdurma önlemi dışında görünür metin önek filtreleriyle uygulamamalıdır; dayanıklılık sözleşmesi 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önmesine izin verin.
• conflict için iletinin zaten var olup olmadığına karar vermek üzere alındı bilgisi/idempotency kurallarını kullanın.
• Bağdaştırıcının platform G/Ç’sini tamamlamış olabileceği ancak alındı bilgisi kaydından önce oluşan herhangi bir hata, bağdaştırıcı platform işleminin gerçekleşmediğini kanıtlayamadığı sürece unknown_after_send olur.

​

Kanal eşlemesi

​

Geçiş planı

​

Aşama 1: Dahili Mesaj Alanı

• Mesajlar, hedefler, ilişkiler, kaynaklar, makbuzlar, kabiliyetler, dayanıklı niyetler, alım bağlamı, gönderim bağlamı, canlı bağlam ve hata sınıfları için src/channels/message/* türleri ekleyin.
• Geçerli yanıt teslimi tarafından kullanılan geçiş köprüsü yük türüne origin?: MessageOrigin ekleyin, ardından refaktör yanıt yüklerini değiştirdikçe bu alanı ChannelMessage ve işlenmiş mesaj türlerine taşıyın.
• Bağdaştırıcılar 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 giden kuyruğunu yanıt yükü dayanıklılığından dayanıklı mesaj gönderme niyetlerine taşıyın.
• Dayanıklı gönderim niyetinin yalnızca tek bir yanıt yükü değil, projeksiyonu yapılmış bir yük dizisi veya toplu plan taşımasına izin verin.
• Uyumluluk dönüştürmesiyle geçerli kuyruk kurtarma davranışını koruyun.
• deliverOutboundPayloads işlevinin messages.send çağırmasını sağlayın.
• Bağdaştırıcı 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 gelen çalıştırıcı ve SDK uyumluluk yolları bu aşamada varsayılan olarak doğrudan gönderimde kalır.
• Makbuzları tutarlı şekilde kaydedin.
• Dayanıklı gönderimi terminal bir yan etki gibi ele almak yerine makbuzları ve teslim sonuçlarını özgün dağıtıcı çağıranına döndürün.
• Kurtarma, yeniden oynatma ve parçalı gönderimler OpenClaw operasyonel kökenini korusun diye mesaj kaynağını dayanıklı gönderim niyetleri üzerinden kalıcı hale getirin.

​

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

• channel.inbound.run ve dispatchChannelInboundReply işlevlerini messages.receive ve messages.send üzerine yeniden uygulayın.
• Geçerli olgu türlerini kararlı tutun.
• Varsayılan olarak eski davranışı koruyun. Birleştirilmiş dönüş kanalı yalnızca bağdaştırıcısı 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 sonlandıran ve henüz güvenli şekilde yeniden oynatamayan yollar için uyumluluk kaçış yolu olarak durable: false değerini koruyun, ancak geçirilmemiş kanalları korumak için false işaretlerine güvenmeyin.
• Birleştirilmiş dönüş dayanıklılığını yalnızca yeni mesaj yaşam döngüsünde, kanal eşlemesi genel gönderim yolunun eski kanal teslim semantiğini 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önderme bağlamı köprüsü kullanın.
• Eski yardımcıyı bir sarmalayıcı olarak tutun.
• Önce Telegram, WhatsApp, Slack, Signal, iMessage ve Discord’u taşıyın çünkü bunlarda zaten durable-final çalışması veya daha basit gönderme yolları var.
• Her hazırlanmış dispatcher’ı, gönderme bağlamına açıkça dahil olana kadar kapsam dışı kabul edin. Dokümantasyon ve changelog girdileri, tüm otomatik final yanıtlarını iddia etmek yerine “birleştirilmiş kanal turları” demeli veya taşınan kanal yollarını adlandırmalıdır.
• recordInboundSessionAndDispatchReply, doğrudan DM yardımcıları ve benzer herkese açık uyumluluk yardımcılarını davranışı koruyacak şekilde tutun. Bunlar daha sonra açık bir gönderme bağlamı katılımı sunabilir, ancak çağıranın sahip olduğu teslim callback’inden önce otomatik olarak genel durable teslimat denememelidir.

​

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

• messages.live öğesini iki kanıt adapter’ı ile oluşturun:
  • Gönderme, düzenleme ve eski final gönderimi için Telegram.
  • Taslak finalizasyonu ve redaction fallback için Matrix.
• Sonra 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: Herkese Açık SDK

• openclaw/plugin-sdk/channel-outbound ekleyin.
• Bunu tercih edilen kanal Plugin API’si olarak belgeleyin.
• Paket export’larını, entrypoint envanterini, üretilen API baseline’larını ve Plugin SDK dokümanlarını güncelleyin.
• Kanal-outbound SDK yüzeyine MessageOrigin, origin encode/decode hook’ları ve paylaşılan shouldDropOpenClawEcho predicate’ini dahil edin.
• Eski alt yollar için uyumluluk sarmalayıcılarını tutun.
• Paketlenmiş Plugin’ler taşındıktan sonra yanıta göre adlandırılmış SDK yardımcılarını dokümanlarda 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ı
• mesaj aracı gönderimleri
• alt ajan tamamlama duyuruları
• açık CLI veya Control UI gönderimleri
• otomasyon/broadcast yolları

​

Aşama 8: Tur Adlı Uyumluluğu Kaldırma

• Uyumluluk penceresi olarak inbound/message adlı sarmalayıcıları tutun.
• Migration notlarını yayımlayın.
• Eski import’lara karşı Plugin SDK uyumluluk testlerini çalıştırın.
• Eski dahili yardımcıları yalnızca hiçbir paketlenmiş Plugin onlara ihtiyaç duymadığında ve üçüncü taraf sözleşmelerinin kararlı bir alternatifi olduğunda kaldırın veya gizleyin.

​

Test planı

• Durable gönderme intent serileştirmesi ve kurtarma.
• Idempotency key yeniden kullanımı ve yinelenenlerin bastırılması.
• Receipt commit ve replay atlama.
• Bir adapter uzlaştırmayı desteklediğinde replay öncesi uzlaştıran unknown_after_send kurtarması.
• Hata sınıflandırma politikası.
• Alma ack politikası sıralaması.
• Yanıt, followup, sistem ve broadcast gönderimleri için ilişki eşlemesi.
• Gateway hatası origin factory’si ve shouldDropOpenClawEcho predicate’i.
• Payload normalizasyonu, chunking, durable kuyruk serileştirmesi ve kurtarma boyunca origin korunması.

• channel.inbound.run basit adapter’ı hâlâ kaydeder ve gönderir.
• Eski birleştirilmiş olay teslimatı, kanal açıkça dahil olmadıkça durable hale gelmez.
• channel.inbound.runPreparedReply köprüsü hâlâ kaydeder ve finalleştirir.
• Herkese açık uyumluluk yardımcıları varsayılan olarak çağırana ait teslim callback’lerini çağırır ve bu callback’lerden önce genel gönderim yapmaz.
• Durable fallback teslimatı, yeniden başlatmadan sonra tüm projekte edilmiş payload dizisini replay eder ve erken bir crash sonrasında sonraki payload’ları kaydedilmemiş bırakamaz.
• Durable birleştirilmiş olay teslimatı, platform mesaj kimliklerini buffered dispatcher’a döndürür.
• Özel teslim hook’ları, durable teslimat devre dışı veya kullanılamaz olduğunda hâlâ platform mesaj kimliklerini döndürür.
• Final yanıt, assistant tamamlaması ile platform gönderimi arasındaki yeniden başlatmadan sağ çıkar.
• Önizleme taslağı, izin verildiğinde yerinde finalleştirilir.
• Medya/hata/yanıt hedefi uyumsuzluğu normal teslimat gerektirdiğinde önizleme taslağı iptal edilir veya redaction uygulanır.
• Blok streaming ve önizleme streaming aynı metni ikisi birden teslim etmez.
• Erken stream edilen medya final teslimatta yinelenmez.

• Telegram konu yanıtında polling ack, 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 önizleme taze final gönderir ve önizlemeyi temizler.
• Telegram sessiz fallback her projekte edilmiş fallback payload’unu gönderir.
• Telegram sessiz fallback dayanıklılığı, döngü iterasyonu başına tek payload’lu durable intent değil, tüm projekte edilmiş fallback dizisini atomik olarak kaydeder.
• Medya/hata/açık yanıt durumunda Discord önizleme iptali.
• Discord final-yanıt dayanıklılığı dokümanlarda veya changelog’da iddia edilmeden önce Discord hazırlanmış dispatcher final’ları gönderme bağlamı üzerinden yönlendirilir.
• iMessage durable final gönderimleri monitor sent-message echo cache’ini doldurur.
• LINE, Zalo ve Nostr eski teslimat yolları, adapter eşdeğerlik testleri var olana kadar genel durable gönderim tarafından bypass edilmez.
• Doğrudan DM/Nostr callback teslimatı, eksiksiz bir mesaj hedefine ve replay güvenli gönderme adapter’ına açıkça taşınmadıkça yetkili kalır.
• Slack etiketli OpenClaw gateway hata mesajları outbound olarak görünür kalır, etiketli bot-room echo’ları allowBots öncesinde düşer ve aynı görünür metne sahip etiketsiz bot mesajları yine normal bot yetkilendirmesini izler.
• Üst düzey DM’lerde Slack native stream fallback’i taslak önizlemeye geçer.
• Matrix önizleme finalizasyonu ve redaction fallback.
• Yapılandırılmış bot hesaplarından gelen Matrix etiketli OpenClaw gateway-failure oda echo’ları allowBots işlemeden önce düşer.
• Discord ve Google Chat paylaşımlı oda gateway-failure cascade denetimleri, orada genel koruma iddia edilmeden önce allowBots modlarını kapsar.
• Mattermost taslak finalizasyonu ve taze gönderim fallback’i.
• Teams native ilerleme finalizasyonu.
• Feishu yinelenen final bastırma.
• QQ Bot accumulator timeout fallback.
• Tlon durable final gönderimleri model-signature rendering’i ve katılım sağlanan thread takibini korur.
• WhatsApp, Signal, iMessage, Google Chat, LINE, IRC, Nostr, Nextcloud Talk, Synology Chat, Tlon, Twitch, Zalo ve Zalo Personal basit durable final gönderimleri.

• Geliştirme sırasında hedefli Vitest dosyaları.
• Tüm değişen yüzey için Testbox içinde pnpm check:changed.
• Tam refactor’ı land etmeden önce veya herkese açık SDK/export değişikliklerinden sonra Testbox içinde daha geniş pnpm check.
• Uyumluluk sarmalayıcılarını 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üzeyi yeniden teslimatı kontrol edebilen tamamen durable bir polling kaynağıyla değiştirip değiştirmemesi.
• Durable canlı önizleme durumunun final gönderme intent’iyle aynı kuyruk kaydında mı yoksa kardeş bir live-state store’da mı saklanması gerektiği.
• plugin-sdk/channel-outbound yayımlandıktan sonra uyumluluk sarmalayıcılarının dokümanlarda ne kadar süre kalacağı.
• Üçüncü taraf Plugin’lerin receive adapter’larını doğrudan mı uygulaması gerektiği yoksa yalnızca defineChannelMessageAdapter üzerinden normalize/send/live hook’ları mı sağlaması gerektiği.
• Hangi receipt alanlarının herkese açık SDK’da gösterilmesinin güvenli olduğu ve hangilerinin dahili runtime durumu olarak kalacağı.
• Self-echo cache’leri ve participated-thread marker’ları gibi yan etkilerin gönderme bağlamı hook’ları, adapter’a ait finalize adımları veya receipt subscriber’ları olarak mı modellenmesi gerektiği.
• Hangi kanalların native origin metadata’sına sahip olduğu, hangilerinin kalıcı outbound registry’lerine ihtiyaç duyduğu ve hangilerinin güvenilir cross-bot echo bastırma sunamayacağı.

​

Kabul kriterleri

• Her paketlenmiş mesaj kanalı final görünür çıktıyı messages.send üzerinden gönderir.
• Her inbound mesaj kanalı messages.receive veya belgelenmiş bir uyumluluk sarmalayıcısı üzerinden girer.
• Her önizleme/düzenleme/stream kanalı taslak durumu ve finalizasyon için messages.live kullanır.
• channel.inbound yalnızca bir sarmalayıcıdır.
• Yanıta göre adlandırılmış SDK yardımcıları önerilen yol değil, uyumluluk export’larıdır.
• Durable kurtarma, yeniden başlatmadan sonra bekleyen final gönderimleri final yanıtı kaybetmeden veya zaten commit edilmiş gönderimleri çoğaltmadan replay edebilir; platform sonucu bilinmeyen gönderimler replay öncesi uzlaştırılır veya ilgili adapter için en az bir kez olarak belgelenir.
• Durable final gönderimleri, çağıran açıkça belgelenmiş non-durable modu seçmediği sürece durable intent yazılamadığında kapalı hata verir.
• Eski SDK uyumluluk yardımcıları varsayılan olarak doğrudan kanalın sahip olduğu teslimatı kullanır; genel durable gönderim yalnızca açık katılımdır.
• Receipt’ler, çok parçalı teslimatlar için tüm platform mesaj kimliklerini ve threading/düzenleme kolaylığı için birincil kimliği korur.
• Durable sarmalayıcılar, doğrudan teslim callback’lerini değiştirmeden önce kanal yerel yan etkilerini korur.
• Hazırlanmış dispatcher’lar, final teslimat yolları açıkça gönderme bağlamını kullanana kadar durable sayılmaz.
• Fallback teslimatı her projekte edilmiş payload’u işler.
• Durable fallback teslimatı her projekte edilmiş payload’u tek bir replay edilebilir intent veya batch plan içinde kaydeder.
• OpenClaw kaynaklı gateway hata çıktısı insanlar tarafından görünürdür, ancak etiketli bot-authored oda echo’ları origin sözleşmesi desteği beyan eden kanallarda bot yetkilendirmesinden önce düşürülür.
• Dokümanlar send, receive, live, state, receipt’ler, ilişkiler, hata politikası, migration ve test kapsamını açıklar.

​

İlgili

• Mesajlar
• Streaming ve chunking
• İlerleme taslakları
• Retry politikası
• Kanal inbound API’si