driftfm 0.1.0

A blazing-fast cyber-synthwave internet radio player & smart tape recorder TUI
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

mod action;
mod app;
mod audio;
mod event;
mod favorites;
mod radio;
mod ui;

use std::time::Duration;
use anyhow::Result;

use app::App;
use favorites::Library;
use radio::fallback_stations;

#[tokio::main]
async fn main() -> Result<()> {
    // Load your station library (seeds with starter stations on first launch)
    let library = Library::load(fallback_stations());

    // Initialize theme from saved settings
    let saved_theme = ui::theme::ThemeName::from_key(&library.settings.theme);
    ui::theme::set_active(saved_theme);

    let mut app = App::new(library);

    // Initialize terminal
    let mut terminal = ratatui::init();

    // ── Channel for API search results ───────────────────────────
    let (search_tx, mut search_rx) =
        tokio::sync::mpsc::unbounded_channel::<Vec<radio::Station>>();

    // ── Main Loop ────────────────────────────────────────────────
    let tick_rate = Duration::from_millis(66); // ~15 FPS

    loop {
        // Draw
        terminal.draw(|frame| ui::draw(frame, &app))?;

        // Poll for user input (mode-aware key mapping)
        if let Some(action) = event::poll_action(tick_rate, &app.input_mode) {
            app.update(action);
        } else {
            app.update(action::Action::Tick);
        }

        // ── Check for pending API search requests ────────────────
        if let Some(query) = app.pending_api_search.take() {
            let tx = search_tx.clone();
            tokio::spawn(async move {
                if let Ok(results) = radio::search_stations(&query).await {
                    let _ = tx.send(results);
                }
            });
        }

        // ── Check for API search results (non-blocking) ─────────
        if let Ok(results) = search_rx.try_recv() {
            app.set_search_results(results);
        }

        if app.should_quit {
            break;
        }
    }

    // Restore terminal
    ratatui::restore();

    Ok(())
}