feat: notify admin to update solvers in the community

bot/start.ts

@@ -62,6 +62,7 @@ import {
   attemptCommunitiesPendingPayments,
   deleteCommunity,
   nodeInfo,
+  checkSolvers,
 } from '../jobs';
 import { logger } from "../logger";
 import { ICommunity, IUsernameId } from '../models/community';
@@ -199,6 +200,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,49 @@
+import { Telegraf } from 'telegraf';
+import { MainContext } from '../bot/start';
+
+import { Community, User, } from '../models';
+import { ICommunity } from '../models/community';
+import { logger } from '../logger';
+
+const MAX_MESSAGES = 5; // Number of messages before disabling the community
+
+const checkSolvers = async (bot: Telegraf<MainContext>) => {
+  try {
+    const communities = await Community.find({ is_disabled: false });
+
+    for (const community of communities) {
+        if (community.solvers.length > 0) {
+            continue;
+        } else {
+            await notifyAdmin(community, bot);
+        }
+    }
+  } catch (error) {
+    const message = String(error);
+    logger.error(`checkSolvers catch error: ${message}`);
+  }
+};
+
+const notifyAdmin = async (community: ICommunity, bot: Telegraf<MainContext>) => {
+  community.messages_sent_count += 1;
+  // The community is disabled if the admin has received the maximum notification message to add a solver
+  if (community.messages_sent_count >= MAX_MESSAGES) {
+    community.is_disabled = true;
+    await community.save();
+
+    logger.info(`Community: ${community.name} has been disabled due to lack of solvers.`);
+    return;
+  }
+
+  await community.save();
+  const admin = await User.findOne({ tg_id: community.creator_id });
+
+  if (admin) {
+    await bot.telegram.sendMessage(
+        admin.tg_id,
+        `Your community ${community.name} doesn't have any solvers. Please add at least one solver to avoid being disabled.`
+    );
+  }
+}
+
+export default checkSolvers;

jobs/index.ts

@@ -7,6 +7,7 @@ import deleteOrders from "./delete_published_orders";
 import calculateEarnings from './calculate_community_earnings'
 import deleteCommunity from './communities'
 import nodeInfo from './node_info'
+import checkSolvers from "./check_solvers";
 
 export {
   attemptPendingPayments,
@@ -16,4 +17,5 @@ export {
   attemptCommunitiesPendingPayments,
   deleteCommunity,
   nodeInfo,
+  checkSolvers,
 };

models/community.ts

@@ -49,6 +49,8 @@ export interface ICommunity extends Document {
     currencies: Array<string>;
     created_at: Date;
     nostr_public_key: string;
+    messages_sent_count: number;
+    is_disabled: 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 },
+    messages_sent_count: { type: Number, default: 0 },
+    is_disabled: { type: Boolean, default: false },
 });