prns-core 0.3.4

Pure Reticulum engine and wire contract for Personal Reticulum
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

use crate::engine::{
    CommandId, EngineReaction, Journaled, SendRequestFailure, SendSinglePacketFailure,
    SendToLinkFailure, Settlement,
};
use crate::routing::delivery::receipts::ReceiptKind;

pub(super) fn settle(
    sink: &mut impl FnMut(EngineReaction<'_>),
    id: CommandId,
    settlement: Settlement,
) {
    sink(EngineReaction::Journaled(Journaled::CommandSettled {
        id,
        settlement,
    }));
}

pub(super) fn culled_settlement(kind: ReceiptKind) -> Settlement {
    match kind {
        ReceiptKind::SendSinglePacket => {
            Settlement::SendSinglePacket(Err(SendSinglePacketFailure::Culled))
        }
        ReceiptKind::SendToLink(_) => Settlement::SendToLink(Err(SendToLinkFailure::Culled)),
        ReceiptKind::SendRequest { .. } => Settlement::SendRequest(Err(SendRequestFailure::Culled)),
    }
}

pub(super) fn timeout_settlement(kind: ReceiptKind) -> Settlement {
    match kind {
        ReceiptKind::SendSinglePacket => {
            Settlement::SendSinglePacket(Err(SendSinglePacketFailure::Timeout))
        }
        ReceiptKind::SendToLink(_) => Settlement::SendToLink(Err(SendToLinkFailure::Timeout)),
        ReceiptKind::SendRequest { .. } => {
            Settlement::SendRequest(Err(SendRequestFailure::Timeout))
        }
    }
}