@ackee/antonio-utils
Custom Saga effects with built-in cancelation of API requests.
Table of contents
Install
yarn add @ackee/antonio-utils -S
API Reference
takeRequest(actionTypes: TakeRequest, saga: Function)
Parameters
actionTypes: TakeRequest
REQUEST: ActionPattern
- action type that launches the sagaCANCEL: ActionPattern
- action type that aborts the running saga
saga(requestAction, signal: Signal): Function
- the actual API request is made here
Example
import { takeRequest } from '@ackee/antonio-utils';
export default function* () {
yield takeRequest(
{
REQUEST: 'FETCH_TODO_ITEM_REQUEST',
CANCEL: 'FETCH_TODO_ITEM_INVALIDATE',
},
fetchTodoItem,
);
}
takeLatestRequest(params: TakeLatestRequest, saga: Function)
Parameters
params: TakeLatestRequest<RequestAction extends AnyAction, CancelAction extends AnyAction>
REQUEST: RequestAction['type']
- action type that launches the sagacancelTask<A extends AnyAction = AnyAction>(requestId: RequestId, action: A): A;
- Redux action that will cancel the
running sagarequestIdSelector?(action: RequestAction): RequestId;
- A function that receives request action as 1st arg. and returns unique ID of this action, e.g. user ID.
saga(requestAction, signal: Signal): Function
- the actual API request is made here
Example
import { takeLatestRequest } from '@ackee/antonio-utils';
function* fetchTodoItem(requestAction, signal) {
const response = yield* api.get(`todos/1`, {
signal,
});
return response.data;
}
const fetchTodoItemInvalidate = () => ({
type: 'FETCH_TODO_ITEM_INVALIDATE',
});
export default function* () {
yield takeLatestRequest(
{
REQUEST: 'FETCH_TODO_ITEM_REQUEST',
cancelTask: fetchTodoItemInvalidate,
},
fetchTodoItem,
);
}
Example - take latest request for certain user
If requestIdSelector
function provided, instead of cancelling of all previous requests and taking only the last one for certain action type, take the lastest request for certain user, i.e. identify the request by action type and by an ID.
import { takeLatestRequest } from '@ackee/antonio-utils';
function* fetchUser(requestAction, signal) {
const { userId } = requestAction;
const response = yield* api.get(`users/${userId}`, {
signal,
});
return response.data;
}
const fetchUserInvalidate = userId => ({
type: 'FETCH_USER_INVALIDATE',
userId,
});
export default function* () {
yield takeLatestRequest(
{
REQUEST: 'FETCH_USER_REQUEST',
cancelTask: fetchUserInvalidate,
requestIdSelector: action => action.userId,
},
fetchUser,
);
}
Sets or deletes the Authorization
header with provided tokenType
and tokenValue
:
const accessToken = 'eqwo123490ewqj123njir43';
const headers = new Headers();
setAuthHeader(headers, accessToken);
console.assert(headers.get('Authorization') === `Bearer eqwo123490ewqj123njir43`);