hongbo-miao/hongbomiao.com

import { StateObservable } from 'redux-observable';
import { Observable, throwError, timer } from 'rxjs';
import { AjaxResponse, AjaxError } from 'rxjs/ajax';
// eslint-disable-next-line import/no-unresolved
import { ColdObservable } from 'rxjs/internal/testing/ColdObservable';
import { switchMap } from 'rxjs/operators';
import { TestScheduler } from 'rxjs/testing';
import RootState from '../../shared/types/RootState';
import MeAction from '../actions/MeAction';
import meQuery from '../queries/meQuery';
import queryMeEpic from './queryMeEpic';

describe('queryMeEpic', () => {
  const res = {
    response: {
      data: {
        name: 'Hongbo Miao',
        bio: 'Making magic happen',
      },
    },
  } as AjaxResponse<unknown>;
  const err = new Error('Test error') as AjaxError;

  test('queryMeSucceed', () => {
    const marbles = {
      i: '-i', // Input action
      r: '--r', // Mock API response
      o: '---o', // Output action
    };

    const scheduler = new TestScheduler((actual, expected) => {
      expect(actual).toEqual(expected);
      expect(actual[0].notification.value.payload.res).toEqual(res);
    });

    scheduler.run(({ hot, cold, expectObservable }) => {
      const action$ = hot(marbles.i, {
        i: MeAction.queryMe(meQuery),
      });
      const state$ = {} as StateObservable<RootState>;
      const dependencies = {
        fetchData: (): ColdObservable<AjaxResponse<unknown>> =>
          cold(marbles.r, {
            r: res,
          }),
      };
      const output$ = queryMeEpic(action$, state$, dependencies);
      expectObservable(output$).toBe(marbles.o, {
        o: MeAction.queryMeSucceed(res),
      });
    });
  });

  test('queryMeFailed', () => {
    const scheduler = new TestScheduler((actual, expected) => {
      expect(actual).toEqual(expected);
      expect(actual[0].notification.value.payload).toEqual(err);
    });
    const marbles = {
      i: '-i', // Input action
      d: '--|', // Mock API response time duration
      o: '---o', // Output action
    };

    scheduler.run(({ hot, expectObservable }) => {
      const action$ = hot(marbles.i, {
        i: MeAction.queryMe(meQuery),
      });
      const state$ = {} as StateObservable<RootState>;
      const duration = scheduler.createTime(marbles.d);
      const dependencies = {
        fetchData: (): Observable<never> => timer(duration).pipe(switchMap(() => throwError(err))),
      };
      const output$ = queryMeEpic(action$, state$, dependencies);
      expectObservable(output$).toBe(marbles.o, {
        o: MeAction.queryMeFailed(err),
      });
    });
  });
});