feat: breaking changes

- drop quiz table
- move quiz data to redis for faster performance
- quiz no longer accepts other answer if it was already answered regardless of correctness
- new top leaderboards
- seperates points to commmand call and added quiz wrong counter per user
- update to rate limiter
- chnage speedtest ttl to 12hour
- and more

Author: mrepol742

prisma/migrations/20251002144334_drop_quiz_table/migration.sql

@@ -0,0 +1,8 @@
+/*
+  Warnings:
+
+  - You are about to drop the `Quiz` table. If the table is not empty, all the data it contains will be lost.
+
+*/
+-- DropTable
+DROP TABLE `Quiz`;

prisma/migrations/20251002150922_add_quiz_answered_wrong_and_points/migration.sql

@@ -0,0 +1,3 @@
+-- AlterTable
+ALTER TABLE `User` ADD COLUMN `points` DOUBLE NOT NULL DEFAULT 0.0,
+    ADD COLUMN `quizAnsweredWrong` INTEGER NOT NULL DEFAULT 0;

prisma/schema.prisma

@@ -14,18 +14,20 @@ datasource db {
 }
 
 model User {
-  id           Int      @id @default(autoincrement())
-  lid          String   @unique
-  name         String
-  number       String
-  countryCode  String
-  type         String
-  mode         String
-  about        String?
-  commandCount Int      @default(0)
-  quizAnswered Int      @default(0)
-  createdAt    DateTime @default(now())
-  updatedAt    DateTime @updatedAt
+  id                Int      @id @default(autoincrement())
+  lid               String   @unique
+  name              String
+  number            String
+  countryCode       String
+  type              String
+  mode              String
+  about             String?
+  commandCount      Int      @default(0)
+  quizAnswered      Int      @default(0)
+  quizAnsweredWrong Int      @default(0)
+  points            Float    @default(0.0)
+  createdAt         DateTime @default(now())
+  updatedAt         DateTime @updatedAt
 }
 
 model Block {
@@ -71,13 +73,3 @@ model Log {
   createdAt DateTime @default(now())
   updatedAt DateTime @updatedAt
 }
-
-model Quiz {
-  id         Int       @id @default(autoincrement())
-  mid        String    @unique
-  lid        String
-  qid        String
-  answeredAt DateTime?
-  createdAt  DateTime  @default(now())
-  updatedAt  DateTime  @updatedAt
-}

src/commands/play.ts

@@ -53,27 +53,28 @@ export default async function play(msg: Message) {
   }
 
   const yt = await Innertube.create({
-    cache: new UniversalCache(false),
+    cache: new UniversalCache(true, "./.youtubei"),
     generate_session_locally: true,
     player_id: "0004de42",
   });
 
-  const audio: any = await search(yt, query);
+  const [audio] = await Promise.all([search(yt, query), msg.react("🔍")]);
   if (!audio) {
     await msg.reply(`No youtube music found for "${query}".`);
     return;
   }
 
   // Only allow audios shorter than 20 minutes (1200 seconds)
   if (audio.duration && audio.duration.seconds > 1200) {
-    await msg.reply(
-      "Opps, the music is quite long we can only process max of 20 minutes.",
-    );
+    await Promise.all([
+      msg.reply(
+        "Opps, the music is quite long we can only process max of 20 minutes.",
+      ),
+      msg.react(""),
+    ]);
     return;
   }
 
-  await msg.react("🔍");
-
   const tempDir = "./.temp";
   await fs.promises.mkdir(tempDir, { recursive: true });
   const tempPath = path.join(tempDir, `${audio.id}.mp3`);
@@ -85,11 +86,14 @@ export default async function play(msg: Message) {
     return;
   }
 
-  const stream = await yt.download(audio.id, {
-    type: "video+audio",
-    quality: "best",
-    format: "mp4",
-  });
+  const [stream] = await Promise.all([
+    yt.download(audio.id, {
+      type: "video+audio",
+      quality: "best",
+      format: "mp4",
+    }),
+    msg.react("⬇️"),
+  ]);
 
   if (!stream) {
     await Promise.all([
@@ -99,12 +103,13 @@ export default async function play(msg: Message) {
     return;
   }
 
-  await msg.react("⬇️");
-
   let writeStream = fs.createWriteStream(tempPath);
-
   for await (const chunk of Utils.streamToIterable(stream)) {
-    writeStream.write(chunk);
+    if (!writeStream.write(chunk)) {
+      await new Promise<void>((resolve) =>
+        writeStream.once("drain", () => resolve()),
+      );
+    }
   }
 
   await new Promise<void>((resolve, reject) => {

src/commands/quiz.ts

@@ -1,7 +1,7 @@
-import { Message } from "../../types/message"
+import { Message } from "../../types/message";
 import { quiz } from "../components/utils/data";
-import { newQuizAttempt } from "../components/services/quiz";
 import log from "../components/utils/log";
+import redis from "../components/redis";
 
 export const info = {
   command: "quiz",
@@ -32,8 +32,9 @@ export default async function (msg: Message) {
   }
 
   const messageReturn = await msg.reply(text);
-  await Promise.all([
-    newQuizAttempt(messageReturn, id.toString()),
-    log.info("quiz", `Quiz question sent: ${response.question}`),
-  ]);
+  redis.set(
+    `quiz:${messageReturn.id.id}`,
+    JSON.stringify({ quiz_id: id.toString() }),
+  );
+  log.info("quiz", `Quiz question sent: ${response.question}`);
 }

src/commands/stalk.ts

@@ -45,6 +45,9 @@ export default async function (msg: Message) {
     Type: ${user.type}
     Mode: ${user.mode}
     Command Count: ${user.commandCount}
+    Quiz Answered: ${user.quizAnswered}
+    Quiz Answered Wrong: ${user.quizAnsweredWrong}
+    Points: ${user.points}
     Last Seen: ${new Date(user.updatedAt).toLocaleString()}
     Blocked: ${
       isBlockPermanently

src/commands/top.ts

@@ -1,6 +1,10 @@
 import { Message } from "../../types/message";
 import log from "../components/utils/log";
-import { getUsers } from "../components/services/user";
+import {
+  getUsersPoints,
+  getUsersCommandCount,
+  getUsersQuiz,
+} from "../components/services/user";
 
 export const info = {
   command: "top",
@@ -14,22 +18,41 @@ export const info = {
 export default async function (msg: Message) {
   if (!/^top$/i.test(msg.body)) return;
 
-  const user = await getUsers();
-  if (!user || user.length === 0) {
-    await msg.reply("No users found.");
-    return;
-  }
+  const [usersPoints, usersCommandCount, usersQuiz] = await Promise.all([
+    getUsersPoints(),
+    getUsersCommandCount(),
+    getUsersQuiz(),
+  ]);
 
   const text = `
-    \`Top Users by Activity:\`
+    \`Points:\`
 
-    ${user
-      .sort((a, b) => (b.totalActivity ?? 0) - (a.totalActivity ?? 0))
-      .slice(0, 50)
+    ${usersPoints
       .map((u, index) => {
         const displayName =
-          u.name.length > 12 ? u.name.slice(0, 12) + ".." : u.name;
-        return `${index + 1}. ${displayName}: ${u.totalActivity} Points`;
+          u.name.length > 16 ? u.name.slice(0, 16) + ".. " : u.name;
+        return `${index + 1}. ${displayName}: ${u.points} Points`;
+      })
+      .join("\n    ")}
+
+    \`Quiz:\`
+
+    ${usersQuiz
+      .sort((a, b) => b.score - a.score)
+      .map((u, index) => {
+        const displayName =
+          u.name.length > 16 ? u.name.slice(0, 16) + ".. " : u.name;
+        return `${index + 1}. ${displayName}: ${u.score} Score`;
+      })
+      .join("\n    ")}
+
+    \`Reputation:\`
+
+    ${usersCommandCount
+      .map((u, index) => {
+        const displayName =
+          u.name.length > 16 ? u.name.slice(0, 16) + ".. " : u.name;
+        return `${index + 1}. ${displayName}: ${u.commandCount} Rep`;
       })
       .join("\n    ")}
     `;

src/commands/video.ts

@@ -45,27 +45,28 @@ export default async function (msg: Message) {
   }
 
   const yt = await Innertube.create({
-    cache: new UniversalCache(false),
+    cache: new UniversalCache(true, "./.youtubei"),
     generate_session_locally: true,
     player_id: "0004de42",
   });
 
-  const video: any = await search(yt, query);
+  const [video] = await Promise.all([search(yt, query), msg.react("🔍")]);
   if (!video) {
     await msg.reply(`No youtube video found for "${query}".`);
     return;
   }
 
   // Only allow audios shorter than 20 minutes (1200 seconds)
   if (video.duration && video.duration.seconds > 1200) {
-    await msg.reply(
-      "Opps, the video is quite long we can only process max of 20 minutes.",
-    );
+    await Promise.all([
+      msg.reply(
+        "Opps, the video is quite long we can only process max of 20 minutes.",
+      ),
+      msg.react(""),
+    ]);
     return;
   }
 
-  await msg.react("🔍");
-
   const tempDir = "./.temp";
   await fs.promises.mkdir(tempDir, { recursive: true });
   const tempPath = path.join(tempDir, `${video.video_id}.mp4`);
@@ -82,11 +83,14 @@ export default async function (msg: Message) {
     return;
   }
 
-  const stream = await yt.download(video.video_id, {
-    type: "video+audio",
-    quality: "best",
-    format: "mp4",
-  });
+  const [stream] = await Promise.all([
+    yt.download(video.video_id, {
+      type: "video+audio",
+      quality: "best",
+      format: "mp4",
+    }),
+    msg.react("⬇️"),
+  ]);
 
   if (!stream) {
     await Promise.all([
@@ -96,12 +100,13 @@ export default async function (msg: Message) {
     return;
   }
 
-  await msg.react("⬇️");
-
   let writeStream = fs.createWriteStream(tempPath);
-
   for await (const chunk of Utils.streamToIterable(stream)) {
-    writeStream.write(chunk);
+    if (!writeStream.write(chunk)) {
+      await new Promise<void>((resolve) =>
+        writeStream.once("drain", () => resolve()),
+      );
+    }
   }
 
   await new Promise<void>((resolve, reject) => {

src/components/ai/agentHandler.ts

@@ -1,3 +1,4 @@
+import crypto from "crypto";
 import { openrouter, generateText } from "./openRouter";
 import { groq } from "./groq";
 import { gemini } from "./gemini";
@@ -9,11 +10,11 @@ const aiProvider = process.env.AI_PROVIDER || "groq";
 const isQueryCachingEnabled = process.env.ALLOW_QUERY_CACHING === "true";
 const queryCachingCount = parseInt(
   process.env.QUERY_CACHING_COUNT || "1000",
-  10
+  10,
 );
 const queryCachingTTL = parseInt(process.env.QUERY_CACHING_TTL || "3600", 10);
 /*
- * As time goes by and new models are released, 
+ * As time goes by and new models are released,
  * these defaults may need to be updated.
  */
 const openRouterModel =
@@ -25,7 +26,8 @@ const openAiModel = process.env.OPENAI_MODEL || "gpt-4o";
 const ollamaModel = process.env.OLLAMA_MODEL || "llama3.1";
 
 function getCacheKey(prompt: string) {
-  return `ai:prompt:${Buffer.from(prompt).toString("base64")}`;
+  const hash = crypto.createHash("sha256").update(prompt).digest("hex");
+  return `ai:prompt:${hash}`;
 }
 
 export default async function (prompt: string, model?: string) {

src/components/events/edit.ts

@@ -23,9 +23,8 @@ export default async function (
   const isMustResent = await getSetting("resent_edit");
   if (!isMustResent || isMustResent == "off") return;
 
-  const isGroup = !!msg.author;
-  const user = (await getUserbyLid(msg.from)) || "Your";
+  const user = (await getUserbyLid(msg.from)) || "User";
   await msg.reply(
-    `${isGroup ? user : "Your"} message was edited from "${prevBody}".`,
+    `${msg.author ? user : "Your"} message was edited from "${prevBody}".`,
   );
 }