Fixes #58 Parametrize irc-channel in process VCSCOMMIT_NOTIFY

src/webhook_launcher/app/boss.py

@@ -16,9 +16,34 @@
 # along with this program; if not, write to the Free Software
 # Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
 
+import json
+import os
+
 from django.conf import settings
 from RuoteAMQP import Launcher
 
+
+def get_process_params(pdef_file_path):
+    """Read process configuration variables if exists
+    :param pdef_file_path: process file path,
+        config file should be with the same name and with '.conf' extension
+    :return Loaded variables or None if couldn't read the conf file
+    """
+    params = {}
+    if os.path.exists(pdef_file_path):
+        file_name, _file_ext = os.path.splitext(pdef_file_path)
+        conf_file_path = file_name + '.conf'
+        try:
+            params = json.load(open(conf_file_path))
+        except IOError:
+            pass
+
+        except ValueError as e:
+            print 'Error while loading json %s:\n%s' % (conf_file_path, str(e))
+
+    return params
+
+
 def launch(process, fields):
     """ BOSS process launcher
 
@@ -28,20 +53,25 @@ def launch(process, fields):
     with open(process, mode='r') as process_file:
         pdef = process_file.read()
 
-    launcher = Launcher(amqp_host = settings.BOSS_HOST,
-                        amqp_user = settings.BOSS_USER,
-                        amqp_pass = settings.BOSS_PASS,
-                        amqp_vhost = settings.BOSS_VHOST)
+    launcher = Launcher(amqp_host=settings.BOSS_HOST,
+                        amqp_user=settings.BOSS_USER,
+                        amqp_pass=settings.BOSS_PASS,
+                        amqp_vhost=settings.BOSS_VHOST)
+
+    fields_dict = get_process_params(process)
+    fields_dict.update(fields)
+
+    print "launching to (%s,%s)" % (settings.BOSS_HOST, settings.BOSS_VHOST)
+    launcher.launch(pdef, fields_dict)
 
-    print "launching to (%s,%s)" %(settings.BOSS_HOST, settings.BOSS_VHOST)
-    launcher.launch(pdef, fields)
 
 def launch_queue(fields):
     launch(settings.VCSCOMMIT_QUEUE, fields)
 
+
 def launch_notify(fields):
     launch(settings.VCSCOMMIT_NOTIFY, fields)
 
+
 def launch_build(fields):
     launch(settings.VCSCOMMIT_BUILD, fields)
-