loopflow 0.11.1

Run steps and flows with coding agents
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

//! Test fixtures shared by the command modules that talk to a wave: a temp
//! store, a wave row, and a booted HTTP surface. They live here rather than in
//! `loopflow-test-support` because they are made of loopflow's own types, and
//! that crate must not depend back on this one.

use std::path::Path;
use std::sync::Arc;

use crate::id::WaveId;
use crate::store::{open_store, SharedStore, StorageConfig};
use crate::wave::runtime::{InboxItem, WaveRuntime};
use crate::wave::server;
use crate::wave::Wave;

pub(crate) async fn temp_store(dir: &Path) -> SharedStore {
    Arc::new(
        open_store(&StorageConfig::sqlite(dir.join("loopflow.db")))
            .await
            .expect("open sqlite store"),
    )
}

pub(crate) fn make_wave(name: &str, repo: &Path, parent: Option<&WaveId>) -> Wave {
    let mut wave = Wave::new(WaveId::new(), name.to_string(), repo.display().to_string());
    wave.parent_wave_id = parent.cloned();
    wave
}

/// Boot the HTTP surface over a runtime (the wave/mod.rs harness pattern).
/// The inbox receiver is subscribed before serving, so a caller can assert on
/// ops the door delivers.
pub(crate) async fn boot_server(
    origin: &Path,
    wave: &str,
) -> (
    String,
    Arc<WaveRuntime>,
    tokio::sync::broadcast::Receiver<InboxItem>,
) {
    let runtime = WaveRuntime::open(wave.to_string(), origin.to_path_buf()).expect("open runtime");
    let inbox_rx = runtime.subscribe_inbox();
    let listener = tokio::net::TcpListener::bind("127.0.0.1:0").await.unwrap();
    let addr = listener.local_addr().unwrap();
    server::write_endpoint(origin, wave, addr).expect("write endpoint pointer");
    let app = server::router(
        runtime.clone(),
        server::ResidentDoor::new("test-token"),
        None,
        None,
        server::ShutdownDoor::new(),
    );
    tokio::spawn(async move {
        axum::serve(listener, app).await.ok();
    });
    (addr.to_string(), runtime, inbox_rx)
}