twitch_tohell 0.1.1

Twitch EventSub webhook and WebSocket support
Documentation 
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
44

use std::{
    convert::Infallible,
    fmt::{Debug, Formatter, Result as FmtResult},
    future::{Ready, ready},
    task::{Context, Poll},
};

use tower::Service;

use crate::websocket::{
    Request, Response,
    router::route::{Route, RouteFuture},
};

pub struct Fallback<E = Infallible>(pub(crate) Route<E>);

impl<E> Fallback<E> {
    pub fn call_with_state<S>(self, req: Request, _state: S) -> RouteFuture<E> {
        self.0.oneshot_owned(req)
    }
}

impl<E> Debug for Fallback<E> {
    fn fmt(&self, f: &mut Formatter<'_>) -> FmtResult {
        f.debug_struct(stringify!(Fallback)).finish_non_exhaustive()
    }
}

#[derive(Debug, Clone, Copy)]
pub struct NotFound;

impl Service<Request> for NotFound {
    type Response = Response;
    type Error = Infallible;
    type Future = Ready<Result<Response, Self::Error>>;

    fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
        Poll::Ready(Ok(()))
    }

    fn call(&mut self, _req: Request) -> Self::Future {
        ready(Ok(Response::default()))
    }
}