diff --git a/packages/web/src/app/api/board/[id]/comments/route.ts b/packages/web/src/app/api/board/[id]/comments/route.ts
index 94227c5..aa2e323 100644
--- a/packages/web/src/app/api/board/[id]/comments/route.ts
+++ b/packages/web/src/app/api/board/[id]/comments/route.ts
@@ -6,6 +6,7 @@ import { getBoardAuth } from '@/lib/board-auth';
import { errorResponse, Errors, successResponse } from '@/lib/api-error';
import { grantWebScore } from '@/lib/score';
import { sanitizeDescription } from '@/lib/sanitize';
+import { sendPushToMember } from '@/lib/push';
const { boardPosts, boardComments, ActivityScoreType } = sharedDb;
@@ -35,8 +36,9 @@ export async function POST(request: NextRequest, { params }: { params: Promise<{
}
// Validate parentId + secret comment reply restrictions
+ let parent: { id: string; memberId: string; isSecret: boolean } | null = null;
if (parentId) {
- const [parent] = await database
+ const [parentData] = await database
.select({
id: boardComments.id,
memberId: boardComments.memberId,
@@ -46,10 +48,11 @@ export async function POST(request: NextRequest, { params }: { params: Promise<{
.where(and(eq(boardComments.id, parentId), eq(boardComments.postId, postId)))
.limit(1);
- if (!parent) return Errors.badRequest('상위 댓글을 찾을 수 없습니다.').toResponse();
+ if (!parentData) return Errors.badRequest('상위 댓글을 찾을 수 없습니다.').toResponse();
+ parent = parentData as { id: string; memberId: string; isSecret: boolean };
// 비밀댓글 답글: 댓글 작성자/글 작성자/관리자만 가능
- if (parent.isSecret) {
+ if (parent && parent.isSecret) {
const isCommentOwner = parent.memberId === auth.memberId;
const isPostAuthor = post.memberId === auth.memberId;
if (!isCommentOwner && !isPostAuthor && !auth.isAdmin) {
@@ -73,6 +76,10 @@ export async function POST(request: NextRequest, { params }: { params: Promise<{
})
.returning();
+ if (!newComment) {
+ return Errors.externalServiceError('댓글 생성에 실패했습니다.').toResponse();
+ }
+
// Increment comment_count
await database
.update(boardPosts)
@@ -88,6 +95,34 @@ export async function POST(request: NextRequest, { params }: { params: Promise<{
).catch((err) => console.error('[score] grantWebScore failed:', err));
}
+ // 1. 내가 쓴 글에 댓글이 달리면 무조건 알림 (본인 제외)
+ if (post.memberId !== auth.memberId) {
+ const postIdentifier = postId;
+ sendPushToMember(post.memberId, {
+ title: '새 댓글이 달렸습니다',
+ body: `${content.trim().slice(0, 50)}${content.length > 50 ? '...' : ''}`,
+ clickUrl: `/board/${postIdentifier}`,
+ data: { type: 'board_comment', postId: postIdentifier, commentId: newComment.id },
+ }).catch((err) => console.error('[push] Comment notification failed:', err));
+ }
+
+ // 2. 대댓글의 경우 원댓글 작성자에게도 알림
+ if (parentId && parent) {
+ const pmid = parent.memberId;
+ const amid = auth.memberId;
+
+ // 내 댓글에 답글이 달리면 알림 (작성자 본인 제외)
+ if (pmid !== amid) {
+ const postIdentifier = postId;
+ sendPushToMember(pmid, {
+ title: '💬 답글이 달렸습니다',
+ body: `${content.trim().slice(0, 50)}${content.length > 50 ? '...' : ''}`,
+ clickUrl: `/board/${postIdentifier}`,
+ data: { type: 'board_reply', postId: postIdentifier, commentId: newComment.id },
+ }).catch((err) => console.error('[push] Reply notification failed:', err));
+ }
+ }
+
return successResponse(newComment, '댓글이 작성되었습니다.', 201);
} catch (error) {
return errorResponse(error);
diff --git a/packages/web/src/app/api/board/route.ts b/packages/web/src/app/api/board/route.ts
index a00e4d3..11fb158 100644
--- a/packages/web/src/app/api/board/route.ts
+++ b/packages/web/src/app/api/board/route.ts
@@ -14,8 +14,9 @@ import { getAdminDiscordIds } from '@/lib/admin';
import { isValidCategory } from '@/lib/board-config';
import { sanitizeDescription, sanitizeTiptapContent } from '@/lib/sanitize';
import { grantWebScore } from '@/lib/score';
+import { sendPushToMembers } from '@/lib/push';
-const { boardPosts, members, boardPolls, boardPollOptions, ActivityScoreType } = sharedDb;
+const { boardPosts, members, boardPolls, boardPollOptions, ActivityScoreType, MemberStatus } = sharedDb;
export async function GET(request: NextRequest) {
try {
@@ -257,6 +258,24 @@ export async function POST(request: NextRequest) {
sanitizeDescription(title.trim().slice(0, 50))
).catch((err) => console.error('[score] grantWebScore failed:', err));
+ // 공지사항인 경우 활성 멤버 전체에게 알림
+ if (category === 'notice') {
+ const activeMembers = await database
+ .select({ id: members.id })
+ .from(members)
+ .where(eq(members.status, MemberStatus.ACTIVE));
+
+ sendPushToMembers(
+ activeMembers.map((m) => m.id),
+ {
+ title: '📢 새 공지사항',
+ body: title.trim(),
+ clickUrl: `/board/${result.id}`,
+ data: { type: 'board_notice', postId: result.id },
+ }
+ ).catch((err) => console.error('[push] Notice notification failed:', err));
+ }
+
return successResponse(result, '게시글이 작성되었습니다.', 201);
} catch (error) {
return errorResponse(error);
diff --git a/packages/web/src/app/api/notification-preferences/route.ts b/packages/web/src/app/api/notification-preferences/route.ts
new file mode 100644
index 0000000..350f2e8
--- /dev/null
+++ b/packages/web/src/app/api/notification-preferences/route.ts
@@ -0,0 +1,78 @@
+import { NextRequest } from 'next/server';
+import { eq } from 'drizzle-orm';
+import { getDb } from '@/lib/db';
+import { db as sharedDb } from '@blog-study/shared';
+import { getBoardAuth } from '@/lib/board-auth';
+import { errorResponse, Errors, successResponse } from '@/lib/api-error';
+
+const { notificationPreferences, NotificationType } = sharedDb;
+
+/**
+ * GET /api/notification-preferences
+ * 알림 설정 조회
+ */
+export async function GET(_request: NextRequest) {
+ try {
+ const auth = await getBoardAuth();
+ if (!auth) return Errors.unauthorized().toResponse();
+
+ const database = getDb();
+
+ // 모든 알림 타입에 대한 설정 조회 (없으면 기본값 true로 생성)
+ const allTypes = Object.values(NotificationType);
+ const existing = await database
+ .select()
+ .from(notificationPreferences)
+ .where(eq(notificationPreferences.memberId, auth.memberId));
+
+ const existingMap = new Map(existing.map((e) => [e.type, e.enabled]));
+ const preferences = allTypes.map((type) => ({
+ type,
+ enabled: existingMap.get(type) ?? true,
+ }));
+
+ return successResponse(preferences);
+ } catch (error) {
+ return errorResponse(error);
+ }
+}
+
+/**
+ * PUT /api/notification-preferences
+ * 알림 설정 업데이트
+ */
+export async function PUT(request: NextRequest) {
+ try {
+ const auth = await getBoardAuth();
+ if (!auth) return Errors.unauthorized().toResponse();
+
+ const body = await request.json();
+ const { type, enabled } = body;
+
+ if (!type || typeof enabled !== 'boolean') {
+ return Errors.badRequest('type과 enabled 값을 모두 제공해주세요.').toResponse();
+ }
+
+ if (!Object.values(NotificationType).includes(type)) {
+ return Errors.badRequest('잘못된 알림 타입입니다.').toResponse();
+ }
+
+ const database = getDb();
+
+ await database
+ .insert(notificationPreferences)
+ .values({
+ memberId: auth.memberId,
+ type,
+ enabled,
+ })
+ .onConflictDoUpdate({
+ target: [notificationPreferences.memberId, notificationPreferences.type],
+ set: { enabled, updatedAt: new Date() },
+ });
+
+ return successResponse({ type, enabled }, '알림 설정이 저장되었습니다.');
+ } catch (error) {
+ return errorResponse(error);
+ }
+}
diff --git a/packages/web/src/app/api/posts/[id]/comments/route.ts b/packages/web/src/app/api/posts/[id]/comments/route.ts
index fa5d1d4..b29e3ff 100644
--- a/packages/web/src/app/api/posts/[id]/comments/route.ts
+++ b/packages/web/src/app/api/posts/[id]/comments/route.ts
@@ -7,6 +7,7 @@ import { getAdminDiscordIds } from '@/lib/admin';
import { errorResponse, Errors, successResponse } from '@/lib/api-error';
import { grantWebScore } from '@/lib/score';
import { sanitizeDescription } from '@/lib/sanitize';
+import { sendPushToMember } from '@/lib/push';
const { posts, postComments, members, ActivityScoreType } = sharedDb;
@@ -108,9 +109,10 @@ export async function POST(request: NextRequest, { params }: { params: Promise<{
}
// parentId 유효성 검증
+ let parent: { id: string; memberId: string } | null = null;
if (parentId) {
- const [parent] = await database
- .select({ id: postComments.id })
+ const [parentData] = await database
+ .select({ id: postComments.id, memberId: postComments.memberId })
.from(postComments)
.where(
and(
@@ -120,7 +122,8 @@ export async function POST(request: NextRequest, { params }: { params: Promise<{
)
)
.limit(1);
- if (!parent) return Errors.badRequest('상위 댓글을 찾을 수 없습니다.').toResponse();
+ if (!parentData) return Errors.badRequest('상위 댓글을 찾을 수 없습니다.').toResponse();
+ parent = parentData;
}
const [newComment] = await database
@@ -163,6 +166,32 @@ export async function POST(request: NextRequest, { params }: { params: Promise<{
}
}
+ // 1. 내가 쓴 포스트에 댓글이 달리면 무조건 알림 (본인 제외)
+ if (post.memberId !== auth.memberId) {
+ sendPushToMember(post.memberId, {
+ title: '새 댓글이 달렸습니다',
+ body: `${content.trim().slice(0, 50)}${content.length > 50 ? '...' : ''}`,
+ clickUrl: `/posts/${postId}`,
+ data: { type: 'post_comment', postId, commentId: newComment?.id ?? '' },
+ }).catch((err) => console.error('[push] Post comment notification failed:', err));
+ }
+
+ // 2. 대댓글의 경우 원댓글 작성자에게도 알림
+ if (parentId && parent) {
+ const pmid = parent.memberId;
+ const amid = auth.memberId;
+
+ // 내 댓글에 답글이 달리면 알림 (작성자 본인 제외)
+ if (pmid !== amid) {
+ sendPushToMember(pmid, {
+ title: '💬 답글이 달렸습니다',
+ body: `${content.trim().slice(0, 50)}${content.length > 50 ? '...' : ''}`,
+ clickUrl: `/posts/${postId}`,
+ data: { type: 'post_reply', postId, commentId: newComment?.id ?? '' },
+ }).catch((err) => console.error('[push] Post reply notification failed:', err));
+ }
+ }
+
return successResponse(newComment, '댓글이 작성되었습니다.', 201);
} catch (error) {
return errorResponse(error);
diff --git a/packages/web/src/app/api/push/subscribe/route.ts b/packages/web/src/app/api/push/subscribe/route.ts
new file mode 100644
index 0000000..dc1e86f
--- /dev/null
+++ b/packages/web/src/app/api/push/subscribe/route.ts
@@ -0,0 +1,51 @@
+import { NextRequest } from 'next/server';
+import { getDb } from '@/lib/db';
+import { db as sharedDb } from '@blog-study/shared';
+import { getBoardAuth } from '@/lib/board-auth';
+import { errorResponse, Errors, successResponse } from '@/lib/api-error';
+
+const { fcmTokens } = sharedDb;
+
+const MAX_TOKEN_LENGTH = 500;
+const MAX_DEVICE_INFO_LENGTH = 200;
+
+export async function POST(request: NextRequest) {
+ try {
+ const auth = await getBoardAuth();
+ if (!auth) return Errors.unauthorized().toResponse();
+
+ const { token, deviceInfo } = await request.json();
+
+ if (!token || typeof token !== 'string') {
+ return Errors.badRequest('FCM 토큰이 필요합니다.').toResponse();
+ }
+
+ if (token.length > MAX_TOKEN_LENGTH) {
+ return Errors.badRequest('FCM 토큰이 너무 깁니다.').toResponse();
+ }
+
+ const sanitizedDeviceInfo =
+ typeof deviceInfo === 'string' ? deviceInfo.slice(0, MAX_DEVICE_INFO_LENGTH) : null;
+
+ const database = getDb();
+
+ await database
+ .insert(fcmTokens)
+ .values({
+ memberId: auth.memberId,
+ token,
+ deviceInfo: sanitizedDeviceInfo,
+ })
+ .onConflictDoUpdate({
+ target: [fcmTokens.memberId, fcmTokens.token],
+ set: {
+ lastUsedAt: new Date(),
+ deviceInfo: sanitizedDeviceInfo,
+ },
+ });
+
+ return successResponse({ subscribed: true }, '알림이 구독되었습니다.');
+ } catch (error) {
+ return errorResponse(error);
+ }
+}
diff --git a/packages/web/src/app/api/push/test/route.ts b/packages/web/src/app/api/push/test/route.ts
new file mode 100644
index 0000000..534624f
--- /dev/null
+++ b/packages/web/src/app/api/push/test/route.ts
@@ -0,0 +1,71 @@
+import { NextRequest } from 'next/server';
+import { getBoardAuth } from '@/lib/board-auth';
+import { sendPushToMember } from '@/lib/push';
+import { errorResponse, Errors, successResponse } from '@/lib/api-error';
+
+const TEST_MESSAGES: Record
= {
+ board_comment: {
+ title: '💬 게시판 댓글 테스트',
+ body: '누군가 내 게시글에 댓글을 남겼습니다.',
+ },
+ board_reply: {
+ title: '↩️ 게시판 답글 테스트',
+ body: '누군가 내 댓글에 답글을 남겼습니다.',
+ },
+ post_comment: {
+ title: '📝 포스트 댓글 테스트',
+ body: '누군가 내 포스트에 댓글을 남겼습니다.',
+ },
+ post_reply: {
+ title: '↩️ 포스트 답글 테스트',
+ body: '누군가 내 포스트 댓글에 답글을 남겼습니다.',
+ },
+ board_notice: {
+ title: '📢 공지사항 테스트',
+ body: '새로운 공지사항이 게시되었습니다.',
+ },
+};
+
+// 유저별 레이트 리밋 (분당 5회)
+const rateLimitMap = new Map();
+const RATE_LIMIT_WINDOW = 60_000;
+const RATE_LIMIT_MAX = 5;
+
+function checkRateLimit(memberId: string): boolean {
+ const now = Date.now();
+ const timestamps = rateLimitMap.get(memberId) ?? [];
+ const recent = timestamps.filter((t) => now - t < RATE_LIMIT_WINDOW);
+ if (recent.length >= RATE_LIMIT_MAX) return false;
+ recent.push(now);
+ rateLimitMap.set(memberId, recent);
+ return true;
+}
+
+export async function POST(request: NextRequest) {
+ try {
+ const auth = await getBoardAuth();
+ if (!auth) return Errors.unauthorized().toResponse();
+
+ if (!checkRateLimit(auth.memberId)) {
+ return Errors.badRequest('테스트 알림은 1분에 5회까지 가능합니다.').toResponse();
+ }
+
+ const { type } = await request.json();
+
+ const message = TEST_MESSAGES[type];
+ if (!message) {
+ return Errors.badRequest('잘못된 알림 타입입니다.').toResponse();
+ }
+
+ const result = await sendPushToMember(auth.memberId, {
+ title: message.title,
+ body: message.body,
+ clickUrl: '/profile/notifications',
+ data: { type },
+ });
+
+ return successResponse(result, '테스트 알림이 전송되었습니다.');
+ } catch (error) {
+ return errorResponse(error);
+ }
+}
diff --git a/packages/web/src/app/api/push/unsubscribe/route.ts b/packages/web/src/app/api/push/unsubscribe/route.ts
new file mode 100644
index 0000000..1f4cae7
--- /dev/null
+++ b/packages/web/src/app/api/push/unsubscribe/route.ts
@@ -0,0 +1,36 @@
+import { NextRequest } from 'next/server';
+import { eq, and } from 'drizzle-orm';
+import { getDb } from '@/lib/db';
+import { db as sharedDb } from '@blog-study/shared';
+import { getBoardAuth } from '@/lib/board-auth';
+import { errorResponse, Errors, successResponse } from '@/lib/api-error';
+
+const { fcmTokens } = sharedDb;
+
+export async function POST(request: NextRequest) {
+ try {
+ const auth = await getBoardAuth();
+ if (!auth) return Errors.unauthorized().toResponse();
+
+ const { token } = await request.json();
+
+ if (!token) {
+ return Errors.badRequest('FCM 토큰이 필요합니다.').toResponse();
+ }
+
+ const database = getDb();
+
+ await database
+ .delete(fcmTokens)
+ .where(
+ and(
+ eq(fcmTokens.token, token),
+ eq(fcmTokens.memberId, auth.memberId)
+ )
+ );
+
+ return successResponse({ unsubscribed: true }, '구독이 취소되었습니다.');
+ } catch (error) {
+ return errorResponse(error);
+ }
+}
diff --git a/packages/web/src/components/settings/push-notification-settings.tsx b/packages/web/src/components/settings/push-notification-settings.tsx
new file mode 100644
index 0000000..735f398
--- /dev/null
+++ b/packages/web/src/components/settings/push-notification-settings.tsx
@@ -0,0 +1,216 @@
+'use client';
+
+import { useEffect, useState } from 'react';
+import { Bell, Megaphone, MessageCircle, MessageSquare, SendHorizonal } from 'lucide-react';
+import { Button } from '@/components/ui/button';
+import { Switch } from '@/components/ui/switch';
+import { toast } from 'sonner';
+import { usePushNotification } from '@/hooks/use-push-notification';
+
+interface NotificationPreference {
+ type: string;
+ enabled: boolean;
+}
+
+type IconComponent = React.ComponentType<{ className?: string }>;
+
+const NOTIFICATION_LABELS: Record<
+ string,
+ { label: string; icon: IconComponent; description: string }
+> = {
+ board_comment: {
+ label: '게시판 댓글',
+ icon: MessageSquare,
+ description: '내 게시글에 댓글이 달릴 때',
+ },
+ board_reply: {
+ label: '게시판 답글',
+ icon: MessageCircle,
+ description: '내 댓글에 답글이 달릴 때',
+ },
+ post_comment: {
+ label: '포스트 댓글',
+ icon: MessageSquare,
+ description: '내 포스트에 댓글이 달릴 때',
+ },
+ post_reply: {
+ label: '포스트 답글',
+ icon: MessageCircle,
+ description: '내 댓글에 답글이 달릴 때',
+ },
+ board_notice: { label: '공지사항', icon: Megaphone, description: '새 공지사항이 게시될 때' },
+};
+
+export function PushNotificationSettings() {
+ const { permission, token, requestPermission, unsubscribe, isSupported } = usePushNotification();
+ const [preferences, setPreferences] = useState([]);
+ const [loading, setLoading] = useState(true);
+ const [sendingTest, setSendingTest] = useState(null);
+
+ const handleTestPush = async (type: string) => {
+ setSendingTest(type);
+ try {
+ const res = await fetch('/api/push/test', {
+ method: 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body: JSON.stringify({ type }),
+ });
+ const data = await res.json();
+ if (!data.success) {
+ throw new Error(data.message || '테스트 알림 전송에 실패했습니다.');
+ }
+ if (data.data?.success > 0) {
+ toast.success('테스트 알림이 전송되었습니다.');
+ } else {
+ toast.error('알림 전송에 실패했습니다. Firebase 설정을 확인해주세요.');
+ }
+ } catch {
+ toast.error('테스트 알림 전송에 실패했습니다.');
+ } finally {
+ setSendingTest(null);
+ }
+ };
+
+ // 알림 설정 불러오기
+ useEffect(() => {
+ if (permission !== 'granted' || !token) {
+ setLoading(false);
+ return;
+ }
+
+ fetch('/api/notification-preferences')
+ .then((res) => res.json())
+ .then((data) => {
+ if (data.success) {
+ setPreferences(data.data);
+ }
+ })
+ .catch(() => {
+ toast.error('알림 설정을 불러오는데 실패했습니다.');
+ })
+ .finally(() => {
+ setLoading(false);
+ });
+ }, [permission, token]);
+
+ // 알림 토글
+ const handleToggle = async (type: string, enabled: boolean) => {
+ const snapshot = preferences;
+ setPreferences((current) => current.map((p) => (p.type === type ? { ...p, enabled } : p)));
+
+ try {
+ const res = await fetch('/api/notification-preferences', {
+ method: 'PUT',
+ headers: { 'Content-Type': 'application/json' },
+ body: JSON.stringify({ type, enabled }),
+ });
+
+ const data = await res.json();
+ if (!data.success) {
+ throw new Error(data.message || '설정 저장에 실패했습니다.');
+ }
+
+ toast.success(enabled ? '알림이 켜졌습니다.' : '알림이 꺼졌습니다.');
+ } catch {
+ setPreferences(snapshot);
+ toast.error('설정 저장에 실패했습니다. 다시 시도해주세요.');
+ }
+ };
+
+ if (!isSupported) {
+ return (
+ 이 브라우저는 알림을 지원하지 않습니다.
+ );
+ }
+
+ const isPushEnabled = permission === 'granted' && token;
+
+ return (
+
+ {/* 푸시 알림 켜기/끄기 */}
+
+
+
푸시 알림
+
+ {isPushEnabled
+ ? '브라우저 알림이 활성화되어 있습니다.'
+ : '중요한 알림을 실시간으로 받아보세요.'}
+
+
+
+
+
+ {/* 알림 타입별 설정 */}
+ {isPushEnabled && (
+
+
알림 종류
+
+ {loading ? (
+
+ 로딩 중…
+
+ ) : (
+
+ {preferences.map((pref) => {
+ const {
+ label,
+ icon: Icon,
+ description,
+ } = NOTIFICATION_LABELS[pref.type] || {
+ label: pref.type,
+ icon: Bell,
+ description: '',
+ };
+
+ return (
+
+
+
+
+
+
+
+ {label}
+
+
{description}
+
+
+
+
+ handleToggle(pref.type, checked)}
+ aria-labelledby={`label-${pref.type}`}
+ />
+
+
+ );
+ })}
+
+ )}
+
+ )}
+