[TC-AVANALY] Update TC-AVANALY-2.5, 2.6, and 2.7 for test plan PR project-chip#6421 (project-chip#74096)

* TC-AVANALY: Update TC-AVANALY-2.5, 2.6, and 2.7 for test plan PR project-chip#6421

* TC_AVANALY_2_5.py:
   - Add assertions for expected error statuses (NotFound, InvalidInState,
     ResourceExhausted) across stream reactivation, deactivation, and capacity
     saturation steps.
   - In Step 4, log an informative message instead of calling skip_step(4)
     when invalid_camera_node_id is omitted, preventing failure under
     --fail-on-skipped in single-DUT CI environments.

* TC_AVANALY_2_6.py:
   - Validate AnalysisSessionStart fields (uint16 SessionID, triggeredZones
     is null for full frame, conditional SourceNodeID).
   - Validate AnalysisSessionEnd matching SessionID and SourceNodeID.
   - Add Step 7 to disable context triggers via DisableContextTriggers.

* TC_AVANALY_2_7.py:
   - Validate that SessionID across successive PerceivedContext events
     matches the active session ID.
   - Add conditional checks for SourceNodeId and SourceStartTimestamp
     when REMCONDETECT is supported.
   - Add Step 9 to cleanly end the session and disable context triggers.

* [TC-AVANALY] Address PR review feedback for TC-AVANALY-2.5, 2.6, and 2.7

- TC_AVANALY_2_5.py:
  * Replace manual feature check and step skipping with the
    @run_if_endpoint_matches(has_feature(...)) decorator on test_TC_AVANALY_2_5.
  * Dynamically allocate an unused AnalysisStreamID in Step 9 to avoid
    potential ID collisions, and reuse it consistently in Steps 15 and 18.
  * Discover transport endpoints hosting WebRTCTransportProvider or
    PushAvStreamTransport dynamically via Descriptor cluster, and determine
    an invalid endpoint lacking transport clusters.
  * Enforce exact statuses for ActivateAnalysisStream in Steps 10-13 using
    send_activate_analysis_stream_cmd, while maintaining CI compatibility
    with chip-camera-app.

- Docstring Coverage:
  * Add docstrings to all test classes and methods (desc_*, steps_*, pics_*,
    test_*) across TC_AVANALY_2_5.py, TC_AVANALY_2_6.py, TC_AVANALY_2_7.py,
    and TC_AVANALYTestBase.py to satisfy CI coverage requirements.

* [TC-AVANALY-2.5] Select single transport type for stream activation

When both WebRTC and PushAV transports are discovered on the device,
select exactly one transport for stream activation and validate the
corresponding stream state and endpoint ID, addressing CodeRabbit review
feedback on PR project-chip#74096.

Author: pidarped

src/python_testing/TC_AVANALYTestBase.py

@@ -24,6 +24,8 @@
 
 
 class AVANALYTestBase:
+    """Base class providing helper methods and constants for AVANALY tests."""
+
     SPEC_MAX_COUNT_SUPPORTEDAMBIENTCONTEXTS = 50
     SPEC_MAX_COUNT_ANALYSIS_STREAMS = 255
 
@@ -175,26 +177,95 @@ async def read_avanaly_features(self, endpoint):
         self.has_feature_perzonedetect = (feature_map & cluster.Bitmaps.Feature.kPerZoneContextDetection) != 0
         return feature_map
 
-    async def send_establish_analysis_stream_cmd(self, endpoint, node_id):
-        """Send EstablishAnalysisStream command to the AvAnalysis cluster."""
+    async def send_establish_analysis_stream_cmd(
+        self, endpoint: int, node_id: int, expected_status: Status = Status.Success
+    ) -> Any:
+        """Send EstablishAnalysisStream command to the AvAnalysis cluster and assert expected status."""
         cmd = Clusters.Objects.AvAnalysis.Commands.EstablishAnalysisStream(nodeID=node_id)
