microservices 0.9.0

LNP/BP support crate for devloping microservices
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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

// LNP/BP Core Library implementing LNPBP specifications & standards
// Written in 2020 by
//     Dr. Maxim Orlovsky <orlovsky@pandoracore.com>
//
// To the extent possible under law, the author(s) have dedicated all
// copyright and related and neighboring rights to this software to
// the public domain worldwide. This software is distributed without
// any warranty.
//
// You should have received a copy of the MIT License
// along with this software.
// If not, see <https://opensource.org/licenses/MIT>.

use std::fmt::{Debug, Display};

use internet2::addr::ServiceAddr;
use internet2::presentation::{CreateUnmarshaller, Error, TypedEnum};
use internet2::session::LocalSession;
use internet2::{SendRecvMessage, ZmqSocketType};

use crate::rpc::FailureCodeExt;
use crate::ZMQ_CONTEXT;

/// Marker trait for LNP RPC requests
pub trait Request: Debug + Display + TypedEnum + CreateUnmarshaller {}

/// Marker trait for LNP RPC replies
pub trait Reply: Debug + Display + TypedEnum + CreateUnmarshaller {}

/// RPC API pair, connecting [`Request`] type with [`Reply`]
pub trait Api {
    /// Requests supported by RPC API
    type Request: Request;

    /// Replies supported by RPC API
    type Reply: Reply;

    /// Extended failure codes which are service-specific
    type FailureCodeExt: FailureCodeExt;
}

#[allow(dead_code)]
pub struct RpcConnection<A>
where
    A: Api,
{
    api: A,
    session: Box<dyn SendRecvMessage>,
}

impl<A> RpcConnection<A>
where
    A: Api,
{
    pub fn connect(
        api: A,
        // TODO: Convert parameter to ServiceAddr once RpcSession will be complete
        remote: &ServiceAddr,
        local: &ServiceAddr,
    ) -> Result<Self, Error> {
        // TODO: Use RpcSession once its implementation is complete
        let session = Box::new(LocalSession::connect(
            ZmqSocketType::Req,
            remote,
            Some(local),
            None,
            &ZMQ_CONTEXT,
        )?);
        Ok(Self { api, session })
    }

    pub fn accept(api: A, remote: &ServiceAddr, local: &ServiceAddr) -> Result<Self, Error> {
        let session = Box::new(LocalSession::connect(
            ZmqSocketType::Rep,
            remote,
            Some(local),
            None,
            &ZMQ_CONTEXT,
        )?);
        Ok(Self { api, session })
    }
}