pub mod codec;
pub mod error;
pub mod protocol;
pub mod types;
pub use codec::{
decode_request, decode_response, encode_request, encode_response, read_frame, write_frame,
};
pub use error::{CodecError, IpcError};
pub use protocol::{
BearingsRequest, CaptureMode, CaptureRequest, ClusterRequest, ClusterTarget, CompositorRequest,
DpmsCommand, MonitorFocusDirection, MonitorFocusTarget, MonitorRequest, NodeMoveDirection,
NodeRequest, NodeSelector, Request, Response, StackCycleDirection, StackRequest, TileRequest,
TrailDirection, TrailRequest, TrailTarget,
};
pub use types::{
ApertureMode, ApertureStatusResponse, BearingsStatusResponse, CaptureStatusResponse,
ClusterInfo, ClusterLayoutKind, ClusterListResponse, ClusterOutputGroup, ClusterSummary,
LogicalOutputInfo, ModeInfo, NodeInfo, NodeKind, NodeListResponse, NodeOutputGroup,
NodeProtocolFamily, NodeRelationInfo, NodeRole, NodeState, OutputInfo, OutputStatus,
OutputsResponse, TrailEntryInfo, TrailListResponse,
};
use std::env;
use std::io;
use std::os::unix::net::UnixStream;
use std::path::PathBuf;
pub fn default_socket_path() -> io::Result<PathBuf> {
let runtime_dir = env::var_os("XDG_RUNTIME_DIR")
.ok_or_else(|| io::Error::new(io::ErrorKind::NotFound, "XDG_RUNTIME_DIR is not set"))?;
Ok(PathBuf::from(runtime_dir)
.join("halley")
.join("halley.sock"))
}
pub fn send_request(req: &Request) -> Result<Response, CodecError> {
let path = default_socket_path()?;
send_request_to(&path, req)
}
pub fn send_request_to(path: &std::path::Path, req: &Request) -> Result<Response, CodecError> {
let mut stream = UnixStream::connect(path)?;
let bytes = encode_request(req)?;
write_frame(&mut stream, &bytes)?;
let resp_bytes = read_frame(&mut stream)?;
decode_response(&resp_bytes)
}