/** @format */

/**
 * External dependencies
 */
import { __, sprintf } from '@wordpress/i18n';
import { addQueryArgs } from '@wordpress/url';
import apiFetch from '@wordpress/api-fetch';
import { uniq } from 'lodash';

/**
 * Internal dependencies
 */
import { getResourceIdentifier, getResourceName } from '../utils';
import { getSetting, setSetting } from '@woocommerce/wc-admin-settings';
import { JETPACK_NAMESPACE, WC_ADMIN_NAMESPACE } from '../constants';
import { pluginNames } from './constants';

function read( resourceNames, fetch = apiFetch ) {
	return [
		...readActivePlugins( resourceNames, fetch ),
		...readProfileItems( resourceNames, fetch ),
		...readJetpackStatus( resourceNames, fetch ),
		...readJetpackConnectUrl( resourceNames, fetch ),
	];
}

function update( resourceNames, data, fetch = apiFetch ) {
	return [
		...activatePlugins( resourceNames, data, fetch ),
		...installPlugins( resourceNames, data, fetch ),
		...updateProfileItems( resourceNames, data, fetch ),
	];
}

function readProfileItems( resourceNames, fetch ) {
	const resourceName = 'onboarding-profile';

	if ( resourceNames.includes( resourceName ) ) {
		const url = WC_ADMIN_NAMESPACE + '/onboarding/profile';

		return [
			fetch( { path: url } )
				.then( profileItemsToResources )
				.catch( error => {
					return { [ resourceName ]: { error: String( error.message ) } };
				} ),
		];
	}

	return [];
}

function updateProfileItems( resourceNames, data, fetch ) {
	const resourceName = 'onboarding-profile';

	if ( resourceNames.includes( resourceName ) ) {
		const url = WC_ADMIN_NAMESPACE + '/onboarding/profile';

		return [
			fetch( {
				path: url,
				method: 'POST',
				data: data[ resourceName ],
			} )
				.then( profileItemToResource.bind( null, data[ resourceName ] ) )
				.catch( error => {
					return { [ resourceName ]: { error } };
				} ),
		];
	}

	return [];
}

function profileItemsToResources( items ) {
	const resourceName = 'onboarding-profile';

	const itemKeys = Object.keys( items );

	const resources = {};
	itemKeys.forEach( key => {
		const item = items[ key ];
		resources[ getResourceName( resourceName, key ) ] = { data: item };
	} );

	return {
		[ resourceName ]: {
			data: itemKeys,
		},
		...resources,
	};
}

function profileItemToResource( items ) {
	const resourceName = 'onboarding-profile';

	const resources = {};
	Object.keys( items ).forEach( key => {
		const item = items[ key ];
		resources[ getResourceName( resourceName, key ) ] = { data: item };
	} );

	return {
		[ resourceName ]: {
			lastReceived: Date.now(),
		},
		...resources,
	};
}

function readActivePlugins( resourceNames, fetch ) {
	const resourceName = 'active-plugins';
	if ( resourceNames.includes( resourceName ) ) {
		const url = WC_ADMIN_NAMESPACE + '/onboarding/plugins/active';

		return [
			fetch( { path: url } )
				.then( activePluginsToResources )
				.catch( error => {
					return { [ resourceName ]: { error: String( error.message ) } };
				} ),
		];
	}

	return [];
}

function activePluginsToResources( items ) {
	const { plugins } = items;
	const resourceName = 'active-plugins';
	return {
		[ resourceName ]: {
			data: plugins,
		},
	};
}

function activatePlugins( resourceNames, data, fetch ) {
	const resourceName = 'plugin-activate';
	if ( resourceNames.includes( resourceName ) ) {
		const plugins = data[ resourceName ];
		const url = WC_ADMIN_NAMESPACE + '/onboarding/plugins/activate';
		return [
			fetch( {
				path: url,
				method: 'POST',
				data: {
					plugins: plugins.join( ',' ),
				},
			} )
				.then( response => activatePluginToResource( response, plugins ) )
				.catch( error => {
					const resources = { [ resourceName ]: { error } };
					Object.keys( plugins ).forEach( key => {
						const pluginError = { ...error };
						const item = plugins[ key ];
						pluginError.message = getPluginErrorMessage( 'activate', item );
						resources[ getResourceName( resourceName, item ) ] = { error: pluginError };
					} );
					return resources;
				} ),
		];
	}

	return [];
}

