loopflow 0.12.31

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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112

//! Inspect the same budgets and local source snapshot used at launch.

use anyhow::{anyhow, Result};
use serde::Serialize;

use crate::engine::config::load_config;
use crate::engine::context_budget::ContextBudgetReport;
use crate::engine::exec::{preview_exec_prompt, ExecPromptInput};
use crate::engine::prompt::Surface;

#[derive(Debug, Serialize)]
struct ContextReport {
    checkout: std::path::PathBuf,
    wave: Option<String>,
    task: Option<String>,
    skill: String,
    goal_status: String,
    context: ContextBudgetReport,
}

pub fn run(json: bool, wave: Option<&str>, task: Option<&str>, skill: &str) -> Result<()> {
    let mut repo = crate::repo::require_repo_root(&std::env::current_dir()?, "lf context")?;
    let runtime = tokio::runtime::Runtime::new()?;
    let (binding, message) = runtime.block_on(async {
        let Some(store) = crate::store::open_existing_store().await else {
            anyhow::ensure!(task.is_none(), "Task usage unavailable: no local registry");
            return Ok::<_, anyhow::Error>((None, None));
        };
        let store = std::sync::Arc::new(store);
        let binding = if let Some(task) = task {
            Some(crate::ops::resolve_work_binding(&store, &repo, &format!("task:{task}")).await?)
        } else if wave.is_none() {
            crate::ops::resolve_execution_binding(&store, &repo).await?
        } else {
            None
        };
        let message = if let Some(binding) = &binding {
            if let crate::durable::WorkRef::Task(id) = &binding.work {
                let task = store
                    .get_task(id)
                    .await?
                    .ok_or_else(|| anyhow!("Task {id} is missing"))?;
                Some(
                    crate::ops::task_input::read_seed(&store, &task, &binding.wave_name, 0)
                        .await?
                        .message,
                )
            } else {
                Some(binding.context.clone())
            }
        } else {
            None
        };
        Ok((binding, message))
    })?;
    if let Some(binding) = &binding {
        repo = binding.cwd.clone();
    }
    let wave = wave
        .map(str::to_owned)
        .or_else(|| binding.as_ref().map(|binding| binding.wave_name.clone()))
        .or_else(crate::work::wave::context::resolve_ambient_wave_name);
    let task = binding.as_ref().and_then(|binding| match &binding.work {
        crate::durable::WorkRef::Task(id) => Some(id.to_string()),
        _ => None,
    });
    let goal_status = if message.is_some() {
        "local Work seed, including all stored steers"
    } else {
        "no Work seed selected; arbitrary launch messages are not included"
    }
    .to_string();
    let config = load_config(Some(&repo))?.unwrap_or_default();
    let prepared = preview_exec_prompt(
        &config,
        ExecPromptInput {
            repo_root: repo.clone(),
            wave: wave.clone(),
            message,
            skill: Some(skill.to_owned()),
            surface: Surface::Headless,
            // A query never reads the desktop clipboard.
            source_overrides: crate::engine::exec::ContextSourceOverrides {
                clipboard: Some(false),
                ..Default::default()
            },
            ..Default::default()
        },
    )?;
    let report = ContextReport {
        checkout: repo,
        wave,
        task,
        skill: skill.into(),
        goal_status,
        context: prepared.budget_report,
    };
    if json {
        println!("{}", serde_json::to_string_pretty(&report)?);
    } else {
        println!(
            "Checkout: {}\nWave: {}\nTask: {}\nSkill: {}\nGoal: {}\n{}",
            report.checkout.display(),
            report.wave.as_deref().unwrap_or("none"),
            report.task.as_deref().unwrap_or("none"),
            report.skill,
            report.goal_status,
            report.context.render()
        );
    }
    Ok(())
}