support multiple search

src/hami-fetcher/hami-fetcher.service.ts

@@ -4,15 +4,16 @@ import { TwintData, TwintReturn } from '../dto/hami.dto';
 import { ConfigService } from '@nestjs/config';
 import { lastValueFrom } from 'rxjs';
 import { AxiosRequestConfig } from 'axios';
+import _ from 'lodash';
 
 @Injectable()
 export class HamiFetcherService extends ConsoleLogger {
   private readonly twintUrl: string = this.config.get('twintUrl');
   private readonly twintToken: string = this.config.get('twintToken');
   private readonly hamiUsername: string = this.config.get('hamiUsername');
-  private readonly hamiBlacklistSearch: string = this.config.get(
-    'hamiBlacklistSearch',
-  );
+  private readonly hamiBlacklistSearches: string[] = this.config
+    .get('hamiBlacklistSearch')
+    ?.split(',');
   constructor(private http: HttpService, private config: ConfigService) {
     super('HamiFetcherService');
   }
@@ -27,14 +28,17 @@ export class HamiFetcherService extends ConsoleLogger {
     };
   }
 
-  async fetchBlacklist(Since?: string): Promise<TwintData[]> {
+  async fetchBlacklistSingle(
+    Search: string,
+    Since?: string,
+  ): Promise<TwintData[]> {
     try {
       const { data } = await lastValueFrom(
         this.http.post<TwintReturn>(
           `${this.twintUrl}/Search`,
           {
             Username: this.hamiUsername,
-            Search: this.hamiBlacklistSearch,
+            Search,
             Since,
           },
           this.axiosConfig(),
@@ -46,4 +50,17 @@ export class HamiFetcherService extends ConsoleLogger {
       return [];
     }
   }
+
+  async fetchBlacklist(Since?: string): Promise<TwintData[]> {
+    return _.uniqBy(
+      _.flatten(
+        await Promise.all(
+          this.hamiBlacklistSearches.map((search) =>
+            this.fetchBlacklistSingle(search, Since),
+          ),
+        ),
+      ),
+      (tweet) => tweet.id_str,
+    );
+  }
 }