Function persistent_root_lock_rejects_cross_process_open

tests/runtime_smoke.rs:697–737

()

#[test]
fn persistent_root_lock_rejects_cross_process_open() -> anyhow::Result<()> {
    let root = tempfile::TempDir::new()?;
    let child = Command::new(env!("CARGO_BIN_EXE_pglite-proxy"))
        .arg("--root")
        .arg(root.path())
        .args(["--tcp", "127.0.0.1:0", "--print-uri"])
        .stdout(Stdio::piped())
        .stderr(Stdio::piped())
        .spawn()?;
    let mut child = ChildGuard::new(child, "pglite-proxy")?;

    let stdout = child
        .child_mut()
        .stdout
        .take()
        .ok_or_else(|| anyhow::anyhow!("missing pglite-proxy stdout"))?;
    let mut line = String::new();
    let read = BufReader::new(stdout).read_line(&mut line)?;
    if read == 0 {
        let stderr = child.collect_stderr();
        anyhow::bail!("pglite-proxy exited before printing URI\n\nstderr:\n{stderr}");
    }
    assert!(line.starts_with("postgresql://"), "{line:?}");

    let err = match Pglite::builder().path(root.path()).open() {
        Ok(mut db) => {
            let close = db.close();
            let stderr = child.collect_stderr();
            anyhow::bail!(
                "direct open unexpectedly succeeded while another process owns the root lock; close={close:?}\n\nstderr:\n{stderr}"
            );
        }
        Err(err) => err,
    };
    let message = format!("{err:#}");
    if !message.contains("PGlite root is already in use") {
        let stderr = child.collect_stderr();
        anyhow::bail!("unexpected cross-process root-lock error: {message}\n\nstderr:\n{stderr}");
    }
    Ok(())
}

#[test]
fn runtime_smoke() -> anyhow::Result<()> {