SOCKET FOR OUR LIVE INTERACTION

 HERE, WE USE SOCKET.IO FOR OUR LIVE INTERACTION (CHATS) .

WE CREATE THREE PROPERTIES NAMELY, MESSAGES, CONNECTIONS,TIMEONLINE.

THESE THREE ARE USED TO STORE DATA. MESSAGES TO STORE THE MESSAGES SENT BY THE USERS, CONNECTIONS TO STORE THE NUMBER OF CONNECTIONS (SOCKETS) AND TIME ONLINE DENOTES THE TIME SPENT ONLINE BY THE USER.

AS WE KNOW FROM THE PREVIOUS POST, IN SOCKET. IO WE USE TWO OF THE IMPORTANT FUNCTIONS SOCKET.ON ( TO RECEIVE) AND SOCKET.EMIT ( TO EMIT).

WE CREATE A NEW FILE, IN CONTROLLERS FOLDER CALLED SOCKETCONTROLLER.

IN SOCKETCONTROLLER.JS

const { Server } = require("socket.io");
let messages = {};
let connections = {};
let timeOnline = {};
module.exports.SocketConnection = (server) => {
  const io = new Server(server, {
    cors: {
      origin: "*", // TO SOLVE CORS ERROR
      methods: ["GET", "POST"],
      credentials: true,
    },
  });

  io.on("connection", (socket) => {
    socket.on("joined-chat", (path) => {
      if (connections[path] === undefined) { //IF IN CASE THERE ARE NO CONNECTIONS
        connections[path] = [];
      }
      connections[path].push(socket.id); // IF A CONNECTION EXIST, WE PUSH THE
SOCKET ID INTO IT.
      timeOnline[socket.id] = new Date();

      for (let i = 0; i < connections[path].length; i++) {
        io.to(
          connections[path][i].emit("user-joined"),
          socket.id,
          connections[path]
        );
      }
      if (messages[path] !== undefined) {
        for (let i = 0; i < messages[path].length; i++) {
          io.to(socket.id).emit(
            "chat-message",
            messages[path][i]["data"],
            messages[path][i]["sender"],
            messages[path][i]["socketID-sender"]
          );
        }
      }
    });
    socket.on("signal", (toId, message) => {
      io.to(toId).emit("signal", socket.id, message);
    });
    socket.on("chat-msg", (data, sender) => {
      const [matchingRoom, found] = Object.entries(connections).reduce(
        ([room, isFound], [roomKey, roomVal]) => {
          if (!isFound && roomVal.includes(socket.id)) {
            return [roomKey, true];
          }
        },
        ["", false]
      );

      if (found) {
        if (messages[matchingRoom] === undefined) {
          messages[matchingRoom] = [];
        }
        messages[matchingRoom].push({
          sender: sender,
          data: data,
          "socketID-sender": socket.id,
        });
        connections[matchingRoom].forEach((element) => {
          io.to(element).emit("chat-msg", data, sender, socket.id);
        });
      }
    });
    socket.on("disconnect", () => {
      let diffTime = Math.abs(timeOnline[socket.id] - new Date());

      const [matchingRoom, found] = Object.entries(connections).reduce(
        ([Key, Val]) => {
          for (let i = 0; i < Val.length; i++) {
            io.to(connections[Key][i].emit("user-left", socket.id));
          }
          const index = connections[Key].indexOf(socket.id);
          connections[Key].splice(index, 1);

          if (connections[Key].length == 0) {
            delete connections[Key];
          }
        }
      );
    });
  });
};

WE WILL BE DISCUSSING MORE ABOUT THIS , WHILE WE ARE WORKING ON THE FRONTEND






Comments

Post a Comment

Popular posts from this blog

MIDDLEWARE.JS

  const User = require ( "../models/userModel" ); require ( "dotenv" ). config (); const jwt = require ( "jsonwebtoken" ); module . exports . userVerification = async ( req , res ) => {   console . log ( req . cookies );   const token = req . cookies . token ;   if ( ! token ) {     return res . status ( 404 ). json ({ message : "authentication failed!" });   }   jwt . verify ( token , process . env . TOKEN_KEY , async ( err , data ) => {     if ( err ) {       return res . status ( 400 ). json ({ message : "Invalid Token!" });     }     try {       console . log ( data );       const foundUser = await User . findById ( data . id );       if ( foundUser ) {         return res . status ( 200 ). json ({ message : "authentication successful!" });       } else {         r...
Read more

MODELS

 USER MODEL const mongoose = require ( "mongoose" ); const Schema = mongoose . Schema ; const Model = mongoose . model ; const bcrypt = require ( "bcryptjs" ); const userSchema = new Schema ({   name : {     type : String ,     required : true ,   },   username : {     type : String ,     required : true ,     unique : true ,   },   email : {     type : String ,     required : true ,     unique : true ,   },   password : {     type : String ,     required : true ,   }, }); userSchema . pre ( "save" , async function ( next ) {   if ( this . isModified ( "password" )) {     this . password = await bcrypt . hash ( this . password , 10 );   }   next (); }); const User = new Model ( "User" , userSchema ); module . exports = User ; MEETING MODEL const mongoose = require ( "mongoose...
Read more

AUTHENTICATION PAGE

 AUTH.JSX import React , { useState , useEffect } from "react" ; import axios from "axios" ; import Box from "@mui/material/Box" ; import IconButton from "@mui/material/IconButton" ; import Button from "@mui/material/Button" ; import ButtonGroup from "@mui/material/ButtonGroup" ; import InputAdornment from "@mui/material/InputAdornment" ; import TextField from "@mui/material/TextField" ; import Visibility from "@mui/icons-material/Visibility" ; import VisibilityOff from "@mui/icons-material/VisibilityOff" ; import MenuOutlinedIcon from "@mui/icons-material/MenuOutlined" ; import { useSnackbar } from "notistack" ; import Footer from "./Footer" ; import styles from "../styles/Auth.module.css" ; import { useNavigate } from "react-router-dom" ; import { Link } from "react-router-dom" ;...
Read more