Add batch delete message event

Author: SupertigerDev

src/common/ClientEventNames.ts

@@ -45,6 +45,7 @@ export const MESSAGE_CREATED = 'message:created';
 export const MESSAGE_UPDATED = 'message:updated';
 export const CHANNEL_TYPING = 'channel:typing';
 export const MESSAGE_DELETED = 'message:deleted';
+export const MESSAGE_DELETED_BATCH = 'message:deleted_batch';
 export const MESSAGE_REACTION_ADDED = 'message:reaction_added';
 export const MESSAGE_REACTION_REMOVED = 'message:reaction_removed';
 

src/emits/Server.ts

@@ -1,4 +1,4 @@
-import { MESSAGE_CREATED, MESSAGE_DELETED, MESSAGE_REACTION_ADDED, MESSAGE_REACTION_REMOVED, MESSAGE_UPDATED, SERVER_CHANNEL_ORDER_UPDATED, SERVER_EMOJI_ADD, SERVER_EMOJI_REMOVE, SERVER_EMOJI_UPDATE, SERVER_JOINED, SERVER_LEFT, SERVER_MEMBER_JOINED, SERVER_MEMBER_LEFT, SERVER_MEMBER_UPDATED, SERVER_ORDER_UPDATED, SERVER_ROLE_CREATED, SERVER_ROLE_DELETED, SERVER_ROLE_ORDER_UPDATED, SERVER_ROLE_UPDATED, SERVER_UPDATED } from '../common/ClientEventNames';
+import { MESSAGE_CREATED, MESSAGE_DELETED, MESSAGE_DELETED_BATCH, MESSAGE_REACTION_ADDED, MESSAGE_REACTION_REMOVED, MESSAGE_UPDATED, SERVER_CHANNEL_ORDER_UPDATED, SERVER_EMOJI_ADD, SERVER_EMOJI_REMOVE, SERVER_EMOJI_UPDATE, SERVER_JOINED, SERVER_LEFT, SERVER_MEMBER_JOINED, SERVER_MEMBER_LEFT, SERVER_MEMBER_UPDATED, SERVER_ORDER_UPDATED, SERVER_ROLE_CREATED, SERVER_ROLE_DELETED, SERVER_ROLE_ORDER_UPDATED, SERVER_ROLE_UPDATED, SERVER_UPDATED } from '../common/ClientEventNames';
 import { getIO } from '../socket/socket';
 import { Presence, UserCache } from '../cache/UserCache';
 import { UpdateServerOptions } from '../services/Server';
@@ -138,6 +138,17 @@ export const emitServerMessageDeleted = (data: { channelId: string; messageId: s
   io.in(data.channelId).emit(MESSAGE_DELETED, data);
 };
 
+export const emitServerMessageDeletedBatch = (data: { userId: string, serverId: string; fromTime: Date, toTime: Date }) => {
+  const io = getIO();
+
+  io.in(data.serverId).emit(MESSAGE_DELETED_BATCH, {
+    userId: data.userId,
+    fromTime: data.fromTime.getTime(),
+    serverId: data.serverId,
+    toTime: data.toTime.getTime(),
+  });
+}
+
 export const emitServerUpdated = (serverId: string, updated: UpdateServerOptions) => {
   const io = getIO();
 

src/routes/posts/postCreate.ts

@@ -71,7 +71,6 @@ async function route(req: Request, res: Response) {
     body.poll!.choices = body.poll!.choices.map(choice => choice.trim()).filter(choice => choice);
 
   }
-  console.log(body.poll)
 
   const validateError = customExpressValidatorResult(req);
 

src/services/Message.ts

@@ -1,6 +1,6 @@
 import { ChannelCache, getChannelCache } from '../cache/ChannelCache';
 import { emitDMMessageCreated, emitDMMessageDeleted, emitDMMessageReactionAdded, emitDMMessageReactionRemoved, emitDMMessageUpdated } from '../emits/Channel';
-import { emitServerMessageCreated, emitServerMessageDeleted, emitServerMessageReactionAdded, emitServerMessageReactionRemoved, emitServerMessageUpdated } from '../emits/Server';
+import { emitServerMessageCreated, emitServerMessageDeleted, emitServerMessageDeletedBatch, emitServerMessageReactionAdded, emitServerMessageReactionRemoved, emitServerMessageUpdated } from '../emits/Server';
 import { MessageType } from '../types/Message';
 import { dismissChannelNotification } from './Channel';
 import { dateToDateTime, exists, getMessageReactedUserIds, prisma, publicUserExcludeFields } from '../common/database';
@@ -190,18 +190,26 @@ export const getMessagesByChannelId = async (channelId: string, opts?: GetMessag
 
 // delete messages sent in the last 7 hours
 export const deleteRecentMessages = async (userId: string, serverId: string) => {
-  const date = new Date();
-  date.setHours(date.getHours() + 7);
+  const fromTime = new Date();
+  const toTime = new Date();
+  toTime.setHours(toTime.getHours() + 7);
 
   await prisma.message.deleteMany({
     where: {
       createdById: userId,
       channel: { serverId },
       createdAt: {
-        lt: dateToDateTime(date),
+        lt: dateToDateTime(toTime),
       },
     },
   });
+
+  emitServerMessageDeletedBatch({
+    userId,
+    serverId,
+    fromTime,
+    toTime,
+  })
 };
 
 interface EditMessageOptions {