Struct AirVinegRPCService 

pub struct AirVinegRPCService {
    AppState: Arc<ApplicationState>,
    AuthService: Arc<AuthenticationService>,
    UpdateManager: Arc<UpdateManager>,
    DownloadManager: Arc<DownloadManager>,
    FileIndexer: Arc<FileIndexer>,
    ActiveConnections: Arc<RwLock<HashMap<String, ConnectionMetadata>>>,
}

The concrete implementation of the Air gRPC service

Fields

AppState: Arc<ApplicationState>

Application state

AuthService: Arc<AuthenticationService>

Authentication service

UpdateManager: Arc<UpdateManager>

Update manager

DownloadManager: Arc<DownloadManager>

Download manager

FileIndexer: Arc<FileIndexer>

File indexer

ActiveConnections: Arc<RwLock<HashMap<String, ConnectionMetadata>>>

Connection tracking

Implementations

impl AirVinegRPCService

pub fn new( AppState: Arc<ApplicationState>, AuthService: Arc<AuthenticationService>, UpdateManager: Arc<UpdateManager>, DownloadManager: Arc<DownloadManager>, FileIndexer: Arc<FileIndexer>, ) -> Self

Creates a new instance of the Air gRPC service

async fn TrackConnection<RequestType>( &self, Request: &Request<RequestType>, _ServiceName: &str, ) -> Result<String, Status>

Track connection for a request

fn validate_protocol_version(&self, ClientVersion: u32) -> Result<(), Status>

Validate protocol version compatibility

impl AirVinegRPCService

fn detect_mime_type(&self, path: &Path) -> String

Detect MIME type based on file extension

async fn download_file_with_retry( &self, request_id: &str, url: String, DestinationPath: String, checksum: String, progress_callback: Option<Box<dyn Fn(f32) + Send>>, ) -> Result<DownloadResult>

Download file with exponential backoff retry Returns file_info (path, size, checksum) from DownloadManager

async fn validate_range_support(&self, url: &str) -> Result<bool>

Validate URL supports range headers for streaming

async fn prepare_rollback_backup(&self, version: &str) -> Result<()>

Prepare rollback backup before applying update

async fn cleanup_rollback_backup(&self, version: &str) -> Result<()>

Cleanup rollback backup after successful update or failed verification

async fn perform_rollback(&self, version: &str) -> Result<()>

Perform rollback to previous version

Trait Implementations

impl AirService for AirVinegRPCService

type DownloadStreamStream = ReceiverStream<Result<DownloadStreamResponse, Status>>

Handle streaming download requests with bidirectional streaming and chunk delivery

fn authenticate<'life0, 'async_trait>( &'life0 self, Request: Request<AuthenticationRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<AuthenticationResponse>, Status>> + Send + 'async_trait>>

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

Handle authentication requests from Mountain

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

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

Handle update check requests from Mountain

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

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

Handle download requests from Mountain

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

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

Handle file indexing requests from Mountain

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

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

Handle status check requests from Mountain

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

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

Handle service health check

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

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

Handle download update requests

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

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

Handle apply update requests

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

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

Handle file search requests

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

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

Handle get file info requests

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

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

Handle get metrics requests

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

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

Handle get resource usage requests

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

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

Handle set resource limits requests

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

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

Handle get configuration requests

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

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

Handle update configuration requests

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

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

impl Clone for AirVinegRPCService

fn clone(&self) -> AirVinegRPCService

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.