caelix 0.0.37

Public Caelix framework crate.
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

#![cfg(feature = "microservices-nats")]

use caelix::{MessageContext, Microservice, Module, ModuleMetadata, Result};
use serde::{Deserialize, Serialize};

#[derive(Clone, Deserialize, Serialize)]
struct Echo {
    value: String,
}

#[caelix::injectable]
struct EchoMicroservice;

#[caelix::microservice]
impl EchoMicroservice {
    #[caelix::message_pattern("test.echo")]
    async fn echo(&self, #[caelix::payload] input: Echo) -> Result<Echo> {
        Ok(input)
    }

    #[caelix::event_pattern("test.logged")]
    async fn logged(
        &self,
        #[caelix::context] _context: MessageContext,
        #[caelix::payload] _input: Echo,
    ) -> Result<()> {
        Ok(())
    }
}

struct MicroserviceModule;

impl Module for MicroserviceModule {
    fn register() -> ModuleMetadata {
        ModuleMetadata::new().microservice::<EchoMicroservice>()
    }
}

#[caelix::test]
async fn a_microservice_is_a_normal_provider_with_typed_handlers() {
    let container = caelix::build_container::<MicroserviceModule>()
        .await
        .unwrap();
    assert!(container.resolve::<EchoMicroservice>().is_ok());
    assert_eq!(EchoMicroservice::definition().handlers().len(), 2);
}