Stats: Add stats list to redux tree

client/state/action-types.js

@@ -223,6 +223,10 @@ export const SITE_PLANS_TRIAL_CANCEL = 'SITE_PLANS_TRIAL_CANCEL';
 export const SITE_PLANS_TRIAL_CANCEL_COMPLETED = 'SITE_PLANS_TRIAL_CANCEL_COMPLETED';
 export const SITE_PLANS_TRIAL_CANCEL_FAILED = 'SITE_PLANS_TRIAL_CANCEL_FAILED';
 export const SITE_RECEIVE = 'SITE_RECEIVE';
+export const SITE_STATS_RECEIVE = 'SITE_STATS_RECEIVE';
+export const SITE_STATS_REQUEST = 'SITE_STATS_REQUEST';
+export const SITE_STATS_REQUEST_FAILURE = 'SITE_STATS_REQUEST_FAILURE';
+export const SITE_STATS_REQUEST_SUCCESS = 'SITE_STATS_REQUEST_SUCCESS';
 export const SITE_VOUCHERS_ASSIGN_RECEIVE = 'SITE_VOUCHERS_ASSIGN_RECEIVE';
 export const SITE_VOUCHERS_ASSIGN_REQUEST = 'SITE_VOUCHERS_ASSIGN_REQUEST';
 export const SITE_VOUCHERS_ASSIGN_REQUEST_SUCCESS = 'SITE_VOUCHERS_ASSIGN_REQUEST_SUCCESS';

client/state/stats/lists/actions.js

@@ -0,0 +1,73 @@
+/**
+ * External dependencies
+ */
+import omit from 'lodash/omit';
+
+/**
+ * Internal dependencies
+ */
+import wpcom from 'lib/wp';
+import {
+	SITE_STATS_RECEIVE,
+	SITE_STATS_REQUEST,
+	SITE_STATS_REQUEST_FAILURE,
+	SITE_STATS_REQUEST_SUCCESS
+} from 'state/action-types';
+
+/**
+ * Returns an action object to be used in signalling that stats for a given type of stats and query
+ * have been received.
+ *
+ * @param  {Number} siteId   Site ID
+ * @param  {String} statType Stat Key
+ * @param  {Object} query    Stats query
+ * @param  {Array}  data     Stat Data
+ * @return {Object}          Action object
+ */
+export function receiveSiteStats( siteId, statType, query, data ) {
+	return {
+		type: SITE_STATS_RECEIVE,
+		statType,
+		siteId,
+		query,
+		data
+	};
+}
+
+/**
+ * Returns an action thunk which, when invoked, triggers a network request to
+ * retrieve site stats.
+ *
+ * @param  {Number} siteId   Site ID
+ * @param  {String} statType Type of stats
+ * @param  {Object} query    Stats Query
+ * @return {Function}        Action thunk
+ */
+export function requestSiteStats( siteId, statType, query ) {
+	return ( dispatch ) => {
+		dispatch( {
+			type: SITE_STATS_REQUEST,
+			statType,
+			siteId,
+			query
+		} );
+
+		return wpcom.site( siteId )[ statType ]( query ).then( data => {
+			dispatch( receiveSiteStats( siteId, statType, query, omit( data, '_headers' ) ) );
+			dispatch( {
+				type: SITE_STATS_REQUEST_SUCCESS,
+				statType,
+				siteId,
+				query
+			} );
+		} ).catch( error => {
+			dispatch( {
+				type: SITE_STATS_REQUEST_FAILURE,
+				statType,
+				siteId,
+				query,
+				error
+			} );
+		} );
+	};
+}

client/state/stats/lists/reducer.js

@@ -0,0 +1,86 @@
+/**
+ * External dependencies
+ */
+import { combineReducers } from 'redux';
+import merge from 'lodash/merge';
+
+/**
+ * Internal dependencies
+ */
+import { isValidStateWithSchema } from 'state/utils';
+import { getSerializedStatsQuery } from './utils';
+import { itemSchema } from './schema';
+import {
+	DESERIALIZE,
+	SERIALIZE,
+	SITE_STATS_RECEIVE,
+	SITE_STATS_REQUEST,
+	SITE_STATS_REQUEST_FAILURE,
+	SITE_STATS_REQUEST_SUCCESS,
+} from 'state/action-types';
+
+/**
+ * Returns the updated requests state after an action has been dispatched. The
+ * state maps site ID, post ID and stat keys to whether a request is in progress.
+ *
+ * @param  {Object} state  Current state
+ * @param  {Object} action Action payload
+ * @return {Object}        Updated state
+ */
+export function requesting( state = {}, action ) {
+	switch ( action.type ) {
+		case SITE_STATS_REQUEST:
+		case SITE_STATS_REQUEST_SUCCESS:
+		case SITE_STATS_REQUEST_FAILURE:
+			const queryKey = getSerializedStatsQuery( action.query );
+			return merge( {}, state, {
+				[ action.siteId ]: {
+					[ action.statType ]: {
+						[ queryKey ]: SITE_STATS_REQUEST === action.type
+					}
+				}
+			} );
+
+		case SERIALIZE:
+		case DESERIALIZE:
+			return {};
+	}
+
+	return state;
+}
+
+/**
+ * Returns the updated items state after an action has been dispatched. The
+ * state maps site ID, statType and and serialized query key to the stat payload.
+ *
+ * @param  {Object} state  Current state
+ * @param  {Object} action Action payload
+ * @return {Object}        Updated state
+ */
+export function items( state = {}, action ) {
+	switch ( action.type ) {
+		case SITE_STATS_RECEIVE:
+			const queryKey = getSerializedStatsQuery( action.query );
+			return merge( {}, state, {
+				[ action.siteId ]: {
+					[ action.statType ]: {
+						[ queryKey ]: action.data
+					}
+				}
+			} );
+
+		case DESERIALIZE:
+			if ( isValidStateWithSchema( state, itemSchema ) ) {
+				return state;
+			}
+
+			return {};
+	}
+
+	return state;
+}
+
+export default combineReducers( {
+	requesting,
+	items
+} );

