[uss_qualifier] Add scenario for testing data validation by SUT for Get operational_intent

monitoring/uss_qualifier/requirements/interuss/mock_uss/interactions.md

@@ -0,0 +1,10 @@
+InterUss mock_uss interactions requirements
+
+## Overview
+InterUSS provides endpoint to get InterUUS interactions recorded by mock_uss
+
+
+## Requirements
+
+### Interactions
+GET interactions from a time instance to now

monitoring/uss_qualifier/scenarios/astm/utm/interuss/data_exchange_validation/scd_get_op_data_validation_by_sut.md

@@ -0,0 +1,100 @@
+# SCD Data Validation of GET operational intents by SUT test scenario
+
+## Description
+This test checks that the SUT validates the operational intents received as response to its GET request from another USS.
+Control uss which is a mock uss plans a nearby V-shaped operation, and provides the data that SUT GETs.
+SUT validates the GET response to successfully plan its operation
+Notably the following requirements:
+- **[astm.f3548.v21.OPIN0015](../../../../../requirements/astm/f3548/v21.md)**
+- **[astm.f3548.v21.OPIN0020](../../../../../requirements/astm/f3548/v21.md)**
+- **[astm.f3548.v21.OPIN0030](../../../../../requirements/astm/f3548/v21.md)**
+- **[astm.f3548.v21.OPIN0040](../../../../../requirements/astm/f3548/v21.md)**
+- **[astm.f3548.v21.GEN0500](../../../../../requirements/astm/f3548/v21.md)**
+- **[astm.f3548.v21.SCD0035](../../../../../requirements/astm/f3548/v21.md)**
+
+## Resources
+### flight_intents
+FlightIntentsResource that provides the following V-shaped flight intents:
+- `non-conflicting` : flight1 and flight2
+
+### control_uss
+FlightPlannerResource that will control the data shared for validation testing of sut.
+
+### sut
+FlightPlannerResource that will be tested for its validation of operational intents.
+
+### dss
+DSSInstanceResource that provides access to a DSS instance where flight creation/sharing can be verified.
+
+### mock_uss
+MockUSSResource
+
+## Setup test case
+### Check for flight planning readiness test step
+Both USSs are queried for their readiness to ensure this test can proceed.
+
+#### Flight planning USS not ready check
+If either USS does not respond appropriately to the endpoint queried to determine readiness, this check will fail and the USS will have failed to meet **[astm.f3548.v21.GEN0310](../../../../../requirements/astm/f3548/v21.md)** as the USS does not support the InterUSS implementation of that requirement.
+
+### Area clearing test step
+Both USSs are requested to remove all flights from the area under test.
+
+#### Area cleared successfully check
+**[interuss.automated_testing.flight_planning.ClearArea](../../../../../requirements/interuss/automated_testing/flight_planning.md)**
+
+## Attempt to plan no conflict flight - near existing flight test case
+### [Control USS plans flight 2 test step](../../../../flight_planning/plan_flight_intent.md)
+Flight 2 on time range B should be successfully planned by the control USS.
+
+### [Validate flight 2 sharing test step](../../validate_shared_operational_intent.md)
+Validate that flight 2 is planned
+
+### [SUT plans flight 1 test step](../../../../flight_planning/plan_flight_intent.md)
+The test driver attempts to plan the flight 1 on time range B via the tested USS. It checks if any conflicts with flight 2
+which is of equal priority and came first.
+per **[astm.f3548.v21.SCD0035](../../../../../requirements/astm/f3548/v21.md)**.
+
+### [Validate flight 1 sharing test step](../../validate_shared_operational_intent.md)
+Validate Flight 1 is planned.
+
+### [Validate flight2 GET interaction test step](test_steps/validate_get_operational_intent.md)
+Flight1 when being planned, SUT needs to GET information of flight 2
+
+### [Validate flight1 Notification sent to Control USS test step](test_steps/validate_notification_operational_intent.md)
+Flight 2 not notified. As per **[astm.f3548.v21.USS0105](../../../../../requirements/astm/f3548/v21.md)** and **[astm.f3548.v21.SCD0085](../../../../../requirements/astm/f3548/v21.md)**
+
+### [Delete sut flight test step](../../../../flight_planning/delete_flight_intent.md)
+Delete sut flight
+
+### [Delete control flight test step](../../../../flight_planning/delete_flight_intent.md)
+Delete sut flight
+
+## Attempt to plan deconflicted flight - near a flight sharing invalid data test case
+### [Control USS plans flight 2, sharing invalid interuss data test step](../../../../flight_planning/plan_flight_intent.md)
+Flight 2 on time range B should be successfully planned by the control USS.
+
+### [Validate flight 2 shared intent with invalid interuss data test step](test_steps/validate_sharing_operational_intent_but_with_invalid_interuss_data.md)
+Validate that flight 2 is planned
+
+### [SUT attempts to plan flight 1, expect failure test step](test_steps/plan_flight_intent_expect_failed.md)
+The test driver attempts to plan the flight 1 on time range B via the tested USS. It checks if any conflicts with flight 2
+which is of equal priority and came first.
+per **[astm.f3548.v21.SCD0035](../../../../../requirements/astm/f3548/v21.md)**.
+
+### [Validate flight 1 not shared by SUT test step](../../validate_not_shared_operational_intent.md)
+Validate Flight 1 is not shared.
+
+### [Validate flight2 GET interaction test step](test_steps/validate_get_operational_intent.md)
+When Flight1 is being planned, SUT needs to GET information of flight 2
+
+### [Validate flight1 Notification not sent to Control USS test step](test_steps/validate_no_notification_operational_intent.md)
+
+### [Delete Control USS flight test step](../../../../flight_planning/delete_flight_intent.md)
+Delete control USS flight 2
+
+### [Delete SUT flight test step](../../../../flight_planning/delete_flight_intent.md)
+Delete control USS flight 2
+
+## Cleanup
+### Successful flight deletion check
+**[interuss.automated_testing.flight_planning.DeleteFlightSuccess](../../../../../requirements/interuss/automated_testing/flight_planning.md)**

