turso_client.ping().await?;
redb_env.check_integrity()?;

let episodes = turso_client
    .query("SELECT * FROM episodes ORDER BY timestamp DESC LIMIT ?")
    .bind(max_episodes_cache)
    .await?;

tokio::task::spawn_blocking(move || {
    let write_txn = redb.begin_write()?;
    let mut table = write_txn.open_table(EPISODES_TABLE)?;
    for episode in episodes {
        table.insert(episode.id.as_bytes(), episode.to_bytes())?;
    }
    write_txn.commit()?;
});