jeffemmett
/
postiz
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: remove json stringify from cron payload

This commit is contained in:
Nevo David 2024-03-17 12:03:38 +07:00
parent 0d3582c99a
commit 5dc8bcfc01
2 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/cron/src/tasks/check.stars.ts
View File

@ -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 },
});
}
}
}

6
apps/workers/src/app/stars.controller.ts
View File

@ -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);