115 lines
2.4 KiB
TypeScript
115 lines
2.4 KiB
TypeScript
import { getMoodleCourseCompletionStatus, getMoodleUserById } from "./moodle";
|
|
import { CronJob } from "cron";
|
|
import { prisma } from "@repo/db";
|
|
import { participantCompleted } from "helper/event";
|
|
|
|
const syncMoodleIds = async () => {
|
|
try {
|
|
const user = await prisma.user.findMany({
|
|
where: {
|
|
moodleId: null,
|
|
},
|
|
});
|
|
|
|
await Promise.all(
|
|
user.map(async (u) => {
|
|
const moodleUser = await getMoodleUserById(u.id.toString());
|
|
const moodleId = moodleUser?.id.toString();
|
|
if (u.moodleId === parseInt(moodleId)) return;
|
|
await prisma.user.update({
|
|
where: {
|
|
id: u.id,
|
|
},
|
|
data: {
|
|
moodleId: parseInt(moodleId),
|
|
},
|
|
});
|
|
}),
|
|
);
|
|
} catch (error) {
|
|
console.error(error);
|
|
}
|
|
};
|
|
|
|
const updateParticipantMoodleResults = async () => {
|
|
const participantsMoodlePending = await prisma.participant.findMany({
|
|
where: {
|
|
finisherMoodleCurseCompleted: false,
|
|
Event: {
|
|
finisherMoodleCourseId: {
|
|
not: null,
|
|
},
|
|
},
|
|
},
|
|
include: {
|
|
Event: true,
|
|
User: true,
|
|
},
|
|
});
|
|
await Promise.all(
|
|
participantsMoodlePending.map(async (p) => {
|
|
if (!p.User) return;
|
|
if (!p.User.moodleId) return;
|
|
|
|
const quizzResult = await getMoodleCourseCompletionStatus(
|
|
p.User.moodleId.toString(),
|
|
p.Event.finisherMoodleCourseId!,
|
|
);
|
|
|
|
if (quizzResult?.completionstatus?.completed === true) {
|
|
await prisma.participant.update({
|
|
where: {
|
|
id: p.id,
|
|
},
|
|
data: {
|
|
finisherMoodleCurseCompleted: true,
|
|
statusLog: {
|
|
push: {
|
|
event: "Finisher course completed",
|
|
timestamp: new Date(),
|
|
user: "system",
|
|
},
|
|
},
|
|
},
|
|
});
|
|
if (participantCompleted(p.Event, p)) {
|
|
// Event is completed, give relating permissions
|
|
await prisma.user.update({
|
|
where: {
|
|
id: p.userId,
|
|
},
|
|
data: {
|
|
permissions: {
|
|
push: p.Event.finishedPermissions,
|
|
},
|
|
badges: {
|
|
push: p.Event.finishedBadges,
|
|
},
|
|
},
|
|
});
|
|
await prisma.participant.update({
|
|
where: {
|
|
id: p.id,
|
|
},
|
|
data: {
|
|
finished: true,
|
|
},
|
|
});
|
|
}
|
|
}
|
|
}),
|
|
);
|
|
};
|
|
|
|
CronJob.from({ cronTime: "0 * * * *", onTick: syncMoodleIds, start: true });
|
|
CronJob.from({
|
|
cronTime: "*/5 * * * *",
|
|
onTick: async () => {
|
|
console.log("Updating participant moodle results");
|
|
await updateParticipantMoodleResults();
|
|
},
|
|
start: true,
|
|
});
|
|
|
|
updateParticipantMoodleResults();
|