index.js

require("dotenv").config();
const express = require("express");
const app = express();
const bodyParser = require("body-parser");
const axios = require("axios");
const redis = require("redis");
const http = require("http");
const socketIo = require("socket.io");
const redisClient = redis.createClient();
const connectDB = require("./config/db");
const Chat = require("./models/Chat");
const { TELEGRAM_API, URI, WEBHOOK_URL } = require("./constants");

app.set("view engine", "ejs");
connectDB();
const server = http.createServer(app);
const io = socketIo(server);

app.use(bodyParser.json());

const init = async () => {
  const res = await axios.get(`${TELEGRAM_API}/setWebhook?url=${WEBHOOK_URL}`);
  console.log(res.data);
};

// Send all previous messages to the client on connection
io.on("connection", async (socket) => {
  const chats = await Chat.find();
  socket.emit("messageList", chats);
});

app.post(URI, async (req, res) => {
  console.log(req.body);
  const message = req.body.message.text;
  const firstName = req.body.message.from.first_name;
  redisClient.on("connect", () => {
    console.log("Redis client connected");
    redisClient.lPush("chats", message, (error, result) => {
      if (error) {
        console.log(error);
      } else {
        console.log(`Message: ${message} added to queue. Result: ${result}`);
      }
    });
  });

  const chat = new Chat({
    chat: message,
    name: firstName,
  });

  await chat.save();

  io.emit("message", { name: firstName, chat: message });
  res.send("Message added to queue.");
});

const PORT = process.env.PORT || 5000;

app.get("/", async (req, res) => {
  const chats = await Chat.find();
  res.render("index", { chats });
});
server.listen(PORT, async () => {
  console.log(`Server is running on port ${PORT}.`);
  await init();
});