woocommerce/plugins/woocommerce-admin/client/wc-api/reports/stats/operations.js

86 lines
1.9 KiB
JavaScript

/**
* External dependencies
*/
import { addQueryArgs } from '@wordpress/url';
import apiFetch from '@wordpress/api-fetch';
/**
* Internal dependencies
*/
import { getResourceIdentifier, getResourcePrefix } from 'wc-api/utils';
import { NAMESPACE } from 'wc-api/constants';
const statEndpoints = [
'coupons',
'downloads',
'orders',
'products',
'revenue',
'stock',
'taxes',
'customers',
];
const typeEndpointMap = {
'report-stats-query-orders': 'orders',
'report-stats-query-revenue': 'revenue',
'report-stats-query-products': 'products',
'report-stats-query-categories': 'categories',
'report-stats-query-downloads': 'downloads',
'report-stats-query-coupons': 'coupons',
'report-stats-query-stock': 'stock',
'report-stats-query-taxes': 'taxes',
'report-stats-query-customers': 'customers',
};
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 fetchArgs = {
parse: false,
};
if ( statEndpoints.indexOf( endpoint ) >= 0 ) {
fetchArgs.path = addQueryArgs(
`${ NAMESPACE }/reports/${ endpoint }/stats`,
query
);
} else {
fetchArgs.path = addQueryArgs( endpoint, query );
}
try {
const response = await fetch( fetchArgs );
const report = await response.json();
const totalResults = parseInt(
response.headers.get( 'x-wp-total' ), 10
);
const totalPages = parseInt(
response.headers.get( 'x-wp-totalpages' ), 10
);
return {
[ resourceName ]: {
data: report,
totalResults,
totalPages,
},
};
} catch ( error ) {
return { [ resourceName ]: { error } };
}
} );
}
export default {
read,
};