mapepire 0.4.0

Async Rust client for Mapepire — Db2 for IBM i over secure WebSockets
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

//! Transport layer — TLS + WebSocket + dispatcher infrastructure.
//!
//! This module is `pub(crate)` rather than `pub` because the abstractions
//! here are implementation details of `Job`. Consumers interact with the
//! transport indirectly via the public `Job` / `Query` / `Rows` APIs.
//!
//! See `docs/superpowers/specs/2026-04-29-mapepire-rust-design.md` §6 for
//! the lifecycle and dispatcher diagrams.

pub(crate) mod dispatcher;
pub(crate) mod handshake;
pub(crate) mod socket;
pub(crate) mod tls;

use std::pin::Pin;

use bytes::Bytes;
use futures::{Sink, Stream};

/// Minimal transport abstraction the dispatcher reads/writes against.
/// Real implementations: `tokio_tungstenite::WebSocketStream<TlsStream>`.
/// Test mock: an in-memory channel pair.
///
/// The `Transport` trait keeps the dispatcher decoupled from the concrete
/// WebSocket library so we can substitute a mock in unit tests without
/// spinning a real TLS server.
pub(crate) trait Transport:
    Sink<Bytes, Error = crate::error::TransportError>
    + Stream<Item = Result<Bytes, crate::error::TransportError>>
    + Send
    + Unpin
{
}

impl<T> Transport for T where
    T: Sink<Bytes, Error = crate::error::TransportError>
        + Stream<Item = Result<Bytes, crate::error::TransportError>>
        + Send
        + Unpin
{
}

/// Type alias for a boxed dynamic transport — used by `Dispatcher::spawn`.
pub(crate) type BoxedTransport = Pin<Box<dyn Transport>>;

// Re-exports for `Job`.
pub(crate) use dispatcher::{Dispatcher, DispatcherHandle};
pub(crate) use handshake::{ConnectedDispatcher, connect};