1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156 |
- const MessageModel = require('../model/message');
- const UserModel = require('../model/user');
- const ChatModel = require('../model/chat');
- const fs = require('fs').promises;
- const s3 = require('../helpers/aws');
- const AWS_BUCKET_NAME = process.env.AWS_BUCKET_NAME;
- require('dotenv').config();
- const listMessages = async (req, res, next) => {
- try {
- const userId = req.user.id;
- const messages = await MessageModel.getList({ owner: userId }, req.query);
- return res.json({
- status: 'success',
- code: 200,
- data: messages,
- });
- } catch (e) {
- next(e);
- }
- };
- const listMessagesById = async (req, res, next) => {
- try {
- const userId = req.user.id;
- const companionId = req.params.companionId;
- const messages = await MessageModel.getList(
- { owner: userId, companionId },
- {}
- );
- return res.json({
- status: 'success',
- code: 200,
- data: messages,
- });
- } catch (e) {
- next(e);
- }
- };
- const editMessage = async (req, res, next) => {
- try {
- const userId = req.user.id;
- const { id, message, caption } = req.body;
- const userMessage = await MessageModel.getById(id, userId);
- await MessageModel.updateMessage(id, userId, {
- message: userMessage.fullType === null ? message : userMessage.message,
- caption,
- edited: true,
- });
- await MessageModel.findByFieldsAndUpdateMany(
- {
- oldId: userMessage._id,
- },
- {
- forwardMessage:
- userMessage.fullType === null ? message : userMessage.forwardMessage,
- forwardCaption: caption,
- replyMessage:
- userMessage.fullType === null ? message : userMessage.replyMessage,
- replyCaption: caption,
- edited: true,
- }
- );
- const companionMessage = await MessageModel.findByFields(
- userId,
- userMessage.idTime,
- userMessage.companionId
- );
- await MessageModel.findByFieldsAndUpdate(
- userId,
- userMessage.idTime,
- userMessage.companionId,
- {
- message: userMessage.fullType === null ? message : userMessage.message,
- caption,
- edited: true,
- }
- );
- await MessageModel.findByFieldsAndUpdateMany(
- {
- oldId: companionMessage._id,
- },
- {
- forwardMessage:
- userMessage.fullType === null ? message : userMessage.forwardMessage,
- forwardCaption: caption,
- replyMessage:
- userMessage.fullType === null ? message : userMessage.replyMessage,
- replyCaption: caption,
- edited: true,
- }
- );
- const isChat = await ChatModel.getByField(userMessage.companionId, userId);
- const isCompanionChat = await ChatModel.getByField(
- userId,
- userMessage.companionId
- );
- const updatedAt = new Date();
- await ChatModel.update(isChat._id, userId, {
- lastMessage: 'The Message was Edited',
- lastMessageCreatedAt: updatedAt,
- });
- await ChatModel.update(isCompanionChat._id, userMessage.companionId, {
- lastMessage: 'The Message was Edited',
- lastMessageCreatedAt: updatedAt,
- });
- return res.status(200).json({
- status: 'success',
- code: 200,
- data: {},
- });
- } catch (e) {
- next(e);
- }
- };
- const updateMessageEmoji = async (req, res, next) => {
- try {
- const id = req.params.id;
- const userId = req.user.id;
- const { emoji } = req.body;
- const userMessage = await MessageModel.updateMessage(id, userId, { emoji });
- await MessageModel.findByFieldsAndUpdate(
- userId,
- userMessage.idTime,
- userMessage.companionId,
- {
- emojiCompanion: emoji,
- }
- );
- return res.status(200).json({
- status: 'success',
- code: 200,
- data: {},
- });
- } catch (e) {
- next(e);
- }
- };
- const updateMessagePin = async (req, res, next) => {
- try {
- const id = req.params.id;
- const userId = req.user.id;
- const { pinned } = req.body;
- const userMessage = await MessageModel.updateMessage(id, userId, {
- pinned,
- });
- await MessageModel.findByFieldsAndUpdate(
- userId,
- userMessage.idTime,
- userMessage.companionId,
- {
- pinned,
- }
- );
- return res.status(200).json({
- status: 'success',
- code: 200,
- data: {},
- });
- } catch (e) {
- next(e);
- }
- };
- const unpinAllMessage = async (req, res, next) => {
- try {
- const userId = req.user.id;
- const pinnedMessages = req.body.pinnedMessages;
- pinnedMessages.forEach(async (id) => {
- const userMessage = await MessageModel.updateMessage(id, userId, {
- pinned: false,
- });
- await MessageModel.findByFieldsAndUpdate(
- userId,
- userMessage.idTime,
- userMessage.companionId,
- {
- pinned: false,
- }
- );
- });
- return res.status(200).json({
- status: 'success',
- code: 200,
- data: {},
- });
- } catch (e) {
- next(e);
- }
- };
- const removeMessage = async (req, res, next) => {
- try {
- const id = req.params.id;
- const userId = req.user.id;
- const userMessage = await MessageModel.remove(id, userId);
- await MessageModel.findByFieldsAndUpdateMany(
- {
- oldId: userMessage._id,
- },
- {
- deleted: true,
- replyMessage: null,
- replyCaption: null,
- forwardMessage: null,
- forwardCaption: null,
- fullType: null,
- oldId: null,
- }
- );
- const companionMessage = await MessageModel.findByFields(
- userId,
- userMessage.idTime,
- userMessage.companionId
- );
- await MessageModel.findByFieldsAndUpdateMany(
- {
- oldId: companionMessage._id,
- },
- {
- deleted: true,
- replyMessage: null,
- replyCaption: null,
- forwardMessage: null,
- forwardCaption: null,
- fullType: null,
- oldId: null,
- }
- );
- await MessageModel.removeByFields(
- userId,
- userMessage.idTime,
- userMessage.companionId
- );
- if (userMessage.type !== 'text') {
- const params = {
- Bucket: AWS_BUCKET_NAME,
- Key: `${userMessage.message}`,
- };
- s3.deleteObject(params, async function (err, _data) {
- if (err) throw err;
- });
- }
- const isChat = await ChatModel.getByField(userMessage.companionId, userId);
- const isCompanionChat = await ChatModel.getByField(
- userId,
- userMessage.companionId
- );
- const { total } = await MessageModel.getList(
- { owner: userId, companionId: userMessage.companionId },
- {}
- );
- const { total: Total } = await MessageModel.getList(
- { owner: userMessage.companionId, companionId: userId },
- {}
- );
- const seenCalculate = (seen, total) => {
- if (seen <= total) {
- return seen;
- } else {
- return total;
- }
- };
- const updatedAt = new Date();
- await ChatModel.update(isChat._id, userId, {
- total: total,
- seen: seenCalculate(isChat.seen, total),
- seenCompanion: seenCalculate(isChat.seenCompanion, total),
- lastMessage: 'The Message was Deleted',
- lastMessageCreatedAt: updatedAt,
- });
- await ChatModel.update(isCompanionChat._id, userMessage.companionId, {
- total: Total,
- seen: seenCalculate(isCompanionChat.seen, Total),
- seenCompanion: seenCalculate(isCompanionChat.seenCompanion, Total),
- lastMessage: 'The Message was Deleted',
- lastMessageCreatedAt: updatedAt,
- });
- return res.json({
- status: 'success',
- code: 200,
- data: {},
- });
- } catch (e) {
- next(e);
- }
- };
- const removeSelected = async (req, res, next) => {
- try {
- const userId = req.user.id;
- const { selectedArr, companionId } = req.body;
- const toDeleteMessage = async (id) => {
- const userMessage = await MessageModel.remove(id, userId);
- await MessageModel.findByFieldsAndUpdateMany(
- {
- oldId: userMessage._id,
- },
- {
- deleted: true,
- replyMessage: null,
- replyCaption: null,
- forwardMessage: null,
- forwardCaption: null,
- fullType: null,
- oldId: null,
- }
- );
- const companionMessage = await MessageModel.findByFields(
- userId,
- userMessage.idTime,
- companionId
- );
- await MessageModel.findByFieldsAndUpdateMany(
- {
- oldId: companionMessage._id,
- },
- {
- deleted: true,
- replyMessage: null,
- replyCaption: null,
- forwardMessage: null,
- forwardCaption: null,
- fullType: null,
- oldId: null,
- }
- );
- await MessageModel.removeByFields(
- userId,
- userMessage.idTime,
- companionId
- );
- if (userMessage.type !== 'text') {
- const params = {
- Bucket: AWS_BUCKET_NAME,
- Key: `${userMessage.message}`,
- };
- s3.deleteObject(params, async function (err, _data) {
- if (err) throw err;
- });
- }
- };
- await selectedArr.forEach(async (id) => await toDeleteMessage(id));
- const isChat = await ChatModel.getByField(companionId, userId);
- const isCompanionChat = await ChatModel.getByField(userId, companionId);
- const { total } = await MessageModel.getList(
- { owner: userId, companionId },
- {}
- );
- const { total: Total } = await MessageModel.getList(
- { owner: companionId, companionId: userId },
- {}
- );
- const seenCalculate = (seen, total) => {
- if (seen <= total) {
- return seen;
- } else {
- return total;
- }
- };
- const updatedAt = new Date();
- await ChatModel.update(isChat._id, userId, {
- total: total,
- seen: seenCalculate(isChat.seen, total),
- seenCompanion: seenCalculate(isChat.seenCompanion, total),
- lastMessage: 'Some Messages were Deleted',
- lastMessageCreatedAt: updatedAt,
- });
- await ChatModel.update(isCompanionChat._id, companionId, {
- total: Total,
- seen: seenCalculate(isCompanionChat.seen, Total),
- seenCompanion: seenCalculate(isCompanionChat.seenCompanion, Total),
- lastMessage: 'Some Messages were Deleted',
- lastMessageCreatedAt: updatedAt,
- });
- return res.json({
- status: 'success',
- code: 200,
- data: {},
- });
- } catch (e) {
- next(e);
- }
- };
- const sentMessage = async (req, res, next) => {
- try {
- const { id, message, caption } = req.body;
- const idTime = Math.round(Date.now() / 1000);
- const user = req.user;
- const userId = user.id;
- const companion = await UserModel.findById(id);
- const isChat = await ChatModel.getByField(id, userId);
- const isCompanionChat = await ChatModel.getByField(userId, id);
- const { name, lastName, avatarUrl, color, number } = user;
- if (companion && isChat && isCompanionChat) {
- const newMessage = await MessageModel.add({
- message,
- name,
- lastName,
- avatarUrl,
- color,
- number,
- type: 'text',
- caption,
- idTime,
- companionIdFlow: userId,
- companionId: id,
- owner: userId,
- });
- await MessageModel.add({
- message,
- name: isCompanionChat.name,
- lastName: isCompanionChat.lastName,
- avatarUrl,
- color,
- number,
- type: 'text',
- caption,
- idTime,
- companionIdFlow: userId,
- companionId: userId,
- owner: id,
- });
- const { total } = await MessageModel.getList(
- { owner: userId, companionId: id },
- {}
- );
- await ChatModel.update(isChat._id, userId, {
- total,
- seen: total,
- watched: false,
- lastMessage: message,
- lastMessageCreatedAt: newMessage.createdAt,
- });
- const { total: Total } = await MessageModel.getList(
- { owner: id, companionId: userId },
- {}
- );
- await ChatModel.update(isCompanionChat._id, id, {
- total: Total,
- seenCompanion: Total,
- lastMessage: message,
- lastMessageCreatedAt: newMessage.createdAt,
- });
- return res.status(201).json({
- status: 'success',
- code: 201,
- data: newMessage,
- });
- }
- } catch (e) {
- next(e);
- }
- };
- const callMessage = async (req, res, next) => {
- try {
- const { id, duration } = req.body;
- const idTime = Math.round(Date.now() / 1000);
- const user = req.user;
- const userId = user.id;
- const companion = await UserModel.findById(id);
- const isChat = await ChatModel.getByField(id, userId);
- const isCompanionChat = await ChatModel.getByField(userId, id);
- const { name, lastName, avatarUrl, color, number } = user;
- if (companion && isChat && isCompanionChat) {
- const newMessage = await MessageModel.add({
- initiator: true,
- duration,
- message: 'Outgoing Call',
- name,
- lastName,
- avatarUrl,
- color,
- number,
- type: 'text',
- idTime,
- companionIdFlow: userId,
- companionId: id,
- owner: userId,
- });
- await MessageModel.add({
- duration,
- message: 'Incoming Call',
- name: isCompanionChat.name,
- lastName: isCompanionChat.lastName,
- avatarUrl,
- color,
- number,
- type: 'text',
- idTime,
- companionIdFlow: userId,
- companionId: userId,
- owner: id,
- });
- const { total } = await MessageModel.getList(
- { owner: userId, companionId: id },
- {}
- );
- await ChatModel.update(isChat._id, userId, {
- total,
- seen: total,
- watched: false,
- lastMessage: 'Outgoing Call',
- lastMessageCreatedAt: newMessage.createdAt,
- });
- const { total: Total } = await MessageModel.getList(
- { owner: id, companionId: userId },
- {}
- );
- await ChatModel.update(isCompanionChat._id, id, {
- total: Total,
- seenCompanion: Total,
- lastMessage: 'Incoming Call',
- lastMessageCreatedAt: newMessage.createdAt,
- });
- return res.status(201).json({
- status: 'success',
- code: 201,
- data: newMessage,
- });
- }
- } catch (e) {
- next(e);
- }
- };
- const updateMessageCall = async (req, res, next) => {
- try {
- const { id, duration } = req.body;
- const userId = req.user.id;
- const userMessage = await MessageModel.getById(id, userId);
- const isChat = await ChatModel.getByField(userMessage.companionId, userId);
- const isCompanionChat = await ChatModel.getByField(
- userId,
- userMessage.companionId
- );
- const messageOne = duration ? 'Outgoing Call' : 'Canceled Call';
- const messageTwo = duration ? 'Incoming Call' : 'Missed Call';
- await MessageModel.updateMessage(id, userId, {
- message: messageOne,
- duration,
- });
- await MessageModel.findByFieldsAndUpdate(
- userId,
- userMessage.idTime,
- userMessage.companionId,
- {
- message: messageTwo,
- duration,
- }
- );
- await ChatModel.update(isChat._id, userId, {
- lastMessage: messageOne,
- });
- await ChatModel.update(isCompanionChat._id, userMessage.companionId, {
- lastMessage: messageTwo,
- });
- return res.status(200).json({
- status: 'success',
- code: 200,
- data: {},
- });
- } catch (e) {
- next(e);
- }
- };
- const sentMessageReply = async (req, res, next) => {
- try {
- const { id, message, caption } = req.body;
- const idTime = Math.round(Date.now() / 1000);
- const user = req.user;
- const userId = user.id;
- const userMessage = await MessageModel.getById(id, userId);
- const companionMessage = await MessageModel.findByFields(
- userId,
- userMessage.idTime,
- userMessage.companionId
- );
- const isChat = await ChatModel.getByField(userMessage.companionId, userId);
- const isCompanionChat = await ChatModel.getByField(
- userId,
- userMessage.companionId
- );
- if (isChat && isCompanionChat && userMessage && companionMessage) {
- const newMessage = await MessageModel.add({
- message,
- replyMessage: userMessage.message,
- name: user.name,
- lastName: user.lastName,
- replyName: userMessage.name,
- replyLastName: userMessage.lastName,
- avatarUrl: user.avatarUrl,
- color: user.color,
- number: user.number,
- type: 'text',
- fullType: userMessage.fullType,
- caption,
- replyCaption: userMessage.caption,
- idTime,
- oldId: id,
- companionIdFlow: userId,
- companionId: userMessage.companionId,
- owner: userId,
- });
- await MessageModel.add({
- message,
- replyMessage: companionMessage.message,
- name: isCompanionChat.name,
- lastName: isCompanionChat.lastName,
- replyName: companionMessage.name,
- replyLastName: companionMessage.lastName,
- avatarUrl: user.avatarUrl,
- color: user.color,
- number: user.number,
- type: 'text',
- fullType: companionMessage.fullType,
- caption,
- replyCaption: companionMessage.caption,
- idTime,
- oldId: companionMessage._id,
- companionIdFlow: userId,
- companionId: userId,
- owner: userMessage.companionId,
- });
- const { total } = await MessageModel.getList(
- { owner: userId, companionId: userMessage.companionId },
- {}
- );
- await ChatModel.update(isChat._id, userId, {
- total,
- seen: total,
- watched: false,
- lastMessage: message,
- lastMessageCreatedAt: newMessage.createdAt,
- });
- const { total: Total } = await MessageModel.getList(
- { owner: userMessage.companionId, companionId: userId },
- {}
- );
- await ChatModel.update(isCompanionChat._id, userMessage.companionId, {
- total: Total,
- seenCompanion: Total,
- lastMessage: message,
- lastMessageCreatedAt: newMessage.createdAt,
- });
- return res.status(201).json({
- status: 'success',
- code: 201,
- data: newMessage,
- });
- }
- } catch (e) {
- next(e);
- }
- };
- const sentMessageForward = async (req, res, next) => {
- try {
- const { id, companionIdForwardToAndFrom, message, caption } = req.body;
- const idTime = Math.round(Date.now() / 1000);
- const user = req.user;
- const userId = user.id;
- const userMessage = await MessageModel.getById(id, userId);
- const isChat = await ChatModel.getByField(
- companionIdForwardToAndFrom,
- userId
- );
- const companionMessage = await MessageModel.findByFields(
- userId,
- userMessage.idTime,
- userMessage.companionId
- );
- const isCompanionUser = await UserModel.findById(userMessage.companionId);
- const isForwardChat = await ChatModel.getByField(
- userId,
- companionIdForwardToAndFrom
- );
- if (
- userMessage &&
- isCompanionUser &&
- isChat &&
- isForwardChat &&
- companionMessage
- ) {
- const newMessage = await MessageModel.add({
- message,
- caption,
- forwardMessage: userMessage.message,
- forwardCaption: userMessage.caption,
- name: user.name,
- lastName: user.lastName,
- avatarUrl: user.avatarUrl,
- color: user.color,
- number: user.number,
- type: 'text',
- fullType: userMessage.fullType,
- forwardName:
- user.number === userMessage.number ? user.name : isCompanionUser.name,
- forwardLastName:
- user.number === userMessage.number
- ? user.lastName
- : isCompanionUser.lastName,
- oldId: userMessage._id,
- idTime,
- companionIdFlow: userId,
- companionIdForwardToAndFrom: userMessage.companionId,
- companionId: companionIdForwardToAndFrom,
- owner: userId,
- });
- await MessageModel.add({
- message,
- caption,
- forwardMessage: userMessage.message,
- forwardCaption: userMessage.caption,
- name: isForwardChat.name,
- lastName: isForwardChat.lastName,
- avatarUrl: user.avatarUrl,
- color: user.color,
- number: user.number,
- type: 'text',
- fullType: userMessage.fullType,
- forwardName:
- user.number === userMessage.number ? user.name : isCompanionUser.name,
- forwardLastName:
- user.number === userMessage.number
- ? user.lastName
- : isCompanionUser.lastName,
- oldId: companionMessage._id,
- idTime,
- companionIdFlow: userId,
- companionId: userId,
- companionIdForwardToAndFrom: userMessage.companionId,
- owner: companionIdForwardToAndFrom,
- });
- const { total } = await MessageModel.getList(
- { owner: userId, companionId: companionIdForwardToAndFrom },
- {}
- );
- await ChatModel.update(isChat._id, userId, {
- total,
- seen: total,
- watched: false,
- lastMessage: message,
- lastMessageCreatedAt: newMessage.createdAt,
- });
- const { total: Total } = await MessageModel.getList(
- { owner: companionIdForwardToAndFrom, companionId: userId },
- {}
- );
- await ChatModel.update(isForwardChat._id, companionIdForwardToAndFrom, {
- total: Total,
- seenCompanion: Total,
- lastMessage: message,
- lastMessageCreatedAt: newMessage.createdAt,
- });
- return res.status(201).json({
- status: 'success',
- code: 201,
- data: newMessage,
- });
- }
- } catch (e) {
- next(e);
- }
- };
- const imageMessage = async (req, res, next) => {
- try {
- const userId = req.user.id;
- const [id, ...rest] = req.params.companionIdAndCaption.split(' ');
- const caption = rest.join(' ').slice(0, -1);
- const idTime = Math.round(Date.now() / 1000);
- const isChat = await ChatModel.getByField(id, userId);
- const isCompanionChat = await ChatModel.getByField(userId, id);
- const originalName = req.file.originalname;
- const pathToFile = req.file.path;
- const fullType = req.file.mimetype;
- const imgUrl = `${Math.round(Date.now() / 1000)}${userId}${originalName}`;
- const fileContent = await fs.readFile(pathToFile);
- const params = {
- Bucket: AWS_BUCKET_NAME,
- Key: `${imgUrl}`,
- Body: fileContent,
- };
- s3.upload(params, async (err, _data) => {
- if (err) throw err;
- fs.unlink(pathToFile);
- });
- if (isChat && isCompanionChat) {
- const { name, lastName, avatarUrl, color, number } = req.user;
- const newMessage = await MessageModel.add({
- message: imgUrl,
- name,
- lastName,
- avatarUrl,
- color,
- number,
- type: 'image',
- fullType,
- caption,
- idTime,
- companionIdFlow: userId,
- companionId: id,
- owner: userId,
- });
- await MessageModel.add({
- message: imgUrl,
- name: isCompanionChat.name,
- lastName: isCompanionChat.lastName,
- avatarUrl,
- color,
- number,
- type: 'image',
- fullType,
- caption,
- idTime,
- companionIdFlow: userId,
- companionId: userId,
- owner: id,
- });
- const { total } = await MessageModel.getList(
- { owner: userId, companionId: id },
- {}
- );
- await ChatModel.update(isChat._id, userId, {
- total,
- seen: total,
- watched: false,
- lastMessage: fullType,
- lastMessageCreatedAt: newMessage.createdAt,
- });
- const { total: Total } = await MessageModel.getList(
- { owner: id, companionId: userId },
- {}
- );
- await ChatModel.update(isCompanionChat._id, id, {
- total: Total,
- seenCompanion: Total,
- lastMessage: fullType,
- lastMessageCreatedAt: newMessage.createdAt,
- });
- return res.status(201).json({
- status: 'success',
- code: 201,
- data: newMessage,
- });
- }
- } catch (e) {
- next(e);
- }
- };
- const audioMessage = async (req, res, next) => {
- try {
- const userId = req.user.id;
- const [id, ...rest] = req.params.companionIdAndCaption.split(' ');
- let caption = rest.join(' ');
- if (caption.length === 1) caption.slice(0, -1);
- const idTime = Math.round(Date.now() / 1000);
- const isChat = await ChatModel.getByField(id, userId);
- const isCompanionChat = await ChatModel.getByField(userId, id);
- const originalName = req.file.originalname;
- const pathToFile = req.file.path;
- const fullType = req.file.mimetype;
- const audioUrl = `${Math.round(Date.now() / 1000)}${originalName}`;
- const fileContent = await fs.readFile(pathToFile);
- const params = {
- Bucket: AWS_BUCKET_NAME,
- Key: `${audioUrl}`,
- Body: fileContent,
- };
- s3.upload(params, async (err, _data) => {
- if (err) throw err;
- fs.unlink(pathToFile);
- });
- if (isChat && isCompanionChat) {
- const { name, lastName, avatarUrl, color, number } = req.user;
- const newMessage = await MessageModel.add({
- message: audioUrl,
- name,
- lastName,
- avatarUrl,
- color,
- number,
- type: 'audio',
- fullType,
- caption,
- idTime,
- companionIdFlow: userId,
- companionId: id,
- owner: userId,
- });
- await MessageModel.add({
- message: audioUrl,
- name: isCompanionChat.name,
- lastName: isCompanionChat.lastName,
- avatarUrl,
- color,
- number,
- type: 'audio',
- fullType,
- caption,
- idTime,
- companionIdFlow: userId,
- companionId: userId,
- owner: id,
- });
- const { total } = await MessageModel.getList(
- { owner: userId, companionId: id },
- {}
- );
- await ChatModel.update(isChat._id, userId, {
- total,
- seen: total,
- watched: false,
- lastMessage: fullType,
- lastMessageCreatedAt: newMessage.createdAt,
- });
- const { total: Total } = await MessageModel.getList(
- { owner: id, companionId: userId },
- {}
- );
- await ChatModel.update(isCompanionChat._id, id, {
- total: Total,
- seenCompanion: Total,
- lastMessage: fullType,
- lastMessageCreatedAt: newMessage.createdAt,
- });
- return res.status(201).json({
- status: 'success',
- code: 201,
- data: newMessage,
- });
- }
- } catch (e) {
- next(e);
- }
- };
- const videoMessage = async (req, res, next) => {
- try {
- const userId = req.user.id;
- const [id, ...rest] = req.params.companionIdAndCaption.split(' ');
- let caption = rest.join(' ');
- if (caption.length === 1) caption.slice(0, -1);
- const idTime = Math.round(Date.now() / 1000);
- const isChat = await ChatModel.getByField(id, userId);
- const isCompanionChat = await ChatModel.getByField(userId, id);
- const originalName = req.file.originalname;
- const pathToFile = req.file.path;
- const videoUrl = `${Math.round(Date.now() / 1000)}${originalName}`;
- const fullType = req.file.mimetype;
- const fileContent = await fs.readFile(pathToFile);
- const params = {
- Bucket: AWS_BUCKET_NAME,
- Key: `${videoUrl}`,
- Body: fileContent,
- };
- s3.upload(params, async (err, _data) => {
- if (err) throw err;
- fs.unlink(pathToFile);
- });
- if (isChat && isCompanionChat) {
- const { name, lastName, avatarUrl, color, number } = req.user;
- const newMessage = await MessageModel.add({
- message: videoUrl,
- name: isCompanionChat.name,
- lastName: isCompanionChat.lastName,
- avatarUrl,
- color,
- number,
- type: 'video',
- fullType,
- caption,
- idTime,
- companionIdFlow: userId,
- companionId: id,
- owner: userId,
- });
- await MessageModel.add({
- message: videoUrl,
- name,
- lastName,
- avatarUrl,
- color,
- number,
- type: 'video',
- fullType,
- caption,
- idTime,
- companionIdFlow: userId,
- companionId: userId,
- owner: id,
- });
- const { total } = await MessageModel.getList(
- { owner: userId, companionId: id },
- {}
- );
- await ChatModel.update(isChat._id, userId, {
- total,
- seen: total,
- watched: false,
- lastMessage: fullType,
- lastMessageCreatedAt: newMessage.createdAt,
- });
- const { total: Total } = await MessageModel.getList(
- { owner: id, companionId: userId },
- {}
- );
- await ChatModel.update(isCompanionChat._id, id, {
- total: Total,
- seenCompanion: Total,
- lastMessage: fullType,
- lastMessageCreatedAt: newMessage.createdAt,
- });
- return res.status(201).json({
- status: 'success',
- code: 201,
- data: newMessage,
- });
- }
- } catch (e) {
- next(e);
- }
- };
- const fileMessage = async (req, res, next) => {
- try {
- const userId = req.user.id;
- const [id, ...rest] = req.params.companionIdAndCaption.split(' ');
- let caption = rest.join(' ');
- if (caption.length === 1) caption.slice(0, -1);
- const idTime = Math.round(Date.now() / 1000);
- const isChat = await ChatModel.getByField(id, userId);
- const isCompanionChat = await ChatModel.getByField(userId, id);
- const pathToFile = req.file.path;
- const fullType = req.file.mimetype;
- let type;
- switch (fullType) {
- case 'application/pdf':
- type = 'pdf';
- break;
- case 'application/vnd.openxmlformats-officedocument.wordprocessingml.document':
- type = 'docx';
- break;
- case 'application/octet-stream':
- type = 'docx';
- break;
- default:
- break;
- }
- const fileUrl = `${Math.round(Date.now() / 1000)}file.${type}`;
- const fileContent = await fs.readFile(pathToFile);
- const params = {
- Bucket: AWS_BUCKET_NAME,
- Key: `${fileUrl}`,
- Body: fileContent,
- };
- s3.upload(params, async (err, _data) => {
- if (err) throw err;
- fs.unlink(pathToFile);
- });
- if (isChat && isCompanionChat) {
- const { name, lastName, avatarUrl, color, number } = req.user;
- const newMessage = await MessageModel.add({
- message: fileUrl,
- name,
- lastName,
- avatarUrl,
- color,
- number,
- type,
- fullType,
- caption,
- idTime,
- companionIdFlow: userId,
- companionId: id,
- owner: userId,
- });
- await MessageModel.add({
- message: fileUrl,
- name: isCompanionChat.name,
- lastName: isCompanionChat.lastName,
- avatarUrl,
- color,
- number,
- type,
- fullType,
- caption,
- idTime,
- companionIdFlow: userId,
- companionId: userId,
- owner: id,
- });
- const { total } = await MessageModel.getList(
- { owner: userId, companionId: id },
- {}
- );
- await ChatModel.update(isChat._id, userId, {
- total,
- seen: total,
- watched: false,
- lastMessage: fullType,
- lastMessageCreatedAt: newMessage.createdAt,
- });
- const { total: Total } = await MessageModel.getList(
- { owner: id, companionId: userId },
- {}
- );
- await ChatModel.update(isCompanionChat._id, id, {
- total: Total,
- seenCompanion: Total,
- lastMessage: fullType,
- lastMessageCreatedAt: newMessage.createdAt,
- });
- return res.status(201).json({
- status: 'success',
- code: 201,
- data: newMessage,
- });
- }
- } catch (e) {
- next(e);
- }
- };
- module.exports = {
- listMessages,
- removeMessage,
- removeSelected,
- editMessage,
- updateMessageEmoji,
- updateMessagePin,
- unpinAllMessage,
- listMessagesById,
- sentMessage,
- callMessage,
- updateMessageCall,
- sentMessageReply,
- sentMessageForward,
- imageMessage,
- audioMessage,
- videoMessage,
- fileMessage,
- };
|