check-groups.js

require('dotenv').config({ path: './.env' })
const {
  db
} = require('./database')
const Telegram = require('telegraf/telegram')

const telegram = new Telegram(process.env.BOT_TOKEN)

const checkGroup = async (group) => {
  const result = await telegram.sendChatAction(group.group_id, 'typing').catch(error => {
    return error.response
  })
  if (result) {
    const active = result.ok !== false
    // Targeted update — a full group.save() would race with concurrent
    // $inc writes on quoteCounter from the live bot.
    await db.Group.updateOne(
      { _id: group._id },
      { $set: { 'available.active': active, 'available.check': true } }
    )
  }
  return { group_id: group.group_id, result }
}

let checkRunning = false
const MAX_ITERATIONS = 1000 // Prevent infinite loops
let iterationCount = 0

const checkGroups = async () => {
  if (checkRunning) return
  checkRunning = true

  try {
    const groups = await db.Group.find({ 'available.check': { $ne: true } }).limit(100)

    if (groups.length === 0) {
      console.log('All groups checked, exiting...')
      checkRunning = false
      process.exit(0)
      return
    }

    iterationCount++
    if (iterationCount >= MAX_ITERATIONS) {
      console.log('Max iterations reached, exiting...')
      checkRunning = false
      process.exit(0)
      return
    }

    const checkArray = groups.map(checkGroup)
    console.log(await Promise.all(checkArray))

    checkRunning = false

    // Add delay to prevent overwhelming the system
    // Use early return to prevent infinite recursion
    if (iterationCount < MAX_ITERATIONS) {
      setTimeout(() => {
        checkGroups()
      }, 1000)
    } else {
      console.log('Max iterations reached in timeout, exiting...')
      process.exit(0)
    }
  } catch (error) {
    console.error('Error in checkGroups:', error)
    checkRunning = false
    process.exit(1)
  }
}

checkGroups()