Merge pull request #6 from bots-squad/wip-with-events

🐯 starting to work with EventEmitter

core_observers/messengerObserver.js

@@ -0,0 +1,23 @@
+const Observer = require(`./observers`).Observer;
+
+let initialize = (broker) => {
+  let messenger = new Observer(broker)
+
+  messenger.on('failure', data => {
+    console.error(`failure from ${data.from}: ${data.message}`);
+  });
+
+  messenger.on('message', data => {
+    console.log(`message from ${data.from}: ${data.message}`);
+  });
+
+  messenger.on('error', data => {
+    console.log(`error from ${data.from}: ${data.message}`);
+  });
+
+  return messenger;
+}
+
+module.exports = {
+  initialize: initialize
+};

core_observers/observers.js

@@ -0,0 +1,16 @@
+const EventEmitter = require('events').EventEmitter;
+
+class Broker extends EventEmitter { }
+
+class Observer {
+  constructor(broker) {
+    this.broker = broker;
+  }
+  on(message, work) { this.broker.on(message, work); }
+  emit(message, data) { this.broker.emit(message, data); }
+}
+
+module.exports = {
+    Observer: Observer
+  , Broker: Broker
+};

hector.js

@@ -1,10 +1,9 @@
 #!/usr/bin/env node
-const fs = require("fs");
 const express = require('express');
 const bodyParser = require('body-parser');
-const postMessage = require('./libs/helpers.js').postMessage;
 
-const whenEvent = require(`${process.env.HECTOR_PLUGIN_PATH}/app.js`).whenEvent;
+const Broker = require(`./core_observers/observers`).Broker;
+const Observer = require(`./core_observers/observers`).Observer;
 
 /*
 Express application
@@ -14,23 +13,28 @@ app.use(bodyParser.json());
 app.use(bodyParser.urlencoded({extended: false}));
 app.use(express.static('clones'));
 
+
+let broker = new Broker();
+require(`./core_observers/messengerObserver`).initialize(broker);
+// plugin observers
+require(`${process.env.HECTOR_PLUGIN_PATH}/eventsObserver.js`).initialize(broker);
+require(`${process.env.HECTOR_PLUGIN_PATH}/botObserver.js`).initialize(broker);
+require(`${process.env.HECTOR_PLUGIN_PATH}/ciObserver.js`).initialize(broker);
+require(`${process.env.HECTOR_PLUGIN_PATH}/statusObserver.js`).initialize(broker);
+require(`${process.env.HECTOR_PLUGIN_PATH}/gitObserver.js`).initialize(broker); // something more generic? we can share this with other plugins
+require(`${process.env.HECTOR_PLUGIN_PATH}/executorObserver.js`).initialize(broker);
+
+
 /*
 this route is called from the DVCS (eg GitHub)
 (see webhooks in your DVCS settings)
 */
 app.post('/ci', (req, res) => {
-
-  whenEvent(req)
-
+  broker.emit('ci_event', req)
   res.status(201).end();
 });
 
 app.listen(process.env.CI_HTTP_PORT)
 
 let message = `🚀 Hector CI Server is started - listening on ${process.env.CI_HTTP_PORT}`;
-console.log(message)
-
-// ⚠️⚠️⚠️ now, here you could notify a bot, create issue ... What ever
-if (process.env.BOT_NOTIFICATION_URL) {
-  postMessage(process.env.BOT_NOTIFICATION_URL, message)
-}
+broker.emit('message', {message: message, from: "Hector"});

plugins/github/botObserver.js

@@ -0,0 +1,30 @@
+const Observer = require(`../../core_observers/observers`).Observer;
+const postMessage = require('../../libs/helpers.js').postMessage;
+
+let initialize = (broker) => {
+  let botObserver = new Observer(broker);
+
+  botObserver.on('failure', data => {
+    if (process.env.BOT_NOTIFICATION_URL) {
+      postMessage(process.env.BOT_NOTIFICATION_URL, `failure from ${data.from}: ${data.message}`);
+    }
+  });
+
+  botObserver.on('message', data => {
+    if (process.env.BOT_NOTIFICATION_URL) {
+      postMessage(process.env.BOT_NOTIFICATION_URL, `message from ${data.from}: ${data.message}`);
+    }
+  });
+
+  botObserver.on('error', data => {
+    if (process.env.BOT_NOTIFICATION_URL) {
+      postMessage(process.env.BOT_NOTIFICATION_URL, `error from ${data.from}: ${data.message}`);
+    }
+  });
+
+  return botObserver;
+}
+
+module.exports = {
+  initialize: initialize
+};