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 let provider_catalog = build_manifest_provider_catalog(extensions).await?;
151 validate_orchestrator_budget(extensions.root_manifest.as_ref())?;
152 validate_static_trigger_configs(&extensions.triggers, &provider_catalog)?;
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 harn_vm::install_provider_catalog(provider_catalog);
312 Ok(collected)
313}
314
315pub(crate) async fn collect_trigger_flow_control(
316 vm: &mut harn_vm::Vm,
317 trigger: &ResolvedTriggerConfig,
318) -> Result<harn_vm::TriggerFlowControlConfig, PackageError> {
319 let mut flow = harn_vm::TriggerFlowControlConfig::default();
320
321 let concurrency = if let Some(spec) = &trigger.concurrency {
322 Some(spec.clone())
323 } else if let Some(max) = trigger.budget.max_concurrent {
324 eprintln!(
325 "warning: {} uses deprecated budget.max_concurrent; prefer concurrency = {{ max = {} }}",
326 manifest_trigger_location(trigger),
327 max
328 );
329 Some(TriggerConcurrencyManifestSpec { key: None, max })
330 } else {
331 None
332 };
333 if let Some(spec) = concurrency {
334 flow.concurrency = Some(harn_vm::TriggerConcurrencyConfig {
335 key: compile_optional_trigger_expression(
336 vm,
337 trigger,
338 "concurrency.key",
339 spec.key.as_deref(),
340 )
341 .await?,
342 max: spec.max,
343 });
344 }
345
346 if let Some(spec) = &trigger.throttle {
347 flow.throttle = Some(harn_vm::TriggerThrottleConfig {
348 key: compile_optional_trigger_expression(
349 vm,
350 trigger,
351 "throttle.key",
352 spec.key.as_deref(),
353 )
354 .await?,
355 period: harn_vm::parse_flow_control_duration(&spec.period)
356 .map_err(|error| trigger_error(trigger, format!("throttle.period {error}")))?,
357 max: spec.max,
358 });
359 }
360
361 if let Some(spec) = &trigger.rate_limit {
362 flow.rate_limit = Some(harn_vm::TriggerRateLimitConfig {
363 key: compile_optional_trigger_expression(
364 vm,
365 trigger,
366 "rate_limit.key",
367 spec.key.as_deref(),
368 )
369 .await?,
370 period: harn_vm::parse_flow_control_duration(&spec.period)
371 .map_err(|error| trigger_error(trigger, format!("rate_limit.period {error}")))?,
372 max: spec.max,
373 });
374 }
375
376 if let Some(spec) = &trigger.debounce {
377 flow.debounce = Some(harn_vm::TriggerDebounceConfig {
378 key: compile_trigger_expression(vm, trigger, "debounce.key", &spec.key).await?,
379 period: harn_vm::parse_flow_control_duration(&spec.period)
380 .map_err(|error| trigger_error(trigger, format!("debounce.period {error}")))?,
381 });
382 }
383
384 if let Some(spec) = &trigger.singleton {
385 flow.singleton = Some(harn_vm::TriggerSingletonConfig {
386 key: compile_optional_trigger_expression(
387 vm,
388 trigger,
389 "singleton.key",
390 spec.key.as_deref(),
391 )
392 .await?,
393 });
394 }
395
396 if let Some(spec) = &trigger.batch {
397 flow.batch = Some(harn_vm::TriggerBatchConfig {
398 key: compile_optional_trigger_expression(vm, trigger, "batch.key", spec.key.as_deref())
399 .await?,
400 size: spec.size,
401 timeout: harn_vm::parse_flow_control_duration(&spec.timeout)
402 .map_err(|error| trigger_error(trigger, format!("batch.timeout {error}")))?,
403 });
404 }
405
406 if let Some(spec) = &trigger.priority_flow {
407 flow.priority = Some(harn_vm::TriggerPriorityOrderConfig {
408 key: compile_trigger_expression(vm, trigger, "priority.key", &spec.key).await?,
409 order: spec.order.clone(),
410 });
411 }
412
413 Ok(flow)
414}
415
416fn persona_runtime_binding_for_handler(
417 extensions: &RuntimeExtensions,
418 trigger: &ResolvedTriggerConfig,
419 name: &str,
420) -> Result<harn_vm::PersonaRuntimeBinding, PackageError> {
421 let Some(manifest) = extensions.root_manifest.as_ref() else {
422 return Err(trigger_error(
423 trigger,
424 format!("handler persona://{name} requires a root manifest"),
425 ));
426 };
427 let Some(persona) = manifest
428 .personas
429 .iter()
430 .find(|persona| persona.name.as_deref() == Some(name))
431 else {
432 return Err(trigger_error(
433 trigger,
434 format!("handler persona://{name} does not match a declared persona"),
435 ));
436 };
437 Ok(harn_vm::PersonaRuntimeBinding {
438 name: name.to_string(),
439 template_ref: persona_template_ref(persona),
440 entry_workflow: persona.entry_workflow.clone().unwrap_or_default(),
441 schedules: persona.schedules.clone(),
442 triggers: persona.triggers.clone(),
443 budget: harn_vm::PersonaBudgetPolicy {
444 daily_usd: persona.budget.daily_usd,
445 hourly_usd: persona.budget.hourly_usd,
446 run_usd: persona.budget.run_usd,
447 max_tokens: persona.budget.max_tokens,
448 },
449 })
450}
451
452pub(crate) async fn compile_optional_trigger_expression(
453 vm: &mut harn_vm::Vm,
454 trigger: &ResolvedTriggerConfig,
455 field_name: &str,
456 expr: Option<&str>,
457) -> Result<Option<harn_vm::TriggerExpressionSpec>, PackageError> {
458 match expr {
459 Some(expr) => compile_trigger_expression(vm, trigger, field_name, expr)
460 .await
461 .map(Some),
462 None => Ok(None),
463 }
464}
465
466pub(crate) async fn compile_trigger_expression(
467 vm: &mut harn_vm::Vm,
468 trigger: &ResolvedTriggerConfig,
469 field_name: &str,
470 expr: &str,
471) -> Result<harn_vm::TriggerExpressionSpec, PackageError> {
472 let synthetic = PathBuf::from(format!(
473 "<trigger-expr>/{}/{:04}-{}.harn",
474 harn_vm::event_log::sanitize_topic_component(&trigger.id),
475 trigger.table_index,
476 harn_vm::event_log::sanitize_topic_component(field_name),
477 ));
478 let source = format!(
479 "import \"std/triggers\"\n\npub fn __trigger_expr(event: TriggerEvent) -> any {{\n return {expr}\n}}\n"
480 );
481 let exports = vm
482 .load_module_exports_from_source(synthetic, &source)
483 .await
484 .map_err(|error| {
485 trigger_error(
486 trigger,
487 format!("{field_name} '{expr}' is invalid Harn expression: {error}"),
488 )
489 })?;
490 let closure = exports.get("__trigger_expr").ok_or_else(|| {
491 trigger_error(
492 trigger,
493 format!("{field_name} '{expr}' did not compile into an exported closure"),
494 )
495 })?;
496 Ok(harn_vm::TriggerExpressionSpec {
497 raw: expr.to_string(),
498 closure: closure.clone(),
499 })
500}
501
502pub(crate) fn trigger_kind_label(kind: TriggerKind) -> &'static str {
503 match kind {
504 TriggerKind::Webhook => "webhook",
505 TriggerKind::Cron => "cron",
506 TriggerKind::Poll => "poll",
507 TriggerKind::Stream => "stream",
508 TriggerKind::Predicate => "predicate",
509 TriggerKind::A2aPush => "a2a-push",
510 }
511}
512
513pub(crate) fn worker_queue_priority(
514 priority: TriggerDispatchPriority,
515) -> harn_vm::WorkerQueuePriority {
516 match priority {
517 TriggerDispatchPriority::High => harn_vm::WorkerQueuePriority::High,
518 TriggerDispatchPriority::Normal => harn_vm::WorkerQueuePriority::Normal,
519 TriggerDispatchPriority::Low => harn_vm::WorkerQueuePriority::Low,
520 }
521}
522
523pub fn manifest_trigger_binding_spec(
524 trigger: CollectedManifestTrigger,
525) -> harn_vm::TriggerBindingSpec {
526 let flow_control = trigger.flow_control.clone();
527 let config = trigger.config;
528 let (handler, handler_descriptor) = match trigger.handler {
529 CollectedTriggerHandler::Local { reference, closure } => (
530 harn_vm::TriggerHandlerSpec::Local {
531 raw: reference.raw.clone(),
532 closure,
533 },
534 serde_json::json!({
535 "kind": "local",
536 "raw": reference.raw,
537 }),
538 ),
539 CollectedTriggerHandler::A2a {
540 target,
541 allow_cleartext,
542 } => (
543 harn_vm::TriggerHandlerSpec::A2a {
544 target: target.clone(),
545 allow_cleartext,
546 },
547 serde_json::json!({
548 "kind": "a2a",
549 "target": target,
550 "allow_cleartext": allow_cleartext,
551 }),
552 ),
553 CollectedTriggerHandler::Worker { queue } => (
554 harn_vm::TriggerHandlerSpec::Worker {
555 queue: queue.clone(),
556 },
557 serde_json::json!({
558 "kind": "worker",
559 "queue": queue,
560 }),
561 ),
562 CollectedTriggerHandler::Persona { binding } => (
563 harn_vm::TriggerHandlerSpec::Persona {
564 binding: binding.clone(),
565 },
566 serde_json::json!({
567 "kind": "persona",
568 "name": binding.name,
569 "entry_workflow": binding.entry_workflow,
570 }),
571 ),
572 };
573
574 let when_raw = trigger
575 .when
576 .as_ref()
577 .map(|predicate| predicate.reference.raw.clone());
578 let when = trigger.when.map(|predicate| harn_vm::TriggerPredicateSpec {
579 raw: predicate.reference.raw,
580 closure: predicate.closure,
581 });
582 let mut when_budget = config
583 .when_budget
584 .as_ref()
585 .map(|budget| {
586 Ok::<harn_vm::TriggerPredicateBudget, String>(harn_vm::TriggerPredicateBudget {
587 max_cost_usd: budget.max_cost_usd,
588 tokens_max: budget.tokens_max,
589 timeout_ms: budget
590 .timeout
591 .as_deref()
592 .map(parse_duration_millis)
593 .transpose()?,
594 })
595 })
596 .transpose()
597 .unwrap_or_default();
598 if config.budget.max_cost_usd.is_some() || config.budget.max_tokens.is_some() {
599 let budget = when_budget.get_or_insert_with(harn_vm::TriggerPredicateBudget::default);
600 if budget.max_cost_usd.is_none() {
601 budget.max_cost_usd = config.budget.max_cost_usd;
602 }
603 if budget.tokens_max.is_none() {
604 budget.tokens_max = config.budget.max_tokens;
605 }
606 }
607 let id = config.id.clone();
608 let kind = trigger_kind_label(config.kind).to_string();
609 let provider = config.provider.clone();
610 let autonomy_tier = config.autonomy_tier;
611 let match_events = config.match_.events.clone();
612 let dedupe_key = config.dedupe_key.clone();
613 let retry = harn_vm::TriggerRetryConfig::new(
614 config.retry.max,
615 match config.retry.backoff {
616 TriggerRetryBackoff::Immediate => harn_vm::RetryPolicy::Linear { delay_ms: 0 },
617 TriggerRetryBackoff::Svix => harn_vm::RetryPolicy::Svix,
618 },
619 );
620 let filter = config.filter.clone();
621 let dedupe_retention_days = config.retry.retention_days;
622 let daily_cost_usd = config.budget.daily_cost_usd;
623 let hourly_cost_usd = config.budget.hourly_cost_usd;
624 let max_autonomous_decisions_per_hour = config.budget.max_autonomous_decisions_per_hour;
625 let max_autonomous_decisions_per_day = config.budget.max_autonomous_decisions_per_day;
626 let on_budget_exhausted = config.budget.on_budget_exhausted;
627 let max_concurrent = flow_control.concurrency.as_ref().map(|config| config.max);
628 let manifest_path = Some(config.manifest_path.clone());
629 let package_name = config.package_name.clone();
630
631 let fingerprint = serde_json::to_string(&serde_json::json!({
632 "id": &id,
633 "kind": &kind,
634 "provider": provider.as_str(),
635 "autonomy_tier": autonomy_tier,
636 "match": config.match_,
637 "when": when_raw,
638 "when_budget": config.when_budget,
639 "handler": handler_descriptor,
640 "dedupe_key": &dedupe_key,
641 "retry": config.retry,
642 "dispatch_priority": config.dispatch_priority,
643 "budget": config.budget,
644 "flow_control": {
645 "concurrency": config.concurrency,
646 "throttle": config.throttle,
647 "rate_limit": config.rate_limit,
648 "debounce": config.debounce,
649 "singleton": config.singleton,
650 "batch": config.batch,
651 "priority": config.priority_flow,
652 },
653 "window": config.window,
654 "secrets": config.secrets,
655 "filter": &filter,
656 "kind_specific": config.kind_specific,
657 "manifest_path": &manifest_path,
658 "package_name": &package_name,
659 }))
660 .unwrap_or_else(|_| format!("{}:{}:{}", id, kind, provider.as_str()));
661
662 harn_vm::TriggerBindingSpec {
663 id,
664 source: harn_vm::TriggerBindingSource::Manifest,
665 kind,
666 provider,
667 autonomy_tier,
668 handler,
669 dispatch_priority: worker_queue_priority(config.dispatch_priority),
670 when,
671 when_budget,
672 retry,
673 match_events,
674 dedupe_key,
675 filter,
676 dedupe_retention_days,
677 daily_cost_usd,
678 hourly_cost_usd,
679 max_autonomous_decisions_per_hour,
680 max_autonomous_decisions_per_day,
681 on_budget_exhausted,
682 max_concurrent,
683 flow_control,
684 manifest_path,
685 package_name,
686 definition_fingerprint: fingerprint,
687 }
688}
689
690pub async fn install_manifest_triggers(
691 vm: &mut harn_vm::Vm,
692 extensions: &RuntimeExtensions,
693) -> Result<(), PackageError> {
694 install_orchestrator_budget(extensions);
695 let collected = collect_manifest_triggers(vm, extensions).await?;
696 let mut bindings: Vec<_> = collected
697 .iter()
698 .cloned()
699 .map(manifest_trigger_binding_spec)
700 .collect();
701 bindings.extend(collect_persona_trigger_binding_specs(extensions)?);
702 harn_vm::install_manifest_triggers(bindings)
703 .await
704 .map_err(|error| PackageError::Extensions(error.to_string()))
705}
706
707pub async fn install_collected_manifest_triggers(
708 collected: &[CollectedManifestTrigger],
709) -> Result<(), PackageError> {
710 let bindings = collected
711 .iter()
712 .cloned()
713 .map(manifest_trigger_binding_spec)
714 .collect();
715 harn_vm::install_manifest_triggers(bindings)
716 .await
717 .map_err(|error| PackageError::Extensions(error.to_string()))
718}
719
720pub fn collect_persona_trigger_binding_specs(
721 extensions: &RuntimeExtensions,
722) -> Result<Vec<harn_vm::TriggerBindingSpec>, PackageError> {
723 let Some(manifest) = extensions.root_manifest.clone() else {
724 return Ok(Vec::new());
725 };
726 let manifest_path = extensions
727 .root_manifest_path
728 .clone()
729 .unwrap_or_else(|| PathBuf::from(MANIFEST));
730 let manifest_dir = extensions
731 .root_manifest_dir
732 .clone()
733 .or_else(|| manifest_path.parent().map(Path::to_path_buf))
734 .unwrap_or_else(|| PathBuf::from("."));
735 let resolved = validate_and_resolve_personas(manifest, manifest_path.clone(), manifest_dir)
736 .map_err(|errors| {
737 errors
738 .iter()
739 .map(ToString::to_string)
740 .collect::<Vec<_>>()
741 .join("\n")
742 })?;
743 let mut bindings = Vec::new();
744 for persona in resolved.personas {
745 let Some(name) = persona.name.clone() else {
746 continue;
747 };
748 for trigger in &persona.triggers {
749 let Some((provider, kind)) = trigger.split_once('.') else {
750 continue;
751 };
752 let provider = provider.trim();
753 let kind = kind.trim();
754 if provider.is_empty() || kind.is_empty() {
755 continue;
756 }
757 bindings.push(persona_trigger_binding_spec(
758 &resolved.manifest_path,
759 &name,
760 provider,
761 kind,
762 &persona,
763 ));
764 }
765 }
766 Ok(bindings)
767}
768
769fn persona_trigger_binding_spec(
770 manifest_path: &Path,
771 name: &str,
772 provider: &str,
773 kind: &str,
774 persona: &PersonaManifestEntry,
775) -> harn_vm::TriggerBindingSpec {
776 let runtime_binding = harn_vm::PersonaRuntimeBinding {
777 name: name.to_string(),
778 template_ref: persona_template_ref(persona),
779 entry_workflow: persona.entry_workflow.clone().unwrap_or_default(),
780 schedules: persona.schedules.clone(),
781 triggers: persona.triggers.clone(),
782 budget: harn_vm::PersonaBudgetPolicy {
783 daily_usd: persona.budget.daily_usd,
784 hourly_usd: persona.budget.hourly_usd,
785 run_usd: persona.budget.run_usd,
786 max_tokens: persona.budget.max_tokens,
787 },
788 };
789 let id = format!("persona.{name}.{provider}.{kind}");
790 let handler = harn_vm::TriggerHandlerSpec::Persona {
791 binding: runtime_binding.clone(),
792 };
793 let fingerprint = serde_json::to_string(&serde_json::json!({
794 "id": &id,
795 "kind": kind,
796 "provider": provider,
797 "handler": {
798 "kind": "persona",
799 "name": name,
800 "entry_workflow": runtime_binding.entry_workflow,
801 },
802 "budget": runtime_binding.budget,
803 "manifest_path": manifest_path,
804 }))
805 .unwrap_or_else(|_| format!("{id}:{provider}:{kind}:{name}"));
806
807 harn_vm::TriggerBindingSpec {
808 id,
809 source: harn_vm::TriggerBindingSource::Manifest,
810 kind: kind.to_string(),
811 provider: harn_vm::ProviderId::from(provider.to_string()),
812 autonomy_tier: persona
813 .autonomy_tier
814 .map(persona_autonomy_to_vm)
815 .unwrap_or(harn_vm::AutonomyTier::Suggest),
816 handler,
817 dispatch_priority: harn_vm::WorkerQueuePriority::Normal,
818 when: None,
819 when_budget: None,
820 retry: harn_vm::TriggerRetryConfig::default(),
821 match_events: vec![kind.to_string()],
822 dedupe_key: None,
823 filter: None,
824 dedupe_retention_days: 7,
825 daily_cost_usd: persona.budget.daily_usd,
826 hourly_cost_usd: persona.budget.hourly_usd,
827 max_autonomous_decisions_per_hour: None,
828 max_autonomous_decisions_per_day: None,
829 on_budget_exhausted: harn_vm::TriggerBudgetExhaustionStrategy::RetryLater,
830 max_concurrent: None,
831 flow_control: harn_vm::TriggerFlowControlConfig::default(),
832 manifest_path: Some(manifest_path.to_path_buf()),
833 package_name: None,
834 definition_fingerprint: fingerprint,
835 }
836}
837
838fn persona_autonomy_to_vm(value: PersonaAutonomyTier) -> harn_vm::AutonomyTier {
839 match value {
840 PersonaAutonomyTier::Shadow => harn_vm::AutonomyTier::Shadow,
841 PersonaAutonomyTier::Suggest => harn_vm::AutonomyTier::Suggest,
842 PersonaAutonomyTier::ActWithApproval => harn_vm::AutonomyTier::ActWithApproval,
843 PersonaAutonomyTier::ActAuto => harn_vm::AutonomyTier::ActAuto,
844 }
845}
846
847fn persona_template_ref(persona: &PersonaManifestEntry) -> Option<String> {
848 persona
849 .package_source
850 .package
851 .as_ref()
852 .zip(persona.version.as_ref())
853 .map(|(package, version)| format!("{package}@{version}"))
854 .or_else(|| persona.package_source.package.clone())
855 .or_else(|| {
856 persona
857 .name
858 .as_ref()
859 .zip(persona.version.as_ref())
860 .map(|(name, version)| format!("{name}@{version}"))
861 })
862}
863
864pub fn load_personas_from_manifest_path(
865 manifest_path: &Path,
866) -> Result<ResolvedPersonaManifest, Vec<PersonaValidationError>> {
867 let manifest_path = if manifest_path.is_dir() {
868 manifest_path.join(MANIFEST)
869 } else {
870 manifest_path.to_path_buf()
871 };
872 let manifest_dir = manifest_path
873 .parent()
874 .map(Path::to_path_buf)
875 .unwrap_or_else(|| PathBuf::from("."));
876 if manifest_path.extension().and_then(|ext| ext.to_str()) == Some("harn") {
877 return match harn_modules::personas::parse_persona_source_file(&manifest_path) {
878 Ok(document) if !document.personas.is_empty() => {
879 validate_and_resolve_standalone_personas(
880 document.personas,
881 manifest_path,
882 manifest_dir,
883 )
884 }
885 Ok(_) => Err(vec![PersonaValidationError {
886 manifest_path: manifest_path.clone(),
887 field_path: "persona".to_string(),
888 message: "no @persona declarations found".to_string(),
889 }]),
890 Err(message) => Err(vec![PersonaValidationError {
891 manifest_path: manifest_path.clone(),
892 field_path: "persona".to_string(),
893 message,
894 }]),
895 };
896 }
897 let manifest = match read_manifest_from_path(&manifest_path) {
898 Ok(manifest) => manifest,
899 Err(message) => {
900 if let Ok(document) =
901 harn_modules::personas::parse_persona_manifest_file(&manifest_path)
902 {
903 if !document.personas.is_empty() {
904 return validate_and_resolve_standalone_personas(
905 document.personas,
906 manifest_path,
907 manifest_dir,
908 );
909 }
910 }
911 return Err(vec![PersonaValidationError {
912 manifest_path: manifest_path.clone(),
913 field_path: "harn.toml".to_string(),
914 message: message.to_string(),
915 }]);
916 }
917 };
918 if manifest.personas.is_empty() {
919 if let Ok(document) = harn_modules::personas::parse_persona_manifest_file(&manifest_path) {
920 if !document.personas.is_empty() {
921 return validate_and_resolve_standalone_personas(
922 document.personas,
923 manifest_path,
924 manifest_dir,
925 );
926 }
927 }
928 }
929 validate_and_resolve_personas(manifest, manifest_path, manifest_dir)
930}
931
932fn validate_and_resolve_standalone_personas(
933 personas: Vec<PersonaManifestEntry>,
934 manifest_path: PathBuf,
935 manifest_dir: PathBuf,
936) -> Result<ResolvedPersonaManifest, Vec<PersonaValidationError>> {
937 let known_names = personas
938 .iter()
939 .filter_map(|persona| persona.name.as_ref())
940 .filter(|name| !name.trim().is_empty())
941 .cloned()
942 .collect();
943 let context = harn_modules::personas::PersonaValidationContext {
944 known_capabilities: harn_modules::personas::default_persona_capabilities(),
945 known_tools: BTreeSet::new(),
946 known_names,
947 };
948 harn_modules::personas::validate_persona_manifests(&manifest_path, &personas, &context)?;
949 Ok(ResolvedPersonaManifest {
950 manifest_path,
951 manifest_dir,
952 personas,
953 })
954}
955
956pub fn load_personas_config(
957 anchor: Option<&Path>,
958) -> Result<Option<ResolvedPersonaManifest>, Vec<PersonaValidationError>> {
959 let anchor = anchor
960 .map(Path::to_path_buf)
961 .unwrap_or_else(|| std::env::current_dir().unwrap_or_else(|_| PathBuf::from(".")));
962 let Some((manifest, dir)) = find_nearest_manifest(&anchor) else {
963 return Ok(None);
964 };
965 let manifest_path = dir.join(MANIFEST);
966 validate_and_resolve_personas(manifest, manifest_path, dir).map(Some)
967}
968
969pub(crate) fn validate_and_resolve_personas(
970 manifest: Manifest,
971 manifest_path: PathBuf,
972 manifest_dir: PathBuf,
973) -> Result<ResolvedPersonaManifest, Vec<PersonaValidationError>> {
974 let known_capabilities = known_persona_capabilities(&manifest, &manifest_dir);
975 let known_tools = known_persona_tools(&manifest);
976 let known_names: BTreeSet<String> = manifest
977 .personas
978 .iter()
979 .filter_map(|persona| persona.name.as_ref())
980 .filter(|name| !name.trim().is_empty())
981 .cloned()
982 .collect();
983 let context = harn_modules::personas::PersonaValidationContext {
984 known_capabilities,
985 known_tools,
986 known_names,
987 };
988 if let Err(errors) = harn_modules::personas::validate_persona_manifests(
989 &manifest_path,
990 &manifest.personas,
991 &context,
992 ) {
993 Err(errors)
994 } else {
995 let mut personas = manifest.personas;
996 attach_entry_workflow_steps(&mut personas, &manifest_dir);
997 Ok(ResolvedPersonaManifest {
998 manifest_path,
999 manifest_dir,
1000 personas,
1001 })
1002 }
1003}
1004
1005fn attach_entry_workflow_steps(personas: &mut [PersonaManifestEntry], manifest_dir: &Path) {
1006 for persona in personas {
1007 if !persona.steps.is_empty() {
1008 continue;
1009 }
1010 let Some(entry_workflow) = persona.entry_workflow.as_deref() else {
1011 continue;
1012 };
1013 let Some((path, entry_name)) = entry_workflow.split_once('#') else {
1014 continue;
1015 };
1016 if !path.ends_with(".harn") {
1017 continue;
1018 }
1019 let source_path = manifest_dir.join(path);
1020 let Ok(document) = harn_modules::personas::parse_persona_source_file(&source_path) else {
1021 continue;
1022 };
1023 let entry_name = entry_name.trim();
1024 if let Some(source_persona) = document.personas.iter().find(|candidate| {
1025 candidate.entry_workflow.as_deref() == Some(entry_name)
1026 || candidate.name.as_deref() == persona.name.as_deref()
1027 }) {
1028 persona.steps.clone_from(&source_persona.steps);
1029 }
1030 }
1031}
1032
1033pub(crate) fn known_persona_capabilities(
1034 manifest: &Manifest,
1035 manifest_dir: &Path,
1036) -> BTreeSet<String> {
1037 let mut capabilities = BTreeSet::new();
1038 for (capability, operations) in default_persona_capability_map() {
1039 for operation in operations {
1040 capabilities.insert(format!("{capability}.{operation}"));
1041 }
1042 }
1043 for (capability, operations) in &manifest.check.host_capabilities {
1044 for operation in operations {
1045 capabilities.insert(format!("{capability}.{operation}"));
1046 }
1047 }
1048 if let Some(path) = manifest.check.host_capabilities_path.as_deref() {
1049 let path = PathBuf::from(path);
1050 let path = if path.is_absolute() {
1051 path
1052 } else {
1053 manifest_dir.join(path)
1054 };
1055 if let Ok(content) = fs::read_to_string(path) {
1056 let parsed_json = serde_json::from_str::<serde_json::Value>(&content).ok();
1057 let parsed_toml = toml::from_str::<toml::Value>(&content)
1058 .ok()
1059 .and_then(|value| serde_json::to_value(value).ok());
1060 if let Some(value) = parsed_json.or(parsed_toml) {
1061 collect_persona_capabilities_from_json(&value, &mut capabilities);
1062 }
1063 }
1064 }
1065 capabilities
1066}
1067
1068pub(crate) fn collect_persona_capabilities_from_json(
1069 value: &serde_json::Value,
1070 out: &mut BTreeSet<String>,
1071) {
1072 let root = value.get("capabilities").unwrap_or(value);
1073 let Some(capabilities) = root.as_object() else {
1074 return;
1075 };
1076 for (capability, entry) in capabilities {
1077 if let Some(list) = entry.as_array() {
1078 for item in list {
1079 if let Some(operation) = item.as_str() {
1080 out.insert(format!("{capability}.{operation}"));
1081 }
1082 }
1083 } else if let Some(obj) = entry.as_object() {
1084 if let Some(list) = obj
1085 .get("operations")
1086 .or_else(|| obj.get("ops"))
1087 .and_then(|v| v.as_array())
1088 {
1089 for item in list {
1090 if let Some(operation) = item.as_str() {
1091 out.insert(format!("{capability}.{operation}"));
1092 }
1093 }
1094 } else {
1095 for (operation, enabled) in obj {
1096 if enabled.as_bool().unwrap_or(true) {
1097 out.insert(format!("{capability}.{operation}"));
1098 }
1099 }
1100 }
1101 }
1102 }
1103}
1104
1105pub(crate) fn default_persona_capability_map() -> BTreeMap<&'static str, Vec<&'static str>> {
1106 harn_modules::personas::default_persona_capability_map()
1107}
1108
1109pub(crate) fn known_persona_tools(manifest: &Manifest) -> BTreeSet<String> {
1110 let mut tools = BTreeSet::from([
1111 "a2a".to_string(),
1112 "acp".to_string(),
1113 "ci".to_string(),
1114 "filesystem".to_string(),
1115 "github".to_string(),
1116 "linear".to_string(),
1117 "mcp".to_string(),
1118 "notion".to_string(),
1119 "pagerduty".to_string(),
1120 "shell".to_string(),
1121 "slack".to_string(),
1122 ]);
1123 for server in &manifest.mcp {
1124 tools.insert(server.name.clone());
1125 }
1126 for provider in &manifest.providers {
1127 tools.insert(provider.id.as_str().to_string());
1128 }
1129 for trigger in &manifest.triggers {
1130 if let Some(provider) = trigger.provider.as_ref() {
1131 tools.insert(provider.as_str().to_string());
1132 }
1133 for source in &trigger.sources {
1134 tools.insert(source.provider.as_str().to_string());
1135 }
1136 }
1137 tools
1138}
1139
1140#[cfg(test)]
1141#[path = "extensions_tests.rs"]
1142mod tests;