Struct UpdateManager 

pub struct UpdateManager {
    AppState: Arc<ApplicationState>,
    update_status: Arc<RwLock<UpdateStatus>>,
    cache_directory: PathBuf,
    staging_directory: PathBuf,
    backup_directory: PathBuf,
    download_sessions: Arc<RwLock<HashMap<String, DownloadSession>>>,
    rollback_history: Arc<Mutex<RollbackHistory>>,
    update_channel: UpdateChannel,
    platform_config: PlatformConfig,
}

Update manager implementation with full lifecycle support

Fields

AppState: Arc<ApplicationState>

Application state

update_status: Arc<RwLock<UpdateStatus>>

Current update status

cache_directory: PathBuf

Update cache directory

staging_directory: PathBuf

Staging directory for pre-installation verification

backup_directory: PathBuf

Backup directory for rollback capability

download_sessions: Arc<RwLock<HashMap<String, DownloadSession>>>

Active download sessions with resume capability

rollback_history: Arc<Mutex<RollbackHistory>>

Rollback history (max 5 versions)

update_channel: UpdateChannel

Update channel configuration

platform_config: PlatformConfig

Platform-specific configuration

Implementations

impl UpdateManager

pub async fn new(AppState: Arc<ApplicationState>) -> Result<Self>

Create a new update manager with comprehensive initialization

fn detect_platform() -> PlatformConfig

Detect the current platform and configure platform-specific settings

pub async fn CheckForUpdates(&self) -> Result<Option<UpdateInfo>>

Check for available updates from the configured update server

This method:

• Queries the update server based on the configured channel
• Validates the update against minimum compatibility requirements
• Updates the internal status with available update information
• Triggers automatic download if configured

Returns: Some(UpdateInfo) if an update is available, None otherwise

pub async fn DownloadUpdate(&self, update_info: &UpdateInfo) -> Result<()>

Download update package with resumable download support

This method:

• Validates available disk space before starting download
• Supports resumable downloads from network interruptions
• Tracks download progress and calculates ETA
• Updates download speed metrics
• Verifies all checksums after download

Arguments

• update_info - Update information containing download URL and metadata

Returns

Result<()> indicating success or failure

pub async fn ApplyUpdate(&self, update_info: &UpdateInfo) -> Result<()>

Apply update with rollback capability

This method:

• Creates full backup of current installation
• Validates update package integrity
• Applies update atomically
• Automatically rolls back on failure
• Updates rollback history

Arguments

• update_info - Update information for the version to apply

Returns

Result<()> indicating success or failure (with automatic rollback)

async fn FetchUpdateInfo(&self) -> Result<Option<UpdateInfo>>

Fetch update information from the configured update server

This method:

• Queries the update server based on platform, version, and channel
• Uses circuit breakers and retry policies for resilience
• Returns update information if a newer version is available

Returns

Result<Option<UpdateInfo>> - Some if update available, None if up-to-date

async fn VerifyChecksum( &self, file_path: &Path, expected_checksum: &str, ) -> Result<()>

Verify file checksum (SHA256 by default)

This method:

• Reads the entire file into memory
• Computes SHA256 hash
• Compares with expected checksum

Arguments

• file_path - Path to the file to verify
• expected_checksum - Expected SHA256 checksum in hex format

Returns

Result<()> indicating success or failure

async fn VerifyChecksumWithAlgorithm( &self, file_path: &Path, algorithm: &str, expected_checksum: &str, ) -> Result<()>

Verify file checksum with specified algorithm

Supports multiple checksum algorithms for comprehensive integrity checking

Arguments

• file_path - Path to the file to verify
• algorithm - Checksum algorithm (md5, sha1, sha256, sha512)
• expected_checksum - Expected checksum in hex format

Returns

Result<()> indicating success or failure

async fn VerifySignature( &self, _file_path: &Path, _signature: &str, ) -> Result<()>

Verify cryptographic signature of update package

This method:

• Uses Ed25519 signature verification
• Verifies the package hasn’t been tampered with
• Uses the public key configured in the system

Arguments

• file_path - Path to the signed file
• signature - Base64-encoded signature

Returns

Result<()> indicating success or failure

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

Create backup of current installation

This method:

• Creates a timestamped backup directory
• Copies critical files (binaries, config, data)
• Computes checksum of backup for rollback verification

Arguments

• version - Current version being backed up

Returns

Result<RollbackState> containing backup information

pub async fn RollbackToBackup(&self, backup_info: &RollbackState) -> Result<()>

Rollback to a previous version using backup

This method:

• Verifies backup integrity using checksum
• Restores files from backup
• Validated rollback success

Arguments

• backup_info - Rollback state containing backup information

Returns

Result<()> indicating success or failure

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

Rollback to a specific version by version number

This method:

• Searches for backup matching the version
• Calls RollbackToBackup with the backup

Arguments

• version - Version to rollback to

Returns

Result<()> indicating success or failure

pub async fn GetAvailableRollbackVersions(&self) -> Vec<String>

