agdb 0.12.10

Agnesoft Graph Database
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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77

use std::mem::swap;

use crate::DbError;
use crate::StorageData;
use crate::graph::GraphData;
use crate::graph::GraphImpl;
use crate::graph::GraphIndex;
use crate::graph_search::SearchControl;
use crate::graph_search::SearchHandler;
use crate::storage::Storage;

pub struct ElementSearch<'a, D, Data, Handler>
where
    Data: GraphData<D>,
    D: StorageData,
    Handler: SearchHandler,
{
    graph: &'a GraphImpl<D, Data>,
    storage: &'a Storage<D>,
    handler: Handler,
    result: Vec<GraphIndex>,
}

impl<'a, D, Data, Handler> ElementSearch<'a, D, Data, Handler>
where
    Data: GraphData<D>,
    D: StorageData,
    Handler: SearchHandler,
{
    pub fn new(graph: &'a GraphImpl<D, Data>, storage: &'a Storage<D>, handler: Handler) -> Self {
        Self {
            graph,
            storage,
            handler,
            result: vec![],
        }
    }

    pub fn search(&mut self) -> Result<Vec<GraphIndex>, DbError> {
        for (distance, index) in self.graph.iter(self.storage).enumerate() {
            let add_index;
            let finished;

            match self.handler.process(index, distance as u64)? {
                SearchControl::Continue(add) => {
                    add_index = add;
                    finished = false;
                }
                SearchControl::Finish(add) => {
                    add_index = add;
                    finished = true;
                }
                SearchControl::Stop(add) => {
                    add_index = add;
                    finished = false;
                }
            }

            if add_index {
                self.result.push(index);
            }

            if finished {
                break;
            }
        }

        Ok(self.take_result())
    }

    fn take_result(&mut self) -> Vec<GraphIndex> {
        let mut res = Vec::<GraphIndex>::new();
        swap(&mut res, &mut self.result);

        res
    }
}