fix(deps): update all dependencies

CHANGELOG.md

@@ -6,47 +6,6 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
-## [0.7.4] - 2025-07-24
-
-### Added
-- cleanup aggregate error for single error
-
-## [0.7.3] - 2025-07-24
-
-### Added
-- automatic conversion from anyhow::Error and access to aggregate errors
-
-### Fixed
-- *(deps)* update all dependencies (#30)
-
-## [0.7.2] - 2025-06-25
-
-### Added
-- add wait
-- add conditional, allows adding or waiting for close
-
-### Fixed
-- *(deps)* update rust crate async-trait to v0.1.86 (#28)
-- *(deps)* update rust crate rand to 0.9.0 (#27)
-- *(deps)* update rust crate thiserror to v2.0.11 (#26)
-- *(deps)* update all dependencies (#25)
-- *(deps)* update rust crate async-trait to v0.1.84 (#24)
-- *(deps)* update rust crate thiserror to v2.0.9 (#22)
-- *(deps)* update rust crate thiserror to v2.0.8 (#21)
-- *(deps)* update rust crate thiserror to v2.0.7 (#20)
-- *(deps)* update rust crate thiserror to v2.0.6 (#19)
-- *(deps)* update rust crate thiserror to v2.0.5 (#18)
-- *(deps)* update rust crate tokio-util to v0.7.13 (#17)
-
-### Other
-- chore
-
-- *(deps)* update all dependencies (#29)
-- *(deps)* update rust crate anyhow to v1.0.95 (#23)
-- *(deps)* update all dependencies (#16)
-- *(deps)* update rust crate tracing-subscriber to v0.3.19 (#15)
-- *(deps)* update rust crate tracing to v0.1.41 (#13)
-
 ## [0.7.1] - 2024-11-24
 
 ### Fixed

Cargo.lock

@@ -34,9 +34,9 @@ checksum = "e16d2d3311acee920a9eb8d33b8cbc1787ce4a264e85f964c2404b969bdcd487"
 
 [[package]]
 name = "async-trait"
-version = "0.1.88"
+version = "0.1.87"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "e539d3fca749fcee5236ab05e93a52867dd549cc157c8cb7f99595f3cedffdb5"
+checksum = "d556ec1359574147ec0c4fc5eb525f3f23263a592b1a9c07e0a75b427de55c97"
 dependencies = [
  "proc-macro2",
  "quote",
@@ -201,17 +201,6 @@ version = "0.3.9"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "d231dfb89cfffdbc30e7fc41579ed6066ad03abda9e567ccafae602b97ec5024"
 
-[[package]]
-name = "io-uring"
-version = "0.7.8"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "b86e202f00093dcba4275d4636b93ef9dd75d025ae560d2521b45ea28ab49013"
-dependencies = [
- "bitflags",
- "cfg-if",
- "libc",
-]
-
 [[package]]
 name = "lazy_static"
 version = "1.5.0"
@@ -278,7 +267,7 @@ dependencies = [
 
 [[package]]
 name = "notmad"
-version = "0.7.3"
+version = "0.7.1"
 dependencies = [
  "anyhow",
  "async-trait",
@@ -388,12 +377,13 @@ dependencies = [
 
 [[package]]
 name = "rand"
-version = "0.9.2"
+version = "0.9.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "6db2770f06117d490610c7488547d543617b21bfa07796d7a12f6f1bd53850d1"
+checksum = "3779b94aeb87e8bd4e834cee3650289ee9e0d5677f976ecdb6d219e5f4f6cd94"
 dependencies = [
  "rand_chacha",
  "rand_core",
+ "zerocopy 0.8.14",
 ]
 
 [[package]]
@@ -567,19 +557,17 @@ dependencies = [
 
 [[package]]
 name = "tokio"
-version = "1.46.1"
+version = "1.45.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0cc3a2344dafbe23a245241fe8b09735b521110d30fcefbbd5feb1797ca35d17"
+checksum = "75ef51a33ef1da925cea3e4eb122833cb377c61439ca401b770f54902b806779"
 dependencies = [
  "backtrace",
  "bytes",
- "io-uring",
  "libc",
  "mio",
  "parking_lot",
  "pin-project-lite",
  "signal-hook-registry",
- "slab",
  "socket2",
  "tokio-macros",
  "windows-sys",
@@ -598,9 +586,9 @@ dependencies = [
 
 [[package]]
 name = "tokio-util"
-version = "0.7.15"
+version = "0.7.13"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "66a539a9ad6d5d281510d5bd368c973d636c02dbf8a67300bfb6b950696ad7df"
+checksum = "d7fcaa8d55a2bdd6b83ace262b016eca0d79ee02818c5c1bcdf0305114081078"
 dependencies = [
  "bytes",
  "futures-core",

Cargo.toml

@@ -3,7 +3,7 @@ members = ["crates/*"]
 resolver = "2"
 
 [workspace.package]
-version = "0.7.4"
+version = "0.7.1"
 
 [workspace.dependencies]
 mad = { path = "crates/mad" }

crates/mad/Cargo.toml

@@ -4,8 +4,8 @@ version.workspace = true
 description = "notmad is a life-cycle manager for long running rust operations"
 license = "MIT"
 repository = "https://github.com/kjuulh/mad"
-authors = ["kjuulh"]
-edition = "2024"
+author = "kjuulh"
+edition = "2021"
 
 [dependencies]
 anyhow.workspace = true

crates/mad/src/lib.rs

@@ -1,14 +1,10 @@
 use futures::stream::FuturesUnordered;
 use futures_util::StreamExt;
 use std::{fmt::Display, sync::Arc};
-use tokio::signal::unix::{SignalKind, signal};
+use tokio::signal::unix::{signal, SignalKind};
 
 use tokio_util::sync::CancellationToken;
 
-use crate::waiter::Waiter;
-
-mod waiter;
-
 #[derive(thiserror::Error, Debug)]
 pub enum MadError {
     #[error("component failed: {0}")]
@@ -30,33 +26,13 @@ pub enum MadError {
     CloseNotDefined,
 }
 
-impl From<anyhow::Error> for MadError {
-    fn from(value: anyhow::Error) -> Self {
-        Self::Inner(value)
-    }
-}
-
 #[derive(Debug)]
 pub struct AggregateError {
     errors: Vec<MadError>,
 }
 
-impl AggregateError {
-    pub fn get_errors(&self) -> &[MadError] {
-        &self.errors
-    }
-}
-
 impl Display for AggregateError {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
-        if self.errors.is_empty() {
-            return Ok(());
-        }
-
-        if self.errors.len() == 1 {
-            return f.write_str(&self.errors.first().unwrap().to_string());
-        }
-
         f.write_str("MadError::AggregateError: (")?;
 
         for error in &self.errors {
@@ -94,23 +70,6 @@ impl Mad {
         self
     }
 
-    pub fn add_conditional(&mut self, condition: bool, component: impl IntoComponent) -> &mut Self {
-        if condition {
-            self.components.push(component.into_component());
-        } else {
-            self.components
-                .push(Waiter::new(component.into_component()).into_component())
-        }
-
-        self
-    }
-
-    pub fn add_wait(&mut self) -> &mut Self {
-        self.components.push(Waiter::default().into_component());
-
-        self
-    }
-
     pub fn add_fn<F, Fut>(&mut self, f: F) -> &mut Self
     where
         F: Fn(CancellationToken) -> Fut + Send + Sync + 'static,
@@ -141,7 +100,7 @@ impl Mad {
             (Err(run), Err(close)) => {
                 return Err(MadError::AggregateError(AggregateError {
                     errors: vec![run, close],
-                }));
+                }))
             }
             (Ok(_), Ok(_)) => {}
             (Ok(_), Err(close)) => return Err(close),

crates/mad/src/waiter.rs

@@ -1,48 +0,0 @@
-use std::sync::Arc;
-
-use async_trait::async_trait;
-use tokio_util::sync::CancellationToken;
-
-use crate::{Component, MadError};
-
-pub struct DefaultWaiter {}
-#[async_trait]
-impl Component for DefaultWaiter {
-    async fn run(&self, _cancellation_token: CancellationToken) -> Result<(), MadError> {
-        panic!("should never be called");
-    }
-}
-
-pub struct Waiter {
-    comp: Arc<dyn Component + Send + Sync + 'static>,
-}
-
-impl Default for Waiter {
-    fn default() -> Self {
-        Self {
-            comp: Arc::new(DefaultWaiter {}),
-        }
-    }
-}
-
-impl Waiter {
-    pub fn new(c: Arc<dyn Component + Send + Sync + 'static>) -> Self {
-        Self { comp: c }
-    }
-}
-
-#[async_trait]
-impl Component for Waiter {
-    fn name(&self) -> Option<String> {
-        match self.comp.name() {
-            Some(name) => Some(format!("waiter/{name}")),
-            None => Some("waiter".into()),
-        }
-    }
-
-    async fn run(&self, cancellation_token: CancellationToken) -> Result<(), MadError> {
-        cancellation_token.cancelled().await;
-
-        Ok(())
-    }
-}

crates/mad/tests/mod.rs

@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
 use async_trait::async_trait;
-use notmad::{Component, Mad, MadError};
+use notmad::{Component, Mad};
 use rand::Rng;
 use tokio::sync::Mutex;
 use tokio_util::sync::CancellationToken;
@@ -137,20 +137,3 @@ async fn test_can_shutdown_gracefully() -> anyhow::Result<()> {
 
     Ok(())
 }
-
-#[test]
-fn test_can_easily_transform_error() -> anyhow::Result<()> {
-    fn fallible() -> anyhow::Result<()> {
-        Ok(())
-    }
-
-    fn inner() -> Result<(), MadError> {
-        fallible()?;
-
-        Ok(())
-    }
-
-    inner()?;
-
-    Ok(())
-}