fhir-sdk 0.15.1

//! Integration tests for all FHIR versions using the HAPI FHIR servers.
#![cfg(all(feature = "builders", feature = "client"))]
#![allow(
	clippy::tests_outside_test_module,
	clippy::expect_used,
	clippy::unwrap_used,
	clippy::print_stdout,
	clippy::indexing_slicing,
	reason = "Tests"
)]

mod common;

use std::{env, str::FromStr};

use anyhow::Result;
use fhir_sdk::{
	Date, TryStreamExt,
	client::{Client, ResourceWrite, SearchParameters, TokenSearch},
	for_all_versions,
};

// Rustfmt gives up on this one :(
/// Client tests via HAPI for every supported FHIR version.
macro_rules! impl_hapi_tests {
	(@sel stu3) => {
		fhir_sdk::version::FhirStu3
	};
	(@sel r4b) => {
		fhir_sdk::version::FhirR4B
	};
	(@sel r5) => {
		fhir_sdk::version::FhirR5
	};
	(@url stu3) => {
		"http://localhost:8110/fhir/"
	};
	(@url r4b) => {
		"http://localhost:8090/fhir/"
	};
	(@url r5) => {
		"http://localhost:8100/fhir/"
	};
	(@encounter_class stu3) => {
		fhir_sdk::stu3::types::Coding::builder()
			.system("test-system".to_owned())
			.code("test-code".to_owned())
			.build()
			.unwrap()
	};
	(@encounter_class r4b) => {
		fhir_sdk::r4b::types::Coding::builder()
			.system("test-system".to_owned())
			.code("test-code".to_owned())
			.build()
			.unwrap()
	};
	(@encounter_class r5) => {
		vec![]
	};
	($version:ident) => {
		mod $version {
			use fhir_sdk::$version::{
				codes::{AdministrativeGender, EncounterStatus, IssueSeverity, SearchComparator, HTTPVerb, BundleType},
				resources::{
					BaseResource, Bundle, Encounter, OperationOutcome, ParametersParameter,
					ParametersParameterValue, Patient, Resource, ResourceType,
				},
				types::{HumanName, Identifier, Reference},
			};
			use fhir_sdk::client::$version::DateSearch;

			use super::*;

			/// The selected FHIR version.
			type SelVer = impl_hapi_tests!(@sel $version);

			/// Set up a client for testing with the (local) FHIR server.
			async fn client() -> Result<Client<SelVer>> {
				common::setup_logging().await;
				let base_url = env::var("FHIR_SERVER")
					.unwrap_or(impl_hapi_tests!(@url $version).to_owned())
					.parse()?;
				Ok(Client::new(base_url)?)
			}

			/// Go through all entries of the bundle, extracting the outcomes and search
			/// for errors inside. Fail if there is any of severity error or fatal.
			fn ensure_batch_succeeded(bundle: Bundle) {
				let batch_errors = bundle
					.entry
					.iter()
					.flatten()
					.filter_map(|entry| entry.response.as_ref())
					.filter_map(|response| response.outcome.as_ref())
					.filter_map(|resource| <&OperationOutcome>::try_from(resource).ok())
					.flat_map(|outcome| outcome.issue.iter().flatten())
					.any(|issue| {
						matches!(issue.severity, IssueSeverity::Error | IssueSeverity::Fatal)
					});
				let bundle_json = serde_json::to_string_pretty(&bundle).expect("serialize Bundle");
				assert!(!batch_errors, "Batch failed: {bundle_json}");
			}

			#[test]
			fn crud() -> Result<()> {
				common::RUNTIME.block_on(crud_inner())
			}

			async fn crud_inner() -> Result<()> {
				let client = client().await?;

				let mut patient = Patient::builder().active(false).build().unwrap();
				let id = patient.create(&client).await?;
				let resource = client.read::<Patient>(&id).await?.expect("should find resource");
				assert_eq!(resource.active, patient.active);

				patient.active = Some(true);
				patient.update(false, &client).await?;
				patient.active = None;
				patient.update(true, &client).await?;
				let version_id =
					patient.meta.as_ref().and_then(|meta| meta.version_id.as_ref()).expect("get version ID");
				let resource =
					client.read_version::<Patient>(&id, version_id).await?.expect("should find resource");
				assert_eq!(resource.active, patient.active);

				patient.delete(&client).await?;
				let resource = client.read::<Patient>(&id).await?;
				assert_eq!(resource, None);

				Ok(())
			}

			#[test]
			fn read_referenced() -> Result<()> {
				common::RUNTIME.block_on(read_referenced_inner())
			}

			async fn read_referenced_inner() -> Result<()> {
				let client = client().await?;

				let mut patient = Patient::builder().build().unwrap();
				patient.create(&client).await?;

				let reference = Reference::relative_to(&patient).expect("creating reference");
				let read = client.read_referenced(&reference).await?;
				assert_eq!(read.as_base_resource().id(), patient.id());

				Ok(())
			}

			#[test]
			fn patch_via_fhir() -> Result<()> {
				common::RUNTIME.block_on(patch_via_fhir_inner())
			}

			async fn patch_via_fhir_inner() -> Result<()> {
				let client = client().await?;

				let mut patient = Patient::builder()
					.active(false)
					.gender(AdministrativeGender::Male)
					.name(vec![Some(HumanName::builder().family("Test".to_owned()).build().unwrap())])
					.build()
					.unwrap();
				patient.create(&client).await?;

				let date = Date::from_str("2021-02-01").expect("parse Date");
				client
					.patch_via_fhir(ResourceType::Patient, patient.id.as_ref().expect("Patient.id"))
					.add(
						"Patient",
						"birthDate",
						ParametersParameter::builder()
							.name("value".to_owned())
							.value(ParametersParameterValue::Date(date.clone()))
							.build()
							.unwrap(),
					)
					.delete("Patient.active")
					.replace(
						"Patient.gender",
						ParametersParameter::builder()
							.name("value".to_owned())
							.value(ParametersParameterValue::Code("female".to_owned()))
							.build()
							.unwrap(),
					)
					.insert(
						"Patient.name",
						ParametersParameter::builder()
							.name("value".to_owned())
							.value(ParametersParameterValue::HumanName(
								HumanName::builder().family("Family".to_owned()).build().unwrap(),
							))
							.build()
							.unwrap(),
						0,
					)
					.send()
					.await?;

				let patient: Patient =
					client.read(patient.id.as_ref().expect("Patient.id")).await?.expect("Patient should exist");
				assert_eq!(patient.birth_date, Some(date));
				assert_eq!(patient.active, None);
				assert_eq!(patient.gender, Some(AdministrativeGender::Female));
				assert_eq!(patient.name.len(), 2);

				Ok(())
			}

			#[test]
			fn patch_via_json() -> Result<()> {
				common::RUNTIME.block_on(patch_via_json_inner())
			}

			async fn patch_via_json_inner() -> Result<()> {
				let client = client().await?;

				let mut patient = Patient::builder()
					.active(false)
					.gender(AdministrativeGender::Male)
					.name(vec![Some(HumanName::builder().family("Test".to_owned()).build().unwrap())])
					.build()
					.unwrap();
				patient.create(&client).await?;

				let date = Date::from_str("2021-02-01").expect("parse Date");
				client
					.patch_via_json(ResourceType::Patient, patient.id.as_ref().expect("Patient.id"))
					.add("/birthDate", &date)?
					.remove("/active")
					.replace("/gender", AdministrativeGender::Female)?
					.add("/name/0", HumanName::builder().family("Family".to_owned()).build().unwrap())?
					.send()
					.await?;

				let patient: Patient =
					client.read(patient.id.as_ref().expect("Patient.id")).await?.expect("Patient should exist");
				assert_eq!(patient.birth_date, Some(date));
				assert_eq!(patient.active, None);
				assert_eq!(patient.gender, Some(AdministrativeGender::Female));
				assert_eq!(patient.name.len(), 2);

				Ok(())
			}

			#[test]
			fn search() -> Result<()> {
				common::RUNTIME.block_on(search_inner())
			}

			async fn search_inner() -> Result<()> {
				let client = client().await?;

				let date_str = "5123-05-05";
				let date = Date::from_str(date_str).expect("parse Date");

				let mut patient = Patient::builder().active(false).birth_date(date.clone()).build().unwrap();
				let id = patient.create(&client).await?;

				let patients: Vec<Patient> = client
					.search(
						SearchParameters::empty()
							.and_raw("_id", id)
							.and(DateSearch {
								name: "birthdate",
								comparator: Some(SearchComparator::Eq),
								value: date_str,
							})
							.and(TokenSearch::Standard {
								name: "active",
								system: None,
								code: Some("false"),
								not: false,
							}),
					)
					.await?
					.all_matches()
					.try_collect()
					.await?;
				assert_eq!(patients.len(), 1);
				assert_eq!(patients[0].active, Some(false));
				assert_eq!(patients[0].birth_date, Some(date));

				patient.delete(&client).await?;
				Ok(())
			}

			#[test]
			fn transaction() -> Result<()> {
				common::RUNTIME.block_on(transaction_inner())
			}

			async fn transaction_inner() -> Result<()> {
				let client = client().await?;

				let mut patient1 = Patient::builder().build().unwrap();
				patient1.create(&client).await?;
				let mut patient2 = Patient::builder().build().unwrap();
				patient2.create(&client).await?;
				let mut patient3 = Patient::builder().build().unwrap();
				patient3.create(&client).await?;

				let mut transaction = client.transaction();
				transaction.delete(ResourceType::Patient, patient1.id.as_ref().expect("Patient.id"));
				transaction.read(ResourceType::Patient, patient1.id.as_ref().expect("Patient.id"));
				transaction.update(patient3, true)?;
				let patient_ref = transaction.create(Patient::builder().build().unwrap());
				let _encounter_ref = transaction.create(
					Encounter::builder()
						.status(EncounterStatus::Planned)
						.class(impl_hapi_tests!(@encounter_class $version))
						.subject(Reference::builder().reference(patient_ref.clone()).build().unwrap())
						.build()
						.unwrap(),
				);

				let mut entries = transaction.send().await?.0.entry.into_iter().flatten();
				let _delete = entries.next().expect("DELETE response");
				let _read = entries.next().expect("GET response");
				let _update = entries.next().expect("PUT response");
				let _create_patient = entries.next().expect("POST Patient response");
				let create_encounter = entries.next().expect("POST Encounter response");
				assert!(entries.next().is_none());

				let encounter_ref = create_encounter
					.full_url
					.as_ref()
					.or(create_encounter.response.as_ref().and_then(|response| response.location.as_ref()))
					.expect("Encounter ID in response");
				let Resource::Encounter(encounter) = client
					.read_referenced(&Reference::builder().reference(encounter_ref.clone()).build().unwrap())
					.await?
				else {
					panic!("Resource should be Encounter");
				};
				let subject_ref = encounter
					.subject
					.as_ref()
					.expect("Encounter.subject")
					.reference
					.as_ref()
					.expect("Encounter.subject.reference");
				println!("Subject reference is: {subject_ref}");
				assert_ne!(subject_ref, &patient_ref);

				Ok(())
			}

			#[test]
			fn paging() -> Result<()> {
				common::RUNTIME.block_on(paging_inner())
			}

			async fn paging_inner() -> Result<()> {
				let client = client().await?;

				let date = "5123-05-10";
				let n = 99;

				println!("Preparing..");
				let patient = Patient::builder()
					.active(false)
					.birth_date(Date::from_str(date).expect("parse Date"))
					.build()
					.unwrap();
				let mut batch = client.batch();
				for _ in 0..n {
					batch.create(patient.clone());
				}
				ensure_batch_succeeded(batch.send().await?);

				println!("Starting search..");
				let patients: Vec<Patient> = client
					.search(SearchParameters::empty().and(DateSearch {
						name: "birthdate",
						comparator: Some(SearchComparator::Eq),
						value: date,
					}))
					.await?
					.all_matches()
					.try_collect()
					.await?;
				assert_eq!(patients.len(), n);

				println!("Cleaning up..");
				let mut batch = client.batch();
				for patient in patients {
					batch.delete(ResourceType::Patient, patient.id.as_ref().expect("Patient.id"));
				}
				ensure_batch_succeeded(batch.send().await?);
				Ok(())
			}

			#[test]
			fn operation_encounter_everything() -> Result<()> {
				common::RUNTIME.block_on(operation_encounter_everything_inner())
			}

			async fn operation_encounter_everything_inner() -> Result<()> {
				let client = client().await?;

				let mut patient = Patient::builder().build().unwrap();
				patient.create(&client).await?;
				let mut encounter = Encounter::builder()
					.status(EncounterStatus::InProgress)
					.class(impl_hapi_tests!(@encounter_class $version))
					.subject(Reference::relative_to(&patient).expect("Patient reference"))
					.build()
					.unwrap();
				encounter.create(&client).await?;

				let bundle =
					client.operation_encounter_everything(encounter.id.as_ref().expect("Encounter.id")).await?;
				let contains_patient = bundle
					.entry
					.iter()
					.flatten()
					.filter_map(|entry| entry.resource.as_ref())
					.filter_map(|resource| resource.as_base_resource().id().as_ref())
					.any(|id| Some(id) == patient.id.as_ref());
				assert!(contains_patient);

				Ok(())
			}

			#[test]
			#[ignore = "HAPI server does not support this"]
			fn operation_patient_match() -> Result<()> {
				common::RUNTIME.block_on(operation_patient_match_inner())
			}

			async fn operation_patient_match_inner() -> Result<()> {
				let client = client().await?;

				let mut patient = Patient::builder()
					.identifier(vec![Some(Identifier::builder().value("Test".to_owned()).build().unwrap())])
					.build()
					.unwrap();
				patient.create(&client).await?;

				let bundle = client.operation_patient_match(patient.clone(), true, 1).await?;
				let contains_patient = bundle
					.entry
					.iter()
					.flatten()
					.filter_map(|entry| entry.resource.as_ref())
					.filter_map(|resource| resource.as_base_resource().id().as_ref())
					.any(|id| Some(id) == patient.id.as_ref());
				assert!(contains_patient);

				Ok(())
			}

			#[test]
			fn history_without_id() -> Result<()> {
				common::RUNTIME.block_on(history_without_id_inner())
			}

			async fn history_without_id_inner() -> Result<()> {
				let client = client().await?;

				let mut patient = Patient::builder().language("history1".to_owned()).build().unwrap();
				let first_patient_id = patient.create(&client).await?;

				let mut patient = Patient::builder().language("history2".to_owned()).build().unwrap();
				let second_patient_id = patient.create(&client).await?;

				let bundle = client.history::<Patient>(None).await?.into_inner();
				assert_eq!(bundle.r#type, BundleType::History);
				assert!(bundle.entry.len() >= 2);
				for id in &[first_patient_id, second_patient_id] {
					assert!(bundle.entry.iter().any(|entry| {
						entry
							.as_ref()
							.unwrap()
							.resource
							.as_ref()
							.map_or(false, |r| r.as_base_resource().id().as_ref() == Some(id))
					}));
				}

				Ok(())
			}

			#[test]
			fn history_with_id() -> Result<()> {
				common::RUNTIME.block_on(history_with_id_inner())
			}

			async fn history_with_id_inner() -> Result<()> {
				let client = client().await?;

				let mut patient = Patient::builder().language("DE".to_owned()).build().unwrap();
				patient.create(&client).await?;

				patient.language = Some("EN".to_owned());
				patient.update(false, &client).await?;

				patient.clone().delete(&client).await?;

				let bundle = client.history::<Patient>(patient.id.as_deref()).await?.into_inner();
				assert_eq!(bundle.r#type, BundleType::History);
				assert_eq!(bundle.entry.len(), 3);

				let Some(response) = bundle.entry[0].as_ref().unwrap().request.as_ref() else {
					panic!("response should be BundleEntryRequest");
				};

				assert_eq!(response.method, HTTPVerb::Delete);

				let Some(Resource::Patient(last_version)) = bundle.entry[1].as_ref().unwrap().resource.as_ref()
				else {
					panic!("Resource should be Patient");
				};
				assert_eq!(
					last_version.language,
					Some("EN".to_owned()),
					"Last version should have language 'EN'"
				);
				let Some(Resource::Patient(first_version)) =
					bundle.entry[2].as_ref().unwrap().resource.as_ref()
				else {
					panic!("Resource should be Patient");
				};
				assert_eq!(
					first_version.language,
					Some("DE".to_owned()),
					"Last version should have language 'DE'"
				);

				Ok(())
			}
		}
	};
}
for_all_versions!(impl_hapi_tests);