shlinkio / shlink-web-client

import { Action, Dispatch } from 'redux';

import { ShlinkMercureInfo } from '../../utils/services/types';

import { GetState } from '../../container/types';

import { buildReducer } from '../../utils/helpers/redux';

import { ShlinkApiClientBuilder } from '../../utils/services/ShlinkApiClientBuilder';

/* eslint-disable padding-line-between-statements */

export const GET_MERCURE_INFO_START = 'shlink/mercure/GET_MERCURE_INFO_START';

export const GET_MERCURE_INFO_ERROR = 'shlink/mercure/GET_MERCURE_INFO_ERROR';

export const GET_MERCURE_INFO = 'shlink/mercure/GET_MERCURE_INFO';

/* eslint-enable padding-line-between-statements */

export interface MercureInfo {

  token?: string;

  mercureHubUrl?: string;

  interval?: number;

  loading: boolean;

  error: boolean;

}

export type GetMercureInfoAction = Action<string> & ShlinkMercureInfo & { interval?: number };

const initialState: MercureInfo = {

  loading: true,

  error: false,

};

export default buildReducer<MercureInfo, GetMercureInfoAction>({

  [GET_MERCURE_INFO_START]: (state) => ({ ...state, loading: true, error: false }),

  [GET_MERCURE_INFO_ERROR]: (state) => ({ ...state, loading: false, error: true }),

  [GET_MERCURE_INFO]: (_, action) => ({ ...action, loading: false, error: false }),

}, initialState);

export const loadMercureInfo = (buildShlinkApiClient: ShlinkApiClientBuilder) =>

  () => async (dispatch: Dispatch, getState: GetState) => {

    dispatch({ type: GET_MERCURE_INFO_START });

    const { settings } = getState();

    const { mercureInfo } = buildShlinkApiClient(getState);

    if (!settings.realTimeUpdates.enabled) {

      dispatch({ type: GET_MERCURE_INFO_ERROR });

      return;

    }

    try {

      const info = await mercureInfo();

      dispatch<GetMercureInfoAction>({ type: GET_MERCURE_INFO, interval: settings.realTimeUpdates.interval, ...info });

    } catch (e) {

      dispatch({ type: GET_MERCURE_INFO_ERROR });

    }

  };