Get available rollback versions

Returns list of versions that can be rolled back to

async fn ValidateDiskSpace(&self, required_bytes: u64) -> Result<()>

Validate disk space before download

Ensures sufficient space is available for download + staging

Arguments

• required_bytes - Required space in bytes

Returns

Result<()> indicating success or failure

pub async fn verify_update( &self, file_path: &str, update_info: Option<&UpdateInfo>, ) -> Result<bool>

Verify update file integrity comprehensive check

This method:

• Checks file existence and non-zero size
• Verifies all checksums if UpdateInfo provided
• Detects corrupted downloads

Arguments

• file_path - Path to the update file
• update_info - Optional update info with checksums

Returns

Result<bool> - true if valid, false if invalid

async fn ApplyWindowsUpdate(&self, file_path: &Path) -> Result<()>

Platform-specific update installation for Windows

async fn ApplyMacOsUpdate(&self, file_path: &Path) -> Result<()>

Platform-specific update installation for macOS

async fn ApplyLinuxAppImageUpdate(&self, file_path: &Path) -> Result<()>

Platform-specific update installation for Linux (AppImage)

async fn ApplyLinuxDebUpdate(&self, file_path: &Path) -> Result<()>

Platform-specific update installation for Linux (DEB)

async fn ApplyLinuxRpmUpdate(&self, file_path: &Path) -> Result<()>

Platform-specific update installation for Linux (RPM)

async fn record_telemetry( &self, operation: &str, success: bool, duration_ms: u64, download_size: Option<u64>, error_message: Option<String>, )

Record telemetry for update operations

This method:

• Creates telemetry event with operation details
• In production, would send to analytics service
• Currently logs to file for debugging

Arguments

• operation - Type of operation (check, download, install, rollback)
• success - Whether operation succeeded
• duration_ms - Duration in milliseconds
• download_size - Optional download size in bytes
• error_message - Optional error message if failed

fn CalculateSha256(&self, data: &[u8]) -> String

Calculate SHA256 checksum of a byte slice

fn CalculateSha512(&self, data: &[u8]) -> String

Calculate SHA512 checksum of a byte slice

fn CalculateMd5(&self, data: &[u8]) -> String

Calculate MD5 checksum of a byte slice

fn CalculateCrc32(&self, data: &[u8]) -> String

Calculate CRC32 checksum of a byte slice

async fn CalculateFileChecksum(&self, path: &Path) -> Result<String>

Calculate SHA256 checksum of a file

pub fn CompareVersions(v1: &str, v2: &str) -> i32

Compare two semantic version strings

Returns:

• -1 if v1 < v2
• 0 if v1 == v2
• 1 if v1 > v2

Arguments

• v1 - First version string
• v2 - Second version string

Returns

i32 indicating comparison result

pub async fn GetStatus(&self) -> UpdateStatus

Get current update status

Returns a clone of the current update status

pub async fn CancelDownload(&self) -> Result<()>

Cancel ongoing download

This method:

• Cancels the active download session
• Cleans up temporary files
• Updates status to paused

pub async fn ResumeDownload(&self, update_info: &UpdateInfo) -> Result<()>

Resume paused download

This method:

• Resumes a paused download session
• Uses HTTP Range header for resume capability

Arguments

• update_info - Update information to resume download

pub async fn GetUpdateChannel(&self) -> UpdateChannel

Get update configuration

Returns the current update channel configuration

pub async fn SetUpdateChannel(&mut self, channel: UpdateChannel)

Set update channel

Arguments

• channel - New update channel to use

pub async fn StageUpdate(&self, update_info: &UpdateInfo) -> Result<()>

Stage update for pre-installation verification

This method:

• Stages the update in the staging directory
• Verifies the staged update
• Prepares for installation

Arguments

• update_info - Update information to stage

pub async fn CleanupOldUpdates(&self) -> Result<()>

Clean up old update files

Removes downloaded updates older than a certain threshold to free disk space

pub fn GetCacheDirectory(&self) -> &PathBuf

Get the cache directory path

pub async fn StartBackgroundTasks(&self) -> Result<JoinHandle<()>>

Start background update checking task

This method:

• Periodically checks for updates based on configured interval
• Runs in a separate tokio task
• Can be cancelled by stopping the task

Returns

Result<tokio::task::JoinHandle<()>> - Handle to the background task

async fn BackgroundTask(&self)

Background task for periodic update checks

This task:

• Checks for updates at regular intervals
• Logs any errors but doesn’t fail the task
• Can run indefinitely until stopped

pub async fn StopBackgroundTasks(&self)

Stop background tasks

This method:

• Logs the stop request
• In production, would cancel the join handle

fn format_size(&self, bytes: f64) -> String

Format byte count to human-readable string

Arguments

• bytes - Number of bytes (supports both u64 and f64 for rates)

Returns

Formatted string (e.g., “1.5 MB”, “500 KB”)

Trait Implementations

impl Clone for UpdateManager

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.