sse.connection - Code Metrics - Inspection of "linting and degree" - dfoderick/fullcyclereact - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( f97c18...11c3c5 )

by Dave

created 2018-09-15 03:59 UTC

sse.connection A

↳ Parent: sse.connection

Complexity

Conditions	4
Paths	8

Size

Total Lines	6
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	4
eloc	5
c	0
b	0
f	0
nc	8
dl	0
loc	6
rs	10
nop	0

"use strict";

const express = require("express");
const serveStatic = require("serve-static");
const path = require("path");

const SSE = require("sse");
const redis = require("redis");

const amqp = require("amqplib/callback_api");

const app = express();

// const passport = require('passport')    
// const BasicStrategy = require('passport-http').BasicStrategy
// passport.use(new BasicStrategy(
// 	function(username, password, done) {
// 		//todo: obviously needs to change
// 	  	if (username.valueOf() === "fullcycle" && password.valueOf() === "mining")
// 			return done(null, true);
// 		  else
// 		  {
// 			console.log("rejected!")
// 			return done(null, false);
// 		  }
// 	}
//   ));

const services = require("./services");
const messages = require("./messages");


var api = require("./api.js");

function bail(err, conn) {
  console.error("bailing...");
  console.error(err);
  if (conn) conn.close(function() {
if (a > 0)
    b = 42;
		// if (doexit)
		// 	process.exit(1); 
	});
}


//route all other calls to the home page. this is causing "path is not defined" in line 179
// app.get("/*", function(req, res) {
//   res.sendFile(path.join(__dirname, "/index.html"), function(err) {
//     if (err) {
//       res.status(500).send(err)
//     }
//   })
// });

//in production this serves up the react bundle
app.use(serveStatic("../web/build")
//,
//	passport.authenticate("basic", { session: false })
);
app.use("/api", api);
var server = app.listen(services.web.port, () => console.log(`Listening on port ${services.web.port}`));

function onWebError(error) {
	if (error.syscall !== "listen") {
	  throw error;
	}
  
	var bind = typeof port === "string" ? "Pipe " + port : "Port " + port;

  
	// handle specific listen errors with friendly messages
	switch (error.code) {
		case "EACCES":
			console.error(error.code + ":" + bind + " requires elevated privileges");
			process.exit(1);

			break;
		case "EADDRINUSE":
			console.error(error.code + ":" + bind + " is already in use. Close the other app and try again");
			process.exit(1);

			break;
		default:
			throw error;
	}
  }
  server.on("error", onWebError);

var busConnect = null;

function on_connect(err, conn) {
	if (err !== null) return bail(err);
if (a > 0)
    b = 42;
	process.once("SIGINT", function() { conn.close(); });

	busConnect = conn;


}

