웹/앱 푸시 알림 기능 추가

.gitignore

@@ -3,3 +3,6 @@ node_modules
 # env files (can opt-in for committing if needed)
 .env*
 !.env.example
+
+# Firebase Admin SDK 서비스 계정 키 (절대 커밋 금지)
+*firebase-adminsdk*.json

backend/.env.example

@@ -62,3 +62,8 @@ AWS_REQUEST_CHECKSUM_CALCULATION=WHEN_REQUIRED # B2는 WHEN_REQUIRED로 설정
 ADMIN_KEY="random string for admin notice"
 # backend/.env.docker.example
 # be, fe를 도커 컨테이너로 띄울 때는 서비스명으로 설정합니다.
+
+# =================
+# Firebase Admin SDK (FCM 푸시 알림 발송)
+# =================
+FIREBASE_SERVICE_ACCOUNT_PATH=./firebase-adminsdk.json

backend/migrations/1783344174180-CreateFcmToken-migration.ts

@@ -0,0 +1,29 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class CreateFcmTokenMigration1783344174180 implements MigrationInterface {
+  name = 'CreateFcmTokenMigration1783344174180';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `CREATE TABLE "fcm_tokens" (
+        "id" uuid NOT NULL DEFAULT uuid_generate_v4(),
+        "user_id" uuid NOT NULL,
+        "token" text NOT NULL,
+        "platform" character varying(10) NOT NULL,
+        "created_at" TIMESTAMP NOT NULL DEFAULT now(),
+        "updated_at" TIMESTAMP NOT NULL DEFAULT now(),
+        CONSTRAINT "PK_fcm_tokens" PRIMARY KEY ("id")
+      )`,
+    );
+    await queryRunner.query(
+      `CREATE INDEX "IDX_fcm_tokens_user_id_platform" ON "fcm_tokens" ("user_id", "platform")`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `DROP INDEX "public"."IDX_fcm_tokens_user_id_platform"`,
+    );
+    await queryRunner.query(`DROP TABLE "fcm_tokens"`);
+  }
+}

backend/migrations/1783348447838-AddFcmTokenUniqueConstraint-migration.ts

