feat: group-specific actions middleware

README.md

@@ -20,3 +20,6 @@ Our new telegram bot.
    ```sh
    pnpm run dev
    ```
+
+### Maybe useful references
+- [How to send private messages](https://github.com/PoliNetworkOrg/PoliNetworkBot_CSharp/blob/03c7434f06323ffdec301cb105d1d3b2c1ed4a95/PoliNetworkBot_CSharp/Code/Utils/SendMessage.cs#L90)

TODO.md

@@ -29,7 +29,7 @@
   - [ ] exception to send our whatsapp links?
   - [x] do not delete Direttivo's allowed messages (/grant command)
   - [x] check if user has username
-  - [ ] group-specific moderation (eg. #cerco #vendo in polihouse) see [here](https://github.com/PoliNetworkOrg/PoliNetworkBot_CSharp/blob/03c7434f06323ffdec301cb105d1d3b2c1ed4a95/PoliNetworkBot_CSharp/Code/Bots/Moderation/Blacklist/Blacklist.cs#L84)
+  - [x] group-specific moderation (eg. #cerco #vendo in polihouse) see [here](https://github.com/PoliNetworkOrg/PoliNetworkBot_CSharp/blob/03c7434f06323ffdec301cb105d1d3b2c1ed4a95/PoliNetworkBot_CSharp/Code/Bots/Moderation/Blacklist/Blacklist.cs#L84)
 - [x] role management
   - [x] setrole: set role for some username (only Direttivo, maybe HR)
   - [x] getrole: get user role

src/bot.ts

@@ -12,6 +12,7 @@ import { logger } from "./logger"
 import { AutoModerationStack } from "./middlewares/auto-moderation-stack"
 import { BotMembershipHandler } from "./middlewares/bot-membership-handler"
 import { checkUsername } from "./middlewares/check-username"
+import { GroupSpecificActions } from "./middlewares/group-specific-actions"
 import { messageLink } from "./middlewares/message-link"
 import { MessageUserStorage } from "./middlewares/message-user-storage"
 import { UIActionsLogger } from "./middlewares/ui-actions-logger"
@@ -76,6 +77,7 @@ bot.use(MenuGenerator.getInstance())
 bot.use(commands)
 bot.use(new BotMembershipHandler())
 bot.use(new AutoModerationStack())
+bot.use(new GroupSpecificActions())
 bot.use(new UIActionsLogger())
 
 bot.on("message", async (ctx, next) => {

src/middlewares/group-specific-actions.ts

@@ -0,0 +1,108 @@
+import { Composer, type Filter, type MiddlewareObj } from "grammy"
+import { err, ok, type Result } from "neverthrow"
+import { api } from "@/backend"
+import { logger } from "@/logger"
+import { modules } from "@/modules"
+import { fmt, fmtUser } from "@/utils/format"
+import type { Context } from "@/utils/types"
+import { wait } from "@/utils/wait"
+
+const TARGET_GROUPS: Record<string, number> = {
+  alloggi: -1001175999519,
+  ripetizioni: -1001495422899,
+  books: -1001164044303,
+} as const
+
+const TARGET_GROUP_IDS_SET = new Set(Object.values(TARGET_GROUPS))
+
+function groupSpecificHashtags(groupId: number): string[] {
+  switch (groupId) {
+    case TARGET_GROUPS.alloggi:
+      return ["#cerco", "#searching", "#search", "#offro", "#offering", "#offer"]
+    case TARGET_GROUPS.ripetizioni:
+      return ["#richiesta", "#offerta", "#request", "#offer"]
+    case TARGET_GROUPS.books:
+      return ["#cerco", "#vendo"]
+    default:
+      return []
+  }
+}
+
+export class GroupSpecificActions<C extends Context> implements MiddlewareObj<C> {
+  private composer = new Composer<C>()
+
+  constructor() {
+    this.composer
+      .filter((ctx) => !!ctx.chatId && TARGET_GROUP_IDS_SET.has(ctx.chatId))
+      .on("message", async (ctx, next) => {
+        if (ctx.from.id === ctx.me.id) return next() // skip if bot
+        const { roles } = await api.tg.permissions.getRoles.query({ userId: ctx.from.id })
+        if (roles && roles.length > 0) return next() // skip if admin or other roles
+
+        const chatMember = await ctx.getChatMember(ctx.from.id)
+        if (chatMember.status === "administrator" || chatMember.status === "creator") return next() // skip if group-admin
+
+        let check: Result<void, string>
+        switch (ctx.chatId) {
+          case TARGET_GROUPS.alloggi:
+            check = this.checkAlloggi(ctx)
+            break
+
+          case TARGET_GROUPS.ripetizioni:
+            check = this.checkRipetizioni(ctx)
+            break
+
+          case TARGET_GROUPS.books:
+            check = this.checkBooks(ctx)
+            break
+
+          default:
+            logger.error(
+              { chatId: ctx.chatId, targetGroupsMap: TARGET_GROUPS },
+              "GroupSpecificActions: target group matched, but no handler set. This is an unimplemented feature"
+            )
+            return next()
+        }
+
+        if (check.isOk()) return next()
+
+        await modules.get("tgLogger").delete([ctx.message], `User did not follow group rules:\n${check.error}`, ctx.me)
+        const reply = await ctx.reply(
+          fmt(({ b, n }) => [b`${fmtUser(ctx.from)} you sent an invalid message`, b`Reason:`, n`${check.error}`], {
+            sep: "\n",
+          }),
+          { disable_notification: false, reply_markup: { force_reply: true } }
+        )
+
+        // delete error msg after 2 min without blocking the middleware stack
+        void wait(120_000)
+          .then(() => reply.delete())
+          .catch(() => {})
+      })
+  }
+
+  private checkAlloggi(ctx: Filter<C, "message">): Result<void, string> {
+    return this.checkHashtags(ctx, groupSpecificHashtags(ctx.chatId))
+  }
+
+  private checkRipetizioni(ctx: Filter<C, "message">): Result<void, string> {
+    return this.checkHashtags(ctx, groupSpecificHashtags(ctx.chatId))
+  }
+
+  private checkBooks(ctx: Filter<C, "message">): Result<void, string> {
+    return this.checkHashtags(ctx, groupSpecificHashtags(ctx.chatId))
+  }
+
+  private checkHashtags(ctx: Filter<C, "message">, requiredHashtags: string[]): Result<void, string> {
+    const hashtags = ctx.entities("hashtag").map((e) => e.text.toLowerCase())
+    const hasRequired = requiredHashtags.some((tag) => hashtags.includes(tag.toLowerCase()))
+    if (!hasRequired) {
+      return err(`You must include one of the following hashtags in your message: ${requiredHashtags.join(", ")}`)
+    }
+    return ok()
+  }
+
+  middleware() {
+    return this.composer.middleware()
+  }
+}