index.js

const express = require("express");
const dotenv = require("dotenv");
const mongoose = require("mongoose");
const admin = require("firebase-admin");

dotenv.config();
const authRouter = require("./routes/auth_routes");
const balanceRouter = require("./routes/balance_routes");
const transactionRouter = require("./routes/transactions_route");
const notifications = require("./routes/notification_routes");
const userRouter = require("./routes/user_routes");
const cors = require("cors");
const Message = require("./models/message_model");
const Chat = require("./models/chat_model");
const chatRouter = require("./routes/chat_route");
const messageRouter = require("./routes/message_route");

// Decode the base64-encoded service account
const serviceAccountJSON = Buffer.from(process.env.ENCODED_SERVICE_ACCOUNT, "base64").toString("utf8");
const serviceAccount = JSON.parse(serviceAccountJSON);

admin.initializeApp({
  credential: admin.credential.cert(serviceAccount),
  databaseURL: process.env.databaseURL,
});

const app = express();
app.use(express.json());
app.use(cors());
app.use(authRouter);
app.use(transactionRouter);
app.use(balanceRouter);
app.use(notifications);
app.use(userRouter);
app.use(chatRouter);
app.use(messageRouter);

mongoose
  .connect(process.env.DATABASE_URL, {
    useNewUrlParser: true,
    useUnifiedTopology: true,
  })
  .then(() => {
    console.log("Successfully connected to MongoDB!");
  })
  .catch((e) => {
    console.log("Unable to connect to MongoDB");
  });

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

const server = app.listen(PORT, "0.0.0.0", () => {
  console.log(`Server listening on port ${PORT}`);
});

const io = require("socket.io")(server, {
  pingTimeout: 120000,
  cors: {
    origin: process.env.PAY_MOBILE_DATABASE,
  },
});

io.on("connection", (socket) => {
  socket.on("join", ({ chatId }) => {
    socket.join(chatId);
  });

  socket.on("sendMessage", async ({ chatId, sender, content, receiver }) => {
    try {
      const message = new Message({ sender, content, receiver, chat: chatId });
      await message.save();
      await Chat.findByIdAndUpdate(chatId, { latestMessage: content });
      io.to(chatId).emit("message", message);
    } catch (error) {
      console.error(error);
    }
  });
});