feat: run tasks at startup

server/plugins/01.system-init.ts

@@ -1,4 +1,4 @@
-import prisma from "../internal/db/database";
+import prisma from "~/server/internal/db/database";
 
 export default defineNitroPlugin(async (_nitro) => {
   // Ensure system user exists

server/plugins/02.setup-admin.ts

@@ -1,4 +1,4 @@
-import prisma from "../internal/db/database";
+import prisma from "~/server/internal/db/database";
 
 export default defineNitroPlugin(async (_nitro) => {
   const userCount = await prisma.user.count({

server/plugins/04.tasks.ts

@@ -0,0 +1,7 @@
+export default defineNitroPlugin(async (_nitro) => {
+  // all tasks we should run on server boot
+  await Promise.all([
+    runTask("cleanup:invitations"),
+    runTask("cleanup:sessions"),
+  ]);
+});

server/tasks/cleanup/invitations.ts

@@ -5,6 +5,8 @@ export default defineTask({
     name: "cleanup:invitations",
   },
   async run() {
+    console.log("[Task cleanup:invitations]: Cleaning invitations");
+
     const now = new Date();
 
     await prisma.invitation.deleteMany({
@@ -15,6 +17,7 @@ export default defineTask({
       },
     });
 
+    console.log("[Task cleanup:invitations]: Done");
     return { result: true };
   },
 });

server/tasks/cleanup/sessions.ts

@@ -2,11 +2,12 @@ import sessionHandler from "~/server/internal/session";
 
 export default defineTask({
   meta: {
-    name: "cleanup:invitations",
+    name: "cleanup:sessions",
   },
   async run() {
+    console.log("[Task cleanup:sessions]: Cleaning up sessions");
     await sessionHandler.cleanupSessions();
-
+    console.log("[Task cleanup:sessions]: Done");
     return { result: true };
   },
 });