hl7-parser 0.3.0

Parses the structure of HL7v2 messages, but does not validate the correctness of the messages.
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

use crate::{
    message::{Message, Segment},
    parser::{msh::msh, segment::segment},
};
use nom::{
    branch::alt, bytes::complete::tag, character::complete::char, combinator::opt,
    multi::separated_list0, sequence::preceded, IResult,
};

use super::Span;

pub fn message<'i>(
    lenient_newlines: bool,
) -> impl FnMut(Span<'i>) -> IResult<Span<'i>, Message<'i>> {
    move |i| parse_message(i, lenient_newlines)
}

fn parse_message(i: Span<'_>, lenient_newlines: bool) -> IResult<Span<'_>, Message<'_>> {
    let input_src = i.input;
    let (i, msh) = msh(lenient_newlines)(i)?;
    let mut separators = msh.separators;
    separators.lenient_newlines = lenient_newlines;
    let msh: Segment = msh.into();
    let (i, mut segments) = if lenient_newlines {
        preceded(
            opt(alt((tag("\r\n"), tag("\n"), tag("\r")))),
            separated_list0(
                alt((tag("\r\n"), tag("\n"), tag("\r"))),
                segment(separators),
            ),
        )(i)?
    } else {
        preceded(
            opt(char('\r')),
            separated_list0(char('\r'), segment(separators)),
        )(i)?
    };
    segments.insert(0, msh);
    let pos_end = i.offset;
    let source = &input_src[..pos_end];

    Ok((
        i,
        Message {
            source,
            segments,
            separators,
        },
    ))
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn can_parse_message() {
        let input = Span::new("MSH|^~\\&|EPIC|EPICADT|SMS|SMSADT|199912271408|CHARRIS|ADT^A04|1817457|D|2.5|\rEVN|A04|199912271408|||CHARRIS\rPID||0493575^^^2^ID 1|454721||DOE^JOHN^^^^|DOE^JOHN^^^^|19480203|M||B|254 MYSTREET AVE^^MYTOWN^OH^44123^USA||(216)123-4567|||M|NON|400003403~1129086|\rNK1||ROE^MARIE^^^^|SPO||(216)123-4567||EC|||||||||||||||||||||||||||\rPV1||O|168 ~219~C~PMA^^^^^^^^^||||277^ALLEN MYLASTNAME^BONNIE^^^^|||||||||| ||2688684|||||||||||||||||||||||||199912271408||||||002376853");

        let (_, message) = message(false)(input).unwrap();
        assert_eq!(message.segments.len(), 5);
        assert_eq!(message.segments[0].name, "MSH");
        assert_eq!(message.segments[1].name, "EVN");
        assert_eq!(message.segments[2].name, "PID");
        assert_eq!(message.segments[3].name, "NK1");
        assert_eq!(message.segments[4].name, "PV1");
        assert_eq!(message.segments[1].fields[4].raw_value(), "CHARRIS");
    }

    #[test]
    fn cant_parse_message_with_lf_instead_of_cr_strict() {
        let input = Span::new("MSH|^~\\&|EPIC|EPICADT|SMS|SMSADT|199912271408|CHARRIS|ADT^A04|1817457|D|2.5|\nEVN|A04|199912271408|||CHARRIS\nPID||0493575^^^2^ID 1|454721||DOE^JOHN^^^^|DOE^JOHN^^^^|19480203|M||B|254 MYSTREET AVE^^MYTOWN^OH^44123^USA||(216)123-4567|||M|NON|400003403~1129086|\nNK1||ROE^MARIE^^^^|SPO||(216)123-4567||EC|||||||||||||||||||||||||||\nPV1||O|168 ~219~C~PMA^^^^^^^^^||||277^ALLEN MYLASTNAME^BONNIE^^^^|||||||||| ||2688684|||||||||||||||||||||||||199912271408||||||002376853");

        let (_, message) = message(false)(input).unwrap();
        assert_eq!(message.segments.len(), 1);
    }

    #[test]
    fn can_parse_message_with_lf_instead_of_cr() {
        let input = Span::new("MSH|^~\\&|EPIC|EPICADT|SMS|SMSADT|199912271408|CHARRIS|ADT^A04|1817457|D|2.5|\nEVN|A04|199912271408|||CHARRIS\nPID||0493575^^^2^ID 1|454721||DOE^JOHN^^^^|DOE^JOHN^^^^|19480203|M||B|254 MYSTREET AVE^^MYTOWN^OH^44123^USA||(216)123-4567|||M|NON|400003403~1129086|\nNK1||ROE^MARIE^^^^|SPO||(216)123-4567||EC|||||||||||||||||||||||||||\nPV1||O|168 ~219~C~PMA^^^^^^^^^||||277^ALLEN MYLASTNAME^BONNIE^^^^|||||||||| ||2688684|||||||||||||||||||||||||199912271408||||||002376853");

        let (_, message) = message(true)(input).unwrap();
        assert_eq!(message.segments.len(), 5);
        assert_eq!(message.segments[0].name, "MSH");
        assert_eq!(message.segments[1].name, "EVN");
        assert_eq!(message.segments[2].name, "PID");
        assert_eq!(message.segments[3].name, "NK1");
        assert_eq!(message.segments[4].name, "PV1");
        assert_eq!(message.segments[1].fields[4].raw_value(), "CHARRIS");
    }

    #[test]
    fn can_parse_message_with_crlf_instead_of_cr() {
        let input = Span::new("MSH|^~\\&|EPIC|EPICADT|SMS|SMSADT|199912271408|CHARRIS|ADT^A04|1817457|D|2.5|\r\nEVN|A04|199912271408|||CHARRIS\r\nPID||0493575^^^2^ID 1|454721||DOE^JOHN^^^^|DOE^JOHN^^^^|19480203|M||B|254 MYSTREET AVE^^MYTOWN^OH^44123^USA||(216)123-4567|||M|NON|400003403~1129086|\r\nNK1||ROE^MARIE^^^^|SPO||(216)123-4567||EC|||||||||||||||||||||||||||\r\nPV1||O|168 ~219~C~PMA^^^^^^^^^||||277^ALLEN MYLASTNAME^BONNIE^^^^|||||||||| ||2688684|||||||||||||||||||||||||199912271408||||||002376853");

        let (_, message) = message(true)(input).unwrap();
        assert_eq!(message.segments.len(), 5);
        assert_eq!(message.segments[0].name, "MSH");
        assert_eq!(message.segments[1].name, "EVN");
        assert_eq!(message.segments[2].name, "PID");
        assert_eq!(message.segments[3].name, "NK1");
        assert_eq!(message.segments[4].name, "PV1");
        assert_eq!(message.segments[1].fields[4].raw_value(), "CHARRIS");
    }
}