|
import axios from 'axios';
|
|
import MockAdapter from 'axios-mock-adapter';
|
|
import thunk from 'redux-thunk';
|
|
import Immutable from 'seamless-immutable';
|
|
import configureMockStore from 'redux-mock-store';
|
|
import {
|
|
bulkSearchSuccessResponse,
|
|
bulkSearchSuccessActions,
|
|
buildBulkSearchFailureActions,
|
|
getTaskSuccessResponse,
|
|
getTaskSuccessActions,
|
|
buildTaskFailureActions,
|
|
getTaskPendingResponse,
|
|
getTaskPendingActions,
|
|
} from './task.fixtures';
|
|
|
|
import { bulkSearch, loadTask, pollTaskUntilDone, pollBulkSearch } from '../TaskActions';
|
|
|
|
const mockStore = configureMockStore([thunk]);
|
|
const store = mockStore({ tasks: Immutable({}) });
|
|
const mockApi = new MockAdapter(axios);
|
|
|
|
beforeEach(() => {
|
|
store.clearActions();
|
|
mockApi.reset();
|
|
});
|
|
|
|
let originalTimeout;
|
|
let setTimeoutSpy;
|
|
|
|
beforeEach(() => {
|
|
setTimeoutSpy = jest.spyOn(window, 'setTimeout');
|
|
|
|
originalTimeout = jasmine.DEFAULT_TIMEOUT_INTERVAL;
|
|
jasmine.DEFAULT_TIMEOUT_INTERVAL = 10000;
|
|
});
|
|
|
|
afterEach(() => {
|
|
setTimeoutSpy.mockReset();
|
|
setTimeoutSpy.mockRestore();
|
|
|
|
jasmine.DEFAULT_TIMEOUT_INTERVAL = originalTimeout;
|
|
});
|
|
|
|
describe('task actions', () => {
|
|
describe('creates TASK_BULK_SEARCH_REQUEST', () => {
|
|
const url = '/foreman_tasks/api/tasks/bulk_search';
|
|
|
|
it('and then fails with 422', () => {
|
|
mockApi.onPost(url).reply(422);
|
|
|
|
return store.dispatch(bulkSearch())
|
|
.then(() => expect(store.getActions()).toEqual(buildBulkSearchFailureActions()));
|
|
});
|
|
|
|
it('and ends with success', () => {
|
|
mockApi.onPost(url).reply(200, bulkSearchSuccessResponse);
|
|
|
|
return store.dispatch(bulkSearch())
|
|
.then(() => expect(store.getActions()).toEqual(bulkSearchSuccessActions));
|
|
});
|
|
});
|
|
|
|
describe('creates GET_TASK_REQUEST', () => {
|
|
const taskId = 'eb1b6271-8a69-4d98-84fc-bea06ddcc166';
|
|
const url = `/foreman_tasks/api/tasks/${taskId}`;
|
|
|
|
it('and then fails with 422', () => {
|
|
mockApi.onGet(url).reply(422);
|
|
|
|
return store.dispatch(loadTask(taskId))
|
|
.then(() => expect(store.getActions()).toEqual(buildTaskFailureActions()));
|
|
});
|
|
|
|
it('and ends with success', () => {
|
|
mockApi.onGet(url).reply(200, getTaskSuccessResponse);
|
|
|
|
return store.dispatch(loadTask(taskId))
|
|
.then(() => expect(store.getActions()).toEqual(getTaskSuccessActions));
|
|
});
|
|
});
|
|
|
|
describe('pollTaskUntilDone', () => {
|
|
const taskId = 'eb1b6271-8a69-4d98-84fc-bea06ddcc166';
|
|
const url = `/foreman_tasks/api/tasks/${taskId}`;
|
|
|
|
it("doesn't start polling when the task has finished", () => {
|
|
mockApi.onGet(url).replyOnce(200, getTaskSuccessResponse);
|
|
|
|
return store
|
|
.dispatch(pollTaskUntilDone(taskId, {}, 1))
|
|
.then(() => {
|
|
expect(store.getActions()).toEqual(getTaskSuccessActions);
|
|
expect(setTimeoutSpy).toHaveBeenCalledTimes(0);
|
|
});
|
|
});
|
|
|
|
it('polls until a task is done', () => {
|
|
mockApi
|
|
.onGet(url)
|
|
.replyOnce(200, getTaskPendingResponse)
|
|
.onGet(url)
|
|
.replyOnce(200, getTaskPendingResponse)
|
|
.onGet(url)
|
|
.replyOnce(200, getTaskSuccessResponse);
|
|
|
|
const expectedActions = getTaskPendingActions
|
|
.concat(getTaskPendingActions)
|
|
.concat(getTaskSuccessActions);
|
|
|
|
return store
|
|
.dispatch(pollTaskUntilDone(taskId, {}, 1))
|
|
.then(() => {
|
|
expect(store.getActions()).toEqual(expectedActions);
|
|
expect(setTimeoutSpy).toHaveBeenCalledTimes(2);
|
|
});
|
|
});
|
|
|
|
it('stops polling on unauthorized response', () => {
|
|
mockApi
|
|
.onGet(url).replyOnce(200, getTaskPendingResponse)
|
|
.onGet(url).replyOnce(401);
|
|
|
|
const expectedActions = getTaskPendingActions
|
|
.concat(buildTaskFailureActions(401));
|
|
|
|
return store
|
|
.dispatch(pollTaskUntilDone(taskId, {}, 1))
|
|
.catch(() => {
|
|
expect(store.getActions()).toEqual(expectedActions);
|
|
expect(setTimeoutSpy).toHaveBeenCalledTimes(1);
|
|
});
|
|
});
|
|
});
|
|
|
|
describe('pollBulkSearch', () => {
|
|
const url = '/foreman_tasks/api/tasks/bulk_search';
|
|
|
|
it('polls', () => {
|
|
mockApi
|
|
.onPost(url)
|
|
.replyOnce(200, bulkSearchSuccessResponse);
|
|
|
|
return store
|
|
.dispatch(pollBulkSearch({}, 1))
|
|
.then(() => {
|
|
expect(store.getActions()).toEqual(bulkSearchSuccessActions);
|
|
expect(setTimeoutSpy).toHaveBeenCalledTimes(1);
|
|
});
|
|
});
|
|
|
|
it('stops polling on unauthorized response', () => {
|
|
mockApi
|
|
.onPost(url).replyOnce(401);
|
|
|
|
return store
|
|
.dispatch(pollBulkSearch({}, 1))
|
|
.then(() => {
|
|
expect(store.getActions()).toEqual(buildBulkSearchFailureActions(401));
|
|
expect(setTimeoutSpy).toHaveBeenCalledTimes(0);
|
|
});
|
|
});
|
|
});
|
|
});
|