function activatePluginToResource( response, items ) {
	const resourceName = 'plugin-activate';
	const { activePlugins = [] } = getSetting( 'onboarding', {} );
	setSetting( 'onboarding', {
		...getSetting( 'onboarding', {} ),
		activePlugins: uniq( [ ...activePlugins, ...items ] ),
	} );

	const resources = {
		[ resourceName ]: { data: items },
		[ 'active-plugins' ]: { data: response.active },
	};
	Object.keys( items ).forEach( key => {
		const item = items[ key ];
		resources[ getResourceName( resourceName, item ) ] = { data: item };
	} );
	return resources;
}

function readJetpackStatus( resourceNames, fetch ) {
	const resourceName = 'jetpack-status';

	if ( resourceNames.includes( resourceName ) ) {
		const url = JETPACK_NAMESPACE + '/connection';

		return [
			fetch( {
				path: url,
			} )
				.then( response => {
					return { [ resourceName ]: { data: response } };
				} )
				.catch( error => {
					return { [ resourceName ]: { error: String( error.message ) } };
				} ),
		];
	}

	return [];
}

function readJetpackConnectUrl( resourceNames, fetch ) {
	const filteredNames = resourceNames.filter( name => {
		return name.startsWith( 'jetpack-connect-url' );
	} );

	return filteredNames.map( async resourceName => {
		const query = getResourceIdentifier( resourceName );
		const url = addQueryArgs( WC_ADMIN_NAMESPACE + '/onboarding/plugins/connect-jetpack', query );

		return fetch( {
			path: url,
		} )
			.then( response => {
				return { [ resourceName ]: { data: response.connectAction } };
			} )
			.catch( error => {
				error.message = getPluginErrorMessage( 'connect', 'jetpack' );
				return { [ resourceName ]: { error } };
			} );
	} );
}

function getPluginErrorMessage( action, plugin ) {
	const pluginName = pluginNames[ plugin ] || plugin;
	switch ( action ) {
		case 'install':
			return sprintf(
				__( 'There was an error installing %s. Please try again.', 'woocommerce-admin' ),
				pluginName
			);
		case 'connect':
			return sprintf(
				__( 'There was an error connecting to %s. Please try again.', 'woocommerce-admin' ),
				pluginName
			);
		case 'activate':
		default:
			return sprintf(
				__( 'There was an error activating %s. Please try again.', 'woocommerce-admin' ),
				pluginName
			);
	}
}

function installPlugins( resourceNames, data, fetch ) {
	const resourceName = 'plugin-install';
	if ( resourceNames.includes( resourceName ) ) {
		const plugins = data[ resourceName ];

		return plugins.map( async plugin => {
			return fetch( {
				path: `${ WC_ADMIN_NAMESPACE }/onboarding/plugins/install`,
				method: 'POST',
				data: {
					plugin,
				},
			} )
				.then( response => {
					const { installedPlugins = [] } = getSetting( 'onboarding', {} );
					setSetting( 'onboarding', {
						...getSetting( 'onboarding', {} ),
						installedPlugins: uniq( [ ...installedPlugins, ...plugins ] ),
					} );

					return {
						[ resourceName ]: { data: plugins },
						[ getResourceName( resourceName, plugin ) ]: { data: response },
					};
				} )
				.catch( error => {
					error.message = getPluginErrorMessage( 'install', pluginNames[ plugin ] || plugin );
					return {
						[ resourceName ]: { data: plugins },
						[ getResourceName( resourceName, plugin ) ]: { error },
					};
				} );
		} );
	}

	return [];
}

export default {
	read,
	update,
};