Struct RealSlackTransport 

pub struct RealSlackTransport { /* private fields */ }

Production SlackTransport — UNCONDITIONAL (no cfg gate, MC-11). Drives:

• Outbound chat.postMessage via reqwest, fetching the bot token (xoxb-) from the OS keychain by its reference key at use-time (MC-9 — the token is never read out of messaging.json).
• Inbound Socket Mode: opens a WebSocket via apps.connections.open (using the app-level token xapp-, also keychain-fetched), reads frames, ACKs each events_api/interactive envelope within the ~3s window, and maps the two recognized shapes to SlackInboundEvent. The bot’s own echo is suppressed (subtype == "bot_message" / bot_id present).

The reconnect loop (resilient backoff, apps.connections.open per connection, disconnect/warning handling) follows the Socket Mode reference. next_event pulls from an internal channel the background connection task feeds.

Implementations

impl RealSlackTransport

pub fn new( bot_token_key: impl Into<String>, app_token_key: impl Into<String>, ) -> RealSlackTransport

Build the production transport. bot_token_key/app_token_key are the keychain REFERENCE keys (from SlackTokenRefs) — the bearer values live only in the OS keychain (MC-9).

pub fn spawn_socket_loop(self: Arc<RealSlackTransport>, cancel: Receiver<bool>)

Spawn the background Socket Mode reconnect loop. Each connection reads frames, ACKs, maps the two recognized shapes, and forwards them to inbound_tx. Runs until cancel flips. Per the reference: resilient backoff, one apps.connections.open per connection, disconnect/error → reconnect.

Trait Implementations

impl SlackTransport for RealSlackTransport

fn post_message<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, channel: &'life1 str, text: &'life2 str, approval_id: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<String, String>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, RealSlackTransport: 'async_trait,

Post a Block Kit approval message carrying Approve/Deny buttons whose value is the approval_id. text is the human-readable summary (also carries the shared fan-out code for MC-8 equality). Returns the posted message ts on success.

fn next_event<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<SlackInboundEvent>> + Send + 'async_trait>>

where 'life0: 'async_trait, RealSlackTransport: 'async_trait,

Block until the next inbound Slack event (button click or DM), or None when the source is exhausted / cancelled. The adapter ACKs and dispatches each returned event. The transport is responsible for the Socket Mode ACK contract and for suppressing the bot’s own echo (returning SlackInboundEvent::Ignore or skipping it).