uni-algo 0.1.5

Graph algorithms for Uni - PageRank, Louvain, shortest paths, and more
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

// SPDX-License-Identifier: Apache-2.0
// Copyright 2024-2026 Dragonscale Team

//! uni.algo.bidirectionalDijkstra procedure implementation.

use crate::algo::ProjectionBuilder;
use crate::algo::algorithms::{Algorithm, BidirectionalDijkstra, BidirectionalDijkstraConfig};
use crate::algo::procedure_template::{GenericAlgoProcedure, GraphAlgoAdapter};
use crate::algo::procedures::{AlgoResultRow, ValueType};
use anyhow::Result;
use serde_json::{Value, json};
use uni_common::core::id::Vid;

pub struct BidirectionalDijkstraAdapter;

impl GraphAlgoAdapter for BidirectionalDijkstraAdapter {
    const NAME: &'static str = "uni.algo.bidirectionalDijkstra";
    type Algo = BidirectionalDijkstra;

    fn specific_args() -> Vec<(&'static str, ValueType, Option<Value>)> {
        vec![
            ("startNode", ValueType::Node, None),
            ("endNode", ValueType::Node, None),
            ("weightProperty", ValueType::String, Some(Value::Null)),
        ]
    }

    fn yields() -> Vec<(&'static str, ValueType)> {
        vec![("distance", ValueType::Float)]
    }

    fn to_config(args: Vec<Value>) -> BidirectionalDijkstraConfig {
        BidirectionalDijkstraConfig {
            source: Vid::from(args[0].as_u64().unwrap_or(0)),
            target: Vid::from(args[1].as_u64().unwrap_or(0)),
        }
    }

    fn map_result(result: <Self::Algo as Algorithm>::Result) -> Result<Vec<AlgoResultRow>> {
        let mut rows = Vec::new();
        if let Some(d) = result.distance {
            rows.push(AlgoResultRow {
                values: vec![json!(d)],
            });
        }
        Ok(rows)
    }

    fn customize_projection(mut builder: ProjectionBuilder, args: &[Value]) -> ProjectionBuilder {
        if let Some(prop) = args[2].as_str() {
            builder = builder.weight_property(prop);
        }
        builder.include_reverse(true)
    }
}

pub type BidirectionalDijkstraProcedure = GenericAlgoProcedure<BidirectionalDijkstraAdapter>;