From 5dc8bcfc01bfdec65771001a8adc133acd6ac993 Mon Sep 17 00:00:00 2001
From: Nevo David <nevo@notu.co>
Date: Sun, 17 Mar 2024 12:03:38 +0700
Subject: [PATCH] feat: remove json stringify from cron payload

---
 apps/cron/src/tasks/check.stars.ts       | 8 ++++----
 apps/workers/src/app/stars.controller.ts | 6 ++++++
 2 files changed, 10 insertions(+), 4 deletions(-)

diff --git a/apps/cron/src/tasks/check.stars.ts b/apps/cron/src/tasks/check.stars.ts
index c76bc00b..5c5a9f29 100644
--- a/apps/cron/src/tasks/check.stars.ts
+++ b/apps/cron/src/tasks/check.stars.ts
@@ -13,11 +13,11 @@ export class CheckStars {
   async checkStars() {
     const allGitHubRepositories =
       await this._starsService.getAllGitHubRepositories();
+
     for (const repository of allGitHubRepositories) {
-      this._workerServiceProducer.emit(
-        'check_stars',
-        JSON.stringify({ payload: { login: repository.login } })
-      );
+      this._workerServiceProducer.emit('check_stars', {
+        payload: { login: repository.login },
+      });
     }
   }
 }
diff --git a/apps/workers/src/app/stars.controller.ts b/apps/workers/src/app/stars.controller.ts
index d70c7d8a..5f73e182 100644
--- a/apps/workers/src/app/stars.controller.ts
+++ b/apps/workers/src/app/stars.controller.ts
@@ -3,6 +3,7 @@ import { EventPattern, Transport } from '@nestjs/microservices';
 import { JSDOM } from 'jsdom';
 import { StarsService } from '@gitroom/nestjs-libraries/database/prisma/stars/stars.service';
 import { TrendingService } from '@gitroom/nestjs-libraries/services/trending.service';
+import dayjs from 'dayjs';
 
 @Controller()
 export class StarsController {
@@ -33,6 +34,11 @@ export class StarsController {
       data.login
     );
 
+    if (dayjs(lastValue.date).format('YYYY-MM-DD') === dayjs().format('YYYY-MM-DD')) {
+      console.log('stars already synced for today');
+      return ;
+    }
+
     const totalNewsStars = totalStars - (lastValue?.totalStars || 0);
     const totalNewsForks = totalForks - (lastValue?.totalForks || 0);