feat: add optional parameter channelName to grabReddit method

Author: Ni-2

apps/aigency-backend/src/grabbers/reddit/reddit.controller.ts

@@ -11,8 +11,12 @@ import { AllRpcExceptionsFilter } from 'src/common/all-rpc-exceptions.filter';
 export class RedditController {
   constructor(private redditService: RedditService) {}
 
-  @ZodToOpenRPC({ params: z.object({}) })
-  public grabReddits() {
-    return this.redditService.grabReddits();
+  @ZodToOpenRPC({
+    params: z.object({
+      channelName: z.string().optional(),
+    }),
+  })
+  public grabReddits(params: { channelName?: string }) {
+    return this.redditService.grabReddits(params.channelName);
   }
 }

apps/aigency-backend/src/grabbers/reddit/reddit.service.ts

@@ -90,7 +90,7 @@ export class RedditService {
     }
   }
 
-  async grabReddits() {
+  async grabReddits(channelName?: string) {
     try {
       const activeSubscriptions =
         await this.subscriptionService.getSubscriptions({
@@ -99,22 +99,25 @@ export class RedditService {
           offset: 0,
           onlyActive: true,
         });
-      if (!activeSubscriptions || !activeSubscriptions.total) return;
+      if (!channelName && (!activeSubscriptions || !activeSubscriptions.total))
+        return;
 
       const usersWithActiveFinders =
         await this.finderService.getActiveFinders();
 
-      const uniqueReddits = Array.from(
-        new Set(
-          activeSubscriptions.items
-            .filter(
-              (item) =>
-                !item.isByFinder ||
-                usersWithActiveFinders.includes(item.userId),
-            )
-            .map((sub) => sub.link),
-        ),
-      );
+      const uniqueReddits = channelName
+        ? [channelName]
+        : Array.from(
+            new Set(
+              activeSubscriptions.items
+                .filter(
+                  (item) =>
+                    !item.isByFinder ||
+                    usersWithActiveFinders.includes(item.userId),
+                )
+                .map((sub) => sub.link),
+            ),
+          );
       // console.log('uniqueReddits', uniqueReddits);
 
       const submissionXmls = await Promise.allSettled(

apps/aigency-backend/src/subscription/subscription.service.ts

@@ -62,16 +62,18 @@ export class SubscriptionService {
 
     // ToDo: hardcoded subscription checks. Move to service?
     let channelName: string | null | undefined = null;
+    let messages: any[] | null | undefined = null;
     if (source === 'telegram') {
-      const messages =
-        await this.telegramService.getTelegramChannelMessages(link);
-      console.log(messages);
-      if (messages?.length) channelName = messages[0].source;
+      messages = await this.telegramService.getTelegramChannelMessages(link);
+      // console.log(messages);
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment, @typescript-eslint/no-unsafe-member-access
+      if (messages?.length) channelName = messages[0].source!;
     } else if (source === 'reddit') {
-      const messages = await this.redditService.getRedditChannelMessages(link);
-      console.log(messages);
+      messages = await this.redditService.getRedditChannelMessages(link);
+      // console.log(messages);
       if (messages?.length) {
-        channelName = messages[0].category._attributes.label;
+        // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment, @typescript-eslint/no-unsafe-member-access
+        channelName = messages[0].category._attributes.label!;
       }
     }
 
@@ -94,6 +96,7 @@ export class SubscriptionService {
       lastSeenPostTimestamp: subscription.lastSeenPostTimestamp,
       isByFinder: subscription.isByFinder,
       evaluations: subscription.evaluations,
+      messages,
     };
   }