index.js

const WebSocketServer = require("websocket").server;
const bodyParser = require("body-parser");
const upload = require("multer")();
require("./mod/mqttServer.js");
const app = require("./mod/expressServ.js");
const expressServer = require("./mod/expressServer.js");
const socket = require("socket.io-client")("http://localhost");
const eventEmitter = require("./mod/events.js");
const wsServ = require("express")();
const io = require("./mod/socket.js");
const utility = require("./mod/Utility");

app.set("view engine", "pug");
app.set("views", "./Views");
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: true }));
app.use("/", require("./mod/routes.js"));
app.use("/transmit", require("./mod/transmit.js"));
app.use("/upload", require("./mod/upload.js"));

app.get("*", (req, res) => {
	res.writeHead(404);
	res.end("<h1>404 Not Found</h1>");
});

//__________________________________________________________________________________________________________//
expressServer.listen(80, () => {
	console.log("listening on :80");
});
/*
wsServer = new WebSocketServer({
	httpServer: wsServ.listen(8080),
	autoAcceptConnections: false,
});

var originIsAllowed = (origin) => {
	return true;
};

wsServer.on("request", (request) => {
	if (!originIsAllowed(request.origin)) {
		request.reject();
		console.log(
			new Date() + " Connection from origin " + request.origin + " rejected."
		);
		return;
	}
	var connection = request.accept();
	console.log(new Date() + " Connection accepted.");
	connection.on("message", (message) => {
		if (message.type === "utf8") {
			if (utility.isJSON(message.utf8Data)) {
				var clientIP = JSON.parse(message.utf8Data);
				var api = clientIP.api;
				var sensorId = clientIP.id;
				if (sensorId == "JSPYN_IOT") {
					//keeping id : IOT_DEVICE is for IOT_DEVICE to listen
					eventEmitter.on("JSPYN_IOT" + api, (data) => {
						connection.send(data);
					});
				} else {
					eventEmitter.on(api + sensorId, (data) => {
						connection.send(data);
					});
				}
			} else {
				connection.send("Error: Please Send JSON Object");
			}
		} else if (message.type === "binary") {
			console.log(
				"Received Binary Message of " + message.binaryData.length + " bytes"
			);
			connection.send("Error: Please Send JSON Object");
		}
	});
	connection.on("close", (reasonCode, description) => {
		console.log(
			new Date() + " Peer " + connection.remoteAddress + " disconnected."
		);
	});
});

*/