const express = require("express");
const path = require("path");
const app = express();
const SocketIO = require("socket.io");
var mqtt = require('mqtt')
var client = mqtt.connect('mqtt://192.168.1.105',{username:'mdchaparror',password:'un80187452'})

app.set("port", 3000);
app.use(express.static(path.join(__dirname, "public")));
console.log(__dirname);

const server = app.listen(app.get("port"), () => {
  console.log("Servidor iniciado puerto: ", app.get("port"));
});

const io = SocketIO(server);

io.on("connection", (socket) => {
  console.log("Cliente conectado");
  socket.emit('OK',{mensaje:'Bienvenido'})
  socket.on("mensaje", (mensaje) => {
    client.publish('matrix/mensaje',mensaje.message);
    client.publish('matrix/rgb',mensaje.color_rgb);
    console.log("mensaje MQTT =>",mensaje)
  });

  socket.on("mensaje2", (mensaje) => {
    client.publish('matrix/full',mensaje);
    console.log("mensaje2  MQTT =>",mensaje)
  });



});