구독 스페이스 새 포스트 알림 (#2749)

Author: robin-maki

apps/website/src/lib/enums.ts

@@ -238,6 +238,7 @@ export const UserNotificationCategory = {
   COMMENT: 'COMMENT',
   DONATE: 'DONATE',
   EMOJI_REACTION: 'EMOJI_REACTION',
+  NEW_POST: 'NEW_POST',
   PURCHASE: 'PURCHASE',
   REPLY: 'REPLY',
   SUBSCRIBE: 'SUBSCRIBE',

apps/website/src/lib/notification/maker/new-post.ts

@@ -0,0 +1,60 @@
+import { and, eq } from 'drizzle-orm';
+import { database, PostRevisions, Posts, Profiles, SpaceFollows, SpaceMembers, Spaces } from '$lib/server/database';
+import { createNotification, useFirstRow } from '$lib/server/utils';
+import type { NotificationMaker } from './type';
+
+export const SpaceNewPostNotificationMaker: NotificationMaker = async (postId: string) => {
+  const post = await database
+    .select({
+      permalink: Posts.permalink,
+      title: PostRevisions.title,
+      userId: Posts.userId,
+      memberProfileId: SpaceMembers.profileId,
+      memberProfileName: Profiles.name,
+      spaceId: Spaces.id,
+      spaceSlug: Spaces.slug,
+      spaceName: Spaces.name,
+    })
+    .from(Posts)
+    .innerJoin(Spaces, eq(Posts.spaceId, Spaces.id))
+    .innerJoin(PostRevisions, eq(Posts.publishedRevisionId, PostRevisions.id))
+    .innerJoin(
+      SpaceMembers,
+      and(
+        eq(SpaceMembers.spaceId, Posts.spaceId),
+        eq(SpaceMembers.userId, Posts.userId),
+        eq(SpaceMembers.state, 'ACTIVE'),
+      ),
+    )
+    .innerJoin(Profiles, eq(SpaceMembers.profileId, Profiles.id))
+    .where(and(eq(Posts.id, postId), eq(Posts.state, 'PUBLISHED'), eq(Posts.visibility, 'PUBLIC')))
+    .then(useFirstRow);
+
+  if (!post) {
+    return;
+  }
+
+  const followerIds = await database
+    .select({
+      userId: SpaceFollows.userId,
+    })
+    .from(SpaceFollows)
+    .where(and(eq(SpaceFollows.spaceId, post.spaceId)))
+    .then((rows) => rows.map((row) => row.userId));
+
+  await Promise.all(
+    followerIds.map(async (userId) => {
+      await createNotification({
+        userId,
+        category: 'NEW_POST',
+        actorId: post.memberProfileId,
+        data: {
+          postId,
+        },
+        pushTitle: post.spaceName,
+        pushBody: `${post.title} 글이 올라왔어요.`,
+        pushPath: `/${post.spaceSlug}/${post.permalink}`,
+      });
+    }),
+  );
+};

apps/website/src/lib/server/graphql/schemas/notification.ts

@@ -36,6 +36,7 @@ IUserNotification.implement({
       .with('SUBSCRIBE', () => 'SubscribeNotification')
       .with('COMMENT', () => 'CommentNotification')
       .with('EMOJI_REACTION', () => 'EmojiReactionNotification')
+      .with('NEW_POST', () => 'NewPostNotification')
       .run(),
 });
 
@@ -131,6 +132,20 @@ EmojiReactionNotification.implement({
   }),
 });
 
+export const NewPostNotification = createObjectRef('NewPostNotification', UserNotifications);
+NewPostNotification.implement({
+  interfaces: [IUserNotification],
+  fields: (t) => ({
+    post: t.field({
+      type: Post,
+      resolve: async (notification) => {
+        const data = notification.data as { postId: string };
+        return data.postId;
+      },
+    }),
+  }),
+});
+
 /**
  * * Inputs
  */

apps/website/src/lib/server/rest/routes/notification.ts

@@ -71,6 +71,19 @@ notification.get('/notification/:notificationId', async (request) => {
 
           return `/${posts[0].space.slug}/${posts[0].permalink}`;
         })
+        .with({ category: 'NEW_POST' }, async ({ data }) => {
+          const posts = await database
+            .select({ permalink: Posts.permalink, space: { slug: Spaces.slug } })
+            .from(Posts)
+            .innerJoin(Spaces, eq(Spaces.id, Posts.spaceId))
+            .where(eq(Posts.id, data.postId));
+
+          if (posts.length === 0) {
+            return `/404`;
+          }
+
+          return `/${posts[0].space.slug}/${posts[0].permalink}`;
+        })
         .exhaustive(),
     },
   });

apps/website/src/lib/utils/notification.ts

@@ -31,11 +31,20 @@ type EmojiReactionNotification = {
   };
 };
 
+type NewPostNotification = {
+  category: 'NEW_POST';
+  actorId: string;
+  data: {
+    postId: string;
+  };
+};
+
 export type Notification = (
   | PurchaseNotification
   | SubscribeNotification
   | CommentNotification
   | EmojiReactionNotification
+  | NewPostNotification
 ) & {
   userId: string;
 };