feat: notify users who have favorited a post

closes #199
drodil · Feb 25, 2025 · 38bb945 · 38bb945
1 parent fdbd240
commit 38bb945
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 4 deletions.
diff --git a/plugins/qeta-backend/src/database/DatabaseQetaStore.ts b/plugins/qeta-backend/src/database/DatabaseQetaStore.ts
@@ -933,6 +933,12 @@ export class DatabaseQetaStore implements QetaStore {
       .delete());
   }
 
+  async getUsersWhoFavoritedPost(postId: number): Promise<string[]> {
+    const query = this.db('user_favorite').where('postId', '=', postId);
+    const users = await query.select('user');
+    return users.map(u => u.user);
+  }
+
   async deleteAnswerVote(user_ref: string, answerId: number): Promise<boolean> {
     return !!(await this.db('answer_votes')
       .where('author', '=', user_ref)

diff --git a/plugins/qeta-backend/src/database/QetaStore.ts b/plugins/qeta-backend/src/database/QetaStore.ts
@@ -362,16 +362,18 @@ export interface QetaStore {
   /**
    * Mark question favorite for user
    * @param user_ref user name of the user voting question
-   * @param questionId question id
+   * @param postId post id
    */
-  favoritePost(user_ref: string, questionId: number): Promise<boolean>;
+  favoritePost(user_ref: string, postId: number): Promise<boolean>;
 
   /**
    * Mark question unfavorite for user
    * @param user_ref user name of the user voting question
-   * @param questionId question id
+   * @param postId post id
    */
-  unfavoritePost(user_ref: string, questionId: number): Promise<boolean>;
+  unfavoritePost(user_ref: string, postId: number): Promise<boolean>;
+
+  getUsersWhoFavoritedPost(postId: number): Promise<string[]>;
 
   /**
    * Returns all used tags for posts

diff --git a/plugins/qeta-backend/src/service/routes/answers.ts b/plugins/qeta-backend/src/service/routes/answers.ts
@@ -178,6 +178,7 @@ export const answersRoutes = (router: Router, options: RouteOptions) => {
         database.getUsersForTags(post.tags),
         database.getUsersForEntities(post.entities),
         database.getFollowingUsers(username),
+        database.getUsersWhoFavoritedPost(post.id),
       ]);
       const sent = await notificationMgr.onNewAnswer(
         username,
@@ -329,6 +330,7 @@ export const answersRoutes = (router: Router, options: RouteOptions) => {
           database.getUsersForTags(post.tags),
           database.getUsersForEntities(post.entities),
           database.getFollowingUsers(username),
+          database.getUsersWhoFavoritedPost(post.id),
         ]);
         const sent = await notificationMgr.onAnswerComment(
           username,

diff --git a/plugins/qeta-backend/src/service/routes/posts.ts b/plugins/qeta-backend/src/service/routes/posts.ts
@@ -320,6 +320,7 @@ export const postsRoutes = (router: Router, options: RouteOptions) => {
         database.getUsersForTags(post.tags),
         database.getUsersForEntities(post.entities),
         database.getFollowingUsers(username),
+        database.getUsersWhoFavoritedPost(post.id),
       ]);
       const sent = await notificationMgr.onNewPostComment(
         username,
@@ -451,6 +452,7 @@ export const postsRoutes = (router: Router, options: RouteOptions) => {
         database.getUsersForTags(tags),
         database.getUsersForEntities(entities),
         database.getFollowingUsers(username),
+        database.getUsersWhoFavoritedPost(post.id),
       ]);
       const sent = await notificationMgr.onNewPost(
         username,