harn-serve 0.10.121

Shared outbound workflow server core for Harn adapters
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

use harn_vm::event_log::Topic;
use harn_vm::{TenantId, TriggerEvent};

use crate::DispatchError;

pub(super) fn topic(
    name: &str,
    tenant_id: Option<&TenantId>,
) -> Result<Topic, harn_vm::event_log::LogError> {
    let topic = Topic::new(name)?;
    match tenant_id {
        Some(tenant_id) => harn_vm::tenant_topic(tenant_id, &topic),
        None => Ok(topic),
    }
}

pub(super) fn enforce_event(
    event: &mut TriggerEvent,
    tenant_id: Option<&TenantId>,
) -> Result<(), DispatchError> {
    let Some(tenant_id) = tenant_id else {
        return Ok(());
    };
    match event.tenant_id.as_ref() {
        Some(event_tenant) if event_tenant != tenant_id => Err(DispatchError::Validation(format!(
            "worker tenant '{}' cannot dispatch event for tenant '{}'",
            tenant_id.0, event_tenant.0
        ))),
        Some(_) => Ok(()),
        None => {
            event.tenant_id = Some(tenant_id.clone());
            Ok(())
        }
    }
}