raftcli 1.15.5

use crate::raft_cli_utils::utils_get_sys_type;
use std::fs::File;
use std::io::{self, BufReader, Read, Write};
use std::net::TcpStream;
use std::path::Path;
use std::sync::{Arc, Mutex};
use std::time::{Duration, Instant};
use std::collections::VecDeque;

// Struct to track data rate over a period (e.g., 5 seconds)
struct DataRateTracker {
    interval_duration: Duration,          // The duration over which we want to track the rate (e.g., 5 seconds)
    data_points: VecDeque<(Instant, u64)>, // Store timestamps and amount of data sent at each point
    total_data_in_interval: u64,           // The total amount of data sent in the current interval
}

impl DataRateTracker {
    fn new(interval_duration: Duration) -> Self {
        Self {
            interval_duration,
            data_points: VecDeque::new(),
            total_data_in_interval: 0,
        }
    }

    // Method to add data sent to the tracker
    fn add_data(&mut self, bytes_sent: u64) {
        let now = Instant::now();
        self.data_points.push_back((now, bytes_sent));
        self.total_data_in_interval += bytes_sent;

        // Remove data points that are older than the interval duration
        while let Some(&(timestamp, _)) = self.data_points.front() {
            if now.duration_since(timestamp) > self.interval_duration {
                let (_, old_data) = self.data_points.pop_front().unwrap();
                self.total_data_in_interval -= old_data;
            } else {
                break;
            }
        }
    }

    // Method to calculate the average rate over the interval duration
    fn get_average_rate(&self) -> f64 {
        let duration_secs = self.interval_duration.as_secs_f64();
        if duration_secs > 0.0 {
            (self.total_data_in_interval as f64) / duration_secs // Bytes per second
        } else {
            0.0
        }
    }
}

// ProgressReader implementation to track file upload progress
struct ProgressReader<R> {
    inner: R,
    chunk_size: usize,
    total_read: u64,
    total_sent: u64,
    progress: Arc<Mutex<ProgressTracker>>,
}

impl<R: Read> ProgressReader<R> {
    fn new(inner: R, chunk_size: usize, progress: Arc<Mutex<ProgressTracker>>) -> Self {
        Self {
            inner,
            chunk_size,
            total_read: 0,
            total_sent: 0,
            progress,
        }
    }

    fn read_and_send<W: Write>(&mut self, mut stream: W) -> io::Result<()> {
        let mut buf = vec![0; self.chunk_size];
        loop {
            let n = self.inner.read(&mut buf)?;
            if n == 0 {
                break;
            }
            self.total_read += n as u64;

            // Write the chunk to the stream and flush it immediately
            stream.write_all(&buf[..n])?;
            stream.flush()?;

            // Update total bytes sent
            self.total_sent += n as u64;

            // Update progress after each chunk is sent
            let mut progress = self.progress.lock().unwrap();
            progress.update(n);

            // Provide detailed feedback on sent data
            // println!(
            //     "Chunk sent: {} bytes | Total sent: {} bytes",
            //     n, self.total_sent
            // );
        }
        Ok(())
    }
}

// Progress tracking structure
struct ProgressTracker {
    total_size: u64,
    bytes_read: u64,
    last_update: Instant,
    rate_tracker: DataRateTracker,
}

impl ProgressTracker {
    fn new(total_size: u64) -> Self {
        Self {
            total_size,
            bytes_read: 0,
            last_update: Instant::now(),
            rate_tracker: DataRateTracker::new(Duration::from_secs(5)), // Track over 5 seconds
        }
    }

    fn update(&mut self, bytes: usize) {
        self.bytes_read += bytes as u64;

        // Add data to rate tracker
        self.rate_tracker.add_data(bytes as u64);

        // Display progress every 500ms
        if self.last_update.elapsed() >= Duration::from_millis(500) {
            let percentage = (self.bytes_read as f64 / self.total_size as f64) * 100.0;

            // Calculate the rate over the last 5 seconds
            let rate = self.rate_tracker.get_average_rate(); // Bytes/second

            println!(
                "Progress: {:.2}% | {}/{} bytes | Rate: {:.2} KB/s",
                percentage,
                self.bytes_read,
                self.total_size,
                rate / 1024.0 // Convert rate to KB/s for display
            );

            // Update the last update time
            self.last_update = Instant::now();
        }
    }
}

