Merge pull request #20 from Notastica/fix-npm-install

fixing npm package

package.json

@@ -1,12 +1,10 @@
 {
   "name": "data-feed-orchestrator",
-  "version": "0.0.4",
+  "version": "0.0.5",
   "description": "A data feed orchestrator",
-  "bin": "cli.js",
   "main": "lib/index.js",
   "files": [
-    "lib/",
-    "cli.js"
+    "lib/"
   ],
   "keywords": [
     "big data",

src/app.js

@@ -0,0 +1,30 @@
+import Orchestrator from './orchestrator';
+import logger from './logging/logger';
+import uuid from 'node-uuid';
+import * as mq from './mq/connection';
+
+const o = new Orchestrator({
+  registerQueue: uuid.v4(),
+  messagesQueue: uuid.v4(),
+  messagesIndex: uuid.v4()
+});
+
+mq.connect(o.amqpURL).then((context) => {
+  const pub = context.socket('PUSH');
+  const messageSent = { uuid: uuid.v4() };
+
+  pub.connect(o.messagesQueue);
+  pub.write(JSON.stringify(messageSent));
+
+})
+  .then(() => {
+    return o.listen();
+  })
+  .then(() => {
+    logger.info(`Orchestrator ${o.name} ready to receive new modules in the queue ${o.registerQueue}`);
+  });
+
+process.on('SIGINT', function () {
+  logger.warn('Gracefully shutting down from SIGINT (Ctrl-C)');
+  o.shutdown();
+});

src/es/connection.js

@@ -2,7 +2,7 @@ import elasticsearch from 'elasticsearch';
 import isProd from 'isprod';
 import Promise from 'bluebird';
 
-const defaultOptions = { log: isProd ? 'warn' : 'info' };
+const defaultOptions = { log: isProd ? 'warning' : 'info' };
 
 /**
  * Creates an elastic connection

src/index.js

@@ -0,0 +1,5 @@
+import O from './orchestrator';
+import M from './module';
+
+export const Orchestrator = O;
+export const Module = M;

src/logging/logger.js

@@ -1,7 +1,7 @@
 import * as winston from 'winston';
 import isProd from 'isprod';
 
-const level = process.env.NODE_ENV === 'test' || !isProd ? 'debug' : 'info';
+const level = isProd ? 'info' : 'debug';
 
 export const logger = new winston.Logger({
   level: level,