Function merge_endpoint

crates/openshell-policy/src/merge.rs:466–564

(
    existing: &mut NetworkEndpoint,
    incoming: &NetworkEndpoint,
    warnings: &mut Vec<PolicyMergeWarning>,
)

}

fn merge_endpoint(
    existing: &mut NetworkEndpoint,
    incoming: &NetworkEndpoint,
    warnings: &mut Vec<PolicyMergeWarning>,
) -> Result<(), PolicyMergeError> {
    let host = if existing.host.is_empty() {
        incoming.host.clone()
    } else {
        existing.host.clone()
    };
    let port = canonical_ports(existing)
        .into_iter()
        .next()
        .or_else(|| canonical_ports(incoming).into_iter().next())
        .unwrap_or(0);

    if existing.host.is_empty() {
        existing.host.clone_from(&incoming.host);
    }
    if existing.path.is_empty() {
        existing.path.clone_from(&incoming.path);
    }

    merge_endpoint_ports(existing, incoming);
    let existing_protocol = existing.protocol.clone();
    merge_string_field(
        &mut existing.protocol,
        &incoming.protocol,
        PolicyMergeWarning::ExistingProtocolRetained {
            host: host.clone(),
            port,
            existing: existing_protocol,
            incoming: incoming.protocol.clone(),
        },
        warnings,
    );
    let existing_enforcement = existing.enforcement.clone();
    merge_string_field(
        &mut existing.enforcement,
        &incoming.enforcement,
        PolicyMergeWarning::ExistingEnforcementRetained {
            host: host.clone(),
            port,
            existing: existing_enforcement,
            incoming: incoming.enforcement.clone(),
        },
        warnings,
    );
    let existing_tls = existing.tls.clone();
    merge_string_field(
        &mut existing.tls,
        &incoming.tls,
        PolicyMergeWarning::ExistingTlsRetained {
            host: host.clone(),
            port,
            existing: existing_tls,
            incoming: incoming.tls.clone(),
        },