Support for Fire Arrow message channel queue && Upgrade dependencies

[bartekwk2]

• Refactored message/event parsing to support HAPI message channel subscription, old ahds (AzureHealthDataService ) events are supported as well
• Upgraded dependencies

---

Note

Medium Risk
Core message parsing/serialization and event modeling were refactored, so regressions could break queue processing across both formats despite added tests and documentation.

Overview
Adds support for consuming plain JSON HAPI/Fire Arrow MESSAGE-channel subscription notifications alongside existing AHDS/Event Grid CloudEvents by introducing pluggable parsing (AbstractFhirMessageParser) and queue-body encoding selection (QueueMessageEncoding).

Refactors the event model into a common FhirEvent base with format-specific AhdsFhirEvent/HapiFhirEvent, normalizes event types via converters, and optionally parses full-resource payloads into fhir_r4 Resource via payloadResource. Updates AzureMessageClient/Messenger.setupWithAzure to accept messageEncoding + parser, adjusts executor filtering to use fhirEvent.resourceType, and refreshes docs/tests; dependencies are upgraded (Freezed v3, http, adds fhir_r4).

^{Written by Cursor Bugbot for commit 0299b24. This will update automatically on new commits. Configure here.}

[cursor]

Cursor Bugbot has reviewed your changes and found 1 potential issue.

Autofix Details

Bugbot Autofix prepared a fix for the issue found in the latest run.

• ✅ Fixed: Double base64 encoding for poison queue messages
  • sanitizeMessage now reuses the already-base64 payload for base64 mode and only encodes raw JSON in none mode, preventing poison queue double encoding.

Or push these changes by commenting:

@cursor push 375c698c5d

Preview (375c698c5d)

diff --git a/lib/src/fhir_message_client/azure_message_client.dart b/lib/src/fhir_message_client/azure_message_client.dart
--- a/lib/src/fhir_message_client/azure_message_client.dart
+++ b/lib/src/fhir_message_client/azure_message_client.dart
@@ -38,7 +38,9 @@
     final message = _serializeToFhirMessage(fhirPoisonedMessage);
     // Azure Put Message wraps the body in XML; raw JSON can contain <, >, &
     // and invalidate the document. Base64 so the payload is XML-safe.
-    final xmlSafeBody = base64.encode(utf8.encode(message));
+    final xmlSafeBody = _messageEncoding == QueueMessageEncoding.base64
+        ? message
+        : base64.encode(utf8.encode(message));
     await _storage.putQMessage(
       qName: _poisonQueueName,
       message: xmlSafeBody,

_{This Bugbot Autofix run was free. To enable autofix for future PRs, go to the Cursor dashboard.}

[cursor]

Cursor Bugbot has reviewed your changes and found 1 potential issue.

^{Bugbot Autofix is OFF. To automatically fix reported issues with cloud agents, enable autofix in the Cursor dashboard.}