wasccgraph-redis 0.1.0

RedisGraph implementation of the waSCC Graph Database capability provider contract
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

use redisgraph::Graph;
use std::error::Error;
use wascc_codec::core::CapabilityConfiguration;

const ENV_REDIS_URL: &str = "URL";

pub(crate) fn initialize_client(
    config: CapabilityConfiguration,
) -> Result<redis::Client, Box<dyn Error>> {
    let redis_url = match config.values.get(ENV_REDIS_URL) {
        Some(v) => v,
        None => "redis://0.0.0.0:6379/",
    }
    .to_string();

    info!(
        "Attempting to connect {} to Redis(graph) at {}",
        config.module, redis_url
    );
    match redis::Client::open(redis_url.as_ref()) {
        Ok(c) => Ok(c),
        Err(e) => Err(format!("Failed to connect to Redis(graph): {}", e).into()),
    }
}

pub(crate) fn open_graph(
    connection: redis::Connection,
    graph_name: &str,
) -> Result<Graph, Box<dyn Error>> {
    match Graph::open(connection, graph_name.to_string()) {
        // Invokes a dummy node create and a dummy node to delete, ensures graph exists
        Ok(g) => Ok(g),
        Err(e) => Err(format!("Could not open graph: {:?}", e).into()),
    }
}