Enforce original query deadlines and retained result receipts in Rust

.github/workflows/server-parity.yml

@@ -11,6 +11,7 @@ on:
       - tests/Fixtures/ServerParityNormalization/**
       - tests/Unit/ServerParityRunnerTest.mjs
       - tests/Unit/ServerParityArtifactSummaryTest.mjs
+      - tests/Unit/ServerParityQueryObserverTest.mjs
       - tests/Unit/ServerParityCodecDeadlineLoadTest.mjs
       - tests/Unit/ServerParityCooperativeContractTest.mjs
       - tests/Unit/ServerParityChildCancellationContractTest.mjs
@@ -47,6 +48,7 @@ on:
       - tests/Fixtures/ServerParityNormalization/**
       - tests/Unit/ServerParityRunnerTest.mjs
       - tests/Unit/ServerParityArtifactSummaryTest.mjs
+      - tests/Unit/ServerParityQueryObserverTest.mjs
       - tests/Unit/ServerParityCodecDeadlineLoadTest.mjs
       - tests/Unit/ServerParityCooperativeContractTest.mjs
       - tests/Unit/ServerParityChildCancellationContractTest.mjs
@@ -132,6 +134,15 @@ jobs:
           DW_PARITY_CORRECTED_CARGO: sdk-cargo
           DW_PARITY_CORRECTED_TARGET: sdk-target
         run: bash scripts/conformance/server-parity/corrected-marker-adapters.sh
+      - name: Build the separate current query consumers once
+        run: bash scripts/conformance/server-parity/query-authority-adapters.sh
+      - name: Share current query consumers without compiler caches
+        uses: actions/upload-artifact@043fb46d1a93c77aae656e7c1c64a875d1fc6a0a # v7
+        with:
+          name: query-authority-adapters
+          path: query-authority-adapters
+          retention-days: 1
+          if-no-files-found: error
       - name: Share the corrected cohort without compiler caches or target trees
         uses: actions/upload-artifact@043fb46d1a93c77aae656e7c1c64a875d1fc6a0a # v7
         with:
@@ -193,6 +204,8 @@ jobs:
             corrected-marker-adapters/*-build.txt
             corrected-marker-adapters/*-install.txt
             codec-native-build/build.txt
+            query-authority-adapters/*-build.txt
+            query-authority-adapters/*-install.txt
           retention-days: 1
           if-no-files-found: ignore
 
@@ -302,6 +315,12 @@ jobs:
           name: published-sdk-patch-adapters
           path: published-sdk-adapters
           digest-mismatch: error
+      - name: Fetch this run's current query consumers
+        uses: actions/download-artifact@3e5f45b2cfb9172054b4087a40e8e0b5a5461e7c # v8
+        with:
+          name: query-authority-adapters
+          path: query-authority-adapters
+          digest-mismatch: error
       - name: Fetch this run's genuine legacy-marker adapters
         uses: actions/download-artifact@3e5f45b2cfb9172054b4087a40e8e0b5a5461e7c # v8
         with:
@@ -642,6 +661,14 @@ jobs:
         if: always()
         timeout-minutes: 5
         run: bash scripts/conformance/server-parity/external-consumer-cleanup.sh mysql
+      - name: Compare published query deadlines and installed Worker authority
+        if: ${{ !cancelled() }}
+        timeout-minutes: 10
+        run: bash scripts/conformance/server-parity/query-authority-cohort.sh mysql
+      - name: Retire query authority resources
+        if: always()
+        timeout-minutes: 5
+        run: bash scripts/conformance/server-parity/query-authority-cleanup.sh mysql
       - name: Compare pinned PHP, embedded and native worker-fencing source cohort
         if: ${{ !cancelled() }}
         run: bash scripts/conformance/server-parity/worker-fencing-profile.sh mysql
@@ -765,6 +792,12 @@ jobs:
           name: published-sdk-patch-adapters
           path: published-sdk-adapters
           digest-mismatch: error
+      - name: Fetch this run's current query consumers
+        uses: actions/download-artifact@3e5f45b2cfb9172054b4087a40e8e0b5a5461e7c # v8
+        with:
+          name: query-authority-adapters
+          path: query-authority-adapters
+          digest-mismatch: error
       - name: Fetch this run's genuine legacy-marker adapters
         uses: actions/download-artifact@3e5f45b2cfb9172054b4087a40e8e0b5a5461e7c # v8
         with:
@@ -1091,6 +1124,18 @@ jobs:
         env:
           POSTGRES_IMAGE: ${{ matrix.image }}
         run: bash scripts/conformance/server-parity/external-consumer-cleanup.sh pgsql
+      - name: Compare published query deadlines and installed Worker authority
+        if: ${{ !cancelled() }}
+        timeout-minutes: 10
+        env:
+          POSTGRES_IMAGE: ${{ matrix.image }}
+        run: bash scripts/conformance/server-parity/query-authority-cohort.sh pgsql
+      - name: Retire query authority resources
+        if: always()
+        timeout-minutes: 5
+        env:
+          POSTGRES_IMAGE: ${{ matrix.image }}
+        run: bash scripts/conformance/server-parity/query-authority-cleanup.sh pgsql
       - name: Compare pinned PHP, embedded and native worker-fencing source cohort
         if: ${{ !cancelled() }}
         env:
@@ -1233,6 +1278,12 @@ jobs:
           name: published-sdk-patch-adapters
           path: published-sdk-adapters
           digest-mismatch: error
+      - name: Fetch this run's current query consumers
+        uses: actions/download-artifact@3e5f45b2cfb9172054b4087a40e8e0b5a5461e7c # v8
+        with:
+          name: query-authority-adapters
+          path: query-authority-adapters
+          digest-mismatch: error
       - name: Fetch this run's genuine legacy-marker adapters
         uses: actions/download-artifact@3e5f45b2cfb9172054b4087a40e8e0b5a5461e7c # v8
         with:
@@ -1294,7 +1345,7 @@ jobs:
             "$image" --test tests/Unit/ServerParityCodecDeadlineLoadTest.mjs > parity-evidence/codec-load-tests.txt
           docker run --rm --user=1000:1000 --cpus=1 --memory=256m --memory-swap=256m \
             --network=none --entrypoint node -v "$PWD:/source:ro" -w /source \
-            "$image" --test tests/Unit/ServerParityArtifactSummaryTest.mjs > parity-evidence/artifact-summary-tests.txt
+            "$image" --test tests/Unit/ServerParityArtifactSummaryTest.mjs tests/Unit/ServerParityQueryObserverTest.mjs > parity-evidence/artifact-summary-tests.txt
           docker network create "$RESOURCE_SCOPE"
           docker run -d --name "$RESOURCE_SCOPE-rust" --network "$RESOURCE_SCOPE" --network-alias=parity-rust \
             --user="$(id -u):$(id -g)" --cpus=1 --memory=256m --memory-swap=256m \
@@ -1515,6 +1566,18 @@ jobs:
         env:
           RESOURCE_SCOPE: dw-parity-${{ github.run_id }}-${{ github.run_attempt }}-${{ github.job }}
         run: bash scripts/conformance/server-parity/external-consumer-cleanup.sh sqlite
+      - name: Compare published query deadlines and installed Worker authority
+        if: ${{ !cancelled() }}
+        timeout-minutes: 10
+        env:
+          RESOURCE_SCOPE: dw-parity-${{ github.run_id }}-${{ github.run_attempt }}-${{ github.job }}
+        run: bash scripts/conformance/server-parity/query-authority-cohort.sh sqlite
+      - name: Retire query authority resources
+        if: always()
+        timeout-minutes: 5
+        env:
+          RESOURCE_SCOPE: dw-parity-${{ github.run_id }}-${{ github.run_attempt }}-${{ github.job }}
+        run: bash scripts/conformance/server-parity/query-authority-cleanup.sh sqlite
       - name: Compare pinned PHP, embedded and native worker-fencing source cohort
         if: ${{ !cancelled() }}
         env: