ampache_react/app/actions/APIActions.js

import { normalize, arrayOf } from "normalizr";
import humps from "humps";

import { CALL_API } from "../middleware/api";

import { artist, track, album } from "../models/api";

export const DEFAULT_LIMIT = 30;  /** Default max number of elements to retrieve. */

export default function (action, requestType, successType, failureType) {
    const itemName = action.rstrip("s");

    const fetchItemsSuccess = function (jsonData, pageNumber) {
        // Normalize data
        jsonData = normalize(
            jsonData,
            {
                artist: arrayOf(artist),
                album: arrayOf(album),
                song: arrayOf(track)
            },
            {
                assignEntity: function (output, key, value) {
                    // Delete useless fields
                    if (key == "sessionExpire") {
                        delete output.sessionExpire;
                    } else {
                        output[key] = value;
                    }
                }
            }
        );

        const nPages = Math.ceil(jsonData.result[itemName].length / DEFAULT_LIMIT);
        return {
            type: successType,
            payload: {
                result: jsonData.result,
                entities: jsonData.entities,
                nPages: nPages,
                currentPage: pageNumber
            }
        };
    };
    const fetchItemsRequest = function () {
        return {
            type: requestType,
            payload: {
            }
        };
    };
    const fetchItemsFailure = function (error) {
        return {
            type: failureType,
            payload: {
                error: error
            }
        };
    };
    const fetchItems = function (endpoint, username, passphrase, filter, pageNumber, include = [], limit=DEFAULT_LIMIT) {
        const offset = (pageNumber - 1) * DEFAULT_LIMIT;
        let extraParams = {
            offset: offset,
            limit: limit
        };
        if (filter) {
            extraParams.filter = filter;
        }
        if (include && include.length > 0) {
            extraParams.include = include;
        }
        return {
            type: CALL_API,
            payload: {
                endpoint: endpoint,
                dispatch: [
                    fetchItemsRequest,
                    jsonData => dispatch => {
                        dispatch(fetchItemsSuccess(jsonData, pageNumber));
                    },
                    fetchItemsFailure
                ],
                action: action,
                auth: passphrase,
                username: username,
                extraParams: extraParams
            }
        };
    };
    const loadItems = function({ pageNumber = 1, filter = null, include = [] } = {}) {
        return (dispatch, getState) => {
            const { auth } = getState();
            dispatch(fetchItems(auth.endpoint, auth.username, auth.token.token, filter, pageNumber, include));
        };
    };

    const camelizedAction = humps.pascalize(action);
    var returned = {};
    returned["fetch" + camelizedAction + "Success"] = fetchItemsSuccess;
    returned["fetch" + camelizedAction + "Request"] = fetchItemsRequest;
    returned["fetch" + camelizedAction + "Failure"] = fetchItemsFailure;
    returned["fetch" + camelizedAction] = fetchItems;
    returned["load" + camelizedAction] = loadItems;
    return returned;
}