Add gst_video_sync integration test

lg_media/CMakeLists.txt

@@ -68,6 +68,7 @@ if(CATKIN_ENABLE_TESTING)
   find_package(rostest REQUIRED)
   add_rostest(test/online/test_mplayer_adhoc_media.test)
   add_rostest(test/online/test_mplayer_director_bridge.test)
+  add_rostest(test/online/test_gst_video_sync_integration.test)
   # exclude this test. it's starting real mplayer in a ManagedWindow
   # and it sometimes hangs, exceeds ROS allotted time for a test and fails
   # details: https://github.com/EndPointCorp/lg_ros_nodes/issues/215

lg_media/test/online/test_gst_video_sync_integration.py

@@ -0,0 +1,87 @@
+#!/usr/bin/env python
+
+PKG = 'lg_media'
+NAME = 'test_gst_video_sync_integration'
+
+import unittest
+import rospy
+import json
+import subprocess
+import tempfile
+import wave
+from interactivespaces_msgs.msg import GenericMessage
+from contextlib import contextmanager
+
+
+@contextmanager
+def generate_silence():
+    with tempfile.NamedTemporaryFile() as f:
+        wav = wave.open(f.name, mode='wb')
+        wav.setsampwidth(2)
+        wav.setnchannels(1)
+        wav.setframerate(8000)
+        wav.writeframes(bytes([0 * 800000]))
+        wav.close()
+        yield f.name
+
+
+class TestGstVideoSyncIntegration(unittest.TestCase):
+    def setUp(self):
+        self.scene_pub = rospy.Publisher('/director/scene', GenericMessage, queue_size=10)
+        rospy.sleep(1)
+
+    def test_scene(self):
+        with generate_silence() as fname:
+            content_url = 'file://{}'.format(fname)
+            scene = {
+                'name': NAME,
+                'description': NAME,
+                'duration': 60,
+                'slug': NAME,
+                'windows': [
+                    {
+                        'activity': 'video',
+                        'activity_config': {
+                        },
+                        'assets': [
+                            content_url,
+                        ],
+                        'presentation_viewport': 'center',
+                        'width': 640,
+                        'height': 480,
+                        'x_coord': 0,
+                        'y_coord': 0,
+                    },
+                ],
+            }
+            self.scene_pub.publish(GenericMessage(type='json', message=json.dumps(scene)))
+            rospy.sleep(1)
+
+            subprocess.check_call([
+                'pgrep',
+                '-af',
+                'gst_video_sync\s.*-u\s{}'.format(content_url),
+            ])
+
+            scene = {
+                'name': NAME + '_off',
+                'description': NAME + '_off',
+                'duration': 0,
+                'slug': NAME + '_off',
+                'windows': [],
+            }
+            self.scene_pub.publish(GenericMessage(type='json', message=json.dumps(scene)))
+            rospy.sleep(1)
+
+            with self.assertRaises(subprocess.CalledProcessError):
+                subprocess.check_call([
+                    'pgrep',
+                    '-af',
+                    'gst_video_sync\s.*-u\s{}'.format(content_url),
+                ])
+
+
+if __name__ == '__main__':
+    import rostest
+    rospy.init_node(NAME)
+    rostest.rosrun(PKG, NAME, TestGstVideoSyncIntegration)

lg_media/test/online/test_gst_video_sync_integration.test

@@ -0,0 +1,7 @@
+<launch>
+  <param name="/viewport/center" value="640x480+0+0" />
+  <node name="gst_video_sync" pkg="lg_media" type="gstreamer.py">
+    <param name="viewport" value="center" />
+  </node>
+  <test test-name="test_gst_video_sync_integration" pkg="lg_media" type="test_gst_video_sync_integration.py" />
+</launch>