✨ Staff feedback in conversations every month

app/src/app/api/staffreview/route.ts

@@ -0,0 +1,92 @@
+import { TRPCError } from "@trpc/server";
+import { eq, ne, and, gt } from "drizzle-orm";
+import { drizzleDB } from "@/server/db";
+import { userReview, userData } from "@/drizzle/schema";
+import { secondsFromNow } from "@/utils/time";
+import { getHTTPStatusCodeFromError } from "@trpc/server/http";
+import { updateGameSetting, checkGameTimer } from "@/libs/gamesettings";
+import { createConvo } from "@/routers/comments";
+import { cookies } from "next/headers";
+import { generateText } from "ai";
+import { TERR_BOT_ID } from "@/drizzle/constants";
+import { openai } from "@ai-sdk/openai";
+
+/**
+ * DANGER ZONE
+ * This function is responsible for the daily update of the game state.
+ * It is a critical function that should be handled with care!!!
+ * @returns
+ */
+export async function GET() {
+  // disable cache for this server action (https://github.com/vercel/next.js/discussions/50045)
+  cookies();
+
+  // Check timer
+  const frequency = 24 * 7;
+  const response = await checkGameTimer(drizzleDB, frequency);
+  if (response) return response;
+
+  // Update timer
+  await updateGameSetting(drizzleDB, `timer-${frequency}h`, 0, new Date());
+
+  try {
+    // Get all staff
+    const staff = await drizzleDB.query.userData.findMany({
+      where: ne(userData.role, "USER"),
+    });
+
+    // Query all user review from the last 7 days
+    for (const user of staff) {
+      const results = await drizzleDB.query.userReview.findMany({
+        where: and(
+          gt(userReview.createdAt, secondsFromNow(-frequency * 60 * 60)),
+          ne(userReview.review, ""),
+          eq(userReview.targetUserId, user.userId),
+        ),
+      });
+      const allText = results.map((r) => r.review).join("\n");
+
+      // Review
+      const { text } = await generateText({
+        model: openai("gpt-4o"),
+        prompt: `
+          Write a succint version of the following staff reviews, preferably with actionable feedback for the staff in a listed format.
+          Do not give feedback which can not be substantiated from the reviews.
+          Do not give feedback relating to the hiring process.
+          Split your feedback into three areas; strengths, areas for improvement, and actionable feedback
+          Respond in valid html format with the following structure:
+
+          <strong>Strengths:</strong>
+          <ul>
+            <li>...</li>
+          </ul>
+          etc.
+          
+          Reviews to give feedback from: ${allText}
+        `,
+      });
+
+      // Create conversation
+      const now = new Date();
+      await createConvo(
+        drizzleDB,
+        TERR_BOT_ID,
+        [user.userId],
+        `Staff Review: ${now.toLocaleString()}`,
+        `Hey ${user.username}, here is a summary of your recent reviews from the last 7 days. This is an auto-generated message, and everything has been written by an AI based on the reviews, in order to keep the original messages annonymized:
+        <br /><br />${text.replace("```html", "").replace("```", "")}`,
+      );
+    }
+
+    return Response.json(`OK`);
+  } catch (cause) {
+    console.error(cause);
+    if (cause instanceof TRPCError) {
+      // An error from tRPC occured
+      const httpCode = getHTTPStatusCodeFromError(cause);
+      return Response.json(cause, { status: httpCode });
+    }
+    // Another error occured
+    return Response.json("Internal server error", { status: 500 });
+  }
+}

app/src/server/api/routers/reports.ts

@@ -577,6 +577,7 @@ export const reportsRouter = createTRPCRouter({
           .set({
             positive: input.positive,
             review: input.review,
+            createdAt: new Date(),
           })
           .where(eq(userReview.id, review.id));
         return { success: true, message: "Staff review updated" };

app/vercel.json

@@ -23,6 +23,10 @@
     {
       "path": "/api/daily",
       "schedule": "20 0 * * *"
+    },
+    {
+      "path": "/api/staffreview",
+      "schedule": "0 0 1 * *"
     }
   ],
   "functions": {