@@ -0,0 +1,23 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddFcmTokenUniqueConstraint1783348447838 implements MigrationInterface {
+  name = 'AddFcmTokenUniqueConstraint1783348447838';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `DROP INDEX IF EXISTS "public"."IDX_fcm_tokens_user_id_platform"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "fcm_tokens" ADD CONSTRAINT "UQ_fcm_tokens_user_id_platform" UNIQUE ("user_id", "platform")`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "fcm_tokens" DROP CONSTRAINT "UQ_fcm_tokens_user_id_platform"`,
+    );
+    await queryRunner.query(
+      `CREATE INDEX "IDX_fcm_tokens_user_id_platform" ON "fcm_tokens" ("user_id", "platform")`,
+    );
+  }
+}

backend/migrations/1783398050652-AddGroupMemberNotificationMuted-migration.ts

@@ -0,0 +1,17 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddGroupMemberNotificationMuted1783398050652 implements MigrationInterface {
+  name = 'AddGroupMemberNotificationMuted1783398050652';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "group_members" ADD COLUMN IF NOT EXISTS "notification_muted" BOOLEAN NOT NULL DEFAULT FALSE`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "group_members" DROP COLUMN IF EXISTS "notification_muted"`,
+    );
+  }
+}

backend/package.json

@@ -52,6 +52,7 @@
     "class-validator": "^0.14.3",
     "cookie-parser": "^1.4.7",
     "dotenv": "^17.2.3",
+    "firebase-admin": "^14.1.0",
     "logform": "^2.7.0",
     "luxon": "^3.7.2",
     "nest-winston": "^1.10.2",

backend/src/app.module.ts

@@ -21,6 +21,7 @@ import { MediaModule } from './modules/media/media.module';
 import { TrashModule } from './modules/trash/trash.module';
 import { AnnouncementModule } from './modules/announcement/announcement.module';
 import { InquiryModule } from './modules/inquiry/inquiry.module';
+import { NotificationModule } from './modules/notification/notification.module';
 
 @Module({
   imports: [
@@ -51,6 +52,7 @@ import { InquiryModule } from './modules/inquiry/inquiry.module';
     TrashModule,
     AnnouncementModule,
     InquiryModule,
+    NotificationModule,
   ],
   controllers: [AppController],
   providers: [AppService],

backend/src/modules/group/controller/group-management.controller.ts

@@ -189,6 +189,38 @@ export class GroupManagementController {
     return this.groupManagementService.getGroupPermission(user.sub, groupId);
   }
 
+  @Patch(':groupId/members/me/read')
+  @ApiOperation({
+    summary: '그룹 읽음 처리',
+    description: '그룹 페이지 진입 시 lastReadAt을 현재 시간으로 갱신합니다.',
+  })
+  @ApiParam({ name: 'groupId', description: '그룹 ID' })
+  async markGroupAsRead(
+    @User() user: MyJwtPayload,
+    @Param('groupId') groupId: string,
+  ): Promise<void> {
+    await this.groupManagementService.markGroupAsRead(user.sub, groupId);
+  }
+
+  @Patch(':groupId/members/me/notification')
+  @ApiOperation({
+    summary: '그룹 알림 설정 토글',
+    description:
+      '권한에 관계없이 모든 멤버가 해당 그룹의 알림을 켜고 끌 수 있습니다.',
+  })
+  @ApiParam({ name: 'groupId', description: '그룹 ID' })
+  async toggleGroupNotification(
+    @User() user: MyJwtPayload,
+    @Param('groupId') groupId: string,
+    @Body('muted') muted: boolean,
+  ): Promise<void> {
+    await this.groupManagementService.toggleGroupNotification(
+      user.sub,
+      groupId,
+      muted,
+    );
+  }
+
   @UseGuards(GroupRoleGuard)
   @GroupRoles(GroupRoleEnum.VIEWER)
   @Patch(':groupId/members/me')

backend/src/modules/group/dto/get-group-permission.dto.ts

@@ -3,5 +3,8 @@ import { GroupRoleEnum } from '@/enums/group-role.enum';
 
 export class GetGroupPermissionResponseDto {
   @ApiProperty({ enum: GroupRoleEnum })
-  role: GroupRoleEnum;
+  role!: GroupRoleEnum;
+
+  @ApiProperty()
+  notificationMuted!: boolean;
 }

backend/src/modules/group/dto/get-groups.dto.ts

@@ -64,6 +64,12 @@ export class GroupItemDto {
 
   @ApiProperty({ description: '내 권한', enum: GroupRoleEnum, nullable: true })
   permission: GroupRoleEnum | null;
+
+  @ApiProperty({ description: '알림 음소거 여부' })
+  notificationMuted: boolean;
+
+  @ApiProperty({ description: '읽지 않은 활동 여부' })
+  hasUnread: boolean;
 }
 
 export class GetGroupsResponseDto {

backend/src/modules/group/entity/group_member.entity.ts

@@ -65,6 +65,9 @@ export class GroupMember {
   @JoinColumn({ name: 'profile_media_id' })
   profileMedia?: MediaAsset | null;
 
+  @Column({ name: 'notification_muted', type: 'boolean', default: false })
+  notificationMuted: boolean;
+
   @Column({ name: 'last_read_at', type: 'timestamptz', nullable: true })
   lastReadAt?: Date | null;
 

backend/src/modules/group/group.module.ts

@@ -30,6 +30,7 @@ import { GroupActivityActor } from './entity/group-activity-actor.entity';
 import { AuthModule } from '../auth/auth.module';
 import { PostModule } from '../post/post.module';
 import { MediaModule } from '../media/media.module';
+import { NotificationModule } from '../notification/notification.module';
 
 @Module({
   imports: [
@@ -49,6 +50,7 @@ import { MediaModule } from '../media/media.module';
     AuthModule,
     forwardRef(() => PostModule),
     MediaModule,
+    NotificationModule,
   ],
   providers: [
     GroupService,

backend/src/modules/group/service/group-activity.service.ts

@@ -1,6 +1,6 @@
-import { Injectable } from '@nestjs/common';
+import { Injectable, Logger } from '@nestjs/common';
 import { InjectRepository } from '@nestjs/typeorm';
-import { In, Repository, SelectQueryBuilder, Brackets } from 'typeorm';
+import { In, Not, Repository, SelectQueryBuilder, Brackets } from 'typeorm';
 
 import { GroupActivityLog } from '../entity/group-activity-log.entity';
 import { GroupActivityActor } from '../entity/group-activity-actor.entity';
@@ -11,6 +11,7 @@ import {
   GroupActivityItemDto,
   PaginatedGroupActivityResponseDto,
 } from '../dto/group-activity.dto';
+import { NotificationService } from '@/modules/notification/notification.service';
 
 type RecordActivityInput = {
   groupId: string;
@@ -20,15 +21,69 @@ type RecordActivityInput = {
   meta?: Record<string, unknown> | null;
 };
 
+function buildActivityNotification(
+  actorName: string,
+  type: GroupActivityType,
+  meta?: Record<string, unknown> | null,
+): { title: string; body: string } | null {
+  const postTitle = ((meta?.title ?? meta?.afterTitle ?? '') as string) || '';
+  const titlePart = postTitle ? ` "${postTitle}"` : '';
+
+  switch (type) {
+    case GroupActivityType.POST_CREATE:
+      return {
+        title: '새 기록',
+        body: `${actorName}님이 새 기록${titlePart}을(를) 작성했습니다.`,
+      };
+    case GroupActivityType.POST_COLLAB_COMPLETE:
+    case GroupActivityType.POST_EDIT_COMPLETE:
+    case GroupActivityType.POST_UPDATE:
+      return {
+        title: '기록 수정',
+        body: `${actorName}님이${titlePart} 기록을 수정했습니다.`,
+      };
+    case GroupActivityType.POST_DELETE:
+      return {
+        title: '기록 삭제',
+        body: `${actorName}님이${titlePart} 기록을 삭제했습니다.`,
+      };
+    case GroupActivityType.MEMBER_JOIN:
+      return {
+        title: '새 멤버',
+        body: `${actorName}님이 그룹에 참여했습니다.`,
+      };
+    case GroupActivityType.MEMBER_LEAVE:
+      return {
+        title: '멤버 탈퇴',
+        body: `${actorName}님이 그룹에서 나갔습니다.`,
+      };
+    case GroupActivityType.MEMBER_REMOVE:
+      return {
+        title: '멤버 내보내기',
+        body: '그룹에서 멤버가 내보내졌습니다.',
+      };
+    case GroupActivityType.GROUP_NAME_UPDATE:
+      return {
+        title: '그룹 이름 변경',
+        body: `그룹 이름이 "${meta?.afterName as string}"(으)로 변경되었습니다.`,
+      };
+    default:
+      return null;
+  }
+}
+
 @Injectable()
 export class GroupActivityService {
+  private readonly logger = new Logger(GroupActivityService.name);
+
   constructor(
     @InjectRepository(GroupActivityLog)
     private readonly logRepo: Repository<GroupActivityLog>,
     @InjectRepository(GroupActivityActor)
     private readonly actorRepo: Repository<GroupActivityActor>,
     @InjectRepository(GroupMember)
     private readonly groupMemberRepo: Repository<GroupMember>,
+    private readonly notificationService: NotificationService,
   ) {}
 
   async recordActivity(input: RecordActivityInput): Promise<void> {
@@ -58,6 +113,63 @@ export class GroupActivityService {
         await actorRepo.save(actors);
       }
     });
+
+    void this.dispatchNotification(input, actorIds).catch((e) =>
+      this.logger.warn('푸시 알림 전송 실패', e),
+    );
+  }
+
+  private async dispatchNotification(
+    input: RecordActivityInput,
+    actorIds: string[],
+  ): Promise<void> {
+    const actorMembers =
+      actorIds.length > 0
+        ? await this.groupMemberRepo.find({
+            where: { groupId: input.groupId, userId: In(actorIds) },
+            relations: { user: true },
+          })
+        : [];
+
+    const first = actorMembers[0];
+    const baseName = first?.nicknameInGroup ?? first?.user?.nickname ?? '멤버';
+    const extraCount = actorIds.length - 1;
+    const actorDisplayName =
+      extraCount > 0 ? `${baseName} 외 ${extraCount}명` : baseName;
+
+    const notification = buildActivityNotification(
+      actorDisplayName,
+      input.type,
+      input.meta,
+    );
+    if (!notification) return;
+
+    const recipients = await this.groupMemberRepo.find({
+      where:
+        actorIds.length > 0
+          ? {
+              groupId: input.groupId,
+              userId: Not(In(actorIds)),
+              notificationMuted: false,
+            }
+          : { groupId: input.groupId, notificationMuted: false },
+      select: ['userId'],
+    });
+
+    const recipientIds = recipients.map((m) => m.userId);
+    if (recipientIds.length === 0) return;
+
+    const hasPost = input.refId && input.type !== GroupActivityType.POST_DELETE;
+
+    await this.notificationService.sendToUsers(
+      recipientIds,
+      notification.title,
+      notification.body,
+      {
+        groupId: input.groupId,
+        ...(hasPost ? { postId: input.refId as string } : {}),
+      },
+    );
   }
 
   async getGroupActivities(

backend/src/modules/group/service/group-management.service.ts

@@ -598,9 +598,36 @@ export class GroupManagementService {
     groupId: string,
   ): Promise<GetGroupPermissionResponseDto> {
     const member = await this.groupService.ensureMember(userId, groupId, {
-      select: { role: true },
+      select: { role: true, notificationMuted: true },
     });
-    return { role: member.role };
+    return {
+      role: member.role,
+      notificationMuted: Boolean(member.notificationMuted),
+    };
+  }
+
+  async toggleGroupNotification(
+    userId: string,
+    groupId: string,
+    muted: boolean,
+  ): Promise<void> {
+    await this.groupService.ensureMember(userId, groupId, {
+      select: { id: true },
+    });
+    await this.groupMemberRepo.update(
+      { userId, groupId },
+      { notificationMuted: muted },
+    );
+  }
+
+  async markGroupAsRead(userId: string, groupId: string): Promise<void> {
+    await this.groupService.ensureMember(userId, groupId, {
+      select: { id: true },
+    });
+    await this.groupMemberRepo.update(
+      { userId, groupId },
+      { lastReadAt: new Date() },
+    );
   }
 
   /** 그룹 내 내 설정 정보 수정 */