ampache_react/app/actions/APIActions.js

106 lines
3.3 KiB
JavaScript
Raw Normal View History

import { normalize, arrayOf } from "normalizr";
2016-07-07 23:23:18 +02:00
import humps from "humps";
import { CALL_API } from "../middleware/api";
import { artist, track, album } from "../models/api";
export const DEFAULT_LIMIT = 32; /** Default max number of elements to retrieve. */
2016-07-07 23:23:18 +02:00
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);
2016-07-07 23:23:18 +02:00
return {
type: successType,
payload: {
result: jsonData.result,
entities: jsonData.entities,
nPages: nPages,
currentPage: pageNumber
2016-07-07 23:23:18 +02:00
}
};
};
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 = {
2016-07-07 23:23:18 +02:00
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));
2016-07-07 23:23:18 +02:00
},
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));
2016-07-07 23:23:18 +02:00
};
};
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;
}