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

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.
• عدم نشر كل مساعدات الترحيل الداخلية كواجهة SDK مستقرة.
• عدم جعل إعادة المحاولة تعيد تشغيل عمليات منصة غير قابلة لعدم التكرار بعد اكتمالها.

​

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

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

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

​

نموذج اللب

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 وZalo وNostr وغيرها من المسارات المجمّعة/المساعدة الحالية معالجة لرمز الرد، أو تمرير وسائط عبر وكيل، أو ذاكرات مؤقتة للرسائل المرسلة، أو تنظيف للتحميل/الحالة، أو أهداف مخصصة للاستدعاء الخلفي فقط. تبقى هذه على التسليم المملوك للقناة حتى تمثل دلالاتها في محوّل الإرسال وتتحقق منها الاختبارات.
• قد تملك مساعدات الرسائل المباشرة ردًا عبر استدعاء خلفي يكون هدف النقل الصحيح الوحيد. يجب ألا يخمّن الإرسال العام الصادر من 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، استخدم قواعد الإيصال/الإديمبوتنسية لتحديد ما إذا كانت الرسالة موجودة بالفعل.
• أي خطأ بعد أن يكون المحوّل ربما أكمل إدخال/إخراج المنصة لكن قبل تثبيت الإيصال يصبح unknown_after_send ما لم يتمكن المحوّل من إثبات أن عملية المنصة لم تحدث.

​

ربط القنوات

​

خطة الترحيل

​

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

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

​

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

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

​

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

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

​

المرحلة 4: جسر المرسل المُحضّر

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

​

المرحلة 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 الخاص برسائل القناة.
• أبقِ أغلفة التوافق للمسارات الفرعية القديمة.
• علّم مساعدات SDK المسماة بالرد كمهملة في الوثائق بعد نقل Plugin المضمّنة.

​

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

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

​

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

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

​

خطة الاختبار

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

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

• رد موضوع Telegram مع إقرار polling مؤجل حتى علامة الاكتمال الآمنة لسياق الاستلام.
• استعادة polling في Telegram للتحديثات المقبولة لكن غير المسلّمة مغطاة بنموذج الإزاحة الآمنة المكتملة المحفوظ.
• معاينة Telegram القديمة ترسل نهائياً جديداً وتنظف المعاينة.
• احتياط Telegram الصامت يرسل كل حمولة احتياط متوقعة.
• متانة احتياط Telegram الصامت تسجل مصفوفة الاحتياط المتوقعة بالكامل ذرياً، لا نية دائمة مفردة الحمولة واحدة لكل دورة تكرار.
• إلغاء معاينة Discord عند الوسائط/الخطأ/الرد الصريح.
• نهائيات موزّع Discord المحضّر تمر عبر سياق الإرسال قبل أن تدعي الوثائق أو سجل التغييرات متانة الرد النهائي في Discord.
• إرسالات iMessage النهائية الدائمة تملأ ذاكرة صدى الرسائل المرسلة للمراقب.
• لا تتجاوز مسارات التسليم القديمة في LINE وZalo وNostr بواسطة الإرسال الدائم العام حتى توجد اختبارات تكافؤ محوّلاتها.
• يظل تسليم استدعاء Direct-DM/Nostr مرجعياً ما لم يُنقل صراحةً إلى هدف رسالة كامل ومحوّل إرسال آمن للإعادة.
• رسائل فشل Gateway الموسومة من OpenClaw في Slack تظل مرئية صادرة، وأصداء غرفة الروبوت الموسومة تسقط قبل allowBots، ورسائل الروبوت غير الموسومة ذات النص المرئي نفسه لا تزال تتبع تفويض الروبوت العادي.
• احتياط البث الأصلي في Slack إلى معاينة مسودة في الرسائل المباشرة ذات المستوى الأعلى.
• إنهاء معاينة Matrix واحتياط التنقيح.
• أصداء غرف فشل Gateway الموسومة من OpenClaw في Matrix، من حسابات الروبوت المهيأة، تسقط قبل معالجة 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 بمصدر polling دائم بالكامل يمكنه التحكم في إعادة التسليم على مستوى المنصة، لا مجرد علامة إعادة التشغيل المحفوظة في OpenClaw.
• ما إذا كان ينبغي تخزين حالة المعاينة المباشرة الدائمة في سجل الطابور نفسه مثل نية الإرسال النهائي أو في مخزن حالة مباشرة شقيق.
• مدة بقاء أغلفة التوافق موثقة بعد شحن plugin-sdk/channel-message.
• ما إذا كان ينبغي لـ Plugin الجهات الخارجية تنفيذ محوّلات الاستلام مباشرة أو توفير خطافات التطبيع/الإرسال/المباشر فقط عبر defineChannelMessageAdapter.
• أي حقول الإيصال آمنة للكشف في SDK العام مقابل حالة وقت التشغيل الداخلية.
• ما إذا كان ينبغي نمذجة الآثار الجانبية مثل ذاكرات صدى الذات وعلامات الخيوط المشارك فيها كخطافات سياق إرسال، أو خطوات إنهاء مملوكة للمحوّل، أو مشتركي إيصالات.
• أي القنوات لديها بيانات وصفية أصلية للأصل، وأيها يحتاج إلى سجلات خروج محفوظة، وأيها لا يمكنه تقديم قمع صدى موثوق عبر الروبوتات.

​

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

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

​

ذو صلة

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