KawAnime/store/modules/releases/actions.js

import {axios, log, isRoot} from '../../utils'

export default {
  async init ({state, commit, dispatch}) {
    console.log('[INIT] Releases')

    const {data, status} = await axios.get('getLatestNyaa', { params: state.params })

    if (status === 200) {
      commit('set', data)

      if (state.autoRefresh === true) dispatch('autoRefresh')
    } else if (status === 202) {
      log(`An error occurred while getting the latest releases. Retrying in 45 seconds.`)
      commit('setInfoSnackbar', 'Could not get the latest releases. Retrying in 45 seconds.', isRoot)
      setTimeout(() => {
        log(`Retrying to get latest releases.`)
        dispatch('init').catch(err => { void (err) })
      }, 45 * 1000)
    } else if (status === 204) {
      log('nyaa.si does not respond... Switching to nyaa.pantsu.cat.')

      commit('setChoice', 'pantsu')

      const {data, status} = await axios.get('getLatestNyaa', { params: state.params })

      if (status === 200) {
        commit('set', data)

        if (state.autoRefresh === true) dispatch('autoRefresh')
      } else if (status === 202) {
        log(`An error occurred while getting the latest releases. Retrying in 45 seconds.`)
        commit('setInfoSnackbar', 'Could not get the latest releases. Retrying in 45 seconds.')
        setTimeout(() => {
          log(`Retrying to get latest releases.`)
          dispatch('init').catch(err => { void (err) })
        }, 45 * 1000)
      } else if (status === 204) {
        log('nyaa.pantsu.cat does not respond... Switching to HorribleSubs.')

        commit('setChoice', 'si')

        const {data, status} = await axios.get(`getLatest.json?quality=${state.params.quality}`)

        if (status === 200) {
          commit('set', data)

          if (state.autoRefresh === true) dispatch('autoRefresh')
        } else if (status === 202) {
          log(`An error occurred while getting the latest releases. Retrying in 45 seconds.`)
          commit('setInfoSnackbar', 'Could not get the latest releases. Retrying in 45 seconds.')
          setTimeout(function () {
            log(`Retrying to get latest releases.`)
            dispatch('init').catch(err => { void (err) })
          }, 45 * 1000)
        } else if (status === 204) {
          log('HorribleSubs does not respond. Retrying with nyaa.si...')

          dispatch('init')
        }
      }
    }
  },
  async refresh ({state, commit, dispatch}) {
    log(`Refreshing Releases...`)

    commit('empty')

    const {data, status} = await axios.get('getLatestNyaa', { params: state.params })

    if (status === 200) commit('set', data)
    else if (status === 202) {
      log(`An error occurred while getting the latest releases. Retrying in 45 seconds.`)
      commit('setInfoSnackbar', 'Could not get the latest releases. Retrying in 45 seconds.', isRoot)
      setTimeout(() => {
        log(`Retrying to get latest releases.`)
        dispatch('refresh').catch(err => { void (err) })
      }, 45 * 1000)
    } else if (status === 204) {
      const {data, status} = await axios.get(`getLatest.json?quality=${state.params.quality}`)

      if (status === 200) commit('set', data)
      else if (status === 202 || status === 204) {
        log(`An error occurred while getting the latest releases. Retrying in 45 seconds.`)
        commit('setInfoSnackbar', 'Could not get the latest releases. Retrying in 45 seconds.', isRoot)
        setTimeout(() => {
          log(`Retrying to get latest releases.`)
          dispatch('refresh').catch(err => { void (err) })
        }, 45 * 1000)
      }
    }
  },
  async autoRefresh ({dispatch, commit, state}) {
    // Refresh releases every 30 minutes
    setTimeout(async () => {
      log(`Refreshing Releases...`)

      try {
        const {data} = await axios.get('getLatestNyaa', { params: state.params })

        if (data.length === 18) {
          commit('set', data)
          dispatch('autoRefresh')
        } else {
          commit('setInfoSnackbar', 'Auto refresh releases failed... Attempting again in 30 minutes.')

          dispatch('autoRefresh')
        }
      } catch (e) {
        commit('setInfoSnackbar', 'Auto refresh releases failed... Attempting again in 30 minutes.')

        dispatch('autoRefresh')
      }
    }, 30 * 60 * 1000)
  }
}