smos-application 0.1.11

SMOS application layer — use cases and port traits.
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

//! ScriptedNliClassifier + ScriptedExtractor + ConstantEmbedder + FixedClock
//! parity invariants.

use super::*;

#[tokio::test]
async fn scripted_returns_in_order() {
    let v1 = neutral_verdict();
    let v2 = NliResult {
        label: NliLabel::Entailment,
        scores: NliScores {
            entailment: 0.9,
            neutral: 0.08,
            contradiction: 0.02,
        },
        available: true,
    };
    let classifier = ScriptedNliClassifier::new(vec![Ok(v1.clone()), Ok(v2.clone())]);

    let r1 = classifier.classify("p1", "h1").await.unwrap();
    let r2 = classifier.classify("p2", "h2").await.unwrap();
    let r3 = classifier.classify("p3", "h3").await;

    assert_eq!(r1.label, v1.label);
    assert_eq!(r2.label, v2.label);
    assert!(r3.is_err(), "exhausted queue must error");
}

#[tokio::test]
async fn matching_invoked_per_call() {
    let classifier = ScriptedNliClassifier::matching(|_p, _h| Ok(neutral_verdict()));

    classifier
        .classify("premise A", "hypothesis A")
        .await
        .unwrap();
    classifier
        .classify("premise B", "hypothesis B")
        .await
        .unwrap();

    let calls = classifier.calls();
    assert_eq!(calls.len(), 2, "closure invoked once per call");
    assert_eq!(
        calls[0],
        ("premise A".to_string(), "hypothesis A".to_string())
    );
    assert_eq!(
        calls[1],
        ("premise B".to_string(), "hypothesis B".to_string())
    );
}

#[tokio::test]
async fn constant_embedder_returns_same_vec() {
    let embedder = ConstantEmbedder(vec![0.1, 0.2, 0.3]);
    let a = embedder.embed("anything").await.unwrap();
    let b = embedder.embed("something else").await.unwrap();
    assert_eq!(a, Some(vec![0.1, 0.2, 0.3]));
    assert_eq!(a, b, "identical regardless of input");
}

#[tokio::test]
async fn scripted_extractor_returns_in_order_then_empty() {
    let extractor = ScriptedExtractor::new(vec![
        Ok(vec!["first fact".to_string()]),
        Ok(vec!["second fact".to_string()]),
    ]);

    let r1 = extractor.extract_facts("content", &[]).await.unwrap();
    let r2 = extractor.extract_facts("content", &[]).await.unwrap();
    let r3 = extractor.extract_facts("content", &[]).await.unwrap();

    assert_eq!(r1, vec!["first fact".to_string()]);
    assert_eq!(r2, vec!["second fact".to_string()]);
    assert!(r3.is_empty(), "exhausted script yields empty, not error");
    assert_eq!(extractor.call_count(), 3);
}

#[test]
fn fixed_clock_constant() {
    let clock = FixedClock(ts());
    assert_eq!(clock.now(), ts());
    assert_eq!(clock.now(), ts(), "always the same instant");
}