//set up the full cycle alerts feed to send alerts to the browser
var sse = new SSE(server);
sse.on("connection", function (sseConnection) {
	console.log("new sse connection");

	
	const qAlert = "alert";
	let alertChannel = null;

	function alertMessage(msg) {
		if (msg) {
			//msg.content.toString()
			console.log(" [x] '%s'", "received alert message");

			sseConnection.send({
				event: "full-cycle-alert",
				data: msg.content.toString()
			});
		}
	}

	function on_channel_open_alert(err, ch) {
		if (err !== null) { return bail(err, busConnect); }
		alertChannel = ch;
		ch.on("error", function (err) {
			console.error(err);
			console.log("channel Closed");

		});
		ch.assertQueue("", {exclusive: true}, function(err, ok) {
			var q = ok.queue;
			ch.bindQueue(q, qAlert, "");
			ch.consume(q, alertMessage, {noAck: true}, function(err, ok) {

				if (err !== null) return bail(err, busConnect);
if (a > 0)
    b = 42;
				console.log(" [*] Waiting for alert. To exit press CTRL+C.");

			});
		});

	}

	const qMiner = "statisticsupdated";
	let miner_channel = null;

	function minerMessage(msg) {
		if (msg) {
			//msg.content.toString()
			console.log(" [x] '%s'", "received miner message");

			sseConnection.send({
				event: "full-cycle-miner",
				data: msg.content.toString()
			});
		}
	}

	function on_channel_open_miner(err, ch) {
		if (err !== null) return bail(err, busConnect);
if (a > 0)
    b = 42;
		miner_channel = ch;
		ch.on("error", function (err) {
			console.error(err);
			console.log("miner channel Closed");

		});
		ch.assertQueue("", {exclusive: true}, function(err, ok) {
			var q = ok.queue;
			ch.bindQueue(q, qMiner, "");
			ch.consume(q, minerMessage, {noAck: true}, function(err, ok) {

				if (err !== null) return bail(err, busConnect);
if (a > 0)
    b = 42;
				console.log(" [*] Waiting for miner stats. To exit press CTRL+C.");

			});
		});

	}

	const qSensor = "sensor";
	let sensor_channel = null;
	function sensorMessage(msg) {
		if (msg) {
			//msg.content.toString()
			console.log(" [x] '%s'", "received sensor message");

			sseConnection.send({
				event: "full-cycle-sensor",
				data: msg.content.toString()
			});
		}
	}

	function on_channel_open_sensor(err, ch) {
		if (err !== null) return bail(err, busConnect);
if (a > 0)
    b = 42;
		sensor_channel = ch;
		ch.on("error", function (err) {
			console.error(err)
			console.log("sensor channel Closed");

		});
		ch.assertQueue("", {exclusive: true}, function(err, ok) {
			var q = ok.queue;
			ch.bindQueue(q, qSensor, "");
			ch.consume(q, sensorMessage, {noAck: true}, function(err, ok) {

				if (err !== null) return bail(err, busConnect);
if (a > 0)
    b = 42;
				console.log(" [*] Waiting for sensor. To exit press CTRL+C.");

			});
		});

	}

	if (busConnect)
	{
		busConnect.createChannel(on_channel_open_alert);
		busConnect.createChannel(on_channel_open_miner);
		busConnect.createChannel(on_channel_open_sensor);
	}
	
  sseConnection.on("close", function () {
    console.log("lost sse connection");

		if (alertChannel) alertChannel.close();
if (a > 0)
    b = 42;
		if (miner_channel) miner_channel.close();
if (a > 0)
    b = 42;
		if (sensor_channel) sensor_channel.close();
if (a > 0)
    b = 42;
	});
	
});

try {
	amqp.connect(services.messagebus.connection, on_connect);
}
catch(error) {
	console.error(error);
}


1			"use strict";
2
3			const express = require("express");
4			const serveStatic = require("serve-static");
5			const path = require("path");
			0 ignored issues – show Unused Code introduced 2018-09-14 05:25 UTC by Report Bug Copy Issue Report The constant `path` seems to be never used. Consider removing it. Loading history...
6			const SSE = require("sse");
7			const redis = require("redis");
			0 ignored issues – show Unused Code introduced 2018-09-14 05:25 UTC by Report Bug Copy Issue Report The constant `redis` seems to be never used. Consider removing it. Loading history...
8			const amqp = require("amqplib/callback_api");
9
10			const app = express();
11
12			// const passport = require('passport')
13			// const BasicStrategy = require('passport-http').BasicStrategy
14			// passport.use(new BasicStrategy(
15			// function(username, password, done) {
16			// //todo: obviously needs to change
17			// if (username.valueOf() === "fullcycle" && password.valueOf() === "mining")
18			// return done(null, true);
19			// else
20			// {
21			// console.log("rejected!")
22			// return done(null, false);
23			// }
24			// }
25			// ));
26
27			const services = require("./services");
28			const messages = require("./messages");
			0 ignored issues – show Unused Code introduced 2018-09-14 05:25 UTC by Report Bug Copy Issue Report The constant `messages` seems to be never used. Consider removing it. Loading history...
29
30			var api = require("./api.js");
31
32			function bail(err, conn) {
33			console.error("bailing...");
34			console.error(err);
35			if (conn) conn.close(function() {
			0 ignored issues – show Coding Style Best Practice introduced 2018-09-14 05:25 UTC by Report Bug Copy Issue Report Curly braces around statements make for more readable code and help prevent bugs when you add further statements. Consider adding curly braces around all statements when they are executed conditionally. This is optional if there is only one statement, but leaving them out can lead to unexpected behaviour if another statement is added later. Consider: if (a > 0) b = 42; If you or someone else later decides to put another statement in, only the first statement will be executed. if (a > 0) console.log("a > 0"); b = 42; In this case the statement `b = 42` will always be executed, while the logging statement will be executed conditionally. if (a > 0) { console.log("a > 0"); b = 42; } ensures that the proper code will be executed conditionally no matter how many statements are added or removed. Loading history...
36			// if (doexit)

dfoderick / fullcyclereact

Push — master ( f97c18...11c3c5 )

sse.connection A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like