Function spawn_refresh_worker

crates/openshell-server/src/provider_refresh.rs:683–698

(state: std::sync::Arc<crate::ServerState>, interval: Duration)

}

pub fn spawn_refresh_worker(state: std::sync::Arc<crate::ServerState>, interval: Duration) {
    info!(
        interval_seconds = interval.as_secs(),
        "provider credential refresh worker started"
    );
    tokio::spawn(async move {
        let mut ticker = tokio::time::interval(interval);
        ticker.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Delay);
        loop {
            ticker.tick().await;
            if let Err(err) = run_refresh_worker_tick(state.store.as_ref()).await {
                warn!(error = %err, "provider credential refresh worker tick failed");
            }
        }
    });
}

async fn run_refresh_worker_tick(store: &Store) -> Result<(), Status> {
    let now_ms = current_time_ms();