Struct HttpAdapter 

pub struct HttpAdapter { /* private fields */ }

HTTP protocol adapter for consistency engine

This adapter listens to state change events from the consistency engine and updates HTTP middleware/handlers to reflect the unified state.

Implementations

impl HttpAdapter

pub fn new(engine: Arc<ConsistencyEngine>) -> Self

Create a new HTTP adapter

pub async fn get_persona(&self, workspace_id: &str) -> Option<PersonaProfile>

Get current persona for a workspace

pub async fn get_scenario(&self, workspace_id: &str) -> Option<String>

Get current scenario for a workspace

Trait Implementations

impl ProtocolAdapter for HttpAdapter

fn protocol(&self) -> Protocol

Get the protocol this adapter handles

fn on_state_change<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 StateChangeEvent, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Handle a state change event

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

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

Get current protocol state

fn apply_persona<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, workspace_id: &'life1 str, persona: &'life2 PersonaProfile, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Apply persona to this protocol

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

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

Apply scenario to this protocol