iris-chat 0.1.65

Iris Chat command line client and shared encrypted chat core
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

// Protocol receive work yields after a bounded key-search slice. Synchronous
// matrix fixtures drive the same continuation turns the app actor schedules.

use super::*;

pub(super) fn finish_group_search_for_test(
    engine: &mut ProtocolEngine,
    mut result: ProtocolGroupIncomingResult,
) -> ProtocolGroupIncomingResult {
    for _ in 0..128 {
        if !engine.has_ready_group_sender_key_retry_work() {
            return result;
        }
        let retry = engine
            .retry_pending_protocol(NdrUnixSeconds(unix_now().get()))
            .unwrap();
        result.events.extend(retry.group_result.events);
        result.effects.extend(retry.group_result.effects);
        result.effects.extend(retry.effects);
    }
    assert!(
        !engine.has_ready_group_sender_key_retry_work(),
        "Bounded group search did not finish"
    );
    result
}

pub(super) fn deliver_protocol_effects_with_ready_work(
    engine: &mut ProtocolEngine,
    effects: &[ProtocolEffect],
) -> Vec<GroupIncomingEvent> {
    let mut events = deliver_protocol_effects_to_engine(engine, effects);
    let continued = finish_group_search_for_test(engine, ProtocolGroupIncomingResult::default());
    events.extend(continued.events);
    apply_protocol_events_to_engine(
        engine,
        &ordered_protocol_events(&continued.effects),
        &mut events,
    );
    events
}

pub(super) fn deliver_protocol_effects_with_ready_work_once(
    engine: &mut ProtocolEngine,
    effects: &[ProtocolEffect],
) -> (Vec<GroupIncomingEvent>, Vec<ProtocolEffect>) {
    let (mut events, mut effects) = deliver_protocol_effects_to_engine_once(engine, effects);
    let continued = finish_group_search_for_test(engine, ProtocolGroupIncomingResult::default());
    events.extend(continued.events);
    effects.extend(continued.effects);
    (events, effects)
}