monitoring/uss_qualifier/scenarios/astm/utm/interuss/data_exchange_validation/test_steps/expected_interactions_test_steps.py

@@ -0,0 +1,158 @@
+from __future__ import annotations
+
+from typing import List, Optional
+import time
+import jwt
+
+from monitoring.monitorlib.fetch import QueryError
+from monitoring.uss_qualifier.common_data_definitions import Severity
+from monitoring.uss_qualifier.scenarios.scenario import TestScenarioType
+from monitoring.uss_qualifier.resources.interuss.mock_uss.client import MockUSSClient
+from implicitdict import StringBasedDateTime
+from loguru import logger
+from monitoring.monitorlib.clients.mock_uss.interactions import Interaction
+
+
+def expect_interuss_post_interactions(
+    scenario: TestScenarioType,
+    mock_uss: MockUSSClient,
+    st: StringBasedDateTime,
+    posted_to_url: str,
+    test_step: str,
+):
+    found = False
+    if mock_uss is not None:
+        interactions = _get_interuss_interactions(scenario, mock_uss, st, test_step)
+        logger.debug(f"Checking for Post to {posted_to_url}")
+        with scenario.check("Expect Notification sent") as check:
+            found = False
+            for interaction in interactions:
+                method = interaction.query.request.method
+                url = interaction.query.request.url
+                if method == "POST" and posted_to_url in url:
+                    found = True
+            if found == False:
+                check.record_failed(
+                    summary=f"Notification to {posted_to_url} not received",
+                    severity=Severity.Medium,
+                    details=f"Notification to {posted_to_url} not received",
+                    requirements="SCDxxxx",
+                )
+        scenario.end_test_step()
+
+    return found
+
+
+def expect_no_interuss_post_interactions(
+    scenario: TestScenarioType,
+    mock_uss: MockUSSClient,
+    st: StringBasedDateTime,
+    posted_to_url: str,
+    test_step: str,
+):
+    found = False
+    if mock_uss is not None:
+        interactions = _get_interuss_interactions(scenario, mock_uss, st, test_step)
+        logger.debug(f"Checking for POST request to {posted_to_url}")
+        with scenario.check("Expect Notification not sent") as check:
+            found = False
+            for interaction in interactions:
+                method = interaction.query.request.method
+                url = interaction.query.request.url
+                if method == "POST" and posted_to_url in url:
+                    found = True
+            if found == True:
+                check.record_failed(
+                    summary=f"Notification to {posted_to_url} wrongly sent",
+                    severity=Severity.Medium,
+                    details=f"Notification to {posted_to_url} wrongly sent",
+                    requirements="SCDxxxx",
+                )
+        scenario.end_test_step()
+
+    return found
+
+
+def expect_interuss_get_interactions(
+    scenario: TestScenarioType,
+    mock_uss: MockUSSClient,
+    st: StringBasedDateTime,
+    get_from_url: str,
+    id: str,
+    test_step: str,
+):
+    found = False
+    if mock_uss is not None:
+        interactions = _get_interuss_interactions(scenario, mock_uss, st, test_step)
+        logger.debug(f"Checking for GET request to {get_from_url} for id {id}")
+        with scenario.check("Expect GET request") as check:
+            found = False
+            for interaction in interactions:
+                method = interaction.query.request.method
+                url = interaction.query.request.url
+                if method == "GET" and get_from_url in url and id in url:
+                    found = True
+            if found == False:
+                check.record_failed(
+                    summary=f"No GET request received at {get_from_url} for {id} ",
+                    severity=Severity.Medium,
+                    details=f"No GET request received at  {get_from_url} for {id}",
+                    requirements="SCDxxxx",
+                )
+
+        scenario.end_test_step()
+    return found
+
+
+def _get_interuss_interactions(
+    scenario: TestScenarioType,
+    mock_uss: MockUSSClient,
+    st: StringBasedDateTime,
+    test_step: str,
+) -> List[Interaction]:
+    scenario.begin_test_step(test_step)
+    time.sleep(5)
+    with scenario.check("MockUSS interactions request") as check:
+        try:
+            all_interactions, query = mock_uss.get_interactions(st)
+            scenario.record_query(query)
+        except QueryError as e:
+            for q in e.queries:
+                scenario.record_query(q)
+            check.record_failed(
+                summary=f"Error from mock_uss when attempting to get interactions from_time {st}",
+                severity=Severity.High,
+                details=f"{str(e)}\n\nStack trace:\n{e.stacktrace}",
+                query_timestamps=[q.request.timestamp for q in e.queries],
+            )
+
+    exclude_sub = mock_uss.session.auth_adapter.get_sub()
+
+    def is_uss_interaction(interaction: Interaction, excl_sub: str) -> bool:
+        headers = interaction.query.request.headers
+        if "Authorization" in headers:
+            token = headers.get("Authorization").split(" ")[1]
+            payload = jwt.decode(
+                token, algorithms="RS256", options={"verify_signature": False}
+            )
+            sub = payload["sub"]
+            logger.debug(f"sub of interuss_interaction token: {sub}")
+            if sub == excl_sub:
+                logger.debug(f"Excluding interaction with sub: {sub} ")
+                return False
+            else:
+                return True
+        else:
+            logger.error(f"Interaction received without Authorization : {interaction}")
+            return False
+
+    interuss_interactions = []
+    for interaction in all_interactions:
+        if is_uss_interaction(interaction, exclude_sub):
+            interuss_interactions.append(interaction)
+            logger.debug(
+                f"Interuss interaction reported : {interaction.query.request.method} {interaction.query.request.url} "
+                f"with response {interaction.query.response.status_code}"
+            )
+
+    return interuss_interactions