lxmf-sdk 0.7.0

High-level Rust SDK for LXMF clients and RPC-backed LXMF workflows.
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
83
84
85
86
87
88
89
90
91
92

use crate::backend::lxmf_wire_fields_from_payload;
use crate::types::{BatchSendItem, BatchSendRequest, SendRequest};
use serde_json::{json, Value as JsonValue};

pub(super) fn send_params(req: SendRequest, message_id: String) -> JsonValue {
    let SendRequest {
        source,
        destination,
        payload,
        delivery_method,
        stamp_cost,
        include_ticket,
        try_propagation_on_fail,
        idempotency_key,
        ttl_ms,
        correlation_id,
        extensions,
    } = req;
    let content = message_content(&payload);
    let title =
        payload.get("title").and_then(JsonValue::as_str).map(str::to_owned).unwrap_or_default();
    let fields = lxmf_wire_fields_from_payload(payload);
    json!({
        "id": message_id,
        "source": source,
        "destination": destination,
        "title": title,
        "content": content,
        "fields": fields,
        "method": delivery_method,
        "stamp_cost": stamp_cost,
        "include_ticket": include_ticket,
        "try_propagation_on_fail": try_propagation_on_fail,
        "idempotency_key": idempotency_key,
        "ttl_ms": ttl_ms,
        "correlation_id": correlation_id,
        "extensions": extensions,
    })
}

pub(super) fn batch_params(req: BatchSendRequest) -> JsonValue {
    let messages = req.messages.into_iter().map(batch_item_params).collect::<Vec<_>>();
    json!({
        "batch_id": req.batch_id,
        "source": req.source,
        "messages": messages,
    })
}

fn batch_item_params(item: BatchSendItem) -> JsonValue {
    let BatchSendItem {
        id,
        destination,
        payload,
        delivery_method,
        stamp_cost,
        include_ticket,
        try_propagation_on_fail,
        idempotency_key,
        ttl_ms,
        correlation_id,
        extensions,
    } = item;
    let content = message_content(&payload);
    let title =
        payload.get("title").and_then(JsonValue::as_str).map(str::to_owned).unwrap_or_default();
    let fields = lxmf_wire_fields_from_payload(payload);
    json!({
        "id": id,
        "destination": destination,
        "title": title,
        "content": content,
        "fields": fields,
        "method": delivery_method,
        "stamp_cost": stamp_cost,
        "include_ticket": include_ticket,
        "try_propagation_on_fail": try_propagation_on_fail,
        "idempotency_key": idempotency_key,
        "ttl_ms": ttl_ms,
        "correlation_id": correlation_id,
        "extensions": extensions,
    })
}

fn message_content(payload: &JsonValue) -> String {
    payload
        .get("content")
        .or_else(|| payload.get("body"))
        .and_then(JsonValue::as_str)
        .map(str::to_owned)
        .unwrap_or_else(|| payload.to_string())
}