fix csc apps test

Author: Cecylia Borek

tests/searchcommands/test_csc_apps.py

@@ -64,17 +64,86 @@ def test_eventing_app(self):
         self.assertEqual(state.title, "eventing_app")
 
         jobs = self.service.jobs
+        stream = jobs.oneshot(
+            'search index="_internal" | fields status | head 4000 | eventingcsc status=200 | head 10',
+            output_mode='json',
+        )
+        reader = results.JSONResultsReader(stream)
+        items = list(reader)
+
+        actual_results = [item for item in items if isinstance(item, dict)]
+        informational_messages = [
+            item for item in items if isinstance(item, results.Message)
+        ]
+
+        self.assertTrue(
+            len(actual_results) > 0, "Should have actual search results (dicts)"
+        )
+
+        fatal_messages = [
+            msg for msg in informational_messages if msg.type in ['FATAL', 'ERROR']
+        ]
+        self.assertEqual(
+            len(fatal_messages),
+            0,
+            f"Should not have FATAL/ERROR messages, but got: {[msg.message for msg in fatal_messages]}",
+        )
+
+        first_result = actual_results[0]
+        self.assertIn('status', first_result, "Result should contain 'status' field")
+        self.assertEqual(first_result['status'], '200', "Status should be '200'")
+
+    def test_eventing_app_malformed_query_missing_field(self):
+        app_name = "eventing_app"
+        # Fetch the app
+        app = self.service.apps[app_name]
+        app.refresh()
+
+        jobs = self.service.jobs
+        # wrong search query because `status` field is not being passed to eventing app
         stream = jobs.oneshot(
             'search index="_internal" | head 4000 | eventingcsc status=200 | head 10',
-            output_mode="json",
+            output_mode='json',
+        )
+        reader = results.JSONResultsReader(stream)
+        items = list(reader)
+
+        self.assertTrue(len(items) > 0, "Should have at least one item (error message)")
+
+        actual_results = [item for item in items if isinstance(item, dict)]
+        informational_messages = [
+            item for item in items if isinstance(item, results.Message)
+        ]
+
+        self.assertTrue(len(informational_messages) > 0, "Should have message results")
+
+        error_messages = [
+            msg for msg in informational_messages if msg.type in ['FATAL', 'ERROR']
+        ]
+        self.assertTrue(
+            len(error_messages) > 0, "Should have at least one FATAL or ERROR message"
+        )
+
+        error_message = error_messages[0]
+        self.assertIn(
+            'eventingcsc',
+            error_message.message,
+            "Error should mention the failing command",
+        )
+        self.assertIn(
+            'status',
+            error_message.message,
+            "Error should mention the missing 'status' field",
+        )
+        self.assertIn(
+            'KeyError', error_message.message, "Should be a KeyError for missing field"
         )
-        result = results.JSONResultsReader(stream)
-        ds = list(result)
 
-        self.assertEqual(result.is_preview, False)
-        self.assertTrue(isinstance(ds[0], (dict, results.Message)))
-        nonmessages = [d for d in ds if isinstance(d, dict)]
-        self.assertTrue(len(nonmessages) <= 10)
+        self.assertEqual(
+            len(actual_results),
+            0,
+            f"Should not have actual results, but got: {actual_results}",
+        )
 
     def test_generating_app(self):
         app_name = "generating_app"