Struct ProtocolServer 

pub struct ProtocolServer { /* private fields */ }

The gRPC server that implements the AgentService trait generated by tonic from the agent.proto definition.

Holds a shared reference to the Engine (internally concurrent via fine-grained locks) and a SessionManager for stateful agent sessions.

Implementations

impl ProtocolServer

pub fn new(engine: Arc<Engine>, auth_config: AuthConfig) -> Self

Create a new ProtocolServer.

auth_config controls how agents authenticate on every ConnectRequest. The session timeout is fixed at 30 minutes.

pub fn engine(&self) -> &Engine

Borrow the engine.

pub fn session_mgr(&self) -> &SessionManager

Borrow the session manager.

pub fn event_bus(&self) -> &EventBus

Borrow the shared event bus.

pub fn event_bus_arc(&self) -> Arc<EventBus>

Return a cloned Arc handle to the shared event bus.

Callers that need to publish to the engine event bus from a spawned task (where a borrow of &ProtocolServer is not available) should use this to obtain a cheaply-clonable, ownership-safe handle.

pub fn claim_tracker(&self) -> &dyn ClaimTracker

Borrow the shared symbol claim tracker.

pub fn with_claim_tracker( engine: Arc<Engine>, auth_config: AuthConfig, claim_tracker: Arc<dyn ClaimTracker>, ) -> Self

Create a ProtocolServer with a custom claim tracker implementation.

Trait Implementations

impl AgentService for ProtocolServer

type VerifyStream = ReceiverStream<Result<VerifyStepResult, Status>>

Server streaming response type for the Verify method.

type WatchStream = ReceiverStream<Result<WatchEvent, Status>>

Server streaming response type for the Watch method.

fn connect<'life0, 'async_trait>( &'life0 self, request: Request<ConnectRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ConnectResponse>, Status>> + Send + 'async_trait>>

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

fn context<'life0, 'async_trait>( &'life0 self, request: Request<ContextRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ContextResponse>, Status>> + Send + 'async_trait>>

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

fn submit<'life0, 'async_trait>( &'life0 self, request: Request<SubmitRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SubmitResponse>, Status>> + Send + 'async_trait>>

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

fn verify<'life0, 'async_trait>( &'life0 self, request: Request<VerifyRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::VerifyStream>, Status>> + Send + 'async_trait>>

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

Trigger verification pipeline on a changeset (server-streaming)

fn merge<'life0, 'async_trait>( &'life0 self, request: Request<MergeRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<MergeResponse>, Status>> + Send + 'async_trait>>

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

Merge an approved changeset into a Git commit

fn watch<'life0, 'async_trait>( &'life0 self, request: Request<WatchRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::WatchStream>, Status>> + Send + 'async_trait>>

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

Watch for repo events from other agents (server-streaming)

fn file_read<'life0, 'async_trait>( &'life0 self, request: Request<FileReadRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<FileReadResponse>, Status>> + Send + 'async_trait>>

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

File-level operations through the session workspace overlay

fn file_write<'life0, 'async_trait>( &'life0 self, request: Request<FileWriteRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<FileWriteResponse>, Status>> + Send + 'async_trait>>

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

fn file_list<'life0, 'async_trait>( &'life0 self, request: Request<FileListRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<FileListResponse>, Status>> + Send + 'async_trait>>

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

fn pre_submit_check<'life0, 'async_trait>( &'life0 self, request: Request<PreSubmitCheckRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PreSubmitCheckResponse>, Status>> + Send + 'async_trait>>

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

Dry-run conflict detection before SUBMIT

fn get_session_status<'life0, 'async_trait>( &'life0 self, request: Request<SessionStatusRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SessionStatusResponse>, Status>> + Send + 'async_trait>>

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

Get current session workspace state

fn push<'life0, 'async_trait>( &'life0 self, request: Request<PushRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PushResponse>, Status>> + Send + 'async_trait>>

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

Push merged changes to GitHub (branch or PR)

fn approve<'life0, 'async_trait>( &'life0 self, _request: Request<ApproveRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ApproveResponse>, Status>> + Send + 'async_trait>>

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

Approve a submitted changeset (platform-level state transition)

fn resolve<'life0, 'async_trait>( &'life0 self, _request: Request<ResolveRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ResolveResponse>, Status>> + Send + 'async_trait>>

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

Resolve conflicts on a changeset

fn close<'life0, 'async_trait>( &'life0 self, _request: Request<CloseRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CloseResponse>, Status>> + Send + 'async_trait>>

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

Close a session and destroy its workspace

fn review<'life0, 'async_trait>( &'life0 self, _request: Request<ReviewRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ReviewResponse>, Status>> + Send + 'async_trait>>

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

Get code review results for a changeset