client/state/stats/lists/schema.js

@@ -0,0 +1,20 @@
+export const itemSchema = {
+	type: 'object',
+	patternProperties: {
+		'^\\d+$': {
+			type: 'object',
+			patternProperties: {
+				'^[A-Za-z]+$': {
+					type: 'object',
+					patternProperties: {
+						'^\\{[^\\}]*\\}$': {
+							type: 'object'
+						}
+					}
+				}
+			},
+			additionalProperties: false
+		}
+	},
+	additionalProperties: false
+};

client/state/stats/lists/selectors.js

@@ -0,0 +1,92 @@
+/**
+ * External dependencies
+ */
+import get from 'lodash/get';
+
+/**
+ * Internal dependencies
+ */
+import createSelector from 'lib/create-selector';
+import i18n from 'lib/mixins/i18n';
+import {
+	getSerializedStatsQuery
+} from './utils';
+
+/**
+ * Returns true if currently requesting stats for the statType and query combo, or false
+ * otherwise.
+ *
+ * @param  {Object}  state    Global state tree
+ * @param  {Number}  siteId   Site ID
+ * @param  {String}  statType Type of stat
+ * @param  {Object}  query    Stats query object
+ * @return {Boolean}          Whether stats are being requested
+ */
+export function isRequestingSiteStatsForQuery( state, siteId, statType, query ) {
+	const serializedQuery = getSerializedStatsQuery( query );
+	return !! get( state.stats.lists.requesting, [ siteId, statType, serializedQuery ] );
+}
+
+/**
+ * Returns object of stats data for the statType and query combo, or null if no stats have been
+ * received.
+ *
+ * @param  {Object}  state    Global state tree
+ * @param  {Number}  siteId   Site ID
+ * @param  {String}  statType Type of stat
+ * @param  {Object}  query    Stats query object
+ * @return {?Object}           Data for the query
+ */
+export function getSiteStatsForQuery( state, siteId, statType, query ) {
+	const serializedQuery = getSerializedStatsQuery( query );
+	return get( state.stats.lists.items, [ siteId, statType, serializedQuery ], null );
+}
+
+/**
+ * Returns a parsed object of statsStreak data for a given query, or default "empty" object
+ * if no statsStreak data has been received for that site.
+ *
+ * @param  {Object}  state    Global state tree
+ * @param  {Number}  siteId   Site ID
+ * @param  {Object}  query    Stats query object
+ * @return {Object}           Parsed Data for the query
+ */
+export const getParsedStreakDataForQuery = createSelector(
+	( state, siteId, query ) => {
+		const response = { days: {}, best: { day: 0, percent: 0 }, max: 0 };
+		const days = [ 0, 0, 0, 0, 0, 0, 0 ];
+		let total = 0;
+		const data = getSiteStatsForQuery( state, siteId, 'statsStreak', query ) || [];
+
+		Object.keys( data ).forEach( ( timestamp ) => {
+			const postDay = i18n.moment.unix( timestamp );
+			const datestamp = postDay.format( 'YYYY-MM-DD' );
+			if ( 'undefined' === typeof( response.days[ datestamp ] ) ) {
+				response.days[ datestamp ] = 0;
+			}
+
+			response.days[ datestamp ] += data[ timestamp ];
+			days[ postDay.day() ] += data[ timestamp ];
+			total += data[ timestamp ];
+		} );
+
+		Object.keys( response.days ).forEach( ( datestamp ) => {
+			if ( response.days[ datestamp ] > response.max ) {
+				response.max = response.days[ datestamp ];
+			}
+		} );
+
+		const maxDay = Math.max.apply( null, days );
+		response.best.day = days.indexOf( maxDay );
+		if ( total ) {
+			response.best.percent = Math.round( 100 * ( maxDay / total ) );
+		}
+
+		return response;
+	},
+	( state, siteId, query ) => getSiteStatsForQuery( state, siteId, 'statsStreak', query ),
+	( state, siteId, taxonomy, query ) => {
+		const serializedQuery = getSerializedStatsQuery( query );
+		return [ siteId, 'statsStreak', serializedQuery ].join();
+	}
+);