obzenflow_runtime 0.1.2

Runtime services for ObzenFlow - execution and coordination business logic
Documentation 
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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

// SPDX-License-Identifier: MIT OR Apache-2.0
// SPDX-FileCopyrightText: 2025-2026 ObzenFlow Contributors
// https://obzenflow.dev

//! Conversion helpers between core StageId and topology StageId
//!
//! ARCHITECTURE: The ID Bridge Pattern
//! ====================================
//! This module bridges between two different ID systems:
//!
//! 1. obzenflow_core::StageId - Uses standard ulid crate (real ULIDs with crypto randomness)
//! 2. obzenflow_topology::StageId - Uses obzenflow-idkit (type-only, no generation)
//!
//! Why this bridge exists:
//! - Backend (flowstate_rs) generates real ULIDs for production use
//! - Frontend (obzen-flow-ui) uses sequential IDs due to WASM limitations  
//! - Topology acts as a type-safe bridge between both worlds
//!
//! The conversion works because both ID types share the same underlying ULID
//! representation, they just use different crates to handle them.

use obzenflow_core::StageId;

/// Extension trait for converting between core StageId and topology StageId
pub trait StageIdExt {
    fn to_topology_id(&self) -> obzenflow_topology::StageId;
    fn from_topology_id(topology_id: obzenflow_topology::StageId) -> Self;
}

impl StageIdExt for StageId {
    fn to_topology_id(&self) -> obzenflow_topology::StageId {
        // Convert from core's ulid::Ulid to topology's obzenflow-idkit Id
        // Both use the same underlying ULID representation
        obzenflow_topology::StageId::from_ulid(self.as_ulid())
    }

    fn from_topology_id(topology_id: obzenflow_topology::StageId) -> Self {
        // Convert from topology's obzenflow-idkit Id to core's ulid::Ulid
        StageId::from_ulid(topology_id.ulid())
    }
}

/// Extension trait for converting between core SccId and topology SccId.
///
/// Both types share the same underlying ULID representation, they just
/// use different crates to handle them (same pattern as `StageIdExt`).
pub trait SccIdExt {
    fn to_core_scc_id(self) -> obzenflow_core::SccId;
    fn from_core_scc_id(core_id: obzenflow_core::SccId) -> Self;
}

impl SccIdExt for obzenflow_topology::SccId {
    fn to_core_scc_id(self) -> obzenflow_core::SccId {
        obzenflow_core::SccId::from_ulid(self.ulid())
    }

    fn from_core_scc_id(core_id: obzenflow_core::SccId) -> Self {
        obzenflow_topology::SccId::from_ulid(core_id.as_ulid())
    }
}