Updated with fork

Author: andrew

.jshintrc

@@ -0,0 +1 @@
+v9.8.0

.nvmrc

@@ -0,0 +1,12 @@
+FROM node:9.8.0-alpine
+RUN mkdir -p /usr/src/app
+WORKDIR /usr/src/app
+
+ENV NODE_ENV production
+
+COPY package.json yarn.lock /usr/src/app/
+RUN yarn install --production
+
+COPY . /usr/src/app
+
+CMD npm start

Dockerfile

@@ -1,6 +1,6 @@
 The MIT License (MIT)
 
-Copyright (c) 2015 Andrew Nesbitt
+Copyright (c) 2015 Mauro Pompilio
 
 Permission is hereby granted, free of charge, to any person obtaining
 a copy of this software and associated documentation files (the

LICENSE

@@ -1 +1 @@
-web: DEBUG=firehose node app.js
+web: node app.js

Procfile

@@ -1,11 +1,11 @@
-# Libraries Firehose
+# 24 Pull Requests Firehose
 
-Server sent event bridge for the [Libraries.io](https://libraries.io) events firehose.
+Server sent event bridge for the [24 Pull Requests](https://24pullrequests.com) events firehose.
 
 ## Development
 
-Source hosted at [GitHub](http://github.com/librariesio/firehose).
-Report issues/feature requests on [GitHub Issues](http://github.com/librariesio/firehose/issues). Follow us on Twitter [@librariesio](https://twitter.com/librariesio). We also hangout on [Gitter](https://gitter.im/librariesio/support).
+Source hosted at [GitHub](http://github.com/24pullrequests/firehose).
+Report issues/feature requests on [GitHub Issues](http://github.com/24pullrequests/firehose/issues). Follow us on Twitter [@24pullrequests](https://twitter.com/24pullrequests). We also hangout on [Gitter](https://gitter.im/24pullrequests/24pullrequests).
 
 ### Note on Patches/Pull Requests
 
@@ -19,4 +19,4 @@ Report issues/feature requests on [GitHub Issues](http://github.com/librariesio/
 
 ## Copyright
 
-Copyright (c) 2015 Andrew Nesbitt. See [LICENSE](https://github.com/librariesio/firehose/blob/master/LICENSE) for details.
+Copyright (c) 2015 Mauro Pompilio. See [LICENSE](https://github.com/24pullrequests/firehose/blob/master/LICENSE) for details.

README.md

@@ -1,26 +1,18 @@
-/*jshint strict:true, trailing:false, unused:true, node:true */
-'use strict';
-
-require("babel/register");
-
 var express      = require('express');
 var bodyParser   = require('body-parser');
-var serve_static = require('serve-static');
-var debug        = require('debug')('firehose');
 var router       = require('./lib/router');
 var cors         = require('cors')
 
 var app = express();
 app.use(bodyParser.json());
-app.use(serve_static('static'));
-app.use(bodyParser.urlencoded({ 
-  extended: true 
+app.use(bodyParser.urlencoded({
+  extended: true
 }));
 
 app.post('/events', router.firehose.rx);
 app.get('/events', cors(), router.firehose.tx);
 
 var port = process.env.PORT || 5001;
 app.listen(port, function() {
-  debug('Listening on', port);
+  console.log('Listening on', port);
 });

app.js

@@ -1,15 +1,10 @@
-/*jshint strict:true, trailing:false, unused:true, node:true */
-'use strict';
-
-require("babel/register");
-
 var EventEmitter = require('eventemitter3');
 var emitter = new EventEmitter();
 
 var rx = function(req, res) {
-  if(req.query.api_key === process.env.API_KEY){
+  if(req.query.api_key === process.env.API_KEY) {
     var data = req.body;
-    emitter.emit('pullRequest', data);
+    emitter.emit('pkg', data);
   }
   res.end();
 };
@@ -22,21 +17,23 @@ var tx = function(req, res) {
   });
 
   // Heartbeat
-  var nln = () => res.write('\n');
+  var nln = function() {
+    res.write('\n');
+  }
   var hbt = setInterval(nln, 15000);
 
-  var onPullRequest = (data) => {
+  var onPkg = function(data){
     res.write("retry: 500\n");
-    res.write(`event: pullRequest\n`);
+    res.write(`event: event\n`);
     res.write(`data: ${JSON.stringify(data)}\n\n`);
   };
 
-  emitter.on('pullRequest', onPullRequest);
+  emitter.on('pkg', onPkg);
 
   // Clear heartbeat and listener
-  req.on('close', () => {
+  req.on('close', function() {
     clearInterval(hbt);
-    emitter.removeListener('pullRequest', onPullRequest);
+    emitter.removeListener('pkg', onPkg);
   });
 };
 

lib/router/firehose.js

@@ -1,6 +1,3 @@
-/*jshint strict:true, trailing:false, unused:true, node:true */
-'use strict';
-
 module.exports = {
   firehose: require('./firehose')
 };

lib/router/index.js

@@ -1,24 +1,20 @@
 {
   "name": "firehose",
   "version": "1.0.0",
-  "description": "Libraries Firehose",
+  "description": "24 Pull Requests Firehose",
   "main": "app.js",
   "engines": {
-    "node": "0.12.x"
+    "node": "9.8.0"
   },
   "scripts": {
-    "start": "DEBUG=firehose nodemon app.js",
-    "test": "echo \"Error: no test specified\" && exit 1"
+    "start": "node app.js"
   },
   "author": "Mauro Pompilio",
-  "license": "Private",
+  "license": "MIT",
   "dependencies": {
-    "babel": "^4.7.16",
-    "body-parser": "^1.12.2",
-    "cors": "^2.5.3",
-    "debug": "^2.1.3",
-    "eventemitter3": "^0.1.6",
-    "express": "^4.12.3",
-    "serve-static": "^1.9.2"
+    "body-parser": "^1.14.1",
+    "cors": "^2.7.1",
+    "eventemitter3": "^1.2.0",
+    "express": "^4.13.3"
   }
 }