إعادة هيكلة دورة حياة الرسائل

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.

• يجب أن تكون البدائيات الأساسية هي الاستلام والإرسال، لا الرد.
• الرد ليس إلا علاقة في رسالة صادرة.
• الدور هو وسيلة ملائمة لمعالجة الوارد، وليس مالك التسليم.
• يجب أن يستند الإرسال إلى السياق: begin، التصيير، المعاينة أو البث، الإرسال النهائي، التثبيت، الفشل.
• يجب أن يستند الاستلام إلى السياق أيضًا: التطبيع، إزالة التكرار، التوجيه، التسجيل، الإرسال، إقرار المنصة، الفشل.
• يجب أن ينحصر SDK العام لـ Plugin في سطح صغير واحد لرسائل القنوات.

​

المشكلات

• تستخدم محولات الوارد البسيطة 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

​

الأهداف

• دورة حياة أساسية واحدة لكل مسارات استلام وإرسال رسائل القنوات.
• إرسالات نهائية دائمة افتراضيًا في دورة حياة الرسائل الجديدة بعد أن يعلن المحول عن سلوك آمن لإعادة التشغيل.
• دلالات مشتركة للمعاينة، والتعديل، والبث، والإنهاء، وإعادة المحاولة، والاسترداد، والإيصال.
• سطح SDK صغير لـ Plugin يمكن لـ Plugins التابعة لجهات خارجية تعلمه وصيانته.
• توافق مع مستدعي channel.turn الحاليين أثناء الترحيل.
• نقاط توسيع واضحة لقدرات القنوات الجديدة.
• لا توجد تفريعات خاصة بمنصة في الجوهر.
• لا توجد رسائل قناة بفروق الرموز. يبقى بث القنوات تسليمًا عبر معاينة الرسائل، أو تعديلها، أو إلحاقها، أو كتلة مكتملة.
• بيانات وصفية منظمة ذات منشأ من OpenClaw للمخرجات التشغيلية/النظامية حتى لا تعود إخفاقات Gateway المرئية إلى الغرف المشتركة المفعلة للبوتات كمطالبات جديدة.

​

غير الأهداف

• عدم إزالة runtime.channel.turn.* في المرحلة الأولى.
• عدم إجبار كل قناة على السلوك الأصلي نفسه للنقل.
• عدم تعليم الجوهر مواضيع Telegram، أو بثوث Slack الأصلية، أو حذوفات Matrix، أو بطاقات Feishu، أو صوت QQ، أو أنشطة Teams.
• عدم نشر كل مساعدات الترحيل الداخلية كواجهة API مستقرة في SDK.
• عدم جعل إعادات المحاولة تعيد تشغيل عمليات منصة مكتملة وغير عديمة التكرار.

​

النموذج المرجعي

• Chat
• Thread
• Channel
• Message
• أساليب محول مثل postMessage وeditMessage وdeleteMessage، وstream وstartTyping، وجلب السجل
• محول حالة لإزالة التكرار، والأقفال، والطوابير، والاستمرارية

• نوايا إرسال صادرة دائمة قبل استدعاءات النقل المباشر.
• سياقات إرسال صريحة تتضمن البدء، والتثبيت، والفشل.
• سياقات استلام تعرف سياسة إقرار المنصة.
• إيصالات تبقى بعد إعادة التشغيل ويمكنها دفع التعديلات، والحذف، والاسترداد، وكبح التكرارات.
• SDK عام أصغر. يمكن لـ Plugins المضمنة استخدام مساعدات وقت التشغيل الداخلية، لكن يجب أن ترى Plugins التابعة لجهات خارجية واجهة API متماسكة واحدة للرسائل.
• سلوك خاص بالوكيل: الجلسات، والنصوص، وبث الكتل، وتقدم الأدوات، والموافقات، وتوجيهات الوسائط، والردود الصامتة، وسجل إشارات المجموعات.

​

نموذج الجوهر

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