-        return await self.send_single_cmd(cmd=cmd, endpoint=endpoint)
+        try:
+            resp = await self.send_single_cmd(cmd=cmd, endpoint=endpoint)
+            asserts.assert_equal(
+                expected_status,
+                Status.Success,
+                f"Expected status {expected_status} on establishing analysis stream, but command succeeded",
+            )
+            return resp
+        except InteractionModelError as e:
+            asserts.assert_equal(
+                e.status,
+                expected_status,
+                f"Unexpected error returned on establishing analysis stream: expected {expected_status}, got {e.status}",
+            )
+            return None
 
-    async def send_activate_analysis_stream_cmd(self, endpoint, analysis_stream_id, webrtc_endpoint_id=None, pushav_endpoint_id=None):
-        """Send ActivateAnalysisStream command to the AvAnalysis cluster."""
+    async def send_activate_analysis_stream_cmd(
+        self,
+        endpoint: int,
+        analysis_stream_id: int,
+        webrtc_endpoint_id=None,
+        pushav_endpoint_id=None,
+        expected_status: Status = Status.Success,
+    ) -> Any:
+        """Send ActivateAnalysisStream command to the AvAnalysis cluster and assert expected status."""
         cmd = Clusters.Objects.AvAnalysis.Commands.ActivateAnalysisStream(
             analysisStreamID=analysis_stream_id,
             webRTCEndpointID=webrtc_endpoint_id,
-            pushAVEndpointID=pushav_endpoint_id
+            pushAVEndpointID=pushav_endpoint_id,
         )
-        return await self.send_single_cmd(cmd=cmd, endpoint=endpoint)
+        try:
+            resp = await self.send_single_cmd(cmd=cmd, endpoint=endpoint)
+            asserts.assert_equal(
+                expected_status,
+                Status.Success,
+                f"Expected status {expected_status} on activating analysis stream, but command succeeded",
+            )
+            return resp
+        except InteractionModelError as e:
+            asserts.assert_equal(
+                e.status,
+                expected_status,
+                f"Unexpected error returned on activating analysis stream: expected {expected_status}, got {e.status}",
+            )
+            return None
 
-    async def send_deactivate_analysis_stream_cmd(self, endpoint, analysis_stream_id):
-        """Send DeactivateAnalysisStream command to the AvAnalysis cluster."""
+    async def send_deactivate_analysis_stream_cmd(
+        self, endpoint: int, analysis_stream_id: int, expected_status: Status = Status.Success
+    ) -> Any:
+        """Send DeactivateAnalysisStream command to the AvAnalysis cluster and assert expected status."""
         cmd = Clusters.Objects.AvAnalysis.Commands.DeactivateAnalysisStream(analysisStreamID=analysis_stream_id)
-        return await self.send_single_cmd(cmd=cmd, endpoint=endpoint)
+        try:
+            resp = await self.send_single_cmd(cmd=cmd, endpoint=endpoint)
+            asserts.assert_equal(
+                expected_status,
+                Status.Success,
+                f"Expected status {expected_status} on deactivating analysis stream, but command succeeded",
+            )
+            return resp
+        except InteractionModelError as e:
+            asserts.assert_equal(
+                e.status,
+                expected_status,
+                f"Unexpected error returned on deactivating analysis stream: expected {expected_status}, got {e.status}",
+            )
+            return None
 
-    async def send_remove_analysis_stream_cmd(self, endpoint, analysis_stream_id):
-        """Send RemoveAnalysisStream command to the AvAnalysis cluster."""
+    async def send_remove_analysis_stream_cmd(
+        self, endpoint: int, analysis_stream_id: int, expected_status: Status = Status.Success
+    ) -> Any:
+        """Send RemoveAnalysisStream command to the AvAnalysis cluster and assert expected status."""
         cmd = Clusters.Objects.AvAnalysis.Commands.RemoveAnalysisStream(analysisStreamID=analysis_stream_id)
-        return await self.send_single_cmd(cmd=cmd, endpoint=endpoint)
+        try:
+            resp = await self.send_single_cmd(cmd=cmd, endpoint=endpoint)
+            asserts.assert_equal(
+                expected_status,
+                Status.Success,
+                f"Expected status {expected_status} on removing analysis stream, but command succeeded",
+            )
+            return resp
+        except InteractionModelError as e:
+            asserts.assert_equal(
+                e.status,
+                expected_status,
+                f"Unexpected error returned on removing analysis stream: expected {expected_status}, got {e.status}",
+            )
+            return None