Message integration tests work

Signed-off-by: Mitch Gaffigan <mitch.gaffigan@comcast.net>

Author: mgaffigan

.dockerignore

@@ -62,3 +62,4 @@ release.properties
 replay_pid*
 .github/
 ci/
+.github/

.github/workflows/build.yaml

@@ -127,5 +127,14 @@ jobs:
             oie-ci-runner:${{ github.sha }} \
             --workspace /workspace \
             --configuration "${{ matrix.configuration }}" \
-            --server-image "${{ needs.build.outputs.server_image }}"
+            --server-image "${{ needs.build.outputs.server_image }}" \
+            --results-root ci/test-results
+
+      - name: Upload Docker Smoke Test Results
+        if: ${{ !cancelled() }}
+        uses: actions/upload-artifact@v4
+        with:
+          name: Test Results Docker Smoke - ${{ matrix.configuration }}
+          path: |
+            ci/test-results/**/*.xml
 

ci/.gitignore

@@ -0,0 +1,2 @@
+test-results/
+__pycache__/

ci/README.md

@@ -179,14 +179,17 @@ channels/
 Test fixture are split into the original data:
 
 - `source` is the payload sent into the deployed channel.
-- `source_metadata.yml` is the metadata sent with the source payload. (Optional)
+- `source_sourcemap.yml` is the metadata sent with the source payload. (Optional) 
 
 And the optional assertions:
 
+- `source_metadata.yml` is a dictionary of assertions for the source message metadata after submission.
 - `source_status` is the asserted status enumeration text for the source message after submission.
+- `source_response` is the asserted response payload if the channel gives a response to the source submission.
 - `source_transformed` is the asserted transformed source payload if the channel transforms the message before delivery.
 - `dest01_transformed` asserts byte-identical transformed content for destination 1 if the channel transforms the message before delivery.
 - `dest01` asserts byte-identical sent content for destination 1.
+- `dest01_response` asserts byte-identical response content if destination 1 gives a response to the message delivery.
 - `dest01_metadata.yml` is a dictionary of assertions for destination 1 metadata.
 - `dest01_status` asserts the status of the message at destination 1.
 - `dest02*` repeats the same pattern for destination 2, and so on.

ci/runner/Dockerfile

@@ -1,6 +1,6 @@
 FROM docker:27-cli
 
-RUN apk add --no-cache bash curl python3 py3-lxml
+RUN apk add --no-cache bash curl python3 py3-lxml py3-yaml
 
 WORKDIR /app
 COPY *.py /app/

ci/runner/api.py

@@ -1,10 +1,13 @@
+import importlib
 import ssl
-import urllib.error
 import urllib.parse
+import urllib.error
 import urllib.request
 from http.cookiejar import CookieJar
+from xml.etree.ElementTree import Element, SubElement, tostring
 
 REQUESTED_WITH_HEADER = "OpenIntegrationEngine-CI"
+MAX_REQUEST_TIMEOUT_SECONDS = 15
 
 
 class ApiClient:
@@ -18,8 +21,8 @@ def request(
         method: str = "GET",
         data: bytes | None = None,
         content_type: str | None = None,
-        accept: str = "application/json",
-        timeout: int = 15,
+        accept: str = "application/xml",
+        timeout: int = MAX_REQUEST_TIMEOUT_SECONDS,
     ) -> tuple[int, str]:
         headers = {
             "Accept": accept,
@@ -51,17 +54,88 @@ def create_channel(self, channel_xml: bytes) -> None:
             method="POST",
             data=channel_xml,
             content_type="application/xml",
-            accept="application/json",
+            accept="*/*",
         )
 
     def deploy_channel(self, channel_id: str) -> None:
-        self.request(f"/api/channels/{channel_id}/_deploy", method="POST")
+        self.request(f"/api/channels/{channel_id}/_deploy", method="POST", accept="*/*")
+
+    def get_channel_status(self, channel_id: str):
+        _, body = self.request(
+            f"/api/channels/{channel_id}/status",
+            accept="application/xml",
+        )
+        return parse_xml(body)
 
     def undeploy_channel(self, channel_id: str) -> None:
-        self.request(f"/api/channels/{channel_id}/_undeploy", method="POST")
+        self.request(f"/api/channels/{channel_id}/_undeploy", method="POST", accept="*/*")
 
     def remove_channel(self, channel_id: str) -> None:
-        self.request(f"/api/channels/{channel_id}", method="DELETE")
+        self.request(f"/api/channels/{channel_id}", method="DELETE", accept="*/*")
+
+    def process_message(self, channel_id: str, raw_data: str, source_map: dict[str, object] | None = None) -> int:
+        raw_message_xml = build_raw_message_xml(raw_data, source_map or {})
+        _, body = self.request(
+            f"/api/channels/{channel_id}/messagesWithObj",
+            method="POST",
+            data=raw_message_xml,
+            content_type="application/xml",
+            accept="application/xml",
+            timeout=MAX_REQUEST_TIMEOUT_SECONDS,
+        )
+        return parse_xml(body)
+
+    def get_message_content(self, channel_id: str, message_id: int, meta_data_ids: list[int] | None = None):
+        query = ""
+        if meta_data_ids:
+            query = "?" + urllib.parse.urlencode([("metaDataId", meta_data_id) for meta_data_id in meta_data_ids])
+        _, body = self.request(
+            f"/api/channels/{channel_id}/messages/{message_id}{query}",
+            accept="application/xml",
+            timeout=MAX_REQUEST_TIMEOUT_SECONDS,
+        )
+        return parse_xml(body)
+
+    def search_message(self, channel_id: str, message_id: int):
+        query = urllib.parse.urlencode(
+            {
+                "minMessageId": message_id,
+                "maxMessageId": message_id,
+                "includeContent": "true",
+                "offset": 0,
+                "limit": 1,
+            }
+        )
+        _, body = self.request(
+            f"/api/channels/{channel_id}/messages?{query}",
+            accept="application/xml",
+            timeout=MAX_REQUEST_TIMEOUT_SECONDS,
+        )
+        return parse_xml(body)
+
+
+def parse_xml(body: str):
+    etree = importlib.import_module("lxml.etree")
+    return etree.fromstring(body.encode("utf-8"))
+
+
+def build_raw_message_xml(raw_data: str, source_map: dict[str, object]) -> bytes:
+    raw_message = Element("com.mirth.connect.donkey.model.message.RawMessage")
+    SubElement(raw_message, "overwrite").text = "false"
+    SubElement(raw_message, "imported").text = "false"
+    SubElement(raw_message, "rawData").text = raw_data
+
+    source_map_element = SubElement(raw_message, "sourceMap")
+    source_map_element.set("class", "linked-hash-map")
+    for key, value in source_map.items():
+        if isinstance(value, dict):
+            raise RuntimeError(f"Nested source metadata is not supported for message submission: {key}")
+        entry = SubElement(source_map_element, "entry")
+        SubElement(entry, "string").text = str(key)
+        SubElement(entry, "string").text = str(value)
+
+    SubElement(raw_message, "binary").text = "false"
+    return tostring(raw_message, encoding="utf-8", xml_declaration=True)
 
 
 def build_opener() -> urllib.request.OpenerDirector: