import io from 'socket.io-client'
import { htmlAnchorForPlace } from './utils'

export class ImmersSocket extends window.EventTarget {
  #token
  /**
   * Is the socket connection active
   * @type {boolean}
   * @public
   */
  connected = false
  /**
   * @param  {string} homeImmer
   * @param  {string} token
   */
  constructor (homeImmer, token) {
    super()
    this.#token = token
    this.socket = io(homeImmer, {
      transportOptions: {
        polling: {
          extraHeaders: {
            Authorization: `Bearer ${token}`
          }
        }
      }
    })
    this.socket.on('connect', () => {
      this.connected = true
      this.dispatchEvent(new window.CustomEvent('immers-socket-connect'))
    })
    this.socket.on('friends-update', () => {
      this.dispatchEvent(new window.CustomEvent('immers-socket-friends-update'))
    })
    this.socket.on('blocked-update', () => {
      this.dispatchEvent(new window.CustomEvent('immers-socket-blocked-update'))
    })
    this.socket.on('inbox-update', activity => {
      activity = JSON.parse(activity)
      this.dispatchEvent(new window.CustomEvent('immers-socket-inbox-update', { detail: activity }))
    })
    this.socket.on('outbox-update', activity => {
      activity = JSON.parse(activity)
      this.dispatchEvent(new window.CustomEvent('immers-socket-outbox-update', { detail: activity }))
    })
  }

  /**
   * @param  {APActor} actorObj
   * @param  {APObject} place
   */
  prepareLeaveOnDisconnect (actorObj, place) {
    this.socket.emit('entered', {
      // prepare a leave activity to be fired on disconnect
      outbox: actorObj.outbox,
      authorization: `Bearer ${this.#token}`,
      leave: {
        type: 'Leave',
        actor: actorObj.id,
        target: place,
        to: actorObj.followers,
        summary: `<span>Left ${htmlAnchorForPlace(place)}</span>`
      }
    })
  }

  clearLeaveOnDisconnect () {
    if (this.connected) {
      this.socket.emit('entered', {})
    }
  }

  /**
   * Terminate socket connection
   */
  disconnect () {
    this.socket?.disconnect()
    this.connected = false
  }
}