wip

backend/package.json

@@ -28,6 +28,7 @@
     "@nestjs/jwt": "^10.2.0",
     "@nestjs/passport": "^10.0.3",
     "@nestjs/platform-express": "^10.0.0",
+    "@nestjs/schedule": "^4.0.2",
     "bcrypt": "^5.1.1",
     "drizzle-orm": "^0.30.9",
     "passport": "^0.7.0",

backend/src/app.module.ts

@@ -6,9 +6,11 @@ import { AuthController } from './auth/auth.controller';
 import { APP_GUARD } from '@nestjs/core';
 import { JwtAuthGuard } from './auth/jwt-auth.guard';
 import { TaskGroupController } from './task-group.controller';
+import { ScheduleModule } from '@nestjs/schedule';
+import { AssignmentsModule } from './assignment.module';
 
 @Module({
-  imports: [AuthModule],
+  imports: [AuthModule, ScheduleModule.forRoot(), AssignmentsModule],
   controllers: [
     TasksController,
     AssignmentController,

backend/src/assignment-scheduler.service.ts

@@ -0,0 +1,24 @@
+import { Injectable } from '@nestjs/common';
+import { Cron, CronExpression } from '@nestjs/schedule';
+import {
+  dbGetTaskGroupUsers,
+  dbGetTaskGroupsToCreateForCurrentInterval,
+} from './db/functions/task-group';
+import { dbGetAssignmentsForTaskGroup } from './db/functions/assignment-task-group';
+
+@Injectable()
+export class AssignmentSchedulerService {
+  @Cron(CronExpression.EVERY_5_SECONDS)
+  async handleCron() {
+    const taskGroupsToCreateAssignmentsFor =
+      await dbGetTaskGroupsToCreateForCurrentInterval();
+    for (const { taskGroupId } of taskGroupsToCreateAssignmentsFor) {
+      const users = await dbGetTaskGroupUsers(taskGroupId);
+      const assignments = await dbGetAssignmentsForTaskGroup(
+        taskGroupId,
+        users.length,
+      );
+      console.log({ assignments });
+    }
+  }
+}

backend/src/assignment.module.ts

@@ -0,0 +1,7 @@
+import { Module } from '@nestjs/common';
+import { AssignmentSchedulerService } from './assignment-scheduler.service';
+
+@Module({
+  providers: [AssignmentSchedulerService],
+})
+export class AssignmentsModule {}

backend/src/db/functions/assignment-task-group.ts

@@ -0,0 +1,18 @@
+import { desc, eq } from 'drizzle-orm';
+import { db } from '..';
+import { taskGroupAssignmentTable } from '../schema';
+
+export async function dbGetAssignmentsForTaskGroup(
+  taskGroupId: number,
+  limit?: number,
+) {
+  const result = db
+    .select()
+    .from(taskGroupAssignmentTable)
+    .where(eq(taskGroupAssignmentTable.taskGroupId, taskGroupId))
+    .orderBy(desc(taskGroupAssignmentTable.createdAt));
+  if (limit === undefined) {
+    return await result;
+  }
+  return await result.limit(limit);
+}

backend/src/db/functions/task-group.ts

@@ -55,10 +55,10 @@ export async function dbGetTaskGroupsToCreateForCurrentInterval() {
         taskGroupAssignmentTable,
         eq(taskGroupTable.id, taskGroupAssignmentTable.taskGroupId),
       )
-      .groupBy(taskGroupTable.id)
-      .having(
-        sql` MAX(${taskGroupAssignmentTable.createdAt}) < (NOW() - ${taskGroupTable.interval})`,
-      );
+      .groupBy(taskGroupTable.id);
+    // .having(
+    //   sql`MAX(${taskGroupAssignmentTable.createdAt}) < (NOW() - ${taskGroupTable.interval})`,
+    // );
     return taskGroupIdsToCreateAssignmentsFor;
   } catch (error) {
     console.error({ error });