sinks/source/.svn/tmp/text-base/run.py.svn-base

   1 <<<<<<< .mine
   2 #!/usr/bin/env python
   3
   4 import ConfigParser
   5 import sink
   6 import os
   7
   8 def stupidConfig(config):
   9     a={}
  10     for atts in config: a.update({atts[0]:atts[1]})
  11     return a
  12 def getSinks(file):
  13     s=[]
  14     config = ConfigParser.ConfigParser()
  15     config.read([file])
  16     for section in config.sections():
  17         module = __import__('sinks.%s'%section.lower(),globals(),locals(),section.lower())
  18         s.append(getattr(module, 'sink')(stupidConfig(config.items(section))))
  19     return s
  20 def run():
  21     files=[]
  22
  23     print "initializing..."
  24     if os.path.isdir('config'):
  25         for file in os.listdir('config'):
  26             files.append(getSinks(os.path.join('config',file)))
  27     sink.init(files)
  28     print "done initializing..."
  29
  30     sink.loop(files)
  31
  32 run()=======
  33 #!/usr/bin/env python
  34
  35 import ConfigParser
  36 import sink
  37 import os
  38
  39 def stupidConfig(config):
  40     a={}
  41     for atts in config: a.update({atts[0]:atts[1]})
  42     return a
  43 def getSinks(file):
  44     s=[]
  45     config = ConfigParser.ConfigParser()
  46     config.read([file])
  47     for section in config.sections():
  48         module = __import__('sinks.%s'%section.lower(), globals(), locals(), section.lower())
  49         s.append(getattr(module, 'sink')(stupidConfig(config.items(section))))
  50     return s
  51 def run(directory):
  52     files=[]
  53     print "initializing..."
  54     for file in os.listdir(directory):
  55         files.append(getSinks(os.path.join(directory,file)))
  56
  57     sink.init(files)
  58
  59     print "done initializing..."
  60     sink.loop(files)
  61
  62 if os.path.isdir('config'): run('config')>>>>>>> .r14