src/split.js

import {map} from '@iterable-iterator/map';
import {chain} from '@iterable-iterator/chain';

import merge from './merge.js';

const reportParts = function* ({header, blocks, footer}) {
	yield {
		meta: {
			...header.reference.parsed,
			...header.code.parsed,
			...header.extra.parsed,
		},
		patient: {
			...header.identifier.parsed,
			...header.name.parsed,
			birthdate: header.birthdate.parsed.date,
			...header.sex.parsed,
			requestDate: header.requestDate.parsed.date,
		},
		lines: [
			...header.identifier.lines,
			...header.name.lines,
			...header.birthdate.lines,
			...header.sex.lines,
			...header.requestDate.lines,
			...header.reference.lines,
			...header.code.lines,
			...header.extra.lines,
		],
	};

	for (const {begin, title, contents, end} of blocks) {
		yield {
			results: [
				{
					...begin.parsed,
					...title.parsed,
					...contents.parsed,
				},
			],
			lines: [...begin.lines, ...title.lines, ...contents.lines, ...end.lines],
		};
	}

	yield {
		lines: [...footer.lines],
	};
};

const documentHeaderParts = function* (header) {
	if (header.kind === 'lab') {
		yield {
			type: 'lab',
			lab: {
				...header.lab.identifier.parsed,
				...header.lab.name.parsed,
				...header.lab.address.parsed,
				...header.lab.extra.parsed,
			},
			lines: [
				...header.lab.identifier.lines,
				...header.lab.name.lines,
				...header.lab.address.lines,
				...header.lab.extra.lines,
			],
		};
	} else {
		yield {
			type: 'report',
			doctor: {
				...header.doctor.nihdi.parsed,
				...header.doctor.name.parsed,
				...header.doctor.address.parsed,
				...header.doctor.phone.parsed,
				...header.doctor.extra.parsed,
			},
			lines: [
				...header.doctor.nihdi.lines,
				...header.doctor.name.lines,
				...header.doctor.address.lines,
				...header.doctor.phone.lines,
				...header.doctor.extra.lines,
			],
		};
	}

	yield {
		meta: {
			...header.date.parsed,
		},
		requestor: {
			...header.requestor.nihdi.parsed,
			...header.requestor.name.parsed,
		},
		lines: [
			...header.date.lines,
			...header.requestor.nihdi.lines,
			...header.requestor.name.lines,
		],
	};
};

const splitDocument = ({header, reports, footer}) => {
	const commonBegin = merge(documentHeaderParts(header));
	const commonEnd = {
		lines: [...footer.lines],
	};
	return map(
		(report) => merge(chain([commonBegin], reportParts(report), [commonEnd])),
		reports,
	);
};

const split = async function* (documents) {
	for await (const document of documents) yield* splitDocument(document);
};

export default split;