jellyflow-runtime 0.1.0

use crate::io::NodeGraphInteractionState;
use crate::rules::ConnectPlan;
use crate::runtime::policy::NodeGraphPortInteractionPolicy;
use jellyflow_core::core::{Graph, Port, PortId};
use jellyflow_core::interaction::NodeGraphConnectionMode;

use super::endpoints::{ConnectionEndpoints, resolve_connection_endpoints};
use super::rejections::reject_missing_port_owner_node;

pub(in crate::rules::connection) fn resolve_policy_checked_connection<'a>(
    graph: &'a Graph,
    a: PortId,
    b: PortId,
    mode: NodeGraphConnectionMode,
    state: &NodeGraphInteractionState,
) -> Result<ConnectionEndpoints<'a>, ConnectPlan> {
    let endpoints = resolve_connection_endpoints(graph, a, b, mode)?;

    if let Some(reject) = reject_if_connection_policy_disallows(graph, &endpoints, state) {
        return Err(reject);
    }

    Ok(endpoints)
}

pub(in crate::rules::connection) fn reject_if_connection_policy_disallows(
    graph: &Graph,
    endpoints: &ConnectionEndpoints<'_>,
    state: &NodeGraphInteractionState,
) -> Option<ConnectPlan> {
    let from_policy = match port_policy_or_reject(graph, endpoints.from, state) {
        Ok(policy) => policy,
        Err(plan) => return Some(plan),
    };
    if !from_policy.can_start_connection() {
        return Some(ConnectPlan::reject("source port is not connectable"));
    }

    let to_policy = match port_policy_or_reject(graph, endpoints.to, state) {
        Ok(policy) => policy,
        Err(plan) => return Some(plan),
    };
    if !to_policy.can_accept_connection() {
        return Some(ConnectPlan::reject("target port is not connectable"));
    }

    None
}

fn port_policy_or_reject(
    graph: &Graph,
    port: &Port,
    state: &NodeGraphInteractionState,
) -> Result<NodeGraphPortInteractionPolicy, ConnectPlan> {
    let Some(node) = graph.nodes.get(&port.node) else {
        return Err(reject_missing_port_owner_node(port.node));
    };
    Ok(state.port_interaction_policy(node, port))
}