debug: csc test

Author: Cecylia Borek

splunklib/results.py

@@ -327,6 +327,7 @@ def _parse_results(self, stream):
             if strip_line.__len__() == 0:
                 continue
             parsed_line = json_loads(strip_line)
+            print(f"JSONResultReader: Parsed line: {parsed_line}")
             if "preview" in parsed_line:
                 self.is_preview = parsed_line["preview"]
             if "messages" in parsed_line and parsed_line["messages"].__len__() > 0:

tests/searchcommands/test_csc_apps.py

@@ -14,12 +14,16 @@
 # License for the specific language governing permissions and limitations
 # under the License.
 
+import logging
 import unittest
 import pytest
 
+import splunklib
 from tests import testlib
 from splunklib import results
 
+splunklib.setup_logging(logging.DEBUG)
+
 
 @pytest.mark.smoke
 class TestCSC(testlib.SDKTestCase):
@@ -68,9 +72,16 @@ def test_eventing_app(self):
             'search index="_internal" | fields status | head 4000 | eventingcsc status=200 | head 10',
             output_mode='json',
         )
+        print(f"DEBUG: Stream type: {type(stream)}")
+        print(f"DEBUG: Stream class name: {stream.__class__.__name__}")
+        print(f"DEBUG: Stream module: {stream.__class__.__module__}")
+        print(f"DEBUG: Stream repr: {repr(stream)}")
         reader = results.JSONResultsReader(stream)
         items = list(reader)
 
+        for item in items:
+            print(item)
+
         actual_results = [item for item in items if isinstance(item, dict)]
         informational_messages = [
             item for item in items if isinstance(item, results.Message)