Create a scheduled task to update jira ticket status into criteria progres

prisma/seed.ts

@@ -169,5 +169,6 @@ const userPassword = 'taskany';
         prisma.appConfig.create({ data: {} }),
         createSheep(),
         createCronJob('goalPing', '0 0 0 1 * *'),
+        createCronJob('externalTaskCheck', '1/10 * * * *'),
     ]);
 })();

src/utils/recalculateCriteriaScore.ts

@@ -97,10 +97,24 @@ type GoalCalculateScore = Goal & {
  *    then for all goals needs recalculate score and parents project's average score
  */
 
+interface CriteriaScoreUpdateBaseApi {
+    recalcCurrentGoalScore: () => CriteriaScoreUpdateApi & CriteriaScoreUpdateBaseApi;
+    recalcAverageProjectScore: () => CriteriaScoreUpdateApi & CriteriaScoreUpdateBaseApi;
+    recalcLinkedGoalsScores: () => CriteriaScoreUpdateApi & CriteriaScoreUpdateBaseApi;
+}
+
+interface CriteriaScoreUpdateApi {
+    run: () => Promise<void>;
+    makeChain: (
+        ...names: Array<keyof CriteriaScoreUpdateBaseApi>
+    ) => CriteriaScoreUpdateApi & CriteriaScoreUpdateBaseApi;
+}
+
 export const recalculateCriteriaScore = (goalId: string) => {
     let currentGoal: GoalCalculateScore;
     let countsToUpdate: number;
     let count = 0;
+
     const getCurrentGoal = async () => {
         if (!currentGoal || countsToUpdate > count++) {
             currentGoal = await prisma.goal.findUniqueOrThrow({
@@ -118,7 +132,7 @@ export const recalculateCriteriaScore = (goalId: string) => {
     let prismaCtx: Omit<PrismaClient, ITXClientDenyList>;
 
     // eslint-disable-next-line @typescript-eslint/no-explicit-any
-    const promisesChain: (() => Promise<any>)[] = [];
+    const promisesChain: (() => Promise<void>)[] = [];
 
     const updateGoalScore = ({ id, score }: { id: string; score: number | null }) => {
         return prismaCtx.goal.update({
@@ -127,7 +141,16 @@ export const recalculateCriteriaScore = (goalId: string) => {
         });
     };
 
-    const methods = {
+    const run = () => {
+        return prisma.$transaction((ctx) => {
+            prismaCtx = ctx;
+            countsToUpdate = promisesChain.length;
+
+            return promisesChain.reduce((promise, getter) => promise.then(getter), Promise.resolve());
+        });
+    };
+
+    const methods: CriteriaScoreUpdateApi & CriteriaScoreUpdateBaseApi = {
         recalcCurrentGoalScore: () => {
             promisesChain.push(async () => {
                 const goal = await getCurrentGoal();
@@ -181,7 +204,7 @@ export const recalculateCriteriaScore = (goalId: string) => {
                     group by 1
                 `;
 
-                return prismaCtx.$executeRaw`
+                await prismaCtx.$executeRaw`
                     update "Project" as project
                     set "averageScore" = scoreByProject.score
                     from (${countsRequests}) as scoreByProject(projectId, score)
@@ -252,13 +275,13 @@ export const recalculateCriteriaScore = (goalId: string) => {
 
             return methods;
         },
-        async run() {
-            return prisma.$transaction((ctx) => {
-                prismaCtx = ctx;
-                countsToUpdate = promisesChain.length;
-
-                return promisesChain.reduce((promise, getter) => promise.then(getter), Promise.resolve());
+        run,
+        makeChain(...names) {
+            names.forEach((name) => {
+                methods[name]();
             });
+
+            return methods;
         },
     };
     return methods;

src/utils/worker/create.ts

@@ -1,6 +1,7 @@
 import { prisma } from '../prisma';
 
 import * as templates from './mail/templates';
+import { log } from './utils';
 
 export const defaultJobDelay = process.env.WORKER_JOBS_DELAY ? parseInt(process.env.WORKER_JOBS_DELAY, 10) : 1000;
 
@@ -14,6 +15,7 @@ export enum jobKind {
     email = 'email',
     cron = 'cron',
     comment = 'comment',
+    criteriaToUpdate = 'criteriaToUpdate',
 }
 
 type Templates = typeof templates;
@@ -25,15 +27,22 @@ export interface JobDataMap {
         data: any;
     };
     cron: {
-        template: 'goalPing';
+        template: 'goalPing' | 'externalTaskCheck';
     };
     comment: {
         goalId: string;
         activityId: string;
         description: string;
     };
+    criteriaToUpdate: {
+        id: string;
+    };
 }
 
+export const castJobData = <Kind extends jobKind>(kind: Kind, data: unknown): data is JobDataMap[Kind] => {
+    return data != null;
+};
+
 export type JobKind = keyof JobDataMap;
 
 interface CreateJobProps<K extends keyof JobDataMap> {
@@ -43,10 +52,27 @@ interface CreateJobProps<K extends keyof JobDataMap> {
     cron?: string;
 }
 
+export const pickScheduledLastJob = async (kind: JobKind) => {
+    const res = await prisma.job.findMany({
+        where: { kind, state: jobState.scheduled },
+        orderBy: [{ createdAt: 'desc' }, { updatedAt: 'desc' }],
+        take: 1,
+        skip: 0,
+    });
+
+    if (res.length) {
+        return res[0];
+    }
+
+    return null;
+};
+
 export function createJob<K extends keyof JobDataMap>(
     kind: K,
     { data, priority, delay = defaultJobDelay, cron }: CreateJobProps<K>,
 ) {
+    log(`create new ${kind} job`, JSON.stringify(data));
+
     return prisma.job.create({
         data: {
             state: jobState.scheduled,
@@ -86,3 +112,7 @@ export function createCommentJob(data: JobDataMap['comment'], delay?: number) {
         delay,
     });
 }
+
+export const createCriteriaToUpdate = (data: JobDataMap['criteriaToUpdate'], delay?: number) => {
+    return createJob('criteriaToUpdate', { data, delay });
+};