feat: removed redis cmd, and update sql & zsh.

Author: mrepol742

src/commands/help.ts

@@ -38,7 +38,7 @@ function buildRoleHelpPage(
     \`Help\`
     Use: *help [command]* for more details
 
-   |  •  ${commandsForRole.join("\n |  •  ")}
+    •  ${commandsForRole.join("\n    •  ")}
 
     \`Page ${page} of ${totalPages}\`
   `;

src/commands/redis.ts

@@ -1,4 +1,4 @@
-import { Message } from "../types/message"
+import { Message } from "../types/message";
 import axios from "../components/axios";
 import log from "../components/utils/log";
 import prisma from "../components/prisma";
@@ -15,10 +15,22 @@ export const info = {
 export default async function (msg: Message): Promise<void> {
   const query = msg.body.replace(/^sql\b\s*/i, "").trim();
   if (query.length === 0) {
-    await msg.reply("Please provide a sql.");
+    await msg.reply("Please provide a sql query.");
     return;
   }
 
-  const result = await prisma.$queryRawUnsafe(query);
-  await msg.reply(JSON.stringify(result, null, 2));
+  try {
+    const result = await prisma.$queryRawUnsafe(query);
+
+    const output = JSON.stringify(result, null, 2);
+    if (output.length > 4000) {
+      await msg.reply(output.slice(0, 4000) + "\n\n[Output truncated]");
+    } else {
+      await msg.reply(output);
+    }
+  } catch (err: any) {
+    const message = err?.message || "Unknown SQL error.";
+    await msg.reply(message);
+    log.error("sql", `Error running query: ${query}`, err);
+  }
 }

src/commands/sql.ts

@@ -1,4 +1,4 @@
-import { Message } from "../types/message"
+import { Message } from "../types/message";
 import log from "../components/utils/log";
 import { exec } from "child_process";
 import util from "util";
@@ -22,16 +22,29 @@ export default async function (msg: Message): Promise<void> {
 
   const execPromise = util.promisify(exec);
 
-  const { stdout, stderr } = await execPromise(query, {
-    timeout: 30000,
-    maxBuffer: 1024 * 1024,
-    shell: process.env.SHELL || "/bin/zsh",
-  });
-  let response = `${stdout} \n\n ${stderr}`;
-  if (response.length > 4000) {
-    response = response.slice(0, 4000) + "\n\n[Output truncated]";
-  }
+  try {
+    const { stdout, stderr } = await execPromise(query, {
+      timeout: 30000,
+      maxBuffer: 1024 * 1024,
+      shell: process.env.SHELL || "/bin/zsh",
+    });
+
+    let response = `${stdout}\n\n${stderr}`;
+    if (response.length > 4000)
+      response = response.slice(0, 4000) + "\n\n[Output truncated]";
+
+    await Promise.all([msg.reply(response), logService(msg, query, response)]);
+    log.warn("zsh", `Executed command: ${query}`);
+  } catch (err: any) {
+    const stderr = err.stderr || "";
+    const stdout = err.stdout || "";
+    let response = stderr || err.message;
 
-  await Promise.all([msg.reply(response), logService(msg, query, response)]);
-  log.warn("zsh", `Executed command: ${query}`);
+    if (stdout) response = `${stdout}\n\n${response}`;
+    if (response.length > 4000)
+      response = response.slice(0, 4000) + "\n\n[Output truncated]";
+
+    await Promise.all([msg.reply(response), logService(msg, query, response)]);
+    log.error("zsh", `Error executing command: ${query}`, err);
+  }
 }