hl7v2 1.2.1

HL7 v2 message parser and processor for Rust
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
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128

//! Unit tests for message normalization.

use super::*;

type TestResult = Result<(), Box<dyn std::error::Error>>;

fn ensure(condition: bool, message: &'static str) -> TestResult {
    if condition {
        Ok(())
    } else {
        Err(std::io::Error::other(message).into())
    }
}

#[test]
fn normalize_basic_message() -> TestResult {
    let hl7 = b"MSH|^~\\&|SendingApp|SendingFac|ReceivingApp|ReceivingFac|20250128152312||ADT^A01|ABC123|P|2.5.1\r";

    let normalized = normalize(hl7, false)?;

    ensure(normalized.starts_with(b"MSH|^~\\&|"), "MSH not normalized")
}

#[test]
fn normalize_with_canonical_delimiters() -> TestResult {
    let hl7 = b"MSH*%$!?*SendingApp*SendingFac*ReceivingApp*ReceivingFac*20250128152312**ADT%A01*ABC123*P*2.5.1\r";

    let normalized = normalize(hl7, true)?;
    let normalized_str = String::from_utf8(normalized)?;

    ensure(
        normalized_str.starts_with("MSH|^~\\&|"),
        "canonical delimiters not used",
    )
}

#[test]
fn normalize_preserves_custom_delimiters_when_not_canonical() -> TestResult {
    let hl7 = b"MSH*%$!?*SendingApp*SendingFac*ReceivingApp*ReceivingFac*20250128152312**ADT%A01*ABC123*P*2.5.1\r";

    let normalized = normalize(hl7, false)?;

    ensure(
        normalized.starts_with(b"MSH*%$!?*"),
        "custom delimiters not preserved",
    )
}

#[test]
fn normalize_multi_segment_with_canonical() -> TestResult {
    let hl7 = b"MSH*%$!?*SendingApp*SendingFac*ReceivingApp*ReceivingFac*20250128152312**ADT%A01*ABC123*P*2.5.1\rPID*1**123456%%%HOSP%MR**Doe%John\r";

    let normalized = normalize(hl7, true)?;
    let normalized_str = String::from_utf8(normalized)?;

    ensure(
        normalized_str.starts_with("MSH|^~\\&|"),
        "canonical delimiters not used",
    )?;
    ensure(
        normalized_str.contains("PID|1||123456^^^HOSP^MR||Doe^John"),
        "PID segment not normalized",
    )
}

#[test]
fn normalize_rejects_invalid_message() -> TestResult {
    let invalid = b"PID|1||12345\r";

    ensure(
        matches!(normalize(invalid, true), Err(Error::InvalidSegmentId)),
        "invalid message did not return InvalidSegmentId",
    )
}

#[test]
fn normalize_roundtrips_with_canonical_delimiters() -> TestResult {
    let hl7 = b"MSH|^~\\&|SendingApp|SendingFac|ReceivingApp|ReceivingFac|20250128152312||ADT^A01|ABC123|P|2.5.1\rPID|1||123456^^^HOSP^MR||Doe^John\r";

    let normalized = normalize(hl7, true)?;
    let reparsed = crate::parser::parse(&normalized)?;

    ensure(reparsed.segments.len() == 2, "unexpected segment count")?;
    ensure(
        reparsed.delims.field == '|',
        "field delimiter not canonical",
    )?;
    ensure(
        reparsed.delims.comp == '^',
        "component delimiter not canonical",
    )?;
    ensure(
        reparsed.delims.rep == '~',
        "repetition delimiter not canonical",
    )?;
    ensure(
        reparsed.delims.esc == '\\',
        "escape delimiter not canonical",
    )?;
    ensure(
        reparsed.delims.sub == '&',
        "subcomponent delimiter not canonical",
    )
}

#[test]
fn normalize_preserves_escape_sequences() -> TestResult {
    let hl7 = b"MSH|^~\\&|SendingApp|SendingFac|ReceivingApp|ReceivingFac|20250128152312||ADT^A01|ABC123|P|2.5.1\rPID|1||12345||O\\F\\Brien^John\r";

    let normalized = normalize(hl7, false)?;
    let normalized_str = String::from_utf8(normalized)?;

    ensure(
        normalized_str.contains("O\\F\\Brien"),
        "escape sequence not preserved",
    )
}

#[test]
fn normalize_preserves_unicode_text() -> TestResult {
    let hl7 = "MSH|^~\\&|SendingApp|SendingFac|ReceivingApp|ReceivingFac|20250128152312||ADT^A01|ABC123|P|2.5.1\rPID|1||12345||Müller^Jöhn\r".as_bytes();

    let normalized = normalize(hl7, false)?;
    let normalized_str = String::from_utf8(normalized)?;

    ensure(normalized_str.contains("Müller"), "last name not preserved")?;
    ensure(normalized_str.contains("Jöhn"), "first name not preserved")
}