Skip to main content

harn_cli/package/
extensions.rs

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
21/// Load the nearest project manifest plus any installed package manifests and
22/// merge the root project's runtime extensions.
23pub 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
71/// Install merged runtime extensions on the current thread.
72pub 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;