123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120 |
- const ChatModel = require('../model/chat');
- const UserModel = require('../model/user');
- const MessageModel = require('../model/message');
- const listChats = async (req, res, next) => {
- try {
- const userId = req.user.id;
- const chats = await ChatModel.getList(userId, req.query);
- const messages = await MessageModel.getLastMessagesList(userId);
- const lastMessages = await messages.reduce(
- (acc, { message, companionId }) => {
- const obj = { message, companionId };
- if (acc.length === 0) {
- acc.push(obj);
- return acc;
- }
- if (acc.some((el) => el.companionId === companionId)) {
- const i = acc.findIndex((el) => {
- return el.companionId === companionId;
- });
- acc[i] = obj;
- return acc;
- }
- acc.push(obj);
- return acc;
- },
- []
- );
- return res.json({
- status: 'success',
- code: 200,
- data: {
- ...chats,
- lastMessages,
- },
- });
- } catch (e) {
- next(e);
- }
- };
- const startChat = async (req, res, next) => {
- try {
- const id = req.body.id;
- const user = req.user;
- const userId = user.id;
- const companion = await UserModel.findById(id);
- const isUser = await ChatModel.getByField(id, userId);
- const isCompanion = await ChatModel.getByField(userId, id);
- const { name, lastName, avatarUrl, color, online, number } = companion;
- const {
- name: Name,
- lastName: LastName,
- avatarUrl: AvatarUrl,
- color: Color,
- online: Online,
- number: Number,
- } = user;
- if (companion && (isUser || isCompanion)) {
- await ChatModel.update(isUser._id, {
- name,
- lastName,
- avatarUrl,
- color,
- online,
- number,
- });
- await ChatModel.update(isCompanion._id, {
- name: Name,
- lastName: LastName,
- avatarUrl: AvatarUrl,
- color: Color,
- online: Online,
- number: Number,
- });
- const updatedChat = await ChatModel.getByField(id, userId);
- return res.status(200).json({
- status: 'success',
- code: 200,
- data: updatedChat,
- });
- }
- if (companion && !isUser && !isCompanion) {
- const newChat = await ChatModel.add({
- name,
- lastName,
- avatarUrl,
- color,
- online,
- number,
- companionId: id,
- owner: userId,
- });
- await ChatModel.add({
- name: Name,
- lastName: LastName,
- avatarUrl: AvatarUrl,
- color: Color,
- online: Online,
- number: Number,
- companionId: userId,
- owner: id,
- });
- return res.status(201).json({
- status: 'success',
- code: 201,
- data: newChat,
- });
- }
- } catch (e) {
- next(e);
- }
- };
- module.exports = {
- listChats,
- startChat,
- };
|