Struct EnhanceApplication 

pub struct EnhanceApplication { /* private fields */ }

The POST /v1/issues dispatcher — enqueues via Application::handle, drains via EnhanceApplication::tick / EnhanceApplication::run_forever.

Implementations

impl EnhanceApplication

pub fn new( cfg: EnhanceApplicationConfig, issue_store: Arc<dyn IssueStore>, setting_store: Arc<dyn EnhanceSettingStore>, bp_store: Arc<dyn BlueprintStore>, log_store: Arc<dyn EnhanceLogStore>, launch: Arc<TaskLaunchService>, ) -> Self

Wire up an EnhanceApplication from its config and store/service dependencies.

pub fn issue_store(&self) -> &Arc<dyn IssueStore>

The IssueStore this Application enqueues into and drains from.

pub fn bp_store(&self) -> &Arc<dyn BlueprintStore>

The BlueprintStore used to resolve orbit/target Blueprints and to persist Applied commits.

pub fn log_store(&self) -> &Arc<dyn EnhanceLogStore>

The EnhanceLogStore every dispatch outcome is appended to.

pub async fn tick(&self) -> Result<Option<TickOutcome>, EnhanceApplicationError>

Pop one pending issue and dispatch it to the engine. Returns None when nothing is pending.

dispatch_one returns Err only for infra faults — store, launch, clock, shape errors, and the like. Flow verifier denials come back through dispatch_one on the Ok path with a Rejected status, and the corresponding entry has already been appended to log_store in the same commit. Even on an infra fault, tick best-effort tries to update the store-side status; if the store itself is broken the error propagates.

pub async fn run_forever(self: Arc<Self>, interval: Duration)

The consumer loop. At server startup, launch it with tokio::spawn(app.run_forever(interval)); stop it with JoinHandle::abort().

Behaviour:

• tick() returns Some → immediately run another tick (burst drain).
• tick() returns None → sleep for interval (no-work back-off).
• tick() returns Err → log it and sleep for interval (a dispatch failure must not kill the loop).

Trait Implementations

impl Application for EnhanceApplication

fn handle<'life0, 'async_trait>( &'life0 self, input: Self::Input, ) -> Pin<Box<dyn Future<Output = Result<Self::Output, Self::Error>> + Send + 'async_trait>>

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

Just push the issue onto IssueStore — a synchronous enqueue; dispatch is entirely the consumer loop’s job.

type Input = EnhanceApplicationInput

The request type this Application accepts.

type Output = IssueId

The result type returned on success.

type Error = EnhanceApplicationError

The error type returned on failure.

fn name(&self) -> &str

A short identifier for this Application instance (used in logs and diagnostics).