feat: respect paused setting in event handlers

Author: mrepol742

src/components/events/call.ts

@@ -12,6 +12,10 @@ function getRandomResponse(arr: string[]) {
 export default async function (call: Call): Promise<void> {
   try {
     if (call.fromMe || call.isGroup) return;
+
+    const isPaused = await getSetting("paused");
+    if (isPaused && isPaused === "on") return;
+
     const isCallMustReject = await getSetting("call_reject");
     if (!isCallMustReject || isCallMustReject == "off") return;
 

src/components/events/edit.ts

@@ -15,6 +15,9 @@ export default async function (
 
     const lid = (msg.author ?? msg.from).split("@")[0];
 
+    const isPaused = await getSetting("paused");
+    if (isPaused && isPaused === "on") return;
+
     const [isBlocked, isMustResent] = await Promise.all([
       getBlockUser(lid),
       getSetting("resent_edit"),

src/components/events/groups/groupAdminChanged.ts

@@ -4,10 +4,14 @@ import sleep from "../../utils/sleep";
 import { client } from "../../client";
 import { getMessage } from "../../../data/group";
 import * as Sentry from "@sentry/node";
+import { getSetting } from "../../services/settings";
 
 export default async function (notif: GroupNotification): Promise<void> {
   try {
     if (notif.timestamp < Date.now() / 1000 - 10) return;
+
+    const isPaused = await getSetting("paused");
+    if (isPaused && isPaused === "on") return;
   } catch (err) {
     Sentry.captureException(err);
     log.error("GroupJoin", "Failed to process group admin changed event:", err);

src/components/events/groups/join.ts

@@ -5,10 +5,15 @@ import { client } from "../../client";
 import { getMessage } from "../../../data/group";
 import * as Sentry from "@sentry/node";
 import { PROJECT_CANIS_ALIAS } from "../../../config";
+import { getSetting } from "../../services/settings";
 
 export default async function (notif: GroupNotification): Promise<void> {
   try {
     if (notif.timestamp < Date.now() / 1000 - 10) return;
+
+    const isPaused = await getSetting("paused");
+    if (isPaused && isPaused === "on") return;
+
     const group = await notif.getChat();
     const recipients = await notif.getRecipients();
     const text = `

src/components/events/groups/leave.ts

@@ -4,10 +4,15 @@ import sleep from "../../utils/sleep";
 import { client } from "../../client";
 import { getMessage } from "../../../data/group";
 import * as Sentry from "@sentry/node";
+import { getSetting } from "../../services/settings";
 
 export default async function (notif: GroupNotification): Promise<void> {
   try {
     if (notif.timestamp < Date.now() / 1000 - 10) return;
+
+    const isPaused = await getSetting("paused");
+    if (isPaused && isPaused === "on") return;
+
     const group = await notif.getChat();
     const recipients = await notif.getRecipients();
 

src/components/events/reaction.ts

@@ -17,6 +17,9 @@ export default async function (client: Client, react: Reaction): Promise<void> {
   // ignore @Meta AI and others
   if (react.senderId.split("@")[1] === "bot") return;
 
+  const isPaused = await getSetting("paused");
+  if (isPaused && isPaused === "on") return;
+
   const key = `react:${react.id.id}`;
   const alreadyReacted = await redis.get(key);
   if (alreadyReacted) return;

src/components/events/revoke.ts

@@ -15,6 +15,9 @@ export default async function (
 
     const lid = (msg.author ?? msg.from).split("@")[0];
 
+    const isPaused = await getSetting("paused");
+    if (isPaused && isPaused === "on") return;
+
     const [isBlocked, isMustResent] = await Promise.all([
       getBlockUser(lid),
       getSetting("resent_unsent"),