New new weather widget and telegram bot

.env.example

@@ -0,0 +1,38 @@
+environment=dev
+
+# A P I  - N O D E
+API_PORT=3001
+WEBHOOKS_HOST=localhost
+
+
+# M O N G O
+MONGO_USERNAME=admin
+MONGO_PASSWORD=123456
+MONGO_HOST=localhost
+MONGO_PORT=27017
+MONGO_DATABASE=god_level
+
+EMQX_DEFAULT_APPLICATION_SECRET=emqxsecrets
+EMQX_NODE_SUPERUSER_USER=superuser
+EMQX_NODE_SUPERUSER_PASSWORD=superuser
+EMQX_API_HOST=localhost
+EMQX_API_TOKEN=121212
+EMQX_RESOURCES_DELAY=1000
+
+
+# F R O N T
+APP_PORT=3000
+AXIOS_BASE_URL=http://127.0.0.1:3001/api
+MQTT_PORT=8083
+MQTT_HOST=localhost
+MQTT_PREFIX=ws://
+
+# W E A T H E R
+
+WEATHER_API_KEY='YOUR_API_KEY_HERE'
+
+
+# T E L E G R A M
+
+TELEGRAM_API_KEY='your bot api here'
+TELEGRAM_API_PORT='the on listen telegram'

api/bot/index.js

@@ -0,0 +1,45 @@
+const express = require('express');
+const ngrok = require('ngrok');
+const { Telegraf } = require('telegraf');
+
+const app3 = express();
+
+
+const bot = new Telegraf(`${process.env.TELEGRAM_API_KEY}`);
+
+// Comprueba si estamos en un entorno de desarrollo
+if (process.env.environment === 'dev') {
+
+  // Crea un túnel ngrok al puerto 8443
+  (async function()  {
+    try {
+      const url = await ngrok.connect(process.env.TELEGRAM_API_PORT);
+      bot.telegram.setWebhook(`${url}/${process.env.TELEGRAM_API_KEY}`);
+
+    } catch (error) {
+
+    }
+  })();
+} else if (process.env.environment === 'prod') {
+  // Usa una URL fija como webhook para tu bot de Telegram
+  bot.telegram.setWebhook(`https://${process.env.WEBHOOKS_HOST}:${process.env.TELEGRAM_API_PORT}/${process.env.TELEGRAM_API_KEY}`);
+}
+
+  // Inicia el servidor en el puerto 8443
+  app3.listen(8443, () => {
+    console.log(`Servidor iniciado en el puerto ${process.env.TELEGRAM_API_PORT}`);
+  });
+
+
+bot.start((ctx) => {
+    ctx.reply('¡Hola! Envía /miid para recibir tu ID de chat.');
+  });
+
+  bot.command('miid', (ctx) => {
+    const chatId = ctx.chat.id;
+    ctx.reply(`Tu ID de chat es: ${chatId}`);
+  });
+
+  bot.launch();
+
+module.exports = bot;

api/index.js

@@ -33,7 +33,12 @@ app.use("/api", require("./routes/dataprovider.js"));
 
 module.exports = app;
 
+// Importa el archivo de conexión con Telegram
+const bot = require('./bot');
+
+
 //listener
+
 app.listen(process.env.API_PORT, () => {
   console.log("API server listening on port " + process.env.API_PORT);
 });

api/models/emqx_alarm_rule.js

@@ -13,7 +13,9 @@ const alarmRuleSchema = new Schema({
     triggerTime: { type: Number },
     status:  { type: Boolean },
     counter: { type: Number, default: 0},
-    createdTime: {type: Number}
+    createdTime: {type: Number},
+    telegramID: {type: Number},
+    triggerTimeTelegram: {type: Number},
 });
 
 

api/models/user.js

@@ -6,11 +6,13 @@ const Schema = mongoose.Schema;
 const userSchema = new Schema({
   name: { type: String, required: [true] },
   email: { type: String, required: [true], unique: true},
-  password: {  type: String, required: [true]},
+  password: { type: String, required: [true]},
+  telegramID: { type: String, maxlength: 10 }
 });
 
 
-//Validator
+//Validators
+
 userSchema.plugin(uniqueValidator, { message: 'Error, email already exists.'});
 
 

api/routes/alarms.js

@@ -159,7 +159,9 @@ async function createAlarmRule(newAlarm) {
         value: newAlarm.value,
         condition: newAlarm.condition,
         triggerTime: newAlarm.triggerTime,
-        createTime: Date.now()
+        triggerTimeTelegram: newAlarm.triggerTimeTelegram,
+        createTime: Date.now(),
+        telegramID: newAlarm.telegramID
       });
 
       const url = "http://"+process.env.EMQX_API_HOST+":8085/api/v4/rules/" + mongoRule.emqxRuleId;
