Changeset ef235aeb769104f36cc2980beb8b32dae177c7c1 in for resourcetotrac/resourcetotrac/script.py

Timestamp:

05/02/09 13:38:19 (3 years ago)

Author:

Gartersnake Server <gartersnake@…>

Children:

4bceacf6b979775083c8623c2906a66e95eefe48

Parents:

935fbfb3a362aa24429eff491679842cfb8feb81

git-committer:

Gartersnake Server <gartersnake@gartersnake.precisionconversions.com> / 2009-05-02T13:38:19Z-0700

Message:

Restructured file layout, converted to 'resourcetotrac'

File:

• resourcetotrac/resourcetotrac/script.py (modified) (3 diffs)

resourcetotrac/resourcetotrac/script.py

@@ -19 +19 @@
 import daemonize
 from trac.env import Environment
-from trac.core import Component
+from trac.core import Component, ExtensionPoint
 from trac.config import OrderedExtensionsOption
 
 # Local imports
-from emailtoticket.api import IEmailStore
-from emailtoticket.util import EmailParser
+from resourcetotrac.api import IDataSource, IResourceSubmitter
 
 
@@ -30 +29 @@
 
 
-__all__ = ['EmailToTicketConfig']
+__all__ = ['ResourceSubmission']
 
 
-class EmailTicketSubmission(Component):
+class ResourceSubmission(Component):
 
     implemnts(IResourceSubmitter)
 
-    email_stores = OrderedExtensionsOption('email2ticket', 'stores', 
-                                           IEmailStore, include_missing=False,
-                                           doc="List of enabled email stores")
+    data_sources = OrderedExtensionsOption('resource2trac', 'sources', 
+                                           IDataSource, include_missing=False,
+                                           doc="List of enabled data sources")
 
-    archive = BoolOption('email2ticket', 'archive', True,
-                         doc="Whether or not to archive the processed emails")
+    resource_submitters = ExtensionPoint(IResourceSubmitter)
 
-    def submit_ticket(self, email):
-        """ Rape the email and submit/update a ticket """
-
-        parser = EmailParser(self.env)
-        subject = parser.get_subject(email)email['Subject'].strip()
-        author_email = parseaddr(email['From'])[1]
-        update = subject[:3].lower() == 're:'
-        if update:
-            subject = subject[3:].strip()
-        
+    archive = BoolOption('resource2trac', 'archive', True,
+                         doc="Whether or not to archive the processed messages")
 
 
-    def process_tickets(self):
-        self.parser
-        for store in self.email_stores:
-            for id, email in store.get_email():
+    def process_resources(self):
+        for src in self.data_sources:
+            for id, msg in src.get_message():
                 try:
-                    info = self.submit_ticket(email)
+                    resource_type = msg.get_type()
+                    for submitter in self.resource_submitters():
+                        if submitter.match_resource_type(resource_type):
+                            break
+                        continue
+                    submitter.submit_resource(resource_type, msg)
                     if self.archive:
-                        store.archive_email(id)
-                    store.delete_email(id)
+                        src.archive_message(id)
+                    src.delete_message(id)
                 except:
-                    self.log.debug('Unable to submit the ticket')
-            store.cleanup()
+                    self.log.debug('Unable to submit the resource')
+            src.cleanup()
             continue
-            
-
 
 
@@ -103 +95 @@
 def main(argv):
     opts = doArgs(argv)
-    emailticket = EmailTicketSubmission(opts.env) 
+    emailticket = ResourceSubmission(opts.env) 
     emailticket.process_tickets()
     return 0