• إقرار النقل: يخبر Webhook المنصة أو المقبس أن OpenClaw قبل غلاف الحدث. تتطلب بعض المنصات هذا قبل الإرسال.
• إقرار إزاحة الاستطلاع: يقدّم مؤشرًا حتى لا يجري جلب الحدث نفسه مرة أخرى. يجب ألا يتجاوز هذا عملًا لا يمكن استرداده.
• إقرار سجل الوارد: يؤكد أن 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 مع تحرير المعاينة، والإلغاء عند وجود وسائط أو خطأ أو رد صريح.
• تدفق 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 استدعاء التسليم الخاص بالقناة ما لم توفر تلك القناة صراحة كائن سياسة/خيارات متانة مدققًا.
• يبقى channel.turn.runPrepared مملوكًا للقناة حتى يستدعي الموزع المحضّر سياق الإرسال صراحة.
• لا تحقن مساعدات التوافق العامة مثل recordInboundSessionAndDispatchReply و dispatchInboundReplyWithBase ومساعدات الرسائل المباشرة العامة تسليمًا عامًا متينًا قبل استدعاء deliver أو reply الذي يقدمه المستدعي.

• يُرجع التسليم النهائي المتين حالةً مميَّزة. تكون handled_visible و handled_no_send نهائيتين؛ وقد تعود unsupported و not_applicable إلى التسليم المملوك للقناة؛ وتنقل failed فشل الإرسال.
• يُحرس التسليم النهائي المتين العام بقدرات المحوِّل مثل التسليم الصامت، والحفاظ على هدف الرد، والحفاظ على الاقتباس الأصلي، و خطافات إرسال الرسائل. عند غياب التكافؤ، ينبغي اختيار التسليم المملوك للقناة، لا إرسال عام يغيّر السلوك المرئي للمستخدم.
• تكشف عمليات الإرسال المتينة المدعومة بالطابور مرجع نية تسليم. يمكن لحقول الجلسة pendingFinalDelivery* الحالية حمل معرّف النية أثناء الانتقال؛ وتكون الحالة النهائية مخزن MessageSendIntent بدلاً من نص رد مجمّد مع حقول سياق مخصصة.

• ينفّذ محوِّل الإرسال العام سلوك العرض والنقل نفسه الذي كان ينفّذه المسار المباشر القديم.
• تُحفظ الآثار الجانبية المحلية بعد الإرسال من خلال سياق الإرسال.
• يُرجع المحوِّل إيصالات أو نتائج تسليم تحتوي على كل معرّفات رسائل المنصة.
• إما أن تستدعي مسارات المرسِل المحضَّرة سياق الإرسال الجديد، أو تبقى موثّقة على أنها خارج ضمان المتانة.
• يتعامل تسليم الرجوع الاحتياطي مع كل حمولة متوقعة، لا الأولى فقط.
• يسجّل تسليم الرجوع الاحتياطي المتين مصفوفة الحمولات المتوقعة كلها كنية واحدة قابلة لإعادة التشغيل أو خطة دفعة.

• يسجّل تسليم مراقب iMessage الرسائل المرسلة في ذاكرة صدى مؤقتة بعد إرسال ناجح. يجب أن تظل عمليات الإرسال النهائي المتينة تملأ تلك الذاكرة المؤقتة، وإلا يمكن أن يعيد OpenClaw ابتلاع ردوده النهائية الخاصة كرسائل مستخدم واردة.
• يضيف Tlon توقيع نموذج اختياريًا ويسجّل الخيوط التي شارك فيها بعد ردود المجموعات. يجب ألا يتجاوز التسليم المتين العام تلك الآثار؛ إما انقلها إلى محوِّلات العرض/الإرسال/الإنهاء في Tlon أو أبقِ Tlon على المسار المملوك للقناة.
• يمتلك Discord والمرسِلون المحضَّرون الآخرون بالفعل سلوك التسليم المباشر والمعاينة. ولا يغطيهم ضمان المتانة للدورة المجمَّعة حتى توجّه مرسِلاتهم المحضَّرة الردود النهائية صراحةً عبر سياق الإرسال.
• يجب أن يسلّم تسليم الرجوع الاحتياطي الصامت في Telegram مصفوفة الحمولات المتوقعة كاملة. قد يؤدي اختصار الحمولة الواحدة إلى إسقاط حمولات رجوع احتياطي إضافية بعد الإسقاط.
• قد تحتوي LINE و BlueBubbles و Zalo و Nostr وغيرها من المسارات المجمَّعة/المساعدة الحالية على تعامل مع رموز الرد، أو تمرير وسائط عبر وكيل، أو ذاكرات مؤقتة للرسائل المرسلة، أو تنظيف تحميل/حالة، أو أهداف لا تعمل إلا باستدعاء راجع. تبقى هذه على التسليم المملوك للقناة حتى تُمثَّل تلك الدلالات بواسطة محوِّل الإرسال وتتحقق منها الاختبارات.
• قد تحتوي مساعدات الرسائل المباشرة على استدعاء راجع للرد يكون هو هدف النقل الصحيح الوحيد. يجب ألا يخمّن الصادر العام من OriginatingTo أو To ويتجاوز ذلك الاستدعاء الراجع.
• يجب أن يبقى خرج فشل Gateway في OpenClaw مرئيًا للبشر، لكن يجب إسقاط أصداء الغرف الموسومة والمؤلفة بواسطة بوت قبل تخويل 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، استخدم قواعد الإيصال/عدم التكرار لتقرير ما إذا كانت الرسالة موجودة بالفعل.
• أي خطأ يحدث بعد أن يكون المحوِّل قد أتم إدخال/إخراج المنصة لكن قبل تثبيت الإيصال يصبح unknown_after_send ما لم يستطع المحوِّل إثبات أن عملية المنصة لم تحدث.

