gst/gst.defs: Update for new API

Original commit message from CVS:
* gst/gst.defs:
Update for new API
* gst/gst.override:
Added unreffing for gst.Registry.get_plugin_list and .get_feature_list
* testsuite/common.py:
removed crude hack for gst.Registry and gst.Plugin
* testsuite/test_interface.py:
* testsuite/test_caps.py:
* testsuite/test_struct.py:
* testsuite/test_xml.py:
converted to using common's TestCase class
* testsuite/test_event.py:
Enabled/fixed previously non working test
* testsuite/test_registry.py:
Now uses common's TestCase class,
added special case setUp()

ChangeLog

@@ -1,3 +1,24 @@
+2005-10-14  Edward Hervey  <edward@fluendo.com>
+
+	* gst/gst.defs:
+	Update for new API
+	* gst/gst.override:
+	Added unreffing for gst.Registry.get_plugin_list and .get_feature_list
+	* testsuite/common.py:
+	removed crude hack for gst.Registry and gst.Plugin
+	
+	* testsuite/test_interface.py:
+	* testsuite/test_caps.py:
+	* testsuite/test_struct.py:
+	* testsuite/test_xml.py:
+	converted to using common's TestCase class
+
+	* testsuite/test_event.py:
+	Enabled/fixed previously non working test
+	* testsuite/test_registry.py:
+	Now uses common's TestCase class,
+	added special case setUp()
+
 2005-10-13  Edward Hervey  <edward@fluendo.com>
 
 	* gst/Makefile.am: (noinst_HEADERS): 

gst/gst.defs

@@ -5282,6 +5282,27 @@
   )
 )
 
+(define-method get_date
+  (of-object "GstTagList")
+  (c-name "gst_tag_list_get_date")
+  (return-type "gboolean")
+  (parameters
+    '("const-gchar*" "tag")
+    '("GDate**" "value")
+  )
+)
+
+(define-method get_date_index
+  (of-object "GstTagList")
+  (c-name "gst_tag_list_get_date_index")
+  (return-type "gboolean")
+  (parameters
+    '("const-gchar*" "tag")
+    '("guint" "index")
+    '("GDate**" "value")
+  )
+)
+
 
 ;; From ../gstreamer/gst/gsttaginterface.h
 

gst/gst.override

@@ -385,23 +385,23 @@ override gst_registry_get_path_list
 static PyObject *
 _wrap_gst_registry_get_path_list (PyGObject *self)
 {
-	GstRegistry *registry;
-	GList *l, *paths;
-	PyObject *list;
+    GstRegistry *registry;
+    GList *l, *paths;
+    PyObject *list;
     gint i;
-	
-        registry = GST_REGISTRY (self->obj);
-
-	paths = gst_registry_get_path_list (registry);
-
-	list = PyList_New (g_list_length(paths));
-	for (l = paths, i = 0; l; l = l->next, ++i) {
-		gchar *path = (gchar *) l->data;
-	    PyList_SetItem (list, i, PyString_FromString(path));
-	}
-	g_list_free (paths);
-	
-	return list;
+    
+    registry = GST_REGISTRY (self->obj);
+    
+    paths = gst_registry_get_path_list (registry);
+    
+    list = PyList_New (g_list_length(paths));
+    for (l = paths, i = 0; l; l = l->next, ++i) {
+	gchar *path = (gchar *) l->data;
+	PyList_SetItem (list, i, PyString_FromString(path));
+    }
+    g_list_free (paths);
+    
+    return list;
 }
 
 %%
@@ -421,10 +421,13 @@ _wrap_gst_registry_get_plugin_list (PyGObject *self)
 	list = PyList_New (g_list_length(plugins));
 	for (l = plugins, i = 0; l; l = l->next, ++i) {
 		GstPlugin *plugin = (GstPlugin *) l->data;
-		PyList_SetItem (list, i, pygobject_new (G_OBJECT (plugin)));
+		PyObject *object = pygstobject_new (G_OBJECT (plugin));
+		gst_object_unref (plugin);
+
+		PyList_SetItem (list, i, object);
 	}
 	g_list_free (plugins);
-	
+
 	return list;
 }
 
