Added kafka publishevent for cohortmember

src/cohortMembers/cohortMembers.service.ts

@@ -561,6 +561,17 @@ ON CM."userId" = U."userId" ${whereCase}`;
       const savedCohortMember = await this.cohortMembersRepository.save(
         cohortMembers
       );
+
+      const enrichedCohortMember = {
+        ...savedCohortMember,
+        AcademicYearID: academicyearId,
+      };
+
+      await this.publishCohortMemberEvent(
+        "created",
+        enrichedCohortMember,
+        apiId
+      );
 
       return APIResponse.success(
         res,
@@ -1090,6 +1101,20 @@ ${whereCase}`;
               cohortMemberForAcademicYear
             );
             results.push(result);
+
+
+
+            const enrichedCohortMember = {
+              ...result,
+              AcademicYearID: academicyearId,
+              customFields: (cohortMembersDto as any).customFields,
+            };
+
+            await this.publishCohortMemberEvent(
+              "created",
+              enrichedCohortMember,
+              apiId
+            );
 
             // Track user for Kafka event publishing
             affectedUsers.add(userId);

src/cohortMembers/dto/bulkMember-create.dto.ts

@@ -1,12 +1,15 @@
 import { ApiProperty } from "@nestjs/swagger";
+import { Expose, Type } from "class-transformer";
 import {
   IsArray,
   IsUUID,
   ArrayNotEmpty,
   IsOptional,
   IsNotEmpty,
   ArrayMaxSize,
+  ValidateNested,
 } from "class-validator";
+import { FieldValuesOptionDto } from "src/user/dto/user-create.dto";
 
 export class BulkCohortMember {
   @ApiProperty({
@@ -42,6 +45,18 @@ export class BulkCohortMember {
   @ArrayMaxSize(1000)
   removeCohortId: string[];
 
+
+  @ApiProperty({
+    type: [FieldValuesOptionDto],
+    description: "Array of Custom fields",
+  })
+  @Expose()
+  @IsOptional()
+  @ValidateNested({ each: true })
+  @Type(() => FieldValuesOptionDto)
+  customFields?: FieldValuesOptionDto[];
+
+
   constructor(obj: any) {
     Object.assign(this, obj);
   }