@@ -183,7 +185,8 @@ async function createAlarmRule(newAlarm) {
         newAlarm.variableFullName +
         '","triggerTime":' +
         newAlarm.triggerTime +
-        "}";
+        `${(!newAlarm.telegramID) ? "": `, "telegramID": ${newAlarm.telegramID}`}` +
+        `${(!newAlarm.triggerTimeTelegram) ? "}": `, "triggerTimeTelegram": ${newAlarm.triggerTimeTelegram} }`}`;
 
       newRule.actions[0].params.payload_tmpl = payload_templ;
 

api/routes/templates.js

@@ -1,122 +1,136 @@
-const express = require('express');
+const express = require("express");
 const router = express.Router();
-const { checkAuth } = require('../middlewares/authentication.js');
+const { checkAuth } = require("../middlewares/authentication.js");
 
 //models import
-import Template from '../models/template.js';
-import Device from '../models/device.js';
+import Template from "../models/template.js";
+import Device from "../models/device.js";
 
 //get templates
-router.get('/template', checkAuth, async (req, res) => {
+router.get("/template", checkAuth, async (req, res) => {
+  try {
+    const userId = req.userData._id;
 
-    try {
+    const templates = await Template.find({ userId: userId });
 
-        const userId = req.userData._id;
+    const response = {
+      status: "success",
+      data: templates
+    };
 
-        const templates = await Template.find({userId: userId});
+    return res.json(response);
+  } catch (error) {
+    console.log(error);
 
-        console.log(userId);
-        console.log(templates)
-
-        const response = {
-            status: "success",
-            data: templates
-        }
-
-        return res.json(response);
-
-    } catch (error) {
-
-        console.log(error);
-
-        const response = {
-            status: "error",
-            error: error
-        }
-
-        return res.status(500).json(response);
-
-    }
+    const response = {
+      status: "error",
+      error: error
+    };
 
+    return res.status(500).json(response);
+  }
 });
 
 //create template
-router.post('/template', checkAuth, async (req, res) => {
-
-    try {
-
-        const userId = req.userData._id;
-
-        var newTemplate = req.body.template;
+router.post("/template", checkAuth, async (req, res) => {
+  try {
+    const userId = req.userData._id;
 
-        newTemplate.userId = userId;
-        newTemplate.createdTime = Date.now();
+    var newTemplate = req.body.template;
 
-        const r = await Template.create(newTemplate);
+    newTemplate.userId = userId;
+    newTemplate.createdTime = Date.now();
 
-        const response = {
-            status: "success",
-        }
+    const r = await Template.create(newTemplate);
 
-        return res.json(response)
+    const response = {
+      status: "success"
+    };
 
-    } catch (error) {
+    return res.json(response);
+  } catch (error) {
+    console.log(error);
 
-        console.log(error);
-
-        const response = {
-            status: "error",
-            error: error
-        }
-
-        return res.status(500).json(response);
-
-    }
+    const response = {
+      status: "error",
+      error: error
+    };
 
+    return res.status(500).json(response);
+  }
 });
 
 //delete template
-router.delete('/template', checkAuth, async (req, res) => {
-
-    try {
-
-        const userId = req.userData._id;
-        const templateId = req.query.templateId;
-
-        const devices = await Device.find({userId: userId, templateId: templateId });
-
-
-        if (devices.length > 0){
-
-            const response = {
-                status: "fail",
-                error: "template in use"
-            }
-
-            return res.json(response);
-        }
-
-        const r = await Template.deleteOne({userId: userId, _id: templateId});
-
-        const response = {
-            status: "success",
-        }
-
-        return res.json(response)
+router.delete("/template", checkAuth, async (req, res) => {
+  try {
+    const userId = req.userData._id;
+    const templateId = req.query.templateId;
+
+    const devices = await Device.find({
+      userId: userId,
+      templateId: templateId
+    });
+
+    if (devices.length > 0) {
+      const response = {
+        status: "fail",
+        error: "template in use"
+      };
+
+      return res.json(response);
+    }
 
-    } catch (error) {
+    const r = await Template.deleteOne({ userId: userId, _id: templateId });
 
-        console.log(error);
+    const response = {
+      status: "success"
+    };
 
-        const response = {
-            status: "error",
-            error: error
-        }
+    return res.json(response);
+  } catch (error) {
+    console.log(error);
 
-        return res.status(500).json(response);
+    const response = {
+      status: "error",
+      error: error
+    };
 
-    }
+    return res.status(500).json(response);
+  }
+});
 
+// Modifica un documento en la colección "Template"
+router.put("/template", checkAuth, async (req, res) => {
+  try {
+    const userId = req.userData._id;
+    const templateId = req.query.templateId;
+    const update = req.body;
+
+    console.log(userId);
+    console.log(templateId);
+    console.log(update);
+
+    // Utiliza el método "updateOne()" para modificar el documento
+    const r = await Template.updateOne(
+      { userId: userId, _id: templateId },
+      update
+    );
+
+    const response = {
+      status: "success"
+    };
+
+    return res.json(response);
+  } catch (error) {
+    console.log(error);
+
+    const response = {
+      status: "error",
+      error: error
+    };
+
+    return res.status(500).json(response);
+  }
 });
 
-module.exports = router;
+module.exports = router;