Vakyartha documentation

2001 assert_eq!(intent.reading.evidence, *evidence, "{text}");
2002 assert!(!intent.engagement.posture.open_commitment, "{text}");
2003 assert_ne!(
2004 intent.engagement.limits.approval_ceiling,
2005 crate::ApprovalCeiling::Ask,
2006 "{text}"
2007 );
2008 }
2009 // A recurrence adjective names a thing, not a schedule.
2010 let adjective = resolve_text("check whether the nightly job ran").intent();
2011 assert_ne!(adjective.reading.horizon, Horizon::Durable);
2012 assert!(!adjective.engagement.posture.open_commitment);
2013 let adverb = resolve_text("check the cloud bill nightly and alert me").intent();
2014 assert_eq!(adverb.reading.horizon, Horizon::Durable);
2015 // And the ones that should still fire, still do.
2016 let deploy = resolve_text("deploy the service to production").intent();
2017 assert_eq!(deploy.reading.stakes, Stakes::Irreversible);
2018 let nightly = resolve_text("check the cloud bill every day and alert me").intent();
2019 assert_eq!(nightly.reading.horizon, Horizon::Durable);
2020 assert!(nightly.engagement.posture.open_commitment);
2021 let cited = resolve_text("summarise the paper and cite your sources").intent();
2022 assert_eq!(cited.reading.evidence, Evidence::Cited);
2023 }
2024
2025 /// Temporal words ask for a live value only beside a request for a fact.
2026 #[test]
2027 fn live_data_follows_a_request_for_a_fact() {
2028 for text in [
2029 "what is the current price of copper",
2030 "what's the weather in Delhi today",
2031 "give me the latest headlines",
2032 ] {
2033 let intent = resolve_text(text).intent();
2034 assert!(intent.reading.domains.contains("live-data"), "{text}");
2035 }
2036 for text in [
2037 "Refactor the current implementation of the parser to use a state machine",
2038 "update the README to reflect the latest changes",
2039 "fix the live reload bug in the dev server",
2040 "hello there, how are you doing today",
2041 "what time is it right now",
2042 ] {
2043 let intent = resolve_text(text).intent();
2044 assert!(!intent.reading.domains.contains("live-data"), "{text}");
2045 }
2046 }
2047
2048 /// A question about an effect is a question: no effect is demanded.
2049 #[test]
2050 fn a_question_about_an_effect_demands_no_effect() {
2051 let intent = resolve_text("Did the email send?").intent();
2052 assert_eq!(intent.reading.act, Act::Answer);
2053 assert_eq!(intent.engagement.posture.stop, crate::StopProfile::Message);
2054 assert_ne!(intent.reading.stakes, Stakes::Irreversible);
2055 }
2056
2057 /// Pasted material is read as material: one question about a log is one
2058 /// part, whatever the log's lines say.
2059 #[test]
2060 fn a_pasted_log_is_material_not_parts() {
2061 let mut text = String::from("why is this service failing? here is the log:\n");
2062 for i in 0..300 {
2063 let verb = ["check", "update", "send", "delete", "deploy"][i % 5];
2064 text.push_str(&format!(
2065 "2026-09-26T10:{:02}:{:02}Z INFO worker {verb} job {i} for customer account\n",
2066 i / 60,
2067 i % 60
2068 ));
2069 }
2070 let intent = resolve_text(&text).intent();
2071 assert_eq!(intent.strands.len(), 1, "{}", intent.strands.len());
2072 assert_eq!(intent.reading.act, Act::Answer);
2073 assert_ne!(intent.reading.stakes, Stakes::Irreversible);
2074 assert!(intent.engagement.posture.note.is_none());
2075 }
2076
2077 /// Resolution is linear in the size of the request. A 50 KB paste took
2078 /// 105 s in a release build when every fold re-extracted the text.
2079 #[test]
2080 fn a_large_paste_resolves_quickly() {
2081 let mut text = String::from("analyze this data:\n");
2082 for i in 0..2_000 {
2083 text.push_str(&format!(
2084 "{i},{},{},north,widget-{}\n",
2085 i * 3,
2086 i % 7,
2087 i % 13
2088 ));
2089 }
2090 let started = std::time::Instant::now();
2091 let intent = resolve_text(&text).intent();
2092 assert!(
2093 started.elapsed() < std::time::Duration::from_secs(2),
2094 "{:?}",
2095 started.elapsed()
2096 );
2097 assert_eq!(intent.reading.act, Act::Analyze);
2098 }
2099
2100 /// Any number of real parts is supported; the note stays bounded.
2101 #[test]
2102 fn many_parts_are_all_read_and_the_note_stays_bounded() {
2103 let mut text = String::from("do these:\n");
2104 for i in 0..20 {
2105 text.push_str(&format!("{}. fix the parser case {i}\n", i + 1));
2106 }
2107 let intent = resolve_text(&text).intent();
2108 assert_eq!(intent.strands.len(), 20);
2109 let note = intent.engagement.posture.note.as_deref().unwrap();
2110 assert!(note.contains("20 parts"), "{note}");
2111 assert!(note.lines().count() <= 2 * LISTED_PARTS + 4, "{note}");
2112 // No part is labelled with the runtime's own act names.
2113 for act in Act::ALL {
2114 assert!(!note.contains(&format!(": {}", act.as_str())), "{note}");
2115 }
2116 }
2117
2118 /// A below-floor reading keeps what it *observed*: an attached image is a
2119 /// fact, and the ledger must not record a text-only turn.
2120 #[test]
2121 fn the_orienting_fallback_keeps_observed_modalities() {
2122 let attachments = vec![crate::Attachment {
2123 modality: Modality::Image,
2124 name: "x.png".into(),
2125 }];
2126 let mut req = request("zorble the frobnicator");
2127 req.attachments = &attachments;
2128 let config = ResolverConfig {
2129 provisional_confidence: 0.6,
2130 ..ResolverConfig::default()
2131 };
2132 let intent = resolve(&req, &Declared::default(), &Authority::default(), &config).intent();
2133 assert_eq!(intent.provenance.tier, Tier::General);
2134 assert!(intent.reading.input_modalities.contains(&Modality::Image));
2135 assert!(
2136 intent
2137 .engagement
2138 .limits
2139 .required_modalities
2140 .contains(&Modality::Image)
2141 );
2142 }
2143
2144 #[test]
2145 fn an_envelope_narrows_the_strands_it_covers() {
2146 let mut req = request("refactor the parser");
2147 req.turn_id = "turn";
2148 let intent = resolve(
2149 &req,
2150 &Declared::default(),
2151 &Authority::default(),
2152 &ResolverConfig::default(),
2153 )
2154 .intent();
2155 let envelope = Envelope {
2156 envelope_id: "env".into(),
2157 granted_by: "operator".into(),
2158 granted_at: now(),
2159 expires_at: None,
2160 spend_limit_usd: Some(2.0),
2161 path_scope: Vec::new(),
2162 tool_scope: Vec::new(),
2163 permission_ceiling: crate::PermissionCeiling::WorkspaceWrite,
2164 escalation: crate::Escalation::WaitIndefinitely,
2165 revoked_at: None,
2166 };
2167 let envelopes = BTreeMap::from([("turn.0".to_string(), envelope.clone())]);
2168 let narrowed = apply_envelopes(intent.clone(), &envelopes, Autonomy::Delegated, now());
2169 assert_eq!(
2170 narrowed.engagement.limits.permission_ceiling,
2171 crate::PermissionCeiling::WorkspaceWrite
2172 );
2173 assert_eq!(narrowed.engagement.limits.spend_ceiling_usd, Some(2.0));
2174 assert_eq!(narrowed.engagement.posture.hil, HilMode::Envelope);
2175 assert!(
2176 narrowed
2177 .engagement
2178 .limits
2179 .is_at_most(&intent.engagement.limits)
2180 );
2181
2182 // A revoked grant narrows nothing and grants nothing.
2183 let mut revoked = envelope;
2184 revoked.revoked_at = Some(now());
2185 let untouched = apply_envelopes(
2186 intent.clone(),
2187 &BTreeMap::from([("turn.0".to_string(), revoked)]),
2188 Autonomy::Delegated,
2189 now(),
2190 );
2191 assert_eq!(untouched, intent);
2192 }
2193}
2194

