Changeset 9726 for main/waeup.kofa/trunk/src/waeup/kofa/utils/tests

Timestamp:

26 Nov 2012, 23:27:46 (12 years ago)

Author:

uli

Message:

Add VirtualExportJobContainers? for storing export jobs in a central exports container.

File:

• main/waeup.kofa/trunk/src/waeup/kofa/utils/tests/test_batching.py (modified) (13 diffs)

main/waeup.kofa/trunk/src/waeup/kofa/utils/tests/test_batching.py

@@ -25 +25 @@
 from zc.async.interfaces import IJob
 from zope import schema
-from zope.component import provideUtility, getGlobalSiteManager
+from zope.component import provideUtility, getGlobalSiteManager, getUtility
 from zope.component.factory import Factory
-from zope.component.hooks import clearSite
+from zope.component.hooks import clearSite, setSite
 from zope.component.interfaces import IFactory
 from zope.interface import Interface, implements, verify
@@ -33 +33 @@
 from waeup.kofa.interfaces import (
     ICSVExporter, IBatchProcessor, IExportJobContainer, IJobManager,
-    IExportJob)
+    IExportJob, IExportContainerFinder)
 from waeup.kofa.testing import (
     FunctionalLayer, FunctionalTestCase, FakeJob, FakeJobManager)
 from waeup.kofa.utils.batching import (
     ExporterBase, BatchProcessor, export_job, AsyncExportJob,
-    ExportJobContainer)
+    ExportJobContainer, VirtualExportJobContainer, ExportContainerFinder)
 
 optionflags = (
@@ -396 +396 @@
     # Test ExportJobContainer
 
+    TestedClass = ExportJobContainer
+
     def setUp(self):
         # register a suitable ICSVExporter as named utility
@@ -412 +414 @@
     def test_export_job_interfaces(self):
         # the ExportJobContainer implements promised interfaces correctly...
-        container = ExportJobContainer()
-        verify.verifyClass(IExportJobContainer, ExportJobContainer)
+        container = self.TestedClass()
+        verify.verifyClass(IExportJobContainer, self.TestedClass)
         verify.verifyObject(IExportJobContainer, container)
         return
@@ -419 +421 @@
     def test_start_export_job(self):
         # we can start jobs
-        container = ExportJobContainer()
+        container = self.TestedClass()
         container.start_export_job('cave_exporter', 'bob')
         result = self.job_manager._jobs.values()[0]
@@ -431 +433 @@
     def test_get_running_export_jobs_all(self):
         # we can get export jobs of all users
-        container = ExportJobContainer()
+        container = self.TestedClass()
         container.start_export_job('cave_exporter', 'bob')
         container.start_export_job('cave_exporter', 'alice')
@@ -444 +446 @@
     def test_get_running_export_jobs_user(self):
         # we can get the export jobs running for a certain user
-        container = ExportJobContainer()
+        container = self.TestedClass()
         container.start_export_job('cave_exporter', 'bob')
         container.start_export_job('cave_exporter', 'alice')
@@ -457 +459 @@
     def test_get_running_export_jobs_only_if_exist(self):
         # we get only jobs that are accessible through the job manager...
-        container = ExportJobContainer()
+        container = self.TestedClass()
         container.start_export_job('cave_exporter', 'bob')
         container.start_export_job('cave_exporter', 'bob')
@@ -473 +475 @@
     def test_get_export_job_status(self):
         # we can get the stati of jobs...
-        container = ExportJobContainer()
+        container = self.TestedClass()
         container.start_export_job('cave_exporter', 'alice')
         container.start_export_job('cave_exporter', 'bob')
@@ -490 +492 @@
         # we can remove export entries in local lists and the job
         # manager as well...
-        container = ExportJobContainer()
+        container = self.TestedClass()
         container.start_export_job('cave_exporter', 'bob')
         entry = container.running_exports[0]
@@ -503 +505 @@
     def test_delete_export_entry_remove_file(self):
         # any result files of exports are deleted as well
-        container = ExportJobContainer()
+        container = self.TestedClass()
         entry = ('4', 'cave_exporter', 'bob')
         container.running_exports = [entry]
@@ -515 +517 @@
     def test_entry_from_job_id(self):
         # we can get an entry for a job_id if the id exists
-        container = ExportJobContainer()
+        container = self.TestedClass()
         entry = ('4', 'cave_exporter', 'bob')
         container.running_exports = [entry]
@@ -528 +530 @@
         shutil.rmtree(fake_job.dir_path)
         return
+
+class VirtualExportJobContainerTests(ExportJobContainerTests):
+    # VirtualExportJobContainers should provide the
+    # same functionality as regular ones.
+
+    TestedClass = VirtualExportJobContainer
+
+    def setUp(self):
+        super(VirtualExportJobContainerTests, self).setUp()
+        self.root_job_container = ExportJobContainer()
+        def fake_finder():
+            return self.root_job_container
+        self.gsm = getGlobalSiteManager()
+        self.gsm.registerUtility(fake_finder, IExportContainerFinder)
+        return
+
+class ExportContainerFinderTests(FunctionalTestCase):
+    # Tests for export container finder.
+
+    layer = FunctionalLayer
+
+    def test_get_finder_as_util(self):
+        # we can get a finder by utility lookup
+        finder = getUtility(IExportContainerFinder)
+        self.assertTrue(finder is not None)
+        self.assertEqual(
+            IExportContainerFinder.providedBy(finder),
+            True)
+        return
+
+    def test_iface(self):
+        # the finder complies with the promised interface
+        finder = ExportContainerFinder()
+        verify.verifyClass(IExportContainerFinder,
+                           ExportContainerFinder)
+        verify.verifyObject(IExportContainerFinder, finder)
+        return
+
+    def test_no_site(self):
+        # a finder returns None if no site is available
+        finder = ExportContainerFinder()
+        self.assertEqual(
+            finder(), None)
+        return
+
+    def test_active_site(self):
+        # we get the datafinder if one is installed and site set
+        self.getRootFolder()['app'] = University()
+        finder = getUtility(IExportContainerFinder)
+        setSite(self.getRootFolder()['app'])
+        container = finder()
+        self.assertTrue(container is not None)
+        return
+
+    def test_broken_site(self):
+        # if the current site has no ExportContainer, we get None
+        self.getRootFolder()['app'] = University()
+        app = self.getRootFolder()['app']
+        del app['datacenter'] # datacenter _is_ the export container
+        setSite(app)
+        finder = getUtility(IExportContainerFinder)
+        container = finder()
+        self.assertTrue(container is None)
+        return