import { BaseEvent } from '#application/base/baseEvent'
import Database from '#application/database'
import ZoneManager from '#managers/zoneManager'
import CharacterHairRepository from '#repositories/characterHairRepository'
import CharacterRepository from '#repositories/characterRepository'

interface CharacterConnectPayload {
  characterId: number
  characterHairId?: number
}

export default class CharacterConnectEvent extends BaseEvent {
  public listen(): void {
    this.socket.on('character:connect', this.handleEvent.bind(this))
  }

  /**
   * Handle character connect event
   * @TODO:
   * 1. Check if character is already connected
   * 2. Update character hair if provided
   * 3. Emit character connect event
   * 4. Let other clients know of new character
   * @param data
   * @param callback
   * @private
   */
  private async handleEvent(data: CharacterConnectPayload, callback: (response: any) => void): Promise<void> {
    if (!this.socket.userId) {
      this.emitError('User not authenticated')
      return
    }

    try {
      if (await this.checkForActiveCharacters()) {
        this.emitError('You are already connected to another character')
        return
      }

      const character = await CharacterRepository.getByUserAndId(this.socket.userId, data.characterId)

      if (!character) {
        this.emitError('Character not found or does not belong to this user')
        return
      }

      await Database.getEntityManager().populate(character, ['zone'])

      // Set character id
      this.socket.characterId = character.id

      // Set character hair
      if (data.characterHairId !== undefined && data.characterHairId !== null) {
        const characterHair = await CharacterHairRepository.getById(data.characterHairId)
        await character.setCharacterHair(characterHair).update()
      }

      // Emit character connect event
      callback({
        character,
        zone: character.zone,
        characters: ZoneManager.getZoneById(character.zone!.id)?.getCharactersInZone()
      })
    } catch (error) {
      this.handleError('Failed to connect character', error) // @TODO : Make global error handler
    }
  }

  private async checkForActiveCharacters(): Promise<boolean> {
    const characters = await CharacterRepository.getByUserId(this.socket.userId!)
    return characters?.some((char) => ZoneManager.getCharacterById(char.id)) ?? false
  }
}