relay-knowledge 1.1.14

Graph-database-based knowledge graph project.
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

//! QoS-governed network adapter for external worker JSON requests.

use crate::{
    net::{NetworkRuntime, http},
    ports::worker_outbound::{WorkerOutboundError, WorkerOutboundFuture, WorkerOutboundPort},
};

#[derive(Clone)]
pub struct NetworkWorkerOutbound {
    network: NetworkRuntime,
}

impl NetworkWorkerOutbound {
    pub fn new(network: NetworkRuntime) -> Self {
        Self { network }
    }
}

impl WorkerOutboundPort for NetworkWorkerOutbound {
    fn post_json<'a>(
        &'a self,
        endpoint: &'a str,
        payload: &'a serde_json::Value,
    ) -> WorkerOutboundFuture<'a> {
        Box::pin(async move {
            let network = self.network.current();
            http::post_json_with_qos(
                &network.http,
                &self.network.qos_runtime(),
                &network.qos,
                endpoint,
                payload,
            )
            .await
            .map_err(|error| WorkerOutboundError {
                message: error.to_string(),
            })
        })
    }
}