brume-cli 0.1.0

CLI to manage folders synchronized with brume
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

use std::collections::HashMap;

use interprocess::local_socket::{
    GenericNamespaced,
    tokio::{Stream, prelude::*},
};
use tarpc::{
    serde_transport, tokio_serde::formats::Bincode, tokio_util::codec::LengthDelimitedCodec,
};

use brume_daemon_proto::{AnySynchroRef, BRUME_SOCK_NAME, BrumeServiceClient, SynchroId};

pub async fn connect_to_daemon() -> Result<BrumeServiceClient, std::io::Error> {
    let name = BRUME_SOCK_NAME.to_ns_name::<GenericNamespaced>()?;

    let conn = Stream::connect(name).await?;

    let codec_builder = LengthDelimitedCodec::builder();

    let transport = serde_transport::new(codec_builder.new_framed(conn), Bincode::default());

    Ok(BrumeServiceClient::new(Default::default(), transport).spawn())
}

pub async fn get_synchro_id(
    synchro_list: &HashMap<SynchroId, AnySynchroRef>,
    synchro_descriptor: &str,
) -> Option<SynchroId> {
    for (id, sync) in synchro_list {
        if (synchro_descriptor.len() > 3 && id.id().to_string().starts_with(synchro_descriptor))
            || sync.name() == synchro_descriptor
        {
            return Some(*id);
        }
    }
    None
}

pub async fn get_synchro(
    synchro_list: &HashMap<SynchroId, AnySynchroRef>,
    synchro_descriptor: &str,
) -> Option<(SynchroId, AnySynchroRef)> {
    for (id, sync) in synchro_list {
        if (synchro_descriptor.len() > 3 && id.id().to_string().starts_with(synchro_descriptor))
            || sync.name() == synchro_descriptor
        {
            return Some((*id, sync.clone()));
        }
    }
    None
}