Struct HttpChannel 

pub struct HttpChannel { /* private fields */ }

The CoPilot HTTP channel. Owns http:copilot and every http:copilot:* sub-lane.

Implementations

impl HttpChannel

pub fn new( config: HttpConfig, host: Arc<dyn ChannelHost>, db: Db, audit: SharedAuditSink, ) -> Self

Production constructor: db is the shared talon_db::Db.

The /palace/* endpoints are disabled (503) — see HttpDeps::new; use Self::with_palace to supply a (containerized) palace runner.

pub fn with_palace( config: HttpConfig, host: Arc<dyn ChannelHost>, db: Db, audit: SharedAuditSink, palace: Arc<dyn PalaceRunner>, ) -> Self

Like Self::new, serving /palace/* through palace (normally a crate::CommandPalaceRunner running the palace in a hardened container).

pub fn from_state(state: HttpState) -> Self

Build around an existing state (custom dependencies, tests).

pub fn state(&self) -> &HttpState

The shared state (e.g. to build a router for tests).

pub fn local_addr(&self) -> Option<SocketAddr>

The bound address once connected (useful with port 0).

Trait Implementations

impl Channel for HttpChannel

fn name(&self) -> &str

Stable short name ("http", "telegram", …).

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

where Self: 'async_trait, 'life0: 'async_trait,

Start the channel (bind servers, start polling). Must return once the channel is ready; long-running work goes into spawned tasks.

fn send_message<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, jid: &'life1 str, text: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Deliver text to jid. Text is already formatted for channel_type.

fn is_connected(&self) -> bool

fn owns_jid(&self, jid: &str) -> bool

Whether this channel is responsible for jid.

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

where Self: 'async_trait, 'life0: 'async_trait,

Stop background tasks and release sockets.

fn set_typing<'life0, 'life1, 'async_trait>( &'life0 self, jid: &'life1 str, is_typing: bool, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Optional typing indicator.

fn on_turn_complete<'life0, 'life1, 'async_trait>( &'life0 self, jid: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when the agent finishes a turn successfully, before the container goes idle (lets streaming channels close their streams).

fn channel_type(&self) -> ChannelType

Dialect for outbound formatting.

fn sync_groups<'life0, 'async_trait>( &'life0 self, _force: bool, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Optional: refresh chat names from the platform.

impl Debug for HttpChannel

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

Formats the value using the given formatter.