// Function to perform OTA flash using basic TCP stream and progress tracking
fn perform_ota_flash_basic_http_with_streaming(
    fw_image_path: &str,
    fw_image_name: &str,
    ip_addr: &str,
    port: u16,
) -> Result<(), Box<dyn std::error::Error>> {
    // Check if the firmware file exists
    if !Path::new(fw_image_path).exists() {
        return Err(Box::new(io::Error::new(
            io::ErrorKind::NotFound,
            "Firmware image not found",
        )));
    }

    // Get the file size for progress tracking
    let metadata = std::fs::metadata(fw_image_path)?;
    let file_size = metadata.len();

    // Open the file and create a progress tracker
    let file = File::open(fw_image_path)?;
    let progress_tracker = Arc::new(Mutex::new(ProgressTracker::new(file_size)));

    // Create a ProgressReader that owns the file and wrap it in a BufReader for better I/O performance
    let file_reader = BufReader::new(file);
    let mut progress_reader = ProgressReader::new(file_reader, 1024, progress_tracker.clone());

    // Connect to the server
    let addr = format!("{}:{}", ip_addr, port);
    let mut stream = TcpStream::connect(&addr)?;
    println!("Connected to {}", addr);

    // Construct the multipart headers and boundaries
    let boundary = "----CustomBoundary123456";
    let start_boundary = format!("--{}\r\n", boundary);
    let content_disposition = format!(
        "Content-Disposition: form-data; name=\"file\"; filename=\"{}\"\r\n",
        fw_image_name
    );
    let content_type = "Content-Type: application/octet-stream\r\n\r\n";
    let end_boundary = format!("\r\n--{}--\r\n", boundary);

    // Calculate Content-Length
    let headers_length = start_boundary.len() + content_disposition.len() + content_type.len();
    let content_length = headers_length + file_size as usize + end_boundary.len();

    // Create HTTP POST request headers
    let request = format!(
        "POST /api/espFwUpdate HTTP/1.1\r\n\
         Host: {}\r\n\
         Content-Type: multipart/form-data; boundary={}\r\n\
         Content-Length: {}\r\n\
         Connection: close\r\n\r\n",
        ip_addr, boundary, content_length
    );

    // Write request headers to the stream
    stream.write_all(request.as_bytes())?;
    stream.write_all(start_boundary.as_bytes())?;
    stream.write_all(content_disposition.as_bytes())?;
    stream.write_all(content_type.as_bytes())?;
    stream.flush()?;

    // Stream the file content to the server with progress feedback
    progress_reader.read_and_send(&mut stream)?;

    // Write the end boundary to signal the end of the multipart request
    stream.write_all(end_boundary.as_bytes())?;
    stream.flush()?;

    // Read and display the response from the server
    let mut response = String::new();
    stream.read_to_string(&mut response)?;
    // println!("Response: {}", response);

    // Check response for success
    if response.contains("200 OK") && response.contains("\"rslt\":\"ok\"") {
        // println!("OTA flash successful");
    } else {
        println!("OTA flash failed with response: {}", response);
        return Err(Box::new(io::Error::new(
            io::ErrorKind::Other,
            "OTA flash failed",
        )));
    }

    Ok(())
}

pub fn ota_raft_app(
    build_sys_type: &Option<String>,
    app_folder: String,
    ip_addr: String,
    ip_port: Option<u16>,
    use_curl: bool,
) -> Result<(), Box<dyn std::error::Error>> {

    // Get the system type
    let sys_type = utils_get_sys_type(build_sys_type, app_folder.clone());
    if sys_type.is_err() {
        return Err(Box::new(std::io::Error::new(std::io::ErrorKind::Other, "Error determining SysType")));
    }

    // Unwrap the sys_type, ip_addr, and ip_port
    let sys_type = sys_type.unwrap();
    let ip_port = ip_port.unwrap_or(80);
    let fw_image_name = format!("{}.bin", sys_type);
    let fw_image_path = format!("{}/build/{}/{}", app_folder, sys_type, fw_image_name);

    // Check if not using curl
    if !use_curl {
        println!("Flashing {} FW image is {}", sys_type, fw_image_path);

        // Call the synchronous version of perform_ota_flash with progress tracking
        match perform_ota_flash_basic_http_with_streaming(&fw_image_path, &fw_image_name, &ip_addr, ip_port) {
            Ok(_) => println!("OTA flash successful"),
            Err(e) => println!("OTA flash failed: {:?}", e),
        }

    } else {

        // Use curl to perform OTA flashing
        let ota_result = std::process::Command::new("curl")
            .arg("-F")
            .arg(format!("file=@{}", fw_image_path))  // Ensure this uses the correct app folder path
            .arg(format!("http://{}/api/espFwUpdate", ip_addr))
            .output();

        if let Ok(output) = ota_result {
            if output.status.success() {
                println!("OTA flash successful");
                return Ok(());
            } else {
                println!("OTA flash failed: {}", String::from_utf8_lossy(&output.stderr));
                return Err("Failed to execute curl command".to_string().into());
            }
        } else {
            return Err("Failed to execute curl command".to_string().into());
        }
    }

    Ok(())
}