import triggerFetch from '@wordpress/api-fetch';

const createRegistryControl = function createRegistryControl( registryControl ) {
	registryControl.isRegistryControl = true;

	return registryControl;
};

export const apiFetch = ( request ) => {
	return {
		type: 'API_FETCH',
		request,
	};
};

export function select( storeKey, selectorName, ...args ) {
	return {
		type: 'SELECT',
		storeKey,
		selectorName,
		args,
	};
}

export function dispatch( storeKey, actionName, ...args ) {
	return {
		type: 'DISPATCH',
		storeKey,
		actionName,
		args,
	};
}

const resolveSelect = ( registry, { storeKey, selectorName, args } ) => {
	return new Promise( ( resolve ) => {
		const hasFinished = () => registry.select( '' )
			.hasFinishedResolution( storeKey, selectorName, args );

		const getResult = () => registry.select( storeKey )[ selectorName ]
			.apply( null, args );

		const result = getResult();

		if ( hasFinished() ) {
			return resolve( result );
		}

		const unsubscribe = registry.subscribe( () => {
			if ( hasFinished() ) {
				unsubscribe();
				resolve( getResult() );
			}
		} );
	} );
};

export const controls = {
	API_FETCH( { request } ) {
		return triggerFetch( request );
	},
	SELECT: createRegistryControl(
		( registry ) => ( { storeKey, selectorName, args } ) => {
			return registry.select( storeKey )[ selectorName ].hasResolver
				? resolveSelect( registry, { storeKey, selectorName, args } )
				: registry.select( storeKey )[ selectorName ]( ...args );
		}
	),
	DISPATCH: createRegistryControl(
		( registry ) => ( { storeKey, actionName, args } ) => {
			return registry.dispatch( storeKey )[ actionName ]( ...args );
		}
	),
};