package org.argeo.jackrabbit.client;

import java.util.Map;

import javax.jcr.RepositoryException;

import org.apache.jackrabbit.spi.RepositoryService;
import org.apache.jackrabbit.spi.commons.ItemInfoCacheImpl;
import org.apache.jackrabbit.spi2davex.BatchReadConfig;
import org.apache.jackrabbit.spi2davex.Spi2davexRepositoryServiceFactory;

/**
 * Wrapper for {@link Spi2davexRepositoryServiceFactory} in order to create a
 * {@link ClientDavexRepositoryService}.
 */
public class ClientDavexRepositoryServiceFactory extends Spi2davexRepositoryServiceFactory {
	@Override
	public RepositoryService createRepositoryService(Map<?, ?> parameters) throws RepositoryException {
		// retrieve the repository uri
		String uri;
		if (parameters == null) {
			uri = System.getProperty(PARAM_REPOSITORY_URI);
		} else {
			Object repoUri = parameters.get(PARAM_REPOSITORY_URI);
			uri = (repoUri == null) ? null : repoUri.toString();
		}
		if (uri == null) {
			uri = DEFAULT_REPOSITORY_URI;
		}

		// load other optional configuration parameters
		BatchReadConfig brc = null;
		int itemInfoCacheSize = ItemInfoCacheImpl.DEFAULT_CACHE_SIZE;
		int maximumHttpConnections = 0;

		// since JCR-4120 the default workspace name is no longer set to 'default'
		// note: if running with JCR Server < 1.5 a default workspace name must
		// therefore be configured
		String workspaceNameDefault = null;

		if (parameters != null) {
			// batchRead config
			Object param = parameters.get(PARAM_BATCHREAD_CONFIG);
			if (param != null && param instanceof BatchReadConfig) {
				brc = (BatchReadConfig) param;
			}

			// itemCache size config
			param = parameters.get(PARAM_ITEMINFO_CACHE_SIZE);
			if (param != null) {
				try {
					itemInfoCacheSize = Integer.parseInt(param.toString());
				} catch (NumberFormatException e) {
					// ignore, use default
				}
			}

			// max connections config
			param = parameters.get(PARAM_MAX_CONNECTIONS);
			if (param != null) {
				try {
					maximumHttpConnections = Integer.parseInt(param.toString());
				} catch (NumberFormatException e) {
					// using default
				}
			}

			param = parameters.get(PARAM_WORKSPACE_NAME_DEFAULT);
			if (param != null) {
				workspaceNameDefault = param.toString();
			}
		}

		if (maximumHttpConnections > 0) {
			return new ClientDavexRepositoryService(uri, workspaceNameDefault, brc, itemInfoCacheSize,
					maximumHttpConnections);
		} else {
			return new ClientDavexRepositoryService(uri, workspaceNameDefault, brc, itemInfoCacheSize);
		}
	}

}