require("dotenv").config();
const mqtt = require("mqtt");
const express = require("express");

// const db = require("./db");

const app = express();

app.use(require("./routes"))

app.use(express.static("public"));

app.listen(process.env.PORT || 8080, () => {
	console.log(`Listening on port ${process.env.PORT || 8080}`);
});

const mqttClient = mqtt.connect(process.env.MQTT);

mqttClient.on("connect", (a) => {
	console.log(`Connected to ${process.env.MQTT}`);
});

mqttClient.subscribe("motion");
mqttClient.subscribe("sound");
mqttClient.subscribe("temperature");
mqttClient.subscribe("light");

mqttClient.on("message", (topic, message) => {
	console.log(topic, message.toString());
});