getquotes 0.7.0

use crate::cache::get_database_path;
use crate::config::load_or_create_config;
use crate::quotes::{fetch_quotes, get_author_sections};
use rand::RngExt;
use reqwest::Client;
use rusqlite::Connection;
use std::error::Error as StdError;
use std::sync::Arc;
use tokio::time;

pub async fn update_cache(client: Arc<Client>) -> Result<(), Box<dyn StdError + Send + Sync>> {
    let cfg = load_or_create_config()?;
    if cfg.authors.is_empty() {
        return Err("No authors configured for caching.".into());
    }
    let author_idx = rand::rng().random_range(0..cfg.authors.len());
    let author = &cfg.authors[author_idx];

    match get_author_sections(&client, author).await {
        Ok(Some((title, sections))) => {
            for section in sections {
                match fetch_quotes(&client, &title, &section.index).await {
                    Ok(quotes) => {
                        for quote in quotes {
                            let db_path = get_database_path()?;
                            let conn = Connection::open(db_path.to_str().unwrap())?;
                            match conn.execute(
                                "INSERT OR IGNORE INTO quotes (author, quote) VALUES (?1, ?2)",
                                [author, &quote],
                            ) {
                                Ok(_) => println!("Cached quote: {quote}"),
                                Err(e) => eprintln!("Failed to cache quote: {e}"),
                            }
                        }
                    }
                    Err(e) => eprintln!(
                        "Failed to fetch quotes for section {}: {}",
                        section.index, e
                    ),
                }
            }
        }
        Ok(None) => println!("No valid page found for author '{author}'."),
        Err(e) => eprintln!("Failed to get sections for author '{author}': {e}"),
    }
    Ok(())
}

pub async fn cache_quotes(client: Arc<Client>) {
    loop {
        if let Err(e) = update_cache(client.clone()).await {
            eprintln!("Error updating cache: {e}");
        }
        time::sleep(time::Duration::from_secs(24 * 3600)).await;
    }
}