​

ربط القنوات

​

خطة الهجرة

​

المرحلة 1: نطاق الرسائل الداخلي

• أضف أنواع src/channels/message/* للرسائل، والأهداف، والعلاقات، والمصادر، والإيصالات، والقدرات، والنوايا المستدامة، وسياق التلقي، وسياق الإرسال، والسياق الحي، وفئات الإخفاق.
• أضف origin?: MessageOrigin إلى نوع حمولة جسر الهجرة المستخدم بواسطة تسليم الرد الحالي، ثم انقل ذلك الحقل إلى ChannelMessage وأنواع الرسائل المعروضة عندما تستبدل إعادة الهيكلة حمولات الرد.
• أبقِ هذا داخليًا إلى أن تثبت المحوّلات والاختبارات الشكل.
• أضف اختبارات وحدة صافية لانتقالات الحالة والتسلسل.

​

المرحلة 2: نواة الإرسال المستدام

• انقل قائمة الانتظار الصادرة الحالية من استدامة حمولة الرد إلى نوايا إرسال الرسائل المستدامة.
• اسمح لنوايا الإرسال المستدامة بحمل مصفوفة حمولات مسقطة أو خطة دفعات، وليس حمولة رد واحدة فقط.
• حافظ على سلوك استرداد قائمة الانتظار الحالي عبر تحويل التوافق.
• اجعل deliverOutboundPayloads يستدعي messages.send.
• اجعل استدامة الإرسال النهائي هي الافتراضي وأغلق بالفشل عندما لا يمكن كتابة النية المستدامة في دورة حياة الرسالة الجديدة، بعد أن يعلن المحوّل أمان إعادة التشغيل. تظل مسارات توافق channel-turn و SDK الحالية إرسالًا مباشرًا افتراضيًا خلال هذه المرحلة.
• سجّل الإيصالات باتساق.
• أرجع الإيصالات ونتائج التسليم إلى مستدعي الموزّع الأصلي بدلًا من التعامل مع الإرسال المستدام كتأثير جانبي نهائي.
• ثبّت مصدر الرسالة عبر نوايا الإرسال المستدامة بحيث يحافظ الاسترداد، وإعادة التشغيل، والإرسالات المجزأة على منشأ OpenClaw التشغيلي.

​

المرحلة 3: جسر دورة القناة

• أعد تنفيذ channel.turn.run و dispatchAssembledChannelTurn فوق messages.receive و messages.send.
• أبقِ أنواع الحقائق الحالية مستقرة.
• أبقِ السلوك القديم افتراضيًا. لا تصبح قناة الدورة المجمّعة مستدامة إلا عندما يختار محوّلها ذلك صراحةً بسياسة استدامة آمنة لإعادة التشغيل.
• أبقِ durable: false كمخرج توافق للمسارات التي تنهي تحريرات أصلية ولا تستطيع إعادة التشغيل بأمان بعد، لكن لا تعتمد على علامات false لحماية القنوات غير المهاجرة.
• اجعل استدامة الدورة المجمّعة افتراضية فقط في دورة حياة الرسالة الجديدة، بعد أن يثبت ربط القناة أن مسار الإرسال العام يحافظ على دلالات تسليم القناة القديمة.

​

المرحلة 4: جسر الموزّع المحضّر

• استبدل deliverDurableInboundReplyPayload بجسر سياق إرسال.
• أبقِ المساعد القديم كغلاف.
• انقل Telegram وWhatsApp وSlack وSignal وiMessage وDiscord أولًا لأن لديها بالفعل عمل نهائي دائم أو مسارات إرسال أبسط.
• عامل كل موزّع مُحضّر على أنه غير مغطى إلى أن يشترك صراحةً في سياق الإرسال. يجب أن تقول الوثائق وإدخالات سجل التغييرات “منعطفات القناة المجمّعة” أو تسمّي مسارات القنوات المرحّلة بدلًا من الادعاء بكل الردود النهائية التلقائية.
• حافظ على سلوك recordInboundSessionAndDispatchReply ومساعدات الرسائل المباشرة ومساعدات التوافق العامة المشابهة كما هو. قد تكشف لاحقًا عن اشتراك صريح في سياق الإرسال، لكنها يجب ألا تحاول تلقائيًا إجراء تسليم دائم عام قبل استدعاء التسليم الذي يملكه المستدعي.

​

المرحلة 5: دورة حياة مباشرة موحّدة

• ابنِ messages.live بمحوّلين لإثبات المفهوم:
  • Telegram للإرسال مع التحرير مع إرسال نهائي جديد عند التقادم.
  • Matrix لإنهاء المسودة مع احتياطي الحجب.
• ثم رحّل Discord وSlack وMattermost وTeams وQQ Bot وFeishu.
• احذف كود إنهاء المعاينة المكرر فقط بعد أن تصبح لكل قناة اختبارات تكافؤ.

​

المرحلة 6: SDK العام

• أضف openclaw/plugin-sdk/channel-message.
• وثّقه باعتباره API Plugin القنوات المفضّل.
• حدّث صادرات الحزمة، ومخزون نقاط الدخول، وخطوط أساس API المولّدة، ووثائق SDK الخاص بالـPlugin.
• ضمّن MessageOrigin وخطافات ترميز/فك ترميز الأصل، والدالة الشرطية المشتركة shouldDropOpenClawEcho ضمن سطح SDK الخاص بـchannel-message.
• أبقِ أغلفة التوافق للمسارات الفرعية القديمة.
• علّم مساعدات SDK التي تحمل أسماء الردود على أنها مهملة في الوثائق بعد ترحيل Plugins المضمنة.

​

المرحلة 7: كل المرسلين

• إشعارات Cron وHeartbeat
• إكمالات المهام
• نتائج الخطافات
• مطالبات الموافقة ونتائج الموافقة
• عمليات إرسال أداة الرسائل
• إعلانات إكمال الوكيل الفرعي
• عمليات الإرسال الصريحة من CLI أو Control UI
• مسارات الأتمتة/البث

​

المرحلة 8: إهمال Turn

• أبقِ channel.turn كغلاف لنافذة توافق واحدة على الأقل.
• انشر ملاحظات الترحيل.
• شغّل اختبارات توافق SDK الخاص بالـPlugin على الاستيرادات القديمة.
• أزل أو أخفِ المساعدات الداخلية القديمة فقط بعد ألا يعود أي Plugin مضمن بحاجة إليها وبعد أن تمتلك عقود الأطراف الثالثة بديلًا مستقرًا.

​

خطة الاختبار

• تسلسل نية الإرسال الدائم واستردادها.
• إعادة استخدام مفتاح عدم التكرار ومنع التكرارات.
• تثبيت الإيصال وتجاوز إعادة التشغيل.
• استرداد unknown_after_send الذي يوفّق قبل إعادة التشغيل عندما يدعم المحوّل التوفيق.
• سياسة تصنيف الفشل.
• تسلسل سياسة إقرار الاستلام.
• ربط العلاقات لإرسالات الرد والمتابعة والنظام والبث.
• مصنع أصل فشل Gateway والدالة الشرطية shouldDropOpenClawEcho.
• حفظ الأصل عبر تطبيع الحمولة، والتقسيم إلى أجزاء، وتسلسل الطابور الدائم، والاسترداد.

• لا يزال محوّل channel.turn.run البسيط يسجل ويرسل.
• لا يتحول تسليم المنعطف المجمّع القديم إلى دائم إلا إذا اشتركت القناة صراحةً.
• لا يزال جسر channel.turn.runPrepared يسجل وينهي.
• تستدعي مساعدات التوافق العامة استدعاءات التسليم التي يملكها المستدعي افتراضيًا ولا ترسل إرسالًا عامًا قبل تلك الاستدعاءات.
• يعيد تسليم الاحتياطي الدائم تشغيل كامل مصفوفة الحمولات المسقطة بعد إعادة التشغيل، ولا يمكنه ترك الحمولات اللاحقة غير مسجلة بعد تعطل مبكر.
• يعيد تسليم المنعطف المجمّع الدائم معرّفات رسائل المنصة إلى الموزّع المخزّن مؤقتًا.
• لا تزال خطافات التسليم المخصصة تعيد معرّفات رسائل المنصة عندما يكون التسليم الدائم معطلًا أو غير متاح.
• ينجو الرد النهائي من إعادة التشغيل بين إكمال المساعد وإرسال المنصة.
• تُنهى مسودة المعاينة في مكانها عندما يكون ذلك مسموحًا.
• تُلغى مسودة المعاينة أو تُحجب عندما يتطلب عدم تطابق الوسائط/الخطأ/هدف الرد تسليمًا عاديًا.
• لا يسلّم كل من بث الكتل وبث المعاينة النص نفسه.
• لا تُكرّر الوسائط التي بُثت مبكرًا في التسليم النهائي.

• رد موضوع Telegram مع تأخير إقرار الاستطلاع حتى العلامة المائية المكتملة الآمنة لسياق الاستلام.
• استرداد استطلاع Telegram للتحديثات المقبولة ولكن غير المسلّمة مغطى بواسطة نموذج إزاحة الآمن المكتمل المستمر.
• ترسل معاينة Telegram المتقادمة نهائيًا جديدًا وتنظف المعاينة.
• يرسل احتياطي Telegram الصامت كل حمولة احتياطية مسقطة.
• تسجل ديمومة احتياطي Telegram مصفوفة الاحتياطي المسقطة الكاملة ذريًا، وليس نية دائمة ذات حمولة واحدة لكل تكرار حلقة.
• إلغاء معاينة Discord عند الوسائط/الخطأ/الرد الصريح.
• تمر نهائيات موزّع Discord المحضّر عبر سياق الإرسال قبل أن تدعي الوثائق أو سجل التغييرات ديمومة الرد النهائي في Discord.
• تملأ الإرسالات النهائية الدائمة في iMessage ذاكرة صدى الرسائل المرسلة الخاصة بالمراقب.
• لا تُتجاوز مسارات التسليم القديمة في LINE وBlueBubbles وZalo وNostr بواسطة إرسال دائم عام حتى توجد اختبارات تكافؤ لمحوّلاتها.
• يظل تسليم استدعاء Direct-DM/Nostr هو المرجع ما لم يُرحّل صراحةً إلى هدف رسالة كامل ومحوّل إرسال آمن لإعادة التشغيل.
• تبقى رسائل فشل Gateway الخاصة بـOpenClaw الموسومة في Slack ظاهرة للخارج، وتسقط أصداء غرفة البوت الموسومة قبل allowBots، ولا تزال رسائل البوت غير الموسومة التي تحمل النص المرئي نفسه تتبع تفويض البوت العادي.
• احتياطي البث الأصلي في Slack إلى معاينة مسودة في الرسائل المباشرة ذات المستوى الأعلى.
• إنهاء معاينة Matrix واحتياطي الحجب.
• تسقط أصداء غرف Matrix الموسومة لفشل Gateway الخاص بـOpenClaw من حسابات البوت المكوّنة قبل معالجة allowBots.
• تغطي تدقيقات سلسلة فشل Gateway للغرف المشتركة في Discord وGoogle Chat أوضاع allowBots قبل الادعاء بالحماية العامة هناك.
• إنهاء مسودة Mattermost واحتياطي الإرسال الجديد.
• إنهاء التقدم الأصلي في Teams.
• منع تكرار النهائي في Feishu.
• احتياطي مهلة مجمّع QQ Bot.
• تحفظ الإرسالات النهائية الدائمة في Tlon عرض توقيع النموذج وتتبع الخيط المشارك فيه.
• إرسالات نهائية دائمة بسيطة في WhatsApp وSignal وiMessage وGoogle Chat وLINE وIRC وNostr وNextcloud Talk وSynology Chat وTlon وTwitch وZalo وZalo Personal.

• ملفات Vitest مستهدفة أثناء التطوير.
• pnpm check:changed في Testbox لكامل السطح المتغيّر.
• pnpm check أوسع في Testbox قبل إنزال إعادة الهيكلة الكاملة أو بعد تغييرات SDK/الصادرات العامة.
• اختبار دخان مباشر أو qa-channel لقناة واحدة على الأقل قادرة على التحرير وقناة واحدة بسيطة للإرسال فقط قبل إزالة أغلفة التوافق.

​

الأسئلة المفتوحة

• هل ينبغي لـTelegram في النهاية أن يستبدل مصدر مشغّل grammY بمصدر استطلاع دائم بالكامل يستطيع التحكم في إعادة التسليم على مستوى المنصة، وليس فقط علامة إعادة التشغيل المستمرة في OpenClaw.
• هل ينبغي تخزين حالة المعاينة المباشرة الدائمة في سجل الطابور نفسه مثل نية الإرسال النهائي أم في مخزن حالة مباشرة شقيق.
• إلى متى تبقى أغلفة التوافق موثقة بعد شحن plugin-sdk/channel-message.
• هل ينبغي لـPlugins الأطراف الثالثة تنفيذ محوّلات الاستلام مباشرة أم الاكتفاء بتقديم خطافات التطبيع/الإرسال/البث عبر defineChannelMessageAdapter.
• أي حقول الإيصال آمنة للكشف عنها في SDK العام مقابل حالة وقت التشغيل الداخلية.
• هل ينبغي نمذجة الآثار الجانبية مثل ذاكرات صدى الذات ومؤشرات الخيوط المشاركة كخطافات سياق إرسال، أو خطوات إنهاء يملكها المحوّل، أو مشتركين في الإيصالات.
• أي القنوات لديها بيانات وصفية أصلية للأصل، وأيها تحتاج إلى سجلات خروج مستمرة، وأيها لا يمكنها تقديم منع صدى موثوق عبر البوتات.

​

معايير القبول

• ترسل كل قناة رسائل مضمنة الخرج النهائي المرئي عبر messages.send.
• تدخل كل قناة رسائل واردة عبر messages.receive أو غلاف توافق موثق.
• تستخدم كل قناة معاينة/تحرير/بث messages.live لحالة المسودة والإنهاء.
• channel.turn ليس إلا غلافًا.
• مساعدات SDK المسماة بالردود هي صادرات توافق، وليست المسار الموصى به.
• يستطيع الاسترداد الدائم إعادة تشغيل الإرسالات النهائية المعلقة بعد إعادة التشغيل دون فقدان الرد النهائي أو تكرار الإرسالات المثبتة بالفعل؛ وتُوفّق الإرسالات التي تكون نتيجتها على المنصة مجهولة قبل إعادة التشغيل أو تُوثّق على أنها مرة واحدة على الأقل لذلك المحوّل.
• تفشل الإرسالات النهائية الدائمة بشكل مغلق عندما لا يمكن كتابة النية الدائمة، إلا إذا اختار المستدعي صراحةً وضعًا غير دائم موثقًا.
• تعود مساعدات توافق channel-turn وSDK القديمة افتراضيًا إلى التسليم المباشر الذي تملكه القناة؛ الإرسال الدائم العام اشتراك صريح فقط.
• تحفظ الإيصالات كل معرّفات رسائل المنصة للتسليمات متعددة الأجزاء ومعرّفًا أساسيًا لسهولة الخيط/التحرير.
• تحفظ الأغلفة الدائمة الآثار الجانبية المحلية للقناة قبل استبدال استدعاءات التسليم المباشر.
• لا تُحتسب الموزّعات المحضّرة كدائمة حتى يستخدم مسار تسليمها النهائي سياق الإرسال صراحةً.
• يعالج تسليم الاحتياطي كل حمولة مسقطة.
• يسجل تسليم الاحتياطي الدائم كل حمولة مسقطة في نية واحدة قابلة لإعادة التشغيل أو خطة دفعات.
• يكون خرج فشل Gateway الصادر من OpenClaw مرئيًا للبشر، لكن أصداء الغرف الموسومة والمؤلفة بواسطة البوتات تسقط قبل تفويض البوت على القنوات التي تعلن دعم عقد الأصل.
• تشرح الوثائق الإرسال، والاستلام، والمباشر، والحالة، والإيصالات، والعلاقات، وسياسة الفشل، والترحيل، وتغطية الاختبارات.

​

ذو صلة

• الرسائل
• البث والتقسيم إلى أجزاء
• مسودات التقدم
• سياسة إعادة المحاولة
• نواة منعطف القناة