porkchopclub/porkchop

import { createAction } from 'redux-actions'

import cable from '../cable'

export const clockTick = createAction('ONGOING_MATCH_TICK')

export const startTimer = () => (dispatch) =>
  setInterval(
    () => dispatch(clockTick()),
    1000
  )

export const ongoingMatchUpdated = createAction('ONGOING_MATCH_UPDATED')

export const ongoingMatchConnected = createAction('ONGOING_MATCH_CONNECTED')
export const ongoingMatchDisconnected = createAction('ONGOING_MATCH_DISCONNECTED')

export const trackOngoingMatch = (tableId) => (dispatch) => {
  const dispatchMatchUpdate = (match) => dispatch(ongoingMatchUpdated(match))

  cable.subscriptions.create({ channel: 'OngoingMatchChannel', table_id: tableId }, {
    received: (json) => {
      const data = JSON.parse(json)
      dispatchMatchUpdate(data)
    },
    disconnected: () => dispatch(ongoingMatchDisconnected()),
    connected: () => dispatch(ongoingMatchConnected()),
  })

  setInterval(() => {
    if (Date.now() - cable.connection.monitor.pingedAt > 5000) {
      dispatch(ongoingMatchDisconnected())
    } else {
      dispatch(ongoingMatchConnected())
    }
  }, 200)

  fetch(`/api/v2/tables/${tableId}/matches/ongoing`)
    .then((response) => response.json())
    .then((json) => dispatchMatchUpdate(json))

  dispatch(startTimer())
}