Add mutations to mark chat messages as read, update message, update group chat info, add user to group chat, share images in chats, and create dedicated group chats for events

schema.graphql

@@ -206,6 +206,7 @@ type Chat {
   messages: [ChatMessage]
   name: String
   organization: Organization
+  unseenMessagesByUsers: JSON
   updatedAt: DateTime!
   users: [User!]!
 }
@@ -215,12 +216,18 @@ type ChatMessage {
   chatMessageBelongsTo: Chat!
   createdAt: DateTime!
   deletedBy: [User]
+  media: String
   messageContent: String!
   replyTo: ChatMessage
   sender: User!
   updatedAt: DateTime!
 }
 
+input ChatWhereInput {
+  name_contains: String
+  user: UserWhereInput
+}
+
 type CheckIn {
   _id: ID!
   createdAt: DateTime!
@@ -700,6 +707,7 @@ input EventAttendeeInput {
 
 input EventInput {
   allDay: Boolean!
+  createChat: Boolean!
   description: String!
   endDate: Date!
   endTime: Time
@@ -1067,6 +1075,7 @@ type Mutation {
   addPledgeToFundraisingCampaign(campaignId: ID!, pledgeId: ID!): FundraisingCampaignPledge!
   addUserCustomData(dataName: String!, dataValue: Any!, organizationId: ID!): UserCustomData!
   addUserImage(file: String!): User!
+  addUserToGroupChat(chatId: ID!, userId: ID!): Chat
   addUserToUserFamily(familyId: ID!, userId: ID!): UserFamily!
   assignToUserTags(input: TagActionsInput!): UserTag
   assignUserTag(input: ToggleUserTagAssignInput!): User
@@ -1114,6 +1123,7 @@ type Mutation {
   likePost(id: ID!): Post
   login(data: LoginInput!): AuthData!
   logout: Boolean!
+  markChatMessagesAsRead(chatId: ID!, userId: ID!): Chat
   otp(data: OTPInput!): OtpData!
   recaptcha(data: RecaptchaVerification!): Boolean!
   refreshToken(refreshToken: String!): ExtendSession!
@@ -1147,7 +1157,7 @@ type Mutation {
   revokeRefreshTokenForUser: Boolean!
   saveFcmToken(token: String): Boolean!
   sendMembershipRequest(organizationId: ID!): MembershipRequest!
-  sendMessageToChat(chatId: ID!, messageContent: String!, replyTo: ID): ChatMessage!
+  sendMessageToChat(chatId: ID!, media: String, messageContent: String, replyTo: ID): ChatMessage!
   signUp(data: UserInput!, file: String): AuthData!
   togglePostPin(id: ID!, title: String): Post!
   unassignUserTag(input: ToggleUserTagAssignInput!): User
@@ -1161,6 +1171,8 @@ type Mutation {
   updateAgendaCategory(id: ID!, input: UpdateAgendaCategoryInput!): AgendaCategory
   updateAgendaItem(id: ID!, input: UpdateAgendaItemInput!): AgendaItem
   updateAgendaSection(id: ID!, input: UpdateAgendaSectionInput!): AgendaSection
+  updateChat(input: UpdateChatInput!): Chat!
+  updateChatMessage(input: UpdateChatMessageInput!): ChatMessage!
   updateCommunity(data: UpdateCommunityInput!): Boolean!
   updateEvent(data: UpdateEventInput!, id: ID!, recurrenceRuleData: RecurrenceRuleInput, recurringEventUpdateType: RecurringEventMutationType): Event!
   updateEventVolunteer(data: UpdateEventVolunteerInput, id: ID!): EventVolunteer!
@@ -1476,7 +1488,7 @@ type Query {
   agendaItemByOrganization(organizationId: ID!): [AgendaItem]
   agendaItemCategoriesByOrganization(organizationId: ID!): [AgendaCategory]
   chatById(id: ID!): Chat!
-  chatsByUserId(id: ID!): [Chat]
+  chatsByUserId(id: ID!, where: ChatWhereInput): [Chat]
   checkAuth: User!
   customDataByOrganization(organizationId: ID!): [UserCustomData!]!
   customFieldsByOrganization(id: ID!): [OrganizationCustomField]
@@ -1500,9 +1512,11 @@ type Query {
   getFundById(id: ID!, orderBy: CampaignOrderByInput, where: CampaignWhereInput): Fund!
   getFundraisingCampaignPledgeById(id: ID!): FundraisingCampaignPledge!
   getFundraisingCampaigns(campaignOrderby: CampaignOrderByInput, pledgeOrderBy: PledgeOrderByInput, where: CampaignWhereInput): [FundraisingCampaign]!
+  getGroupChatsByUserId: [Chat]
   getNoteById(id: ID!): Note!
   getPledgesByUserId(orderBy: PledgeOrderByInput, userId: ID!, where: PledgeWhereInput): [FundraisingCampaignPledge]
   getPlugins: [Plugin]
+  getUnreadChatsByUserId: [Chat]
   getUserTag(id: ID!): UserTag
   getUserTagAncestors(id: ID!): [UserTag]
   getVenueByOrgId(first: Int, orderBy: VenueOrderByInput, orgId: ID!, skip: Int, where: VenueWhereInput): [Venue]
@@ -1696,6 +1710,18 @@ input UpdateAgendaSectionInput {
   sequence: Int
 }
 
+input UpdateChatInput {
+  _id: ID!
+  image: String
+  name: String
+}
+
+input UpdateChatMessageInput {
+  chatId: ID!
+  messageContent: String!
+  messageId: ID!
+}
+
 input UpdateCommunityInput {
   logo: String!
   name: String!

src/helpers/event/createEventHelpers/createRecurringEvent.ts

@@ -1,5 +1,5 @@
 import type mongoose from "mongoose";
-import type { InterfaceEvent } from "../../../models";
+import type { InterfaceChat, InterfaceEvent } from "../../../models";
 import { Event } from "../../../models";
 import type { MutationCreateEventArgs } from "../../../types/generatedGraphQLTypes";
 import {
@@ -37,6 +37,7 @@ export const createRecurringEvent = async (
   creatorId: string,
   organizationId: string,
   session: mongoose.ClientSession,
+  chat: InterfaceChat | null,
 ): Promise<InterfaceEvent> => {
   // Extract event data and recurrence rule information from arguments
   const { data } = args;
@@ -69,6 +70,7 @@ export const createRecurringEvent = async (
         creatorId,
         admins: [creatorId],
         organization: organizationId,
+        chat: chat?._id,
       },
     ],
     { session }, // Use the provided session if available

src/helpers/event/createEventHelpers/createRecurringEventInstancesDuringQuery.ts

@@ -62,6 +62,7 @@ export const createRecurringEventInstancesDuringQuery = async (
       // Prepare input data for generating recurring event instances
       const currentInputData: InterfaceRecurringEvent = {
         ...data,
+        createChat: false,
         organizationId: recurrenceRule.organizationId.toString(),
       };
 

src/helpers/event/createEventHelpers/createSingleEvent.ts

@@ -1,5 +1,5 @@
 import type mongoose from "mongoose";
-import type { InterfaceEvent } from "../../../models";
+import type { InterfaceChat, InterfaceEvent } from "../../../models";
 import { AppUserProfile, Event, EventAttendee, User } from "../../../models";
 import type { MutationCreateEventArgs } from "../../../types/generatedGraphQLTypes";
 import { cacheEvents } from "../../../services/EventCache/cacheEvents";
@@ -31,6 +31,7 @@ export const createSingleEvent = async (
   creatorId: string,
   organizationId: string,
   session: mongoose.ClientSession,
+  chat: InterfaceChat | null,
 ): Promise<InterfaceEvent> => {
   // Create the single event in the database
   const createdEvent = await Event.create(
@@ -40,6 +41,7 @@ export const createSingleEvent = async (
         creatorId,
         admins: [creatorId],
         organization: organizationId,
+        chat: chat?._id,
       },
     ],
     { session },

src/helpers/event/updateEventHelpers/getEventData.ts

@@ -31,12 +31,14 @@ export const getEventData = (
     longitude: event.longitude,
     creatorId: event.creatorId,
     organizationId: event.organization,
+    chat: event.chat,
   };
 
   // Step 2: Update the current data with the input data (if provided).
   const updatedEventData: InterfaceRecurringEvent = {
     ...eventCurrentData,
     ...(updateEventInputData as Partial<InterfaceRecurringEvent>),
+    createChat: event.chat ? true : false,
   };
 
   return updatedEventData;

src/models/Chat.ts

@@ -11,6 +11,7 @@ export interface InterfaceChat {
   _id: Types.ObjectId;
   isGroup: boolean;
   name: string;
+  image: string;
   users: PopulatedDoc<InterfaceUser & Document>[];
   messages: PopulatedDoc<InterfaceChatMessage & Document>[];
   creatorId: PopulatedDoc<InterfaceUser & Document>;
@@ -20,6 +21,7 @@ export interface InterfaceChat {
   createdAt: Date;
   updatedAt: Date;
   lastMessageId: string;
+  unseenMessagesByUsers: JSON;
 }
 
 /**
@@ -98,9 +100,13 @@ const chatSchema = new Schema(
       type: String,
       required: false,
     },
+    unseenMessagesByUsers: {
+      type: JSON,
+      required: true,
+    },
   },
   {
-    timestamps: true,
+    timestamps: false,
   },
 );
 

src/models/ChatMessage.ts

@@ -13,6 +13,7 @@ export interface InterfaceChatMessage {
   sender: PopulatedDoc<InterfaceUser & Document>;
   replyTo: PopulatedDoc<InterfaceChatMessage & Document>;
   messageContent: string;
+  media: string;
   status: string;
   deletedBy: PopulatedDoc<InterfaceUser & Document>[];
   createdAt: Date;
@@ -66,7 +67,11 @@ const chatMessageSchema = new Schema(
     },
     messageContent: {
       type: String,
-      required: true,
+      required: false,
+    },
+    media: {
+      type: String,
+      required: false,
     },
     status: {
       type: String,

src/models/Event.ts

@@ -6,6 +6,7 @@ import { createLoggingMiddleware } from "../libraries/dbLogger";
 import type { InterfaceEventVolunteerGroup } from "./EventVolunteerGroup";
 import type { InterfaceRecurrenceRule } from "./RecurrenceRule";
 import type { InterfaceAgendaItem } from "./AgendaItem";
+import type { InterfaceChat } from "./Chat";
 
 /**
  * Represents a document for an event in the MongoDB database.
@@ -39,6 +40,7 @@ export interface InterfaceEvent {
   updatedAt: Date;
   volunteerGroups: PopulatedDoc<InterfaceEventVolunteerGroup & Document>[];
   agendaItems: PopulatedDoc<InterfaceAgendaItem & Document>[];
+  chat: PopulatedDoc<InterfaceChat & Document>;
 }
 
 /**
@@ -178,6 +180,11 @@ const eventSchema = new Schema(
       ref: "Organization",
       required: true,
     },
+    chat: {
+      type: Schema.Types.ObjectId,
+      ref: "Chat",
+      required: false,
+    },
     volunteerGroups: [
       {
         type: Schema.Types.ObjectId,

src/resolvers/Chat/admins.ts

@@ -8,7 +8,7 @@ import type { ChatResolvers } from "../../types/generatedGraphQLTypes";
 export const admins: ChatResolvers["users"] = async (parent) => {
   return await User.find({
     _id: {
-      $in: parent.users,
+      $in: parent.admins,
     },
   }).lean();
 };

src/resolvers/Chat/messages.ts

@@ -5,10 +5,22 @@
  * @param parent - An object that is the return value of the resolver for this field's parent.
  * @returns An `object` that contains the list of messages.
  */
-export const messages: ChatResolvers["messages"] = async (parent) => {
-  return await ChatMessage.find({
+export const messages: ChatResolvers["messages"] = async (
+  parent,
+  _args,
+  context,
+) => {
+  let messages = await ChatMessage.find({
     _id: {
       $in: parent.messages,
     },
   }).lean();
+
+  messages = messages.map((message) => {
+    if (message.media) {
+      return { ...message, media: `${context.apiRootUrl}${message.media}` };
+    }
+    return message;
+  });
+  return messages;
 };