observer: Basic nose tests using static PCAP files

pathspider/observer/__init__.py

@@ -450,26 +450,3 @@ def simple_observer(lturi):
                     ip4_chain=[basic_count],
                     ip6_chain=[basic_count])
 
-def test_observer(lturi):
-    import threading
-
-    logging.basicConfig()
-    logging.getLogger().setLevel(logging.DEBUG)
-
-    o = simple_observer(lturi)
-    q = queue.Queue()
-    t = threading.Thread(target=o.run_flow_enqueuer,
-                         args=(q,),
-                         daemon=True)
-    t.start()
-
-    flowcount = 0
-    while True:
-        f = q.get()
-        if f == SHUTDOWN_SENTINEL:
-            break
-        flowcount += 1
-
-    logging.getLogger().info("test observer received "+str(flowcount)+" flows")
-
-

tests/test_observer.py

@@ -0,0 +1,41 @@
+
+import logging
+import queue
+import threading
+
+import nose
+
+from pathspider.base import SHUTDOWN_SENTINEL
+from pathspider.observer import simple_observer
+
+def _test_observer(lturi):
+    try:
+        import plt # libtrace may not be available
+    except:
+        raise nose.SkipTest
+
+    logging.getLogger().setLevel(logging.INFO)
+
+    o = simple_observer(lturi)
+    q = queue.Queue()
+    t = threading.Thread(target=o.run_flow_enqueuer,
+                         args=(q,),
+                         daemon=True)
+    t.start()
+
+    flowcount = 0
+    while True:
+        f = q.get()
+        if f == SHUTDOWN_SENTINEL:
+            break
+        flowcount += 1
+
+    return flowcount
+
+def test_observer_random_flowcount():
+    lturi = "pcap:tests/testdata/random.pcap"
+    assert _test_observer(lturi) == 0
+
+def test_observer_real_flowcount():
+    lturi = "pcap:tests/testdata/real.pcap"
+    assert _test_observer(lturi) == 6342