blob: a3766658887127a2703b3e217af306298088b54d (
plain)
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
|
use openvpn_plugin;
use std::collections::HashMap;
use std::sync::Mutex;
use talpid_ipc::{IpcServerId, WsIpcClient};
error_chain! {
errors {
IpcSendingError {
description("Failed while sending an event over the IPC channel")
}
}
}
/// Struct processing OpenVPN events and notifies listeners over IPC
pub struct EventProcessor {
ipc_client: Mutex<WsIpcClient>,
}
impl EventProcessor {
pub fn new(server_id: &IpcServerId) -> Result<EventProcessor> {
trace!("Creating EventProcessor");
let ipc_client =
WsIpcClient::connect(server_id).chain_err(|| "Unable to create IPC client")?;
Ok(EventProcessor {
ipc_client: Mutex::new(ipc_client),
})
}
pub fn process_event(
&mut self,
event: openvpn_plugin::types::OpenVpnPluginEvent,
env: HashMap<String, String>,
) -> Result<()> {
trace!("Processing \"{:?}\" event", event);
self.ipc_client
.lock()
.expect("a thread panicked while using the RPC client in the OpenVPN plugin")
.call("openvpn_event", &(event, env))
.map(|_: Option<()>| ())
.chain_err(|| ErrorKind::IpcSendingError)
}
}
|