2001 assert_eq!(intent.reading.evidence, *evidence, "{text}");
2002 assert!(!intent.engagement.posture.open_commitment, "{text}");
2003 assert_ne!(
2004 intent.engagement.limits.approval_ceiling,
2005 crate::ApprovalCeiling::Ask,
2006 "{text}"
2007 );
2008 }
2009 // A recurrence adjective names a thing, not a schedule.
2010 let adjective = resolve_text("check whether the nightly job ran").intent();
2011 assert_ne!(adjective.reading.horizon, Horizon::Durable);
2012 assert!(!adjective.engagement.posture.open_commitment);
2013 let adverb = resolve_text("check the cloud bill nightly and alert me").intent();
2014 assert_eq!(adverb.reading.horizon, Horizon::Durable);
2015 // And the ones that should still fire, still do.
2016 let deploy = resolve_text("deploy the service to production").intent();
2017 assert_eq!(deploy.reading.stakes, Stakes::Irreversible);
2018 let nightly = resolve_text("check the cloud bill every day and alert me").intent();
2019 assert_eq!(nightly.reading.horizon, Horizon::Durable);
2020 assert!(nightly.engagement.posture.open_commitment);
2021 let cited = resolve_text("summarise the paper and cite your sources").intent();
2022 assert_eq!(cited.reading.evidence, Evidence::Cited);
2023 }
2024
2025 /// Temporal words ask for a live value only beside a request for a fact.
2026 #[test]
2027 fn live_data_follows_a_request_for_a_fact() {
2028 for text in [
2029 "what is the current price of copper",
2030 "what's the weather in Delhi today",
2031 "give me the latest headlines",
2032 ] {
2033 let intent = resolve_text(text).intent();
2034 assert!(intent.reading.domains.contains("live-data"), "{text}");
2035 }
2036 for text in [
2037 "Refactor the current implementation of the parser to use a state machine",
2038 "update the README to reflect the latest changes",
2039 "fix the live reload bug in the dev server",
2040 "hello there, how are you doing today",
2041 "what time is it right now",
2042 ] {
2043 let intent = resolve_text(text).intent();
2044 assert!(!intent.reading.domains.contains("live-data"), "{text}");
2045 }
2046 }
2047
2048 /// A question about an effect is a question: no effect is demanded.
2049 #[test]
2050 fn a_question_about_an_effect_demands_no_effect() {
2051 let intent = resolve_text("Did the email send?").intent();
2052 assert_eq!(intent.reading.act, Act::Answer);
2053 assert_eq!(intent.engagement.posture.stop, crate::StopProfile::Message);
2054 assert_ne!(intent.reading.stakes, Stakes::Irreversible);
2055 }
2056
2057 /// Pasted material is read as material: one question about a log is one
2058 /// part, whatever the log's lines say.
2059 #[test]
2060 fn a_pasted_log_is_material_not_parts() {
2061 let mut text = String::from("why is this service failing? here is the log:\n");
2062 for i in 0..300 {
2063 let verb = ["check", "update", "send", "delete", "deploy"][i % 5];
2064 text.push_str(&format!(
2065 "2026-09-26T10:{:02}:{:02}Z INFO worker {verb} job {i} for customer account\n",
2066 i / 60,
2067 i % 60
2068 ));
2069 }
2070 let intent = resolve_text(&text).intent();
2071 assert_eq!(intent.strands.len(), 1, "{}", intent.strands.len());
2072 assert_eq!(intent.reading.act, Act::Answer);
2073 assert_ne!(intent.reading.stakes, Stakes::Irreversible);
2074 assert!(intent.engagement.posture.note.is_none());
2075 }
2076
2077 /// Resolution is linear in the size of the request. A 50 KB paste took
2078 /// 105 s in a release build when every fold re-extracted the text.
2079 #[test]
2080 fn a_large_paste_resolves_quickly() {
2081 let mut text = String::from("analyze this data:\n");
2082 for i in 0..2_000 {
2083 text.push_str(&format!(
2084 "{i},{},{},north,widget-{}\n",
2085 i * 3,
2086 i % 7,
2087 i % 13
2088 ));
2089 }
2090 let started = std::time::Instant::now();
2091 let intent = resolve_text(&text).intent();
2092 assert!(
2093 started.elapsed() < std::time::Duration::from_secs(2),
2094 "{:?}",
2095 started.elapsed()
2096 );
2097 assert_eq!(intent.reading.act, Act::Analyze);
2098 }
2099
2100 /// Any number of real parts is supported; the note stays bounded.
2101 #[test]
2102 fn many_parts_are_all_read_and_the_note_stays_bounded() {
2103 let mut text = String::from("do these:\n");
2104 for i in 0..20 {
2105 text.push_str(&format!("{}. fix the parser case {i}\n", i + 1));
2106 }
2107 let intent = resolve_text(&text).intent();
2108 assert_eq!(intent.strands.len(), 20);
2109 let note = intent.engagement.posture.note.as_deref().unwrap();
2110 assert!(note.contains("20 parts"), "{note}");
2111 assert!(note.lines().count() <= 2 * LISTED_PARTS + 4, "{note}");
2112 // No part is labelled with the runtime's own act names.
2113 for act in Act::ALL {
2114 assert!(!note.contains(&format!(": {}", act.as_str())), "{note}");
2115 }
2116 }
2117
2118 /// A below-floor reading keeps what it *observed*: an attached image is a
2119 /// fact, and the ledger must not record a text-only turn.
2120 #[test]
2121 fn the_orienting_fallback_keeps_observed_modalities() {
2122 let attachments = vec![crate::Attachment {
2123 modality: Modality::Image,
2124 name: "x.png".into(),
2125 }];
2126 let mut req = request("zorble the frobnicator");
2127 req.attachments = &attachments;
2128 let config = ResolverConfig {
2129 provisional_confidence: 0.6,
2130 ..ResolverConfig::default()
2131 };
2132 let intent = resolve(&req, &Declared::default(), &Authority::default(), &config).intent();
2133 assert_eq!(intent.provenance.tier, Tier::General);
2134 assert!(intent.reading.input_modalities.contains(&Modality::Image));
2135 assert!(
2136 intent
2137 .engagement
2138 .limits
2139 .required_modalities
2140 .contains(&Modality::Image)
2141 );
2142 }
2143
2144 #[test]
2145 fn an_envelope_narrows_the_strands_it_covers() {
2146 let mut req = request("refactor the parser");
2147 req.turn_id = "turn";
2148 let intent = resolve(
2149 &req,
2150 &Declared::default(),
2151 &Authority::default(),
2152 &ResolverConfig::default(),
2153 )
2154 .intent();
2155 let envelope = Envelope {
2156 envelope_id: "env".into(),
2157 granted_by: "operator".into(),
2158 granted_at: now(),
2159 expires_at: None,
2160 spend_limit_usd: Some(2.0),
2161 path_scope: Vec::new(),
2162 tool_scope: Vec::new(),
2163 permission_ceiling: crate::PermissionCeiling::WorkspaceWrite,
2164 escalation: crate::Escalation::WaitIndefinitely,
2165 revoked_at: None,
2166 };
2167 let envelopes = BTreeMap::from([("turn.0".to_string(), envelope.clone())]);
2168 let narrowed = apply_envelopes(intent.clone(), &envelopes, Autonomy::Delegated, now());
2169 assert_eq!(
2170 narrowed.engagement.limits.permission_ceiling,
2171 crate::PermissionCeiling::WorkspaceWrite
2172 );
2173 assert_eq!(narrowed.engagement.limits.spend_ceiling_usd, Some(2.0));
2174 assert_eq!(narrowed.engagement.posture.hil, HilMode::Envelope);
2175 assert!(
2176 narrowed
2177 .engagement
2178 .limits
2179 .is_at_most(&intent.engagement.limits)
2180 );
2181
2182 // A revoked grant narrows nothing and grants nothing.
2183 let mut revoked = envelope;
2184 revoked.revoked_at = Some(now());
2185 let untouched = apply_envelopes(
2186 intent.clone(),
2187 &BTreeMap::from([("turn.0".to_string(), revoked)]),
2188 Autonomy::Delegated,
2189 now(),
2190 );
2191 assert_eq!(untouched, intent);
2192 }
2193}
2194

Indexing the workspace…