@@ -457,6 +460,7 @@ _wrap_gst_registry_get_feature_list (PyGObject *self, PyObject *args, PyObject *
     for (l = features, i = 0; l; l = l->next, ++i) {
         GstPluginFeature *feature = (GstPluginFeature *) l->data;
         PyList_SetItem (list, i, pygobject_new (G_OBJECT (feature)));
+	gst_object_unref (feature);
     }
     g_list_free (features);
 	

testsuite/common.py

@@ -111,7 +111,6 @@ def run_silent(function, *args, **kwargs):
 class TestCase(unittest.TestCase):
 
     _types = [gst.Object, gst.MiniObject]
-    _except_types = [gst.Registry, gst.Plugin, gst.PluginFeature]
 
     def gccollect(self):
         # run the garbage collector
@@ -142,8 +141,6 @@ class TestCase(unittest.TestCase):
             objs = [o for o in gc.get_objects() if isinstance(o, c)]
             new.extend([o for o in objs if o not in self._tracked[c]])
 
-        for u in self._except_types:
-            new = [o for o in new if not isinstance(o, u)]
         self.failIf(new, new)
         #self.failIf(new, ["%r:%d" % (type(o), id(o)) for o in new])
         del self._tracked

testsuite/test_caps.py

@@ -21,10 +21,11 @@
 # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA
 
 import sys
-from common import gst, unittest
+from common import gst, unittest, TestCase
 
-class CapsTest(unittest.TestCase):
+class CapsTest(TestCase):
     def setUp(self):
+        TestCase.setUp(self)
         self.caps = gst.caps_from_string('video/x-raw-yuv,width=10,framerate=5.0;video/x-raw-rgb,width=15,framerate=10.0')
         self.assertEquals(self.caps.__refcount__, 1)
         self.structure = self.caps[0]

testsuite/test_event.py

@@ -60,57 +60,62 @@ class EventTest(TestCase):
         self.assertRaises(TypeError, self.sink.send_event, number)
 
 
-# FIXME: fix these tests
-#class EventFileSrcTest(unittest.TestCase):
-#    # FIXME: properly create temp files
-#    filename = '/tmp/gst-python-test-file'
-#    def setUp(self):
-#        if os.path.exists(self.filename):
-#            os.remove(self.filename)
-#        open(self.filename, 'w').write(''.join(map(str, range(10))))
-#                
-#        self.pipeline = gst.parse_launch('filesrc name=source location=%s blocksize=1 ! fakesink signal-handoffs=1 name=sink' % self.filename)
-#        self.source = self.pipeline.get_by_name('source')
-#        self.sink = self.pipeline.get_by_name('sink')
-#        self.sink.connect('handoff', self.handoff_cb)
-#        self.bus = self.pipeline.get_bus()
-#        self.pipeline.set_state(gst.STATE_PLAYING)
-#        
-#    def tearDown(self):
-#        assert self.pipeline.set_state(gst.STATE_PLAYING)
-#        if os.path.exists(self.filename):
-#            os.remove(self.filename)
-#
-#    def handoff_cb(self, element, buffer, pad):
-#        self.handoffs.append(str(buffer))
-#
-#    def playAndIter(self):
-#        self.handoffs = []
-#        assert self.pipeline.set_state(gst.STATE_PLAYING)
-#        while 42:
-#            msg = self.bus.pop()
-#            if msg and msg.type == gst.MESSAGE_EOS:
-#                break
-#        assert self.pipeline.set_state(gst.STATE_PAUSED)
-#        handoffs = self.handoffs
-#        self.handoffs = []
-#        return handoffs
-#
-#    def sink_seek(self, offset, method=gst.SEEK_METHOD_SET):
-#        method |= (gst.SEEK_FLAG_FLUSH | gst.FORMAT_BYTES)
-#        self.source.send_event(gst.event_new_seek(method, offset))
-#        self.source.send_event(gst.Event(gst.EVENT_FLUSH)) 
-#        self.sink.send_event(gst.event_new_seek(method, offset))
-#        self.sink.send_event(gst.Event(gst.EVENT_FLUSH))
-#       
-#    def testSimple(self):
-#        handoffs = self.playAndIter()
-#        assert handoffs == map(str, range(10))
-#    
-#    def testSeekCur(self):
-#        self.sink_seek(8)
-#        
-#        #print self.playAndIter()
+class EventFileSrcTest(TestCase):
+   # FIXME: properly create temp files
+   filename = '/tmp/gst-python-test-file'
+   def setUp(self):
+       TestCase.setUp(self)
+       gst.info("start")
+       if os.path.exists(self.filename):
+           os.remove(self.filename)
+       open(self.filename, 'w').write(''.join(map(str, range(10))))
+       
+       self.pipeline = gst.parse_launch('filesrc name=source location=%s blocksize=1 ! fakesink signal-handoffs=1 name=sink' % self.filename)
+       self.source = self.pipeline.get_by_name('source')
+       self.sink = self.pipeline.get_by_name('sink')
+       self.sigid = self.sink.connect('handoff', self.handoff_cb)
+       self.bus = self.pipeline.get_bus()
+       
+   def tearDown(self):
+       self.pipeline.set_state(gst.STATE_NULL)
+       self.sink.disconnect(self.sigid)
+       if os.path.exists(self.filename):
+           os.remove(self.filename)
+       del self.bus
+       del self.pipeline
+       del self.source
+       del self.sink
+       del self.handoffs
+       TestCase.tearDown(self)
+
+   def handoff_cb(self, element, buffer, pad):
+       self.handoffs.append(str(buffer))
+
+   def playAndIter(self):
+       self.handoffs = []
+       self.pipeline.set_state(gst.STATE_PLAYING)
+       assert self.pipeline.set_state(gst.STATE_PLAYING)
+       while 42:
+           msg = self.bus.pop()
+           if msg and msg.type == gst.MESSAGE_EOS:
+               break
+       assert self.pipeline.set_state(gst.STATE_PAUSED)
+       handoffs = self.handoffs
+       self.handoffs = []
+       return handoffs
+
+   def sink_seek(self, offset, method=gst.SEEK_TYPE_SET):
+       self.sink.seek(1.0, gst.FORMAT_BYTES, gst.SEEK_FLAG_FLUSH,
+                      method, offset,
+                      gst.SEEK_TYPE_NONE, 0)
+      
+   def testSimple(self):
+       handoffs = self.playAndIter()
+       assert handoffs == map(str, range(10))
+   
+   def testSeekCur(self):
+       self.sink_seek(8)
+       self.playAndIter()
 
 class TestEmit(TestCase):
     def testEmit(self):

testsuite/test_interface.py

@@ -20,11 +20,11 @@
 # License along with this library; if not, write to the Free Software
 # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA
 
-from common import gst, unittest
+from common import gst, unittest, TestCase
 
 import gobject
 
-class Availability(unittest.TestCase):
+class Availability(TestCase):
     def testXOverlay(self):
         assert hasattr(gst.interfaces, 'XOverlay')
         assert issubclass(gst.interfaces.XOverlay, gobject.GInterface)
@@ -33,7 +33,7 @@ class Availability(unittest.TestCase):
         assert hasattr(gst.interfaces, 'Mixer')
         assert issubclass(gst.interfaces.Mixer, gobject.GInterface)
 
-class FunctionCall(unittest.TestCase):
+class FunctionCall(TestCase):
     def FIXME_testXOverlay(self):
         # obviously a testsuite is not allowed to instantiate this
         # since it needs a running X or will fail.  find some way to

testsuite/test_registry.py

@@ -21,39 +21,48 @@
 # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA
 
 import sys
-from common import gst, unittest
+import gc
+from common import gst, unittest, TestCase
+
+class RegistryTest(TestCase):
+    def setUp(self):
+        self.registry = gst.registry_get_default()
+        self.plugins = self.registry.get_plugin_list()
+        TestCase.setUp(self)
 
-class RegistryTest(unittest.TestCase):
     def testGetDefault(self):
-        registry = gst.registry_get_default()
+        assert(self.registry)
 
     def testPluginList(self):
-        registry = gst.registry_get_default()
-        plugins = registry.get_plugin_list()
-        names = map(lambda p: p.get_name(), plugins)
+        names = map(lambda p: p.get_name(), self.plugins)
         self.failUnless('gstcoreelements' in names)
 
-    def testFeatureList(self):
-        registry = gst.registry_get_default()
-        self.assertRaises(TypeError, registry.get_feature_list, "kaka")
-        
-        features = registry.get_feature_list(gst.TYPE_ELEMENT_FACTORY)
-        elements = map(lambda f: f.get_name(), features)
-        self.failUnless('fakesink' in elements)
-
-        features = registry.get_feature_list(gst.TYPE_TYPE_FIND_FACTORY)
-        typefinds = map(lambda f: f.get_name(), features)
-
-        features = registry.get_feature_list(gst.TYPE_INDEX_FACTORY)
-        indexers = map(lambda f: f.get_name(), features)
-        self.failUnless('memindex' in indexers)
-
     def testGetPathList(self):
         # FIXME: this returns an empty list; probably due to core;
         # examine problem
-        registry = gst.registry_get_default()
         
-        paths = registry.get_path_list()
+        paths = self.registry.get_path_list()
 
+class RegistryFeatureTest(TestCase):
+    def setUp(self):
+        self.registry = gst.registry_get_default()
+        self.plugins = self.registry.get_plugin_list()
+        self.efeatures = self.registry.get_feature_list(gst.TYPE_ELEMENT_FACTORY)
+        self.tfeatures = self.registry.get_feature_list(gst.TYPE_TYPE_FIND_FACTORY)
+        self.ifeatures = self.registry.get_feature_list(gst.TYPE_INDEX_FACTORY)
+        TestCase.setUp(self)
+
+    def testFeatureList(self):
+        self.assertRaises(TypeError, self.registry.get_feature_list, "kaka")
+        
+        elements = map(lambda f: f.get_name(), self.efeatures)
+        self.failUnless('fakesink' in elements)
+
+        typefinds = map(lambda f: f.get_name(), self.tfeatures)
+
+        indexers = map(lambda f: f.get_name(), self.ifeatures)
+        self.failUnless('memindex' in indexers)
+        
+        
 if __name__ == "__main__":
     unittest.main()

testsuite/test_struct.py

@@ -21,10 +21,11 @@
 # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA
 
 import sys
-from common import gst, unittest
+from common import gst, unittest, TestCase
 
-class StructureTest(unittest.TestCase):
+class StructureTest(TestCase):
     def setUp(self):
+        TestCase.setUp(self)
         self.struct = gst.structure_from_string('video/x-raw-yuv,width=10,foo="bar",pixel-aspect-ratio=1/2,framerate=5.0,boolean=(boolean)true')
 
     def testName(self):

testsuite/test_xml.py

@@ -20,9 +20,9 @@
 # License along with this library; if not, write to the Free Software
 # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA
 
-from common import gst, unittest
+from common import gst, unittest, TestCase
 
-class PadTest(unittest.TestCase):
+class PadTest(TestCase):
         
     def testQuery(self):
         xml = gst.XML()