ASTM/TCP results inbound channel

var raw = String(connectorMessage.getRawData())
    .replace(/\r\n/g, '\r')
    .replace(/\n/g, '\r');

var records = raw.split('\r').filter(function (record) {
    return record.length > 0;
});

var header = records.filter(function (record) {
    return record.indexOf('H|') === 0;
})[0];

var patient = records.filter(function (record) {
    return record.indexOf('P|') === 0;
})[0];

if (!patient) {
    throw 'ASTM message does not contain a P specimen record.';
}

var specimenNumber = patient.split('|')[3];

var results = records
    .filter(function (record) {
        return record.indexOf('R|') === 0;
    })
    .map(function (record) {
        var field = record.split('|');
        var testParts = field[2].split('^');

        return {
            analyzer_test_code: testParts[testParts.length - 1],
            value: field[3],
            unit: field[4],
            flag: field[6] || null,
            observed_at: new Date().toISOString()
        };
    });

if (results.length === 0) {
    throw 'ASTM message does not contain result records.';
}

var headerFields = header ? header.split('|') : [];
var messageId = headerFields.length
    ? headerFields[headerFields.length - 1]
    : java.util.UUID.randomUUID().toString();

msg = JSON.stringify({
    message_id: messageId,
    instrument_code: 'PILOT-HEM-01',
    specimen_number: specimenNumber,
    received_at: new Date().toISOString(),
    results: results
});