Add cronjob to notify admin about missing solvers (#314)

bot/start.ts

@@ -63,6 +63,7 @@ const {
   attemptCommunitiesPendingPayments,
   deleteCommunity,
   nodeInfo,
+  checkSolvers,
 } = require('../jobs');
 const { logger } = require('../logger');
 export interface MainContext extends Context {
@@ -197,6 +198,10 @@ const initialize = (botToken: string, options: Partial<Telegraf.Options<MainCont
     await nodeInfo(bot);
   });
 
+  schedule.scheduleJob('0 0 * * *', async () => {
+    await checkSolvers(bot);
+  });
+
   bot.start(async (ctx: MainContext) => {
     try {
       if (!('message' in ctx.update) || !('text' in ctx.update.message)){

jobs/check_solvers.ts

@@ -0,0 +1,40 @@
+import { Community, User } from '../models';
+import { Telegraf } from 'telegraf';
+import { MainContext } from '../bot/start';
+import { logger } from '../logger';
+
+const MAX_MESSAGES = 5; // Number of messages before disabling the community
+
+exports.checkSolvers = async (bot: Telegraf<MainContext>): Promise<void> => {
+    try {
+        const communities = await Community.find({ isDisabled: false });
+
+        for (const community of communities) {
+            const solvers = await User.find({ default_community_id: community._id, role: 'solver' });
+
+            if (solvers.length === 0) {
+                community.messagesSent += 1;
+
+                if (community.messagesSent >= MAX_MESSAGES) {
+                    community.isDisabled = true;
+                    await community.save();
+                    logger.info(`Community ${community._id} has been disabled due to lack of solvers.`);
+                } else {
+                    await community.save();
+                    const admin = await User.findOne({ tg_id: community.creator_id, admin: true });
+                    if (admin) {
+                        await bot.telegram.sendMessage(
+                            admin.tg_id,
+                            `Your community ${community.name} doesn't have any solvers. Please add at least one solver.`
+                        );
+                    }
+                }
+            } else {
+                community.messagesSent = 0; // Reset the counter if solvers are added
+                await community.save();
+            }
+        }
+    } catch (error) {
+        logger.error(error);
+    }
+};

models/community.ts

@@ -49,6 +49,8 @@ export interface ICommunity extends Document {
     currencies: Array<string>;
     created_at: Date;
     nostr_public_key: string;
+    messagesSent: number;
+    isDisabled: boolean;
 }
 
 const CommunitySchema = new Schema<ICommunity>({
@@ -81,6 +83,8 @@ const CommunitySchema = new Schema<ICommunity>({
     },
     created_at: { type: Date, default: Date.now },
     nostr_public_key: { type: String },
+    messagesSent: { type: Number, default: 0 },
+    isDisabled: { type: Boolean, default: false },
 });