iridis-layout 0.4.0

iridis is a framework that lets you define and build dataflow applications with ease.
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

//! This module defines the 'flows' part of the `dataflow` application.

use std::collections::HashSet;

use crate::prelude::*;

/// Represents the flows of the application.
#[derive(Debug, Clone)]
pub struct FlowLayout {
    pub connections: HashSet<(Uuid, Uuid)>, // Send -> Receive
}

impl FlowLayout {
    fn connect_output_input(&mut self, output: impl AsRef<Uuid>, input: impl AsRef<Uuid>) {
        self.connections.insert((*output.as_ref(), *input.as_ref()));
    }

    fn connect_queryable_query(&mut self, queryable: impl AsRef<Uuid>, query: impl AsRef<Uuid>) {
        self.connections
            .insert((*queryable.as_ref(), *query.as_ref()));

        self.connections
            .insert((*query.as_ref(), *queryable.as_ref()));
    }

    /// Connects two primitives in the graph. The order does not matter.
    pub fn connect(&mut self, a: impl Into<PrimitiveID>, b: impl Into<PrimitiveID>) -> Result<()> {
        let (a, b) = (a.into(), b.into());

        match (a, b) {
            (PrimitiveID::Input(input), PrimitiveID::Output(output)) => {
                self.connect_output_input(output.uuid, input.uuid);
                Ok(())
            }
            (PrimitiveID::Query(query), PrimitiveID::Queryable(queryable)) => {
                self.connect_queryable_query(queryable.uuid, query.uuid);
                Ok(())
            }
            (PrimitiveID::Output(output), PrimitiveID::Input(input)) => {
                self.connect_output_input(output.uuid, input.uuid);
                Ok(())
            }
            (PrimitiveID::Queryable(queryable), PrimitiveID::Query(query)) => {
                self.connect_queryable_query(queryable.uuid, query.uuid);
                Ok(())
            }
            _ => Err(eyre::eyre!(
                "Invalid connection! types `a` and `b` must verify: a != b and (a, b) in {{Input, Output}} or {{Query, Queryable}}"
            )),
        }
    }
}