Struct InboundMessageMeta 

#[non_exhaustive]
pub struct InboundMessageMeta {
    pub kind: InboundKind,
    pub sender_id: Option<String>,
    pub msg_id: Option<String>,
    pub inbound_ts: Option<DateTime<Utc>>,
    pub reply_to_msg_id: Option<String>,
    pub has_media: bool,
    pub origin_session_id: Option<Uuid>,
}

Binding context propagated to tool calls so extensions and MCP servers can route per-(channel, account_id, agent_id) tuple without re-deriving it from each tool call’s payload.

Serialised under _meta.nexo.binding in JSON-RPC tools/call (extensions ignore unknown fields) and as the meta block of MCP call_tool_with_meta.

agent_id is mandatory; the rest are Option because some dispatch paths (delegation receive, heartbeat bootstrap, tests) have no binding match — None is the correct state, not a sentinel string.

mcp_channel_source is populated when the inbound that triggered this turn arrived via an MCP channel server (e.g., "slack", "telegram"). Lets a tool distinguish “telegram-binding answered via MCP slack server” from “telegram-binding answered via native Telegram plugin” while still seeing the same (channel, account_id) binding tuple. Matches the goal_turns.source = "channel:slack" audit column. Per-turn metadata about the inbound message that triggered the agent turn.

Stamped on every tool call dispatched to a stdio extension or an MCP server (under params._meta.nexo.inbound). All fields except kind are optional; consumers must tolerate absence and branch gracefully.

Example — external user message

use nexo_tool_meta::{InboundKind, InboundMessageMeta};

let meta = InboundMessageMeta::external_user("+5491100", "wa.ABCD1234");
assert_eq!(meta.kind, InboundKind::ExternalUser);
assert_eq!(meta.sender_id.as_deref(), Some("+5491100"));
assert_eq!(meta.msg_id.as_deref(), Some("wa.ABCD1234"));

Example — internal system tick

use nexo_tool_meta::{InboundKind, InboundMessageMeta};

let meta = InboundMessageMeta::internal_system();
assert_eq!(meta.kind, InboundKind::InternalSystem);
assert!(meta.sender_id.is_none());
assert!(meta.msg_id.is_none());

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

kind: InboundKind

Origin discriminator. Always present when the bucket is.

sender_id: Option<String>

Provider-native sender id (E.164 phone, telegram_user_id, RFC822 from-address, slack U-id, …). None for kinds other than ExternalUser and for paths where the provider does not expose a sender id (e.g. webhook with no auth).

msg_id: Option<String>

Provider-native message id (single canonical, no shortened alias). Used for idempotency, dedupe, and as the reply_to_msg_id target on subsequent turns. When a debounce window collapses several inbound messages into a single turn, this carries the id of the first message in the batch.

inbound_ts: Option<DateTime<Utc>>

Inbound timestamp in UTC. Wire shape: RFC3339 string via chrono’s serde adapter. Producers must clamp wildly-skewed provider timestamps to now() before emitting.

reply_to_msg_id: Option<String>

Provider-native id of the message this one replies to. None when the inbound is not a reply.

has_media: bool

true when the inbound carries non-text media (image/audio/video/file/sticker). Microapps gate media-aware tools on this; the actual bytes/URLs live in arguments, not in _meta.

origin_session_id: Option<Uuid>

Origin session id when kind == InterSession (delegation receive). None otherwise.

Implementations

impl InboundMessageMeta

pub fn external_user( sender_id: impl Into<String>, msg_id: impl Into<String>, ) -> InboundMessageMeta

Build the minimum meta for an external user message (channel plugin / webhook / MCP-channel inbound).

pub fn internal_system() -> InboundMessageMeta

Build the meta for a heartbeat / scheduler tick or a yaml-declared internal_system event-subscriber binding.

pub fn inter_session(origin_session_id: Uuid) -> InboundMessageMeta

Build the meta for an inter-agent delegation receive. origin_session_id is required — None would be indistinguishable from internal_system.

pub fn with_ts(self, ts: DateTime<Utc>) -> InboundMessageMeta

Builder: layer the inbound timestamp.

pub fn with_reply_to( self, reply_to_msg_id: impl Into<String>, ) -> InboundMessageMeta

Builder: layer the reply-to message id.

pub fn with_media(self) -> InboundMessageMeta

Builder: flag that the inbound carries non-text media.

Trait Implementations

impl Clone for InboundMessageMeta

fn clone(&self) -> InboundMessageMeta

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for InboundMessageMeta

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for InboundMessageMeta

fn deserialize<__D>( __deserializer: __D, ) -> Result<InboundMessageMeta, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for InboundMessageMeta

impl PartialEq for InboundMessageMeta

fn eq(&self, other: &InboundMessageMeta) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for InboundMessageMeta

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for InboundMessageMeta