Sena

Library for composable handlers. Many things can be expressed in the following way:

1. Receive event
2. Handle event
3. Reply with a something meaningful

sena is a library that simplifies writing code in that pattern, for example:

use std::num::ParseIntError;
use sena::handling::Handler;

fn increment<E>() -> impl Handler<i32, E, Output = i32> {
  |req: i32| async move {
    Ok(req + 1)
  }
}

fn parse_int<E: From<ParseIntError>>() -> impl Handler<String, E, Output = i32> {
  |req: String| async move { req.parse().map_err(Into::into) }
}

async fn entrypoint() -> Result<(), ParseIntError> {
  let chain = parse_int::<ParseIntError>() // parses input string
    .pipe(increment())  // pipes output from parse_int to increment
    .pipe(increment()); // one more time
  let result = chain.handle("100".to_owned()).await?;

  assert_eq!(result, 102);
  Ok(())
}

Let's break that code into parts:

1. First, we define a handler, handler can be plain function or closure or any type that implements handling::Handler trait
2. parse_int is a handler that converts String to a i32
3. .pipe method on the handler pipes input from left-hand side handler (before the dot) to right-hand side handler (increment() in ourcase)
4. Then, we calling chain.handle on resulting handler

There's more handlers for composability, like handling::seq::Seq handler that allows running "middlewares" (functions with continuations) on the handler or handling::map::MapAsync/handling::map::Map that allows converting handler's input to another type.

Also take a look at [csp] module and at handling::server::Server, this can be used to turn your handler into a server or "actor".

Dependency injection

sena doesn't provide batteries for dependency injection, however, it provides handling::Handler::provide and dependent::Dependent for basic dependency injection needs, these can be sufficient for great amount of use-cases.

Why error type is generic?

It is a good solution, since it allows usage of handler in more flexible way: handler can be used with any error type as long as its specific errors can be converted to that type.

Examples

Take a look at github: https://github.com/nerodono/sena-rs