istat 0.6.0

A lightweight and batteries-included status_command for i3 and sway
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

mod client;
pub mod protocol;
mod server;

use std::env;
use std::path::PathBuf;

use tokio_util::sync::CancellationToken;

pub use self::server::{create_ipc_socket, handle_ipc_events};
use crate::bar::Bar;
use crate::config::AppConfig;
use crate::dispatcher::Dispatcher;
use crate::error::Result;
use crate::util::RcCell;

#[derive(Debug, Clone)]
pub struct IpcContext {
    bar: RcCell<Bar>,
    token: CancellationToken,
    config: RcCell<AppConfig>,
    dispatcher: RcCell<Dispatcher>,
}

impl IpcContext {
    pub fn new(
        bar: RcCell<Bar>,
        token: CancellationToken,
        config: RcCell<AppConfig>,
        dispatcher: RcCell<Dispatcher>,
    ) -> IpcContext {
        IpcContext {
            bar,
            token,
            config,
            dispatcher,
        }
    }
}

pub fn get_socket_path(socket_path: Option<&PathBuf>) -> Result<PathBuf> {
    socket_path.map_or_else(
        || {
            let i3_socket = PathBuf::from(match env::var("I3SOCK") {
                Ok(v) => v,
                Err(e) => bail!("I3SOCK: {}", e),
            });

            let my_socket = PathBuf::from(&i3_socket).with_extension(
                i3_socket
                    .extension()
                    .map(|ext| format!("{}.istat", ext.to_string_lossy()))
                    .unwrap(),
            );

            Ok(my_socket)
        },
        |p| Ok(p.clone()),
    )
}