notification.js

import axios from 'axios'
import dayjs from 'dayjs'
import utc from 'dayjs/plugin/utc.js'
import timezone from 'dayjs/plugin/timezone.js'

dayjs.extend(utc)
dayjs.extend(timezone)

import { database } from './firebase.js'

const timezoneBR = 'America/Sao_Paulo'

const SLACK_WEBHOOK = process.env.SLACK_WEBHOOK
const BISPER_WEBHOOK = process.env.BISPER_WEBHOOK

const BISPER_DEBOUNCE_INTERVAL = 4 * 60 * 60 * 1000 // 4 hours
let lastBisperNotification = dayjs().subtract(3, 'hour')

let namesDictionary

function formatMessage(ranking, recentReactions = []) {
  const sortedNames = Object.keys(ranking).sort((a, b) => ranking[a].position - ranking[b].position)

  const detailedPositions = sortedNames.reduce((msg, name) => {
    const rnkngInfo = ranking[name]
    const positionChange = rnkngInfo.prevRelease?.position - rnkngInfo.position
    const positivePositionChangeText = positionChange > 0 ? `:arrow_up: ${positionChange}` : ''
    const negativePositionChangeText = positionChange < 0 ? `:small_red_triangle_down: ${positionChange * -1}` : ''
    const positionChangeText = positivePositionChangeText || negativePositionChangeText
    const pointsChange = rnkngInfo.points - rnkngInfo.prevRelease?.points
    const pointsChangeText = pointsChange ? (pointsChange > 0 ? `(+${pointsChange})` : `(${pointsChange})`) : ''
    return `${msg} ${rnkngInfo.position}º ${namesDictionary[name] || name}: ${rnkngInfo.points}${pointsChangeText} ${positionChangeText} \n`
  }, '')

  const dateLabel = dayjs().tz(timezoneBR).format('D, MMMM, YYYY')
  
  const message = `:wave: Ranking Individual do IEE :statue_of_liberty: \n\n :spiral_calendar_pad: ${dateLabel} \n\n ${detailedPositions}`
  
  return message
}

async function notify(ranking) {
  if (!namesDictionary) {
    const namesSnap = await database.ref('names').once('value')
    namesDictionary = namesSnap.val()
  }

  const message = formatMessage(ranking)

  const now = dayjs()
  const shouldSendBisper = now.diff(lastBisperNotification, 'millisecond') >= BISPER_DEBOUNCE_INTERVAL

  console.log('lastBisperNotification', lastBisperNotification.format(), now.format())
  console.log('shouldSendBisper', shouldSendBisper)

  const promises = [axios.post(SLACK_WEBHOOK, { text: message })]
  
  if (shouldSendBisper) {
    promises.push(axios.post(BISPER_WEBHOOK, { text: message }, {
      headers: {
        'key': process.env.BISPER_API_KEY
      }
    }))
    lastBisperNotification = now
  }

  await Promise.all(promises)
}

async function notifyReaction(reaction) {
  if (!namesDictionary) {
    const namesSnap = await database.ref('names').once('value')
    namesDictionary = namesSnap.val()
  }

  const associateName = namesDictionary[reaction.associateName] || reaction.associateName
  const emoji = reaction.emoji
  const createdBy = reaction.createdBy || 'Anônimo'
  const message = reaction.message ? `\n💬 "${reaction.message}"` : ''
  
  const reactionMessage = `${associateName} recebeu ${emoji} de ${createdBy}${message}\n`

  try {
    await axios.post(BISPER_WEBHOOK, { text: reactionMessage }, {
      headers: {
        'key': process.env.BISPER_API_KEY
      }
    })
  } catch (error) {
    console.error('Erro ao enviar notificação de reação:', error)
  }
}

export { notify, notifyReaction }