Function main

web/scripts/discord/index.ts:71–180

()

}

async function main() {
  const startTime = Date.now()
  log('info', 'Discord bot script starting', {
    pid: process.pid,
    hostname: os.hostname(),
    nodeVersion: process.version,
    platform: process.platform,
  })

  // Handle SIGTERM/SIGINT - shutdown() handles deduplication internally
  process.on('SIGTERM', () => {
    log('info', 'Received SIGTERM signal')
    void shutdown(0)
  })
  process.on('SIGINT', () => {
    log('info', 'Received SIGINT signal')
    void shutdown(0)
  })

  let consecutiveErrors = 0
  let attemptCount = 0

  while (!isShuttingDown) {
    attemptCount++
    const elapsedSec = Math.round((Date.now() - startTime) / 1000)
    log('info', `Attempting to acquire Discord bot lock`, { attemptCount, elapsedSeconds: elapsedSec })

    let acquired = false
    let handle: LockHandle | null = null

    try {
      const result = await tryAcquireAdvisoryLock(ADVISORY_LOCK_IDS.DISCORD_BOT)
      acquired = result.acquired
      handle = result.handle
      consecutiveErrors = 0 // Reset on successful DB connection
      log('info', 'Lock acquisition attempt completed', { acquired, consecutiveErrors })
    } catch (error) {
      consecutiveErrors++
      log('error', `Error acquiring lock`, {
        consecutiveErrors,
        maxErrors: MAX_CONSECUTIVE_ERRORS,
        error: String(error),
      })

      if (consecutiveErrors >= MAX_CONSECUTIVE_ERRORS) {
        log('error', 'Too many consecutive errors, exiting...')
        await shutdown(1)
        return
      }

      log('info', `Will retry in ${LOCK_RETRY_INTERVAL_MS / 1000} seconds...`)
      await sleep(LOCK_RETRY_INTERVAL_MS)
      continue
    }

    if (!acquired || !handle) {
      log('info', `Another instance is already running the Discord bot`, {
        retryInSeconds: LOCK_RETRY_INTERVAL_MS / 1000,