rucksack 0.9.0

A terminal-based secrets manager, generator, and importer/exporter (Firefox, Chrome) backed with a concurrent hashmap
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

use actix::{Actor, AsyncContext, Context, Handler, Recipient, System, SystemRunner};
use anyhow::Result;

use crate::app::App;

use super::protocol::Command;

pub struct Commander {
    pub app: App,
    #[allow(dead_code)] // TODO: will be used when command dispatch is implemented
    recipient: Recipient<Command>,
}

impl Commander {
    pub fn start(app: App) -> Result<SystemRunner> {
        log::info!(operation = "start_daemon"; "Starting rucksack daemon");
        let system = System::new();
        system.block_on(async {
            Commander::create(|ctx| Commander {
                app,
                recipient: ctx.address().recipient(),
            });
        });
        log::debug!(operation = "start_runner"; "Starting Actix system runner");
        Ok(system)
    }

    pub fn stop() {
        log::info!(operation = "stop_daemon"; "Stopping rucksack daemon");
        System::current().stop()
    }
}

impl Actor for Commander {
    type Context = Context<Self>;

    fn started(&mut self, _ctx: &mut Context<Self>) {
        log::info!(operation = "start"; "Commander has started");
    }

    fn stopped(&mut self, _ctx: &mut Context<Self>) {
        log::info!(operation = "stop"; "Commander has stopped");
    }
}

impl Handler<Command> for Commander {
    type Result = anyhow::Result<()>;

    fn handle(&mut self, _msg: Command, _ctx: &mut actix::Context<Self>) -> Result<()> {
        log::info!(operation = "handle"; "Got message");
        // TODO: add a command dispatch
        Ok(())
    }
}