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    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;