universoimpulso/atena

import { sendError } from 'log-on-slack'

import Reaction from '../models/Reaction'
import User from '../models/User'
import ScoreController from './ScoreController'
class ReactionController {
  async handle(payload) {
    try {
      const { provider, reactions } = payload

      const reactionsSaved = await Reaction.find({
        'provider.messageId': provider.messageId
      })

      if (reactionsSaved.length > reactions.length) {
        const reactionsRemoved = this.findReactions({
          mostReactions: reactionsSaved,
          lessReactions: reactions
        })
        this.removeReactions({ reactionsRemoved, payload })
      }

      if (reactionsSaved.length < reactions.length) {
        const reactionsAdded = this.findReactions({
          mostReactions: reactions,
          lessReactions: reactionsSaved
        })
        this.saveReactions({ reactionsAdded, payload })
      }
    } catch (error) {
      sendError({
        file: 'src/controllers/reaction - handle',
        payload,
        error
      })
    }
  }

  findReactions({ mostReactions, lessReactions }) {
    const reactions = []
    for (const reaction of mostReactions) {
      const { provider, content } = reaction
      const duplicated = lessReactions.find(
        reaction =>
          reaction.content === content &&
          reaction.provider.username === provider.username
      )
      if (duplicated) continue
      reactions.push(reaction)
    }
    return reactions
  }

  async saveReactions({ reactionsAdded, payload }) {
    try {
      for (const reaction of reactionsAdded) {
        const { provider } = reaction
        const user = await User.findOne({
          [`${provider.name}.username`]: provider.username
        })

        if (user) reaction.user = user.uuid

        await Reaction.create(reaction)
        ScoreController.handleReaction({ reaction, payload })
      }
    } catch (error) {
      sendError({
        file: 'src/controllers/reaction - saveReactions',
        payload: { reactionsAdded, payload },
        error
      })
    }
  }

  async removeReactions({ reactionsRemoved, payload }) {
    try {
      for (const reaction of reactionsRemoved) {
        await Reaction.deleteOne({ _id: reaction._id })
        ScoreController.removeScoreFromReaction({ reaction, payload })
      }
    } catch (error) {
      sendError({
        file: 'src/controllers/reaction - removeReactions',
        payload: { reactionsRemoved, payload },
        error
      })
    }
  }

  async anonymize(uuid) {
    try {
      const reactions = await Reaction.find({ user: uuid })

      for (const reaction of reactions) {
        reaction.provider.username = null
        await reaction.save()
      }
    } catch (error) {
      sendError({
        file: 'Reaction.anonymize',
        payload: uuid,
        error
      })
    }
  }
}

export default new ReactionController()