.-.-.-.-.-

const funcs = require('../functions/functions')
const compiledTemplates = require('../compiledTemplates/compiledTemplates')
const socketEvents = require('../events/events')
const { Sequelize, Op, DataTypes } = require("sequelize");
const striptags = require('striptags');
const moment = require("moment")

const IsChatOnController = async (ctx, data, io,socket) => {
  let last_message = {}

if (data.message_id) {
      last_message = await ctx.wo_messages.findOne({
          where: {
              id: data.message_id
          }
      })
  }
  let toUser = await ctx.wo_users.findOne({
      where: {
          user_id: {
              [Op.eq]: ctx.userHashUserId[data.user_id]
          }
      }
  })
  if (toUser == null) {
      return;
  }
  if (data.isGroup) {
      ctx.userIdGroupChatOpen[ctx.userHashUserId[data.user_id]] && ctx.userIdGroupChatOpen[ctx.userHashUserId[data.user_id]].length ? ctx.userIdGroupChatOpen[ctx.userHashUserId[data.user_id]].push(data.recipient_id) : ctx.userIdGroupChatOpen[ctx.userHashUserId[data.user_id]] = [data.recipient_id]
  }
  else {
      ctx.userIdChatOpen[ctx.userHashUserId[data.user_id]] && ctx.userIdChatOpen[ctx.userHashUserId[data.user_id]].length ? ctx.userIdChatOpen[ctx.userHashUserId[data.user_id]].push(data.recipient_id) : ctx.userIdChatOpen[ctx.userHashUserId[data.user_id]] = [data.recipient_id]
  }

if (ctx.userIdChatOpen[ctx.userHashUserId[data.user_id]] && ctx.userIdChatOpen[ctx.userHashUserId[data.user_id]].length) {
      let arr = new Set(ctx.userIdChatOpen[ctx.userHashUserId[data.user_id]])
      ctx.userIdChatOpen[ctx.userHashUserId[data.user_id]] = Array.from(arr)
  }
  if (ctx.userIdGroupChatOpen[ctx.userHashUserId[data.user_id]] && ctx.userIdGroupChatOpen[ctx.userHashUserId[data.user_id]].length) {
      let arr = new Set(ctx.userIdGroupChatOpen[ctx.userHashUserId[data.user_id]])
      ctx.userIdGroupChatOpen[ctx.userHashUserId[data.user_id]] = Array.from(arr)
  }
  if (last_message.seen == 0) {
      var seen = Math.floor(Date.now() / 1000);
      let seenMsg = funcs.Wo_Time_Elapsed_String(ctx, seen)
      await io.to(data.recipient_id).emit("lastseen", {
          can_seen: 1,
          time: seenMsg,
          seen: seenMsg,
          message_id: data.message_id,
          user_id: ctx.userHashUserId[data.user_id]
      })
  }
  if (last_message.seen > 0) {
      let seenMsg = funcs.Wo_Time_Elapsed_String(ctx, last_message.seen)
      await io.to(data.recipient_id).emit("lastseen", {
          can_seen: 1,
          time: seenMsg,
          seen: seenMsg,
          message_id: last_message.id,
          user_id: ctx.userHashUserId[data.user_id]
      })
  }
  else {
      await socketEvents.unseen(ctx, socket)
  }
  let user_id = ctx.userHashUserId[data.user_id]
  let unseenmessages = await funcs.Wo_CountUnseenMessages(ctx, user_id);
  await io.to(user_id).emit("messages_count", { count: unseenmessages })
};

module.exports = { IsChatOnController };

/home/users/unlimited/www/facebook.codeskitter.site/nodejs/./controllers/IsChatOnController.js