javascript 用于调试无状态Redux-Observable的Action Logger

Posted 2021-05-03

import { filter, ignoreElements, tap } from 'rxjs/operators'

import { TOTAL_UPDATED } from './actions/requests'

const ignoreList = [
  TOTAL_UPDATED,
]

const actionLoggerEpic = (
  action$
) => (
  action$
  .pipe(
    filter(action => {
      !action
      || typeof action !== 'object'
      && (
        console
        .error("Action must be an `object` type.")
      )

      return action
    }),
    filter(action => {
      !action.type
      && (
        console
        .error("Action must have a `type` property.")
      )

      return action.type
    }),
    filter(({ type }) => (
      !(
        ignoreList
        .includes(type)
      )
    )),
    tap(({
      type,
      ...payload
    }) => {
      console
      .info(
        type,
        payload,
      )
    }),
    ignoreElements(),
  )
)

export default actionLoggerEpic