application/redux/actions/user-actions.js

import BaseService from './../../services/base-service';
 
class UserService extends BaseService {
 
    fetch(opts) {
        return this.get('/v3/user', opts);
    }
 
    fetchOne(id) {
        return this.get('/v3/user/' + id);
    }
 
    create(data) {
        return this.post('/v3/user', data);
    }
 
    update(id, data) {
        return this.put('/v3/user/' + id, data);
    }
 
    remove(uuid) {
        return this.delete('/v3/user/' + uuid);
    }
 
    updateMe(data) {
        return this.put('/v3/me', data);
    }
 
    search(query) {
        return this.get('/v3/search', data);
    }
}
 
const service = new UserService;
 
/**
 * Action types
 */
export const USERS_REQUEST = 'USERS_REQUEST';
export const USERS_RECEIVE = 'USERS_RECEIVE';
export const USER_RECEIVE = 'USER_RECEIVE';
export const USER_SELECTED = 'USER_SELECTED';
export const USERS_INVALIDATE = 'USERS_INVALIDATE';
 
export const USERS_RECEIVE_PAGINATION = 'USERS_RECEIVE_PAGINATION';
 
/**
 * Action creators
 */
export function usersReceivePagination(pagination) {
    return {
        type: USERS_RECEIVE_PAGINATION,
        payload: {
            before: pagination.get('before'),
            current: pagination.get('current'),
            first: pagination.get('first'),
            last: pagination.get('last'),
            limit: pagination.get('limit'),
            next: pagination.get('next'),
            total_items: pagination.get('total_items'),
            total_pages: pagination.get('total_pages'),
        }
    };
}
 
export function usersRequest(params = {}) {
    return {
        type: USERS_REQUEST,
        payload: {
            params: params
        }
    };
}
 
export function usersReceive(items) {
 
    return {
        type: USERS_RECEIVE,
        payload: {
            users: items ? items : []
        }
    };
}
 
export function userReceive(user) {
    return {
        type: USER_RECEIVE,
        payload: {
            user: user ? user : {}
        }
    };
}
 
export function userSetSelected(user) {
    return {
        type: USER_SELECTED,
        payload: {
            selected: user ? user : false
        }
    };
}
 
export function usersInvalidate() {
    return {
        type: USERS_INVALIDATE,
        payload: {
        }
    };
}
 
export function userUpdate(id, data) {
    return function(dispatch, getState) {
        dispatch(usersRequest({}));
 
        return service.update(id, data)
            .then(response => {
                return dispatch(userReceive(response.first()));
            });
   }
}
 
export function userUpdateMe(data) {
    return function(dispatch, getState) {
        dispatch(usersRequest({}));
        return service.updateMe(data)
            .then(response => {
                return response.first();
            });
    }
}
 
export function userCreate(data) {
    return function(dispatch, getState) {
        dispatch(usersRequest({}));
 
        return service.create(data)
            .then(response => {
                return dispatch(userReceive(response.first()));
            });
   }
}
 
export function usersShouldFetch(state) {
    const users = state.users;
    if (!users.items.length) {
        return true;
    } else if (users.isFetching) {
        return false;
    }
 
    return users.didInvalidate;
}
 
export function usersMaybeFetch(params = {}) {
    return function(dispatch, getState) {
        const users = getState().users.items;
 
        if (getState().users.isFetching) {
            return Promise.resolve();
        }
 
        if (!users.items || !users.items.size) {
            return dispatch(usersFetch(params));
        }
 
        return Promise.resolve();
    }
};
 
export function usersSearch(params = {}) {
    return function(dispatch, getState) {
        dispatch(usersRequest(params));
 
        params.per_page = params.per_page ? params.per_page : 20;
        params.order = params.order ? params.order : "name";
        params.dir = params.dir ? params.dir : "asc";
 
        // default page
        let page = 0;
 
        if (params.page) {
            // specific page is requested
            page = params.page;
        } else if (getState().users.pagination.current) {
            // existing pagination
            page = getState().users.pagination.current;
        }
 
        if (page) {
            params.page = page;
        }
 
        return service.search(params)
            .then(response => {
                dispatch(usersReceivePagination(response));
                return dispatch(usersReceive(response.get('items')));
            });
    };
};
 
export function usersFetch(params = {}) {
    return function(dispatch, getState) {
        dispatch(usersRequest(params));
 
        params.per_page = params.per_page ? params.per_page : 20;
        params.order = params.order ? params.order : "name";
        params.dir = params.dir ? params.dir : "asc";
 
        // default page
        let page = 0;
 
        if (params.page) {
            // specific page is requested
            page = params.page;
        } else if (getState().users.pagination.current) {
            // existing pagination
            page = getState().users.pagination.current;
        }
 
        if (page) {
            params.page = page;
        }
 
        return service.fetch(params)
            .then(response => {
                dispatch(usersReceivePagination(response));
                return dispatch(usersReceive(response.get('items')));
            });
    };
}
 
export function usersFetchOne(id) {
    return function (dispatch, getState) {
        dispatch(usersRequest({}));
 
        return service.fetchOne(id)
            .then(response => {
                return dispatch(userReceive(response.first()));
            });
    }
}
 
export function usersRemove(uuid) {
    return function (dispatch, getState) {
        dispatch(usersInvalidate());
 
        return service.remove(uuid);
    }
}