query-repeat

thxprotocol · Jun 12, 2024 · 31bddec · 31bddec
1 parent 84f7e3b
commit 31bddec
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 1 deletion.
diff --git a/apps/api/src/app/controllers/pools/integrations/twitter/queries/post.controller.ts b/apps/api/src/app/controllers/pools/integrations/twitter/queries/post.controller.ts
@@ -5,7 +5,11 @@ import { TwitterQuery as TwitterQueryParser } from '@thxnetwork/common/twitter';
 import { BadRequestError } from '@thxnetwork/api/util/errors';
 import TwitterQueryService from '@thxnetwork/api/services/TwitterQueryService';
 
-const validation = [param('id').isMongoId(), body('operators').customSanitizer((ops) => TwitterQueryParser.parse(ops))];
+const validation = [
+    param('id').isMongoId(),
+    body('frequencyInHours').isInt(),
+    body('operators').customSanitizer((ops) => TwitterQueryParser.parse(ops)),
+];
 
 const controller = async (req: Request, res: Response) => {
     const query = TwitterQueryParser.create(req.body.operators);
@@ -17,6 +21,7 @@ const controller = async (req: Request, res: Response) => {
 
     const twitterQuery = await TwitterQuery.create({
         poolId: req.params.id,
+        frequencyInHours: req.body.frequencyInHours,
         operators: req.body.operators,
         defaults: req.body.defaults,
         query,

diff --git a/apps/api/src/app/models/TwitterQuery.ts b/apps/api/src/app/models/TwitterQuery.ts
@@ -8,6 +8,7 @@ export const TwitterQuery = mongoose.model<TwitterQueryDocument>(
         {
             poolId: String,
             query: String,
+            frequencyInHours: Number,
             operators: {
                 from: [String],
                 to: [String],

diff --git a/libs/common/src/lib/types/Twitter.d.ts b/libs/common/src/lib/types/Twitter.d.ts
@@ -3,6 +3,7 @@ type TTwitterQuery = {
     createdAt: Date;
     poolId: string;
     query: string;
+    frequencyInHours: number;
     posts: TTwitterPost[];
     operators: TTwitterOperators;
     defaults: {