Changeset 57 for trunk/factory/src/backends/__init__.py

Timestamp:

02/03/09 15:51:59 (12 years ago)

Author:

sander

Message:

Add basic structure of OOOServer and make polling work

File:

• trunk/factory/src/backends/__init__.py (modified) (1 diff)

trunk/factory/src/backends/__init__.py

@@ -20 +20 @@
 """
 
+class BackendException:
+        """
+        A base Backend exception class. Backends should derive their own
+        exceptions from this.
+
+        When the Factory catches this exception and recoverable is False, then
+        the backend will be unloaded.
+        """
+        def __init__(self, message, recoverable = False):
+                self.message = message
+                self.recoverable = recoverable
+        
+        def __str__(self):
+                if self.recoverable:
+                        return self.message + ' (Recoverable)'
+                return self.message + ' (Not recoverable)'
+
 class Backend:
+        """
+        The base backend class. Backends shoudl derive from this
+        """
         def __init__(self, options, config, section):
                 self.options = options
                 self.config = config
                 self.section = section
+
+                self.application = config.get(section, 'application')
+                self.major = config.get(section, 'major')
+                self.minor = config.get(section, 'minor')
+                self.doctype = config.get(section, 'doctype')
+                self.formats = [s.strip() for s in config.get(section, 'formats').split(',')]
+        
+        def initialize(self):
+                """
+                This is called right after instanciating the backend.
+                Returning False will cause the backend not to be loaded
+                """
+                return True
+
+        def can_process(self, job):
+                """
+                Return True if this backend is eligable to process this Job, False otherwise
+                """
+                eligable = (
+                        job['application'] == self.application and
+                        job['major'] == self.major and
+                        job['minor'] == self.minor and
+                        job['doctype'] == self.doctype and
+                        job['format'] in self.formats
+                )
+                return eligable
+
+        def process(self, job):
+                """
+                Process a job. Backends must override this method.
+                """
+                raise NotImplementedError