nowaki 0.2.0

A fast full-stack web framework with a Rust toolchain and islands architecture
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

use std::path::Path;
use std::process::Stdio;

use anyhow::{anyhow, Context, Result};
use tokio::io::{AsyncBufReadExt, BufReader};
use tokio::process::{Child, Command};

/// SSRサイドカー (Nodeプロセス)。stdoutの READY 行からポートを得る。
pub struct Sidecar {
    pub port: u16,
    #[allow(dead_code)] // Dropでkillさせるために保持する
    child: Child,
}

pub async fn spawn(root: &Path, rust_port: u16) -> Result<Sidecar> {
    let entry = root.join("node_modules/@nowaki-dev/runtime/server/sidecar.mjs");
    if !entry.exists() {
        return Err(anyhow!(
            "@nowaki-dev/runtime が見つかりません ({}). アプリで `pnpm install` を実行してください",
            entry.display()
        ));
    }

    let mut child = Command::new("node")
        .arg(&entry)
        .current_dir(root)
        .env("NOWAKI_RUST_PORT", rust_port.to_string())
        .stdout(Stdio::piped())
        .stderr(Stdio::inherit())
        .kill_on_drop(true)
        .spawn()
        .context("nodeの起動に失敗しました")?;

    let stdout = child.stdout.take().expect("piped stdout");
    let mut lines = BufReader::new(stdout).lines();
    let mut port = None;
    while let Some(line) = lines.next_line().await? {
        if let Some(rest) = line.strip_prefix("NOWAKI_SIDECAR_READY ") {
            port = Some(
                rest.trim()
                    .parse::<u16>()
                    .context("サイドカーのポートが不正です")?,
            );
            break;
        }
        println!("[sidecar] {line}");
    }
    let port = port.ok_or_else(|| anyhow!("サイドカーがREADYを報告せずに終了しました"))?;

    // 以降のstdoutはログとして流し続ける
    tokio::spawn(async move {
        while let Ok(Some(line)) = lines.next_line().await {
            println!("[sidecar] {line}");
        }
    });

    Ok(Sidecar { port, child })
}