venus 0.1.1-beta.2

Reactive notebook environment for Rust
Documentation 
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

//! Serve command implementation for Venus CLI.
//!
//! Starts an interactive WebSocket server for the notebook.

use std::path::Path;

use venus_server::ServerConfig;

use crate::colors;

/// Start the interactive notebook server.
pub async fn execute(notebook_path: &str, port: u16) -> anyhow::Result<()> {
    let path = Path::new(notebook_path);
    if !path.exists() {
        anyhow::bail!("Notebook not found: {}", notebook_path);
    }

    println!(
        "\n{}Venus Server{} - Interactive Notebook",
        colors::BOLD,
        colors::RESET
    );
    println!("{}", "─".repeat(50));

    println!(
        "{}  ◆ Notebook:{} {}",
        colors::CYAN,
        colors::RESET,
        path.display()
    );

    let config = ServerConfig {
        host: "127.0.0.1".to_string(),
        port,
        open_browser: false,
    };

    println!(
        "{}  ◆ Server:{} http://{}:{}",
        colors::CYAN,
        colors::RESET,
        config.host,
        config.port
    );
    println!(
        "{}  ◆ WebSocket:{} ws://{}:{}/ws",
        colors::CYAN,
        colors::RESET,
        config.host,
        config.port
    );
    println!("{}", "─".repeat(50));
    println!("{}Press Ctrl+C to stop{}", colors::GREEN, colors::RESET);
    println!();

    // Run server (handles Ctrl+C internally with graceful shutdown)
    venus_server::serve(path, config).await?;

    // Clean up any remaining LSP processes
    venus_server::kill_all_lsp_processes().await;

    Ok(())
}