1use super::errors::PackageError;
2use super::*;
3
4pub(crate) fn manifest_capabilities(
5 manifest: &Manifest,
6) -> Option<&harn_vm::llm::capabilities::CapabilitiesFile> {
7 manifest.capabilities.as_ref()
8}
9
10pub(crate) fn is_empty_capabilities(file: &harn_vm::llm::capabilities::CapabilitiesFile) -> bool {
11 file.provider.is_empty() && file.provider_family.is_empty()
12}
13
14pub fn validate_runtime_manifest_extensions(anchor: &Path) -> Result<(), PackageError> {
15 let Some((manifest, _manifest_dir)) = find_nearest_manifest(anchor) else {
16 return Ok(());
17 };
18 validate_handoff_routes(&manifest.handoff_routes, &manifest)
19}
20
21pub fn try_load_runtime_extensions(anchor: &Path) -> Result<RuntimeExtensions, PackageError> {
24 ensure_dependencies_materialized(anchor)?;
25 let Some((root_manifest, manifest_dir)) = find_nearest_manifest(anchor) else {
26 return Ok(RuntimeExtensions::default());
27 };
28
29 let mut llm = harn_vm::llm_config::ProvidersConfig::default();
30 let mut capabilities = harn_vm::llm::capabilities::CapabilitiesFile::default();
31 let mut hooks = Vec::new();
32 let mut triggers = Vec::new();
33
34 llm.merge_from(&root_manifest.llm);
35 if let Some(file) = manifest_capabilities(&root_manifest) {
36 merge_capability_overrides(&mut capabilities, file);
37 }
38 hooks.extend(resolved_hooks_from_manifest(&root_manifest, &manifest_dir));
39 triggers.extend(resolved_triggers_from_manifest(
40 &root_manifest,
41 &manifest_dir,
42 ));
43 let handoff_routes = root_manifest.handoff_routes.clone();
44 validate_handoff_routes(&handoff_routes, &root_manifest)?;
45 let provider_connectors =
46 resolved_provider_connectors_from_manifest(&root_manifest, &manifest_dir);
47
48 Ok(RuntimeExtensions {
49 root_manifest_path: Some(manifest_dir.join(MANIFEST)),
50 root_manifest_dir: Some(manifest_dir),
51 root_manifest: Some(root_manifest),
52 llm: (!llm.is_empty()).then_some(llm),
53 capabilities: (!is_empty_capabilities(&capabilities)).then_some(capabilities),
54 hooks,
55 triggers,
56 handoff_routes,
57 provider_connectors,
58 })
59}
60
61pub fn load_runtime_extensions(anchor: &Path) -> RuntimeExtensions {
62 match try_load_runtime_extensions(anchor) {
63 Ok(extensions) => extensions,
64 Err(error) => {
65 eprintln!("error: {error}");
66 process::exit(1);
67 }
68 }
69}
70
71pub fn install_runtime_extensions(extensions: &RuntimeExtensions) {
73 harn_vm::llm_config::set_user_overrides(extensions.llm.clone());
74 harn_vm::llm::capabilities::set_user_overrides(extensions.capabilities.clone());
75 install_manifest_handoff_routes(extensions);
76 install_orchestrator_budget(extensions);
77}
78
79pub fn install_manifest_handoff_routes(extensions: &RuntimeExtensions) {
80 harn_vm::install_handoff_routes(extensions.handoff_routes.clone());
81}
82
83pub fn install_orchestrator_budget(extensions: &RuntimeExtensions) {
84 let budget = extensions
85 .root_manifest
86 .as_ref()
87 .map(|manifest| harn_vm::OrchestratorBudgetConfig {
88 daily_cost_usd: manifest.orchestrator.budget.daily_cost_usd,
89 hourly_cost_usd: manifest.orchestrator.budget.hourly_cost_usd,
90 })
91 .unwrap_or_default();
92 harn_vm::install_orchestrator_budget(budget);
93}
94
95pub async fn install_manifest_hooks(
96 vm: &mut harn_vm::Vm,
97 extensions: &RuntimeExtensions,
98) -> Result<(), PackageError> {
99 harn_vm::orchestration::clear_runtime_hooks();
100 let mut loaded_exports: HashMap<ManifestModuleCacheKey, ManifestModuleExports> = HashMap::new();
101 for hook in &extensions.hooks {
102 let Some((module_name, function_name)) = hook.handler.rsplit_once("::") else {
103 return Err(format!(
104 "invalid hook handler '{}': expected <module>::<function>",
105 hook.handler
106 )
107 .into());
108 };
109 let cache_key = (
110 hook.manifest_dir.clone(),
111 hook.package_name.clone(),
112 Some(module_name.to_string()),
113 );
114 if !loaded_exports.contains_key(&cache_key) {
115 let exports = resolve_manifest_exports(
116 vm,
117 &hook.manifest_dir,
118 hook.package_name.as_deref(),
119 &hook.exports,
120 Some(module_name),
121 )
122 .await?;
123 loaded_exports.insert(cache_key.clone(), exports);
124 }
125 let exports = loaded_exports
126 .get(&cache_key)
127 .expect("manifest hook exports cached");
128 let Some(closure) = exports.get(function_name) else {
129 return Err(format!(
130 "hook handler '{}' is not exported by module '{}'",
131 function_name, module_name
132 )
133 .into());
134 };
135 harn_vm::orchestration::register_vm_hook(
136 hook.event,
137 hook.pattern.clone(),
138 hook.handler.clone(),
139 closure.clone(),
140 );
141 }
142 Ok(())
143}
144
145pub async fn collect_manifest_triggers(
146 vm: &mut harn_vm::Vm,
147 extensions: &RuntimeExtensions,
148) -> Result<Vec<CollectedManifestTrigger>, PackageError> {
149 let _provider_schema_guard = lock_manifest_provider_schemas().await;
150 install_manifest_provider_schemas(extensions).await?;
151 validate_orchestrator_budget(extensions.root_manifest.as_ref())?;
152 validate_static_trigger_configs(&extensions.triggers)?;
153 let mut loaded_exports: HashMap<ManifestModuleCacheKey, ManifestModuleExports> = HashMap::new();
154 let mut module_signatures: HashMap<PathBuf, BTreeMap<String, TriggerFunctionSignature>> =
155 HashMap::new();
156 let mut collected = Vec::new();
157
158 for trigger in &extensions.triggers {
159 let handler = parse_trigger_handler_uri(trigger)?;
160 let collected_handler = match handler {
161 TriggerHandlerUri::Local(reference) => {
162 let cache_key = (
163 trigger.manifest_dir.clone(),
164 trigger.package_name.clone(),
165 reference.module_name.clone(),
166 );
167 if !loaded_exports.contains_key(&cache_key) {
168 let exports = resolve_manifest_exports(
169 vm,
170 &trigger.manifest_dir,
171 trigger.package_name.as_deref(),
172 &trigger.exports,
173 reference.module_name.as_deref(),
174 )
175 .await
176 .map_err(|error| trigger_error(trigger, error))?;
177 loaded_exports.insert(cache_key.clone(), exports);
178 }
179 let exports = loaded_exports
180 .get(&cache_key)
181 .expect("manifest trigger exports cached");
182 let Some(closure) = exports.get(&reference.function_name) else {
183 return Err(trigger_error(
184 trigger,
185 format!(
186 "handler '{}' is not exported by the resolved module",
187 reference.raw
188 ),
189 ));
190 };
191 CollectedTriggerHandler::Local {
192 reference,
193 closure: closure.clone(),
194 }
195 }
196 TriggerHandlerUri::A2a {
197 target,
198 allow_cleartext,
199 } => CollectedTriggerHandler::A2a {
200 target,
201 allow_cleartext,
202 },
203 TriggerHandlerUri::Worker { queue } => CollectedTriggerHandler::Worker { queue },
204 TriggerHandlerUri::Persona { name } => {
205 let binding = persona_runtime_binding_for_handler(extensions, trigger, &name)?;
206 CollectedTriggerHandler::Persona { binding }
207 }
208 };
209
210 let collected_when = if let Some(when_raw) = &trigger.when {
211 let reference = parse_local_trigger_ref(when_raw, "when", trigger)?;
212 let cache_key = (
213 trigger.manifest_dir.clone(),
214 trigger.package_name.clone(),
215 reference.module_name.clone(),
216 );
217 if !loaded_exports.contains_key(&cache_key) {
218 let exports = resolve_manifest_exports(
219 vm,
220 &trigger.manifest_dir,
221 trigger.package_name.as_deref(),
222 &trigger.exports,
223 reference.module_name.as_deref(),
224 )
225 .await
226 .map_err(|error| trigger_error(trigger, error))?;
227 loaded_exports.insert(cache_key.clone(), exports);
228 }
229 let exports = loaded_exports
230 .get(&cache_key)
231 .expect("manifest trigger predicate exports cached");
232 let Some(closure) = exports.get(&reference.function_name) else {
233 return Err(trigger_error(
234 trigger,
235 format!(
236 "when predicate '{}' is not exported by the resolved module",
237 reference.raw
238 ),
239 ));
240 };
241
242 let source_path = manifest_module_source_path(
243 &trigger.manifest_dir,
244 trigger.package_name.as_deref(),
245 &trigger.exports,
246 reference.module_name.as_deref(),
247 )
248 .map_err(|error| trigger_error(trigger, error))?;
249 if !module_signatures.contains_key(&source_path) {
250 let signatures = load_trigger_function_signatures(&source_path)
251 .map_err(|error| trigger_error(trigger, error))?;
252 module_signatures.insert(source_path.clone(), signatures);
253 }
254 let signatures = module_signatures
255 .get(&source_path)
256 .expect("module signatures cached");
257 let Some(signature) = signatures.get(&reference.function_name) else {
258 return Err(trigger_error(
259 trigger,
260 format!(
261 "when predicate '{}' must resolve to a function declaration",
262 reference.raw
263 ),
264 ));
265 };
266 if signature.params.len() != 1
267 || signature.params[0]
268 .as_ref()
269 .is_none_or(|param| !is_trigger_event_type(param))
270 {
271 return Err(trigger_error(
272 trigger,
273 format!(
274 "when predicate '{}' must have signature fn(TriggerEvent) -> bool",
275 reference.raw
276 ),
277 ));
278 }
279 if signature
280 .return_type
281 .as_ref()
282 .is_none_or(|return_type| !is_predicate_return_type(return_type))
283 {
284 return Err(trigger_error(
285 trigger,
286 format!(
287 "when predicate '{}' must have signature fn(TriggerEvent) -> bool or Result<bool, _>",
288 reference.raw
289 ),
290 ));
291 }
292
293 Some(CollectedTriggerPredicate {
294 reference,
295 closure: closure.clone(),
296 })
297 } else {
298 None
299 };
300
301 let flow_control = collect_trigger_flow_control(vm, trigger).await?;
302
303 collected.push(CollectedManifestTrigger {
304 config: trigger.clone(),
305 handler: collected_handler,
306 when: collected_when,
307 flow_control,
308 });
309 }
310
311 Ok(collected)
312}
313
314pub(crate) async fn collect_trigger_flow_control(
315 vm: &mut harn_vm::Vm,
316 trigger: &ResolvedTriggerConfig,
317) -> Result<harn_vm::TriggerFlowControlConfig, PackageError> {
318 let mut flow = harn_vm::TriggerFlowControlConfig::default();
319
320 let concurrency = if let Some(spec) = &trigger.concurrency {
321 Some(spec.clone())
322 } else if let Some(max) = trigger.budget.max_concurrent {
323 eprintln!(
324 "warning: {} uses deprecated budget.max_concurrent; prefer concurrency = {{ max = {} }}",
325 manifest_trigger_location(trigger),
326 max
327 );
328 Some(TriggerConcurrencyManifestSpec { key: None, max })
329 } else {
330 None
331 };
332 if let Some(spec) = concurrency {
333 flow.concurrency = Some(harn_vm::TriggerConcurrencyConfig {
334 key: compile_optional_trigger_expression(
335 vm,
336 trigger,
337 "concurrency.key",
338 spec.key.as_deref(),
339 )
340 .await?,
341 max: spec.max,
342 });
343 }
344
345 if let Some(spec) = &trigger.throttle {
346 flow.throttle = Some(harn_vm::TriggerThrottleConfig {
347 key: compile_optional_trigger_expression(
348 vm,
349 trigger,
350 "throttle.key",
351 spec.key.as_deref(),
352 )
353 .await?,
354 period: harn_vm::parse_flow_control_duration(&spec.period)
355 .map_err(|error| trigger_error(trigger, format!("throttle.period {error}")))?,
356 max: spec.max,
357 });
358 }
359
360 if let Some(spec) = &trigger.rate_limit {
361 flow.rate_limit = Some(harn_vm::TriggerRateLimitConfig {
362 key: compile_optional_trigger_expression(
363 vm,
364 trigger,
365 "rate_limit.key",
366 spec.key.as_deref(),
367 )
368 .await?,
369 period: harn_vm::parse_flow_control_duration(&spec.period)
370 .map_err(|error| trigger_error(trigger, format!("rate_limit.period {error}")))?,
371 max: spec.max,
372 });
373 }
374
375 if let Some(spec) = &trigger.debounce {
376 flow.debounce = Some(harn_vm::TriggerDebounceConfig {
377 key: compile_trigger_expression(vm, trigger, "debounce.key", &spec.key).await?,
378 period: harn_vm::parse_flow_control_duration(&spec.period)
379 .map_err(|error| trigger_error(trigger, format!("debounce.period {error}")))?,
380 });
381 }
382
383 if let Some(spec) = &trigger.singleton {
384 flow.singleton = Some(harn_vm::TriggerSingletonConfig {
385 key: compile_optional_trigger_expression(
386 vm,
387 trigger,
388 "singleton.key",
389 spec.key.as_deref(),
390 )
391 .await?,
392 });
393 }
394
395 if let Some(spec) = &trigger.batch {
396 flow.batch = Some(harn_vm::TriggerBatchConfig {
397 key: compile_optional_trigger_expression(vm, trigger, "batch.key", spec.key.as_deref())
398 .await?,
399 size: spec.size,
400 timeout: harn_vm::parse_flow_control_duration(&spec.timeout)
401 .map_err(|error| trigger_error(trigger, format!("batch.timeout {error}")))?,
402 });
403 }
404
405 if let Some(spec) = &trigger.priority_flow {
406 flow.priority = Some(harn_vm::TriggerPriorityOrderConfig {
407 key: compile_trigger_expression(vm, trigger, "priority.key", &spec.key).await?,
408 order: spec.order.clone(),
409 });
410 }
411
412 Ok(flow)
413}
414
415fn persona_runtime_binding_for_handler(
416 extensions: &RuntimeExtensions,
417 trigger: &ResolvedTriggerConfig,
418 name: &str,
419) -> Result<harn_vm::PersonaRuntimeBinding, PackageError> {
420 let Some(manifest) = extensions.root_manifest.as_ref() else {
421 return Err(trigger_error(
422 trigger,
423 format!("handler persona://{name} requires a root manifest"),
424 ));
425 };
426 let Some(persona) = manifest
427 .personas
428 .iter()
429 .find(|persona| persona.name.as_deref() == Some(name))
430 else {
431 return Err(trigger_error(
432 trigger,
433 format!("handler persona://{name} does not match a declared persona"),
434 ));
435 };
436 Ok(harn_vm::PersonaRuntimeBinding {
437 name: name.to_string(),
438 template_ref: persona_template_ref(persona),
439 entry_workflow: persona.entry_workflow.clone().unwrap_or_default(),
440 schedules: persona.schedules.clone(),
441 triggers: persona.triggers.clone(),
442 budget: harn_vm::PersonaBudgetPolicy {
443 daily_usd: persona.budget.daily_usd,
444 hourly_usd: persona.budget.hourly_usd,
445 run_usd: persona.budget.run_usd,
446 max_tokens: persona.budget.max_tokens,
447 },
448 })
449}
450
451pub(crate) async fn compile_optional_trigger_expression(
452 vm: &mut harn_vm::Vm,
453 trigger: &ResolvedTriggerConfig,
454 field_name: &str,
455 expr: Option<&str>,
456) -> Result<Option<harn_vm::TriggerExpressionSpec>, PackageError> {
457 match expr {
458 Some(expr) => compile_trigger_expression(vm, trigger, field_name, expr)
459 .await
460 .map(Some),
461 None => Ok(None),
462 }
463}
464
465pub(crate) async fn compile_trigger_expression(
466 vm: &mut harn_vm::Vm,
467 trigger: &ResolvedTriggerConfig,
468 field_name: &str,
469 expr: &str,
470) -> Result<harn_vm::TriggerExpressionSpec, PackageError> {
471 let synthetic = PathBuf::from(format!(
472 "<trigger-expr>/{}/{:04}-{}.harn",
473 harn_vm::event_log::sanitize_topic_component(&trigger.id),
474 trigger.table_index,
475 harn_vm::event_log::sanitize_topic_component(field_name),
476 ));
477 let source = format!(
478 "import \"std/triggers\"\n\npub fn __trigger_expr(event: TriggerEvent) -> any {{\n return {expr}\n}}\n"
479 );
480 let exports = vm
481 .load_module_exports_from_source(synthetic, &source)
482 .await
483 .map_err(|error| {
484 trigger_error(
485 trigger,
486 format!("{field_name} '{expr}' is invalid Harn expression: {error}"),
487 )
488 })?;
489 let closure = exports.get("__trigger_expr").ok_or_else(|| {
490 trigger_error(
491 trigger,
492 format!("{field_name} '{expr}' did not compile into an exported closure"),
493 )
494 })?;
495 Ok(harn_vm::TriggerExpressionSpec {
496 raw: expr.to_string(),
497 closure: closure.clone(),
498 })
499}
500
501pub(crate) fn trigger_kind_label(kind: TriggerKind) -> &'static str {
502 match kind {
503 TriggerKind::Webhook => "webhook",
504 TriggerKind::Cron => "cron",
505 TriggerKind::Poll => "poll",
506 TriggerKind::Stream => "stream",
507 TriggerKind::Predicate => "predicate",
508 TriggerKind::A2aPush => "a2a-push",
509 }
510}
511
512pub(crate) fn worker_queue_priority(
513 priority: TriggerDispatchPriority,
514) -> harn_vm::WorkerQueuePriority {
515 match priority {
516 TriggerDispatchPriority::High => harn_vm::WorkerQueuePriority::High,
517 TriggerDispatchPriority::Normal => harn_vm::WorkerQueuePriority::Normal,
518 TriggerDispatchPriority::Low => harn_vm::WorkerQueuePriority::Low,
519 }
520}
521
522pub fn manifest_trigger_binding_spec(
523 trigger: CollectedManifestTrigger,
524) -> harn_vm::TriggerBindingSpec {
525 let flow_control = trigger.flow_control.clone();
526 let config = trigger.config;
527 let (handler, handler_descriptor) = match trigger.handler {
528 CollectedTriggerHandler::Local { reference, closure } => (
529 harn_vm::TriggerHandlerSpec::Local {
530 raw: reference.raw.clone(),
531 closure,
532 },
533 serde_json::json!({
534 "kind": "local",
535 "raw": reference.raw,
536 }),
537 ),
538 CollectedTriggerHandler::A2a {
539 target,
540 allow_cleartext,
541 } => (
542 harn_vm::TriggerHandlerSpec::A2a {
543 target: target.clone(),
544 allow_cleartext,
545 },
546 serde_json::json!({
547 "kind": "a2a",
548 "target": target,
549 "allow_cleartext": allow_cleartext,
550 }),
551 ),
552 CollectedTriggerHandler::Worker { queue } => (
553 harn_vm::TriggerHandlerSpec::Worker {
554 queue: queue.clone(),
555 },
556 serde_json::json!({
557 "kind": "worker",
558 "queue": queue,
559 }),
560 ),
561 CollectedTriggerHandler::Persona { binding } => (
562 harn_vm::TriggerHandlerSpec::Persona {
563 binding: binding.clone(),
564 },
565 serde_json::json!({
566 "kind": "persona",
567 "name": binding.name,
568 "entry_workflow": binding.entry_workflow,
569 }),
570 ),
571 };
572
573 let when_raw = trigger
574 .when
575 .as_ref()
576 .map(|predicate| predicate.reference.raw.clone());
577 let when = trigger.when.map(|predicate| harn_vm::TriggerPredicateSpec {
578 raw: predicate.reference.raw,
579 closure: predicate.closure,
580 });
581 let mut when_budget = config
582 .when_budget
583 .as_ref()
584 .map(|budget| {
585 Ok::<harn_vm::TriggerPredicateBudget, String>(harn_vm::TriggerPredicateBudget {
586 max_cost_usd: budget.max_cost_usd,
587 tokens_max: budget.tokens_max,
588 timeout_ms: budget
589 .timeout
590 .as_deref()
591 .map(parse_duration_millis)
592 .transpose()?,
593 })
594 })
595 .transpose()
596 .unwrap_or_default();
597 if config.budget.max_cost_usd.is_some() || config.budget.max_tokens.is_some() {
598 let budget = when_budget.get_or_insert_with(harn_vm::TriggerPredicateBudget::default);
599 if budget.max_cost_usd.is_none() {
600 budget.max_cost_usd = config.budget.max_cost_usd;
601 }
602 if budget.tokens_max.is_none() {
603 budget.tokens_max = config.budget.max_tokens;
604 }
605 }
606 let id = config.id.clone();
607 let kind = trigger_kind_label(config.kind).to_string();
608 let provider = config.provider.clone();
609 let autonomy_tier = config.autonomy_tier;
610 let match_events = config.match_.events.clone();
611 let dedupe_key = config.dedupe_key.clone();
612 let retry = harn_vm::TriggerRetryConfig::new(
613 config.retry.max,
614 match config.retry.backoff {
615 TriggerRetryBackoff::Immediate => harn_vm::RetryPolicy::Linear { delay_ms: 0 },
616 TriggerRetryBackoff::Svix => harn_vm::RetryPolicy::Svix,
617 },
618 );
619 let filter = config.filter.clone();
620 let dedupe_retention_days = config.retry.retention_days;
621 let daily_cost_usd = config.budget.daily_cost_usd;
622 let hourly_cost_usd = config.budget.hourly_cost_usd;
623 let max_autonomous_decisions_per_hour = config.budget.max_autonomous_decisions_per_hour;
624 let max_autonomous_decisions_per_day = config.budget.max_autonomous_decisions_per_day;
625 let on_budget_exhausted = config.budget.on_budget_exhausted;
626 let max_concurrent = flow_control.concurrency.as_ref().map(|config| config.max);
627 let manifest_path = Some(config.manifest_path.clone());
628 let package_name = config.package_name.clone();
629
630 let fingerprint = serde_json::to_string(&serde_json::json!({
631 "id": &id,
632 "kind": &kind,
633 "provider": provider.as_str(),
634 "autonomy_tier": autonomy_tier,
635 "match": config.match_,
636 "when": when_raw,
637 "when_budget": config.when_budget,
638 "handler": handler_descriptor,
639 "dedupe_key": &dedupe_key,
640 "retry": config.retry,
641 "dispatch_priority": config.dispatch_priority,
642 "budget": config.budget,
643 "flow_control": {
644 "concurrency": config.concurrency,
645 "throttle": config.throttle,
646 "rate_limit": config.rate_limit,
647 "debounce": config.debounce,
648 "singleton": config.singleton,
649 "batch": config.batch,
650 "priority": config.priority_flow,
651 },
652 "window": config.window,
653 "secrets": config.secrets,
654 "filter": &filter,
655 "kind_specific": config.kind_specific,
656 "manifest_path": &manifest_path,
657 "package_name": &package_name,
658 }))
659 .unwrap_or_else(|_| format!("{}:{}:{}", id, kind, provider.as_str()));
660
661 harn_vm::TriggerBindingSpec {
662 id,
663 source: harn_vm::TriggerBindingSource::Manifest,
664 kind,
665 provider,
666 autonomy_tier,
667 handler,
668 dispatch_priority: worker_queue_priority(config.dispatch_priority),
669 when,
670 when_budget,
671 retry,
672 match_events,
673 dedupe_key,
674 filter,
675 dedupe_retention_days,
676 daily_cost_usd,
677 hourly_cost_usd,
678 max_autonomous_decisions_per_hour,
679 max_autonomous_decisions_per_day,
680 on_budget_exhausted,
681 max_concurrent,
682 flow_control,
683 manifest_path,
684 package_name,
685 definition_fingerprint: fingerprint,
686 }
687}
688
689pub async fn install_manifest_triggers(
690 vm: &mut harn_vm::Vm,
691 extensions: &RuntimeExtensions,
692) -> Result<(), PackageError> {
693 install_orchestrator_budget(extensions);
694 let collected = collect_manifest_triggers(vm, extensions).await?;
695 let mut bindings: Vec<_> = collected
696 .iter()
697 .cloned()
698 .map(manifest_trigger_binding_spec)
699 .collect();
700 bindings.extend(collect_persona_trigger_binding_specs(extensions)?);
701 harn_vm::install_manifest_triggers(bindings)
702 .await
703 .map_err(|error| PackageError::Extensions(error.to_string()))
704}
705
706pub async fn install_collected_manifest_triggers(
707 collected: &[CollectedManifestTrigger],
708) -> Result<(), PackageError> {
709 let bindings = collected
710 .iter()
711 .cloned()
712 .map(manifest_trigger_binding_spec)
713 .collect();
714 harn_vm::install_manifest_triggers(bindings)
715 .await
716 .map_err(|error| PackageError::Extensions(error.to_string()))
717}
718
719pub fn collect_persona_trigger_binding_specs(
720 extensions: &RuntimeExtensions,
721) -> Result<Vec<harn_vm::TriggerBindingSpec>, PackageError> {
722 let Some(manifest) = extensions.root_manifest.clone() else {
723 return Ok(Vec::new());
724 };
725 let manifest_path = extensions
726 .root_manifest_path
727 .clone()
728 .unwrap_or_else(|| PathBuf::from(MANIFEST));
729 let manifest_dir = extensions
730 .root_manifest_dir
731 .clone()
732 .or_else(|| manifest_path.parent().map(Path::to_path_buf))
733 .unwrap_or_else(|| PathBuf::from("."));
734 let resolved = validate_and_resolve_personas(manifest, manifest_path.clone(), manifest_dir)
735 .map_err(|errors| {
736 errors
737 .iter()
738 .map(ToString::to_string)
739 .collect::<Vec<_>>()
740 .join("\n")
741 })?;
742 let mut bindings = Vec::new();
743 for persona in resolved.personas {
744 let Some(name) = persona.name.clone() else {
745 continue;
746 };
747 for trigger in &persona.triggers {
748 let Some((provider, kind)) = trigger.split_once('.') else {
749 continue;
750 };
751 let provider = provider.trim();
752 let kind = kind.trim();
753 if provider.is_empty() || kind.is_empty() {
754 continue;
755 }
756 bindings.push(persona_trigger_binding_spec(
757 &resolved.manifest_path,
758 &name,
759 provider,
760 kind,
761 &persona,
762 ));
763 }
764 }
765 Ok(bindings)
766}
767
768fn persona_trigger_binding_spec(
769 manifest_path: &Path,
770 name: &str,
771 provider: &str,
772 kind: &str,
773 persona: &PersonaManifestEntry,
774) -> harn_vm::TriggerBindingSpec {
775 let runtime_binding = harn_vm::PersonaRuntimeBinding {
776 name: name.to_string(),
777 template_ref: persona_template_ref(persona),
778 entry_workflow: persona.entry_workflow.clone().unwrap_or_default(),
779 schedules: persona.schedules.clone(),
780 triggers: persona.triggers.clone(),
781 budget: harn_vm::PersonaBudgetPolicy {
782 daily_usd: persona.budget.daily_usd,
783 hourly_usd: persona.budget.hourly_usd,
784 run_usd: persona.budget.run_usd,
785 max_tokens: persona.budget.max_tokens,
786 },
787 };
788 let id = format!("persona.{name}.{provider}.{kind}");
789 let handler = harn_vm::TriggerHandlerSpec::Persona {
790 binding: runtime_binding.clone(),
791 };
792 let fingerprint = serde_json::to_string(&serde_json::json!({
793 "id": &id,
794 "kind": kind,
795 "provider": provider,
796 "handler": {
797 "kind": "persona",
798 "name": name,
799 "entry_workflow": runtime_binding.entry_workflow,
800 },
801 "budget": runtime_binding.budget,
802 "manifest_path": manifest_path,
803 }))
804 .unwrap_or_else(|_| format!("{id}:{provider}:{kind}:{name}"));
805
806 harn_vm::TriggerBindingSpec {
807 id,
808 source: harn_vm::TriggerBindingSource::Manifest,
809 kind: kind.to_string(),
810 provider: harn_vm::ProviderId::from(provider.to_string()),
811 autonomy_tier: persona
812 .autonomy_tier
813 .map(persona_autonomy_to_vm)
814 .unwrap_or(harn_vm::AutonomyTier::Suggest),
815 handler,
816 dispatch_priority: harn_vm::WorkerQueuePriority::Normal,
817 when: None,
818 when_budget: None,
819 retry: harn_vm::TriggerRetryConfig::default(),
820 match_events: vec![kind.to_string()],
821 dedupe_key: None,
822 filter: None,
823 dedupe_retention_days: 7,
824 daily_cost_usd: persona.budget.daily_usd,
825 hourly_cost_usd: persona.budget.hourly_usd,
826 max_autonomous_decisions_per_hour: None,
827 max_autonomous_decisions_per_day: None,
828 on_budget_exhausted: harn_vm::TriggerBudgetExhaustionStrategy::RetryLater,
829 max_concurrent: None,
830 flow_control: harn_vm::TriggerFlowControlConfig::default(),
831 manifest_path: Some(manifest_path.to_path_buf()),
832 package_name: None,
833 definition_fingerprint: fingerprint,
834 }
835}
836
837fn persona_autonomy_to_vm(value: PersonaAutonomyTier) -> harn_vm::AutonomyTier {
838 match value {
839 PersonaAutonomyTier::Shadow => harn_vm::AutonomyTier::Shadow,
840 PersonaAutonomyTier::Suggest => harn_vm::AutonomyTier::Suggest,
841 PersonaAutonomyTier::ActWithApproval => harn_vm::AutonomyTier::ActWithApproval,
842 PersonaAutonomyTier::ActAuto => harn_vm::AutonomyTier::ActAuto,
843 }
844}
845
846fn persona_template_ref(persona: &PersonaManifestEntry) -> Option<String> {
847 persona
848 .package_source
849 .package
850 .as_ref()
851 .zip(persona.version.as_ref())
852 .map(|(package, version)| format!("{package}@{version}"))
853 .or_else(|| persona.package_source.package.clone())
854 .or_else(|| {
855 persona
856 .name
857 .as_ref()
858 .zip(persona.version.as_ref())
859 .map(|(name, version)| format!("{name}@{version}"))
860 })
861}
862
863pub fn load_personas_from_manifest_path(
864 manifest_path: &Path,
865) -> Result<ResolvedPersonaManifest, Vec<PersonaValidationError>> {
866 let manifest_path = if manifest_path.is_dir() {
867 manifest_path.join(MANIFEST)
868 } else {
869 manifest_path.to_path_buf()
870 };
871 let manifest_dir = manifest_path
872 .parent()
873 .map(Path::to_path_buf)
874 .unwrap_or_else(|| PathBuf::from("."));
875 if manifest_path.extension().and_then(|ext| ext.to_str()) == Some("harn") {
876 return match harn_modules::personas::parse_persona_source_file(&manifest_path) {
877 Ok(document) if !document.personas.is_empty() => {
878 validate_and_resolve_standalone_personas(
879 document.personas,
880 manifest_path,
881 manifest_dir,
882 )
883 }
884 Ok(_) => Err(vec![PersonaValidationError {
885 manifest_path: manifest_path.clone(),
886 field_path: "persona".to_string(),
887 message: "no @persona declarations found".to_string(),
888 }]),
889 Err(message) => Err(vec![PersonaValidationError {
890 manifest_path: manifest_path.clone(),
891 field_path: "persona".to_string(),
892 message,
893 }]),
894 };
895 }
896 let manifest = match read_manifest_from_path(&manifest_path) {
897 Ok(manifest) => manifest,
898 Err(message) => {
899 if let Ok(document) =
900 harn_modules::personas::parse_persona_manifest_file(&manifest_path)
901 {
902 if !document.personas.is_empty() {
903 return validate_and_resolve_standalone_personas(
904 document.personas,
905 manifest_path,
906 manifest_dir,
907 );
908 }
909 }
910 return Err(vec![PersonaValidationError {
911 manifest_path: manifest_path.clone(),
912 field_path: "harn.toml".to_string(),
913 message: message.to_string(),
914 }]);
915 }
916 };
917 if manifest.personas.is_empty() {
918 if let Ok(document) = harn_modules::personas::parse_persona_manifest_file(&manifest_path) {
919 if !document.personas.is_empty() {
920 return validate_and_resolve_standalone_personas(
921 document.personas,
922 manifest_path,
923 manifest_dir,
924 );
925 }
926 }
927 }
928 validate_and_resolve_personas(manifest, manifest_path, manifest_dir)
929}
930
931fn validate_and_resolve_standalone_personas(
932 personas: Vec<PersonaManifestEntry>,
933 manifest_path: PathBuf,
934 manifest_dir: PathBuf,
935) -> Result<ResolvedPersonaManifest, Vec<PersonaValidationError>> {
936 let known_names = personas
937 .iter()
938 .filter_map(|persona| persona.name.as_ref())
939 .filter(|name| !name.trim().is_empty())
940 .cloned()
941 .collect();
942 let context = harn_modules::personas::PersonaValidationContext {
943 known_capabilities: harn_modules::personas::default_persona_capabilities(),
944 known_tools: BTreeSet::new(),
945 known_names,
946 };
947 harn_modules::personas::validate_persona_manifests(&manifest_path, &personas, &context)?;
948 Ok(ResolvedPersonaManifest {
949 manifest_path,
950 manifest_dir,
951 personas,
952 })
953}
954
955pub fn load_personas_config(
956 anchor: Option<&Path>,
957) -> Result<Option<ResolvedPersonaManifest>, Vec<PersonaValidationError>> {
958 let anchor = anchor
959 .map(Path::to_path_buf)
960 .unwrap_or_else(|| std::env::current_dir().unwrap_or_else(|_| PathBuf::from(".")));
961 let Some((manifest, dir)) = find_nearest_manifest(&anchor) else {
962 return Ok(None);
963 };
964 let manifest_path = dir.join(MANIFEST);
965 validate_and_resolve_personas(manifest, manifest_path, dir).map(Some)
966}
967
968pub(crate) fn validate_and_resolve_personas(
969 manifest: Manifest,
970 manifest_path: PathBuf,
971 manifest_dir: PathBuf,
972) -> Result<ResolvedPersonaManifest, Vec<PersonaValidationError>> {
973 let known_capabilities = known_persona_capabilities(&manifest, &manifest_dir);
974 let known_tools = known_persona_tools(&manifest);
975 let known_names: BTreeSet<String> = manifest
976 .personas
977 .iter()
978 .filter_map(|persona| persona.name.as_ref())
979 .filter(|name| !name.trim().is_empty())
980 .cloned()
981 .collect();
982 let context = harn_modules::personas::PersonaValidationContext {
983 known_capabilities,
984 known_tools,
985 known_names,
986 };
987 if let Err(errors) = harn_modules::personas::validate_persona_manifests(
988 &manifest_path,
989 &manifest.personas,
990 &context,
991 ) {
992 Err(errors)
993 } else {
994 let mut personas = manifest.personas;
995 attach_entry_workflow_steps(&mut personas, &manifest_dir);
996 Ok(ResolvedPersonaManifest {
997 manifest_path,
998 manifest_dir,
999 personas,
1000 })
1001 }
1002}
1003
1004fn attach_entry_workflow_steps(personas: &mut [PersonaManifestEntry], manifest_dir: &Path) {
1005 for persona in personas {
1006 if !persona.steps.is_empty() {
1007 continue;
1008 }
1009 let Some(entry_workflow) = persona.entry_workflow.as_deref() else {
1010 continue;
1011 };
1012 let Some((path, entry_name)) = entry_workflow.split_once('#') else {
1013 continue;
1014 };
1015 if !path.ends_with(".harn") {
1016 continue;
1017 }
1018 let source_path = manifest_dir.join(path);
1019 let Ok(document) = harn_modules::personas::parse_persona_source_file(&source_path) else {
1020 continue;
1021 };
1022 let entry_name = entry_name.trim();
1023 if let Some(source_persona) = document.personas.iter().find(|candidate| {
1024 candidate.entry_workflow.as_deref() == Some(entry_name)
1025 || candidate.name.as_deref() == persona.name.as_deref()
1026 }) {
1027 persona.steps.clone_from(&source_persona.steps);
1028 }
1029 }
1030}
1031
1032pub(crate) fn known_persona_capabilities(
1033 manifest: &Manifest,
1034 manifest_dir: &Path,
1035) -> BTreeSet<String> {
1036 let mut capabilities = BTreeSet::new();
1037 for (capability, operations) in default_persona_capability_map() {
1038 for operation in operations {
1039 capabilities.insert(format!("{capability}.{operation}"));
1040 }
1041 }
1042 for (capability, operations) in &manifest.check.host_capabilities {
1043 for operation in operations {
1044 capabilities.insert(format!("{capability}.{operation}"));
1045 }
1046 }
1047 if let Some(path) = manifest.check.host_capabilities_path.as_deref() {
1048 let path = PathBuf::from(path);
1049 let path = if path.is_absolute() {
1050 path
1051 } else {
1052 manifest_dir.join(path)
1053 };
1054 if let Ok(content) = fs::read_to_string(path) {
1055 let parsed_json = serde_json::from_str::<serde_json::Value>(&content).ok();
1056 let parsed_toml = toml::from_str::<toml::Value>(&content)
1057 .ok()
1058 .and_then(|value| serde_json::to_value(value).ok());
1059 if let Some(value) = parsed_json.or(parsed_toml) {
1060 collect_persona_capabilities_from_json(&value, &mut capabilities);
1061 }
1062 }
1063 }
1064 capabilities
1065}
1066
1067pub(crate) fn collect_persona_capabilities_from_json(
1068 value: &serde_json::Value,
1069 out: &mut BTreeSet<String>,
1070) {
1071 let root = value.get("capabilities").unwrap_or(value);
1072 let Some(capabilities) = root.as_object() else {
1073 return;
1074 };
1075 for (capability, entry) in capabilities {
1076 if let Some(list) = entry.as_array() {
1077 for item in list {
1078 if let Some(operation) = item.as_str() {
1079 out.insert(format!("{capability}.{operation}"));
1080 }
1081 }
1082 } else if let Some(obj) = entry.as_object() {
1083 if let Some(list) = obj
1084 .get("operations")
1085 .or_else(|| obj.get("ops"))
1086 .and_then(|v| v.as_array())
1087 {
1088 for item in list {
1089 if let Some(operation) = item.as_str() {
1090 out.insert(format!("{capability}.{operation}"));
1091 }
1092 }
1093 } else {
1094 for (operation, enabled) in obj {
1095 if enabled.as_bool().unwrap_or(true) {
1096 out.insert(format!("{capability}.{operation}"));
1097 }
1098 }
1099 }
1100 }
1101 }
1102}
1103
1104pub(crate) fn default_persona_capability_map() -> BTreeMap<&'static str, Vec<&'static str>> {
1105 harn_modules::personas::default_persona_capability_map()
1106}
1107
1108pub(crate) fn known_persona_tools(manifest: &Manifest) -> BTreeSet<String> {
1109 let mut tools = BTreeSet::from([
1110 "a2a".to_string(),
1111 "acp".to_string(),
1112 "ci".to_string(),
1113 "filesystem".to_string(),
1114 "github".to_string(),
1115 "linear".to_string(),
1116 "mcp".to_string(),
1117 "notion".to_string(),
1118 "pagerduty".to_string(),
1119 "shell".to_string(),
1120 "slack".to_string(),
1121 ]);
1122 for server in &manifest.mcp {
1123 tools.insert(server.name.clone());
1124 }
1125 for provider in &manifest.providers {
1126 tools.insert(provider.id.as_str().to_string());
1127 }
1128 for trigger in &manifest.triggers {
1129 if let Some(provider) = trigger.provider.as_ref() {
1130 tools.insert(provider.as_str().to_string());
1131 }
1132 for source in &trigger.sources {
1133 tools.insert(source.provider.as_str().to_string());
1134 }
1135 }
1136 tools
1137}
1138
1139#[cfg(test)]
1140#[path = "extensions_tests.rs"]
1141mod tests;