woocommerce/plugins/woocommerce-admin/client/wc-api/items/operations.js

150 lines
3.9 KiB
JavaScript
Raw Normal View History

/**
* External dependencies
*/
import { addQueryArgs } from '@wordpress/url';
import apiFetch from '@wordpress/api-fetch';
/**
* Internal dependencies
*/
import {
getResourceIdentifier,
getResourcePrefix,
getResourceName,
} from '../utils';
import { NAMESPACE } from '../constants';
const typeEndpointMap = {
'items-query-categories': 'products/categories',
'items-query-customers': 'customers',
'items-query-coupons': 'coupons',
'items-query-leaderboards': 'leaderboards',
'items-query-orders': 'orders',
'items-query-products': 'products',
'items-query-taxes': 'taxes',
};
function read( resourceNames, fetch = apiFetch ) {
const filteredNames = resourceNames.filter( ( name ) => {
const prefix = getResourcePrefix( name );
return Boolean( typeEndpointMap[ prefix ] );
} );
return filteredNames.map( async ( resourceName ) => {
const prefix = getResourcePrefix( resourceName );
const endpoint = typeEndpointMap[ prefix ];
const query = getResourceIdentifier( resourceName );
const url = addQueryArgs( `${ NAMESPACE }/${ endpoint }`, query );
const isUnboundedRequest = query.per_page === -1;
try {
const response = await fetch( {
/* eslint-disable max-len */
/**
* A false parse flag allows a full response including headers which are useful
* to determine totalCount. However, this invalidates an unbounded request, ie
* `per_page: -1` by skipping middleware in apiFetch.
*
* See the Gutenberg code for more:
* https://github.com/WordPress/gutenberg/blob/dee3dcf49028717b4af3164e3096bfe747c41ed2/packages/api-fetch/src/middlewares/fetch-all-middleware.js#L39-L45
*/
/* eslint-enable max-len */
parse: isUnboundedRequest,
path: url,
} );
let items;
let totalCount;
if ( isUnboundedRequest ) {
items = response;
totalCount = items.length;
} else {
items = await response.json();
totalCount = parseInt(
response.headers.get( 'x-wp-total' ),
10
);
}
const ids = items.map( ( item ) => item.id );
const itemResources = items.reduce( ( resources, item ) => {
resources[ getResourceName( `${ prefix }-item`, item.id ) ] = {
data: item,
};
return resources;
}, {} );
return {
[ resourceName ]: {
data: ids,
totalCount,
},
...itemResources,
};
} catch ( error ) {
return { [ resourceName ]: { error } };
}
} );
}
function update( resourceNames, data, fetch = apiFetch ) {
const updateableTypes = [ 'items-query-products-item' ];
const filteredNames = resourceNames.filter( ( name ) => {
return updateableTypes.includes( getResourcePrefix( name ) );
} );
return filteredNames.map( async ( resourceName ) => {
const { id, parent_id: parentId, type, ...itemData } = data[
resourceName
];
let url = NAMESPACE;
switch ( type ) {
case 'variation':
url += `/products/${ parentId }/variations/${ id }`;
break;
case 'variable':
case 'simple':
default:
url += `/products/${ id }`;
}
return fetch( { path: url, method: 'PUT', data: itemData } )
.then( ( item ) => {
return { [ resourceName ]: { data: item } };
} )
.catch( ( error ) => {
return { [ resourceName ]: { error } };
} );
} );
}
function updateLocally( resourceNames, data ) {
const updateableTypes = [ 'items-query-products-item' ];
const filteredNames = resourceNames.filter( ( name ) => {
return updateableTypes.includes( getResourcePrefix( name ) );
} );
const lowStockResourceName = getResourceName( 'items-query-products', {
page: 1,
per_page: 1,
low_in_stock: true,
status: 'publish',
} );
return filteredNames.map( async ( resourceName ) => {
return {
[ resourceName ]: { data: data[ resourceName ] },
// Force low stock products to be re-fetched after updating an item.
[ lowStockResourceName ]: { lastReceived: null },
};
} );
}
export default {
read,
update,
updateLocally,
};