proto-packet 0.1.0-rc.13

This library provides the dependencies for generated ProtoPacket code.
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
45
46
47
48
49
50
51
52
53
54
55
56
57
58

use crate::service::ServiceError;
use actix_web::web;
use serde::Serialize;
use serde::de::DeserializeOwned;
use std::sync::Mutex;

use super::handle_request;

/// A builder for creating an actix-web scope from a service.
pub struct ServiceScope<S> {
    scope: actix_web::Scope,
    service: web::Data<Mutex<S>>,
}

impl<S: 'static> ServiceScope<S> {
    //! Construction

    /// Creates a new service scope with the given `path` and `service`.
    pub fn new(path: &str, service: S) -> Self {
        Self {
            scope: web::scope(path),
            service: web::Data::new(Mutex::new(service)),
        }
    }
}

impl<S: 'static> ServiceScope<S> {
    //! Calls

    /// Registers a service call at the given `path`.
    pub fn call<I, O, F>(mut self, path: &str, f: F) -> Self
    where
        I: DeserializeOwned + 'static,
        O: Serialize + 'static,
        F: Fn(&mut S, I) -> Result<O, ServiceError> + 'static + Clone,
    {
        let service: web::Data<Mutex<S>> = self.service.clone();
        let handler = move |body: web::Bytes| {
            let service: web::Data<Mutex<S>> = service.clone();
            let f: F = f.clone();
            async move {
                let mut service = service.lock().unwrap_or_else(|e| e.into_inner());
                handle_request::<I, O, _>(&body, |req| f(&mut *service, req))
            }
        };
        self.scope = self.scope.route(path, web::post().to(handler));
        self
    }
}

impl<S: 'static> ServiceScope<S> {
    //! Build

    /// Builds the actix-web scope.
    pub fn build(self) -> actix_web::Scope {
        self.scope.app_data(self.service)
    }
}