aboutsummaryrefslogtreecommitdiffstats
path: root/src/bin/rbw-agent/agent.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/bin/rbw-agent/agent.rs')
-rw-r--r--src/bin/rbw-agent/agent.rs12
1 files changed, 3 insertions, 9 deletions
diff --git a/src/bin/rbw-agent/agent.rs b/src/bin/rbw-agent/agent.rs
index 655c3dc..2d9b08e 100644
--- a/src/bin/rbw-agent/agent.rs
+++ b/src/bin/rbw-agent/agent.rs
@@ -48,8 +48,7 @@ pub struct Agent {
impl Agent {
pub fn new() -> anyhow::Result<Self> {
- let config =
- rbw::config::Config::load().context("failed to load config")?;
+ let config = rbw::config::Config::load()?;
let timeout_duration =
tokio::time::Duration::from_secs(config.lock_timeout);
let (w, r) = tokio::sync::mpsc::unbounded_channel();
@@ -125,16 +124,11 @@ async fn handle_request(
sock: &mut crate::sock::Sock,
state: std::sync::Arc<tokio::sync::RwLock<State>>,
) -> anyhow::Result<()> {
- let req = sock
- .recv()
- .await
- .context("failed to receive incoming message")?;
+ let req = sock.recv().await?;
let req = match req {
Ok(msg) => msg,
Err(error) => {
- sock.send(&rbw::protocol::Response::Error { error })
- .await
- .context("failed to send response")?;
+ sock.send(&rbw::protocol::Response::Error { error }).await?;
return Ok(());
}
};