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

feat: missing payload

This commit is contained in:
Nevo David 2024-03-13 09:49:56 +07:00
parent ae7dfa2a09
commit 46037de01c
1 changed files with 18 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1,20 +1,23 @@
import { Injectable } from '@nestjs/common';
import {Cron} from '@nestjs/schedule';
import {StarsService} from "@gitroom/nestjs-libraries/database/prisma/stars/stars.service";
import {BullMqClient} from "@gitroom/nestjs-libraries/bull-mq-transport/client/bull-mq.client";
import { Cron } from '@nestjs/schedule';
import { StarsService } from '@gitroom/nestjs-libraries/database/prisma/stars/stars.service';
import { BullMqClient } from '@gitroom/nestjs-libraries/bull-mq-transport/client/bull-mq.client';
@Injectable()
export class CheckStars {
constructor(
private _starsService: StarsService,
private _workerServiceProducer: BullMqClient
) {
constructor(
private _starsService: StarsService,
private _workerServiceProducer: BullMqClient
) {}
@Cron('0 0 * * *')
async checkStars() {
const allGitHubRepositories =
await this._starsService.getAllGitHubRepositories();
for (const repository of allGitHubRepositories) {
this._workerServiceProducer.emit(
'check_stars',
JSON.stringify({ payload: { login: repository.login } })
);
}
@Cron('0 0 * * *')
async checkStars() {
const allGitHubRepositories = await this._starsService.getAllGitHubRepositories();
for (const repository of allGitHubRepositories) {
this._workerServiceProducer.emit('check_stars', JSON.stringify({login: repository.login}));
}
}
}
}
}