epcis-cli 0.2.0

Command line interface for EPCIS event hashing and identifier translation
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
93
94
95
96

use std::process::Command;

#[test]
fn test_cli_translate() {
    let output = Command::new("cargo")
        .args([
            "run",
            "-p",
            "epcis-cli",
            "--",
            "--translate",
            "urn:epc:id:sgtin:4012345.098765.12345",
        ])
        .output()
        .expect("Failed to execute command");

    assert!(
        output.status.success(),
        "Stderr: {}",
        String::from_utf8_lossy(&output.stderr)
    );
    let stdout = String::from_utf8(output.stdout).unwrap();
    assert_eq!(
        stdout.trim(),
        "https://id.gs1.org/01/04012345987652/21/12345"
    );
}

#[test]
fn test_cli_translate_dl() {
    let output = Command::new("cargo")
        .args([
            "run",
            "-p",
            "epcis-cli",
            "--",
            "--translate",
            "https://id.gs1.org/01/04012345987652/21/12345",
        ])
        .output()
        .expect("Failed to execute command");

    assert!(
        output.status.success(),
        "Stderr: {}",
        String::from_utf8_lossy(&output.stderr)
    );
    let stdout = String::from_utf8(output.stdout).unwrap();
    assert_eq!(stdout.trim(), "urn:epc:id:sgtin:4012345.098765.12345");
}

#[test]
fn test_cli_hash_json() {
    let json_input = r#"{
      "@context": ["https://ref.gs1.org/standards/epcis/2.0.0/epcis-context.jsonld"],
      "type": "EPCISDocument",
      "schemaVersion": "2.0",
      "creationDate": "2020-03-04T11:00:30.000Z",
      "epcisBody": {
        "eventList": [
          {
            "type": "ObjectEvent",
            "eventTime": "2020-03-04T11:00:30.000Z",
            "eventTimeZoneOffset": "+00:00",
            "action": "OBSERVE",
            "epcList": ["urn:epc:id:sgtin:4012345.098765.12345"]
          }
        ]
      }
    }"#;

    use std::io::Write;
    let mut child = Command::new("cargo")
        .args(["run", "-p", "epcis-cli", "--", "-p"])
        .stdin(std::process::Stdio::piped())
        .stdout(std::process::Stdio::piped())
        .spawn()
        .expect("Failed to spawn process");

    {
        let stdin = child.stdin.as_mut().expect("Failed to open stdin");
        stdin
            .write_all(json_input.as_bytes())
            .expect("Failed to write to stdin");
    }

    let output = child.wait_with_output().expect("Failed to wait on child");
    assert!(
        output.status.success(),
        "Stderr: {}",
        String::from_utf8_lossy(&output.stderr)
    );
    let stdout = String::from_utf8(output.stdout).unwrap();
    assert!(stdout.contains("eventType=ObjectEvent"));
    assert!(stdout.contains("action=OBSERVE"));
}