servi/org.eclipse.statet.rj.servi/src/org/eclipse/statet/rj/servi/node/RServiImpl.java

/*=============================================================================#
 # Copyright (c) 2009, 2019 Stephan Wahlbrink and others.
 # 
 # This program and the accompanying materials are made available under the
 # terms of the Eclipse Public License 2.0 which is available at
 # https://www.eclipse.org/legal/epl-2.0, or the Apache License, Version 2.0
 # which is available at https://www.apache.org/licenses/LICENSE-2.0.
 # 
 # SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
 # 
 # Contributors:
 #     Stephan Wahlbrink <sw@wahlbrink.eu> - initial API and implementation
 #=============================================================================*/

package org.eclipse.statet.rj.servi.node;

import static org.eclipse.statet.rj.server.util.ServerUtils.JCOMMONS_UTIL_ID;
import static org.eclipse.statet.rj.server.util.ServerUtils.RJ_DATA_ID;
import static org.eclipse.statet.rj.server.util.ServerUtils.RJ_SERVER_ID;
import static org.eclipse.statet.rj.servi.RServiUtils.RJ_SERVI_ID;

import org.eclipse.statet.jcommons.collections.ImCollections;
import org.eclipse.statet.jcommons.collections.ImList;
import org.eclipse.statet.jcommons.lang.NonNullByDefault;
import org.eclipse.statet.jcommons.rmi.RMIRegistry;

import org.eclipse.statet.internal.rj.servi.LocalNodeFactory;
import org.eclipse.statet.internal.rj.servi.LocalNodeManager;
import org.eclipse.statet.internal.rj.servi.PoolManager;
import org.eclipse.statet.rj.RjInvalidConfigurationException;
import org.eclipse.statet.rj.server.util.RJContext;
import org.eclipse.statet.rj.servi.pool.RServiPoolManager;


/**
 * Factory for RServi objects
 */
@NonNullByDefault
public class RServiImpl {
	
	
	private static final ImList<String> LIB_IDS= ImCollections.newList(
			RJ_SERVI_ID, RJ_SERVER_ID, RJ_DATA_ID, JCOMMONS_UTIL_ID );
	
	
	/**
	 * Creates a node factory establishing RServi nodes on the local system.
	 * 
	 * This method is intended for RServi pools when utilizing the default bundles.
	 * 
	 * @param poolId the id of the pool or application
	 * @param context context to resolve the RJ libraries
	 * @return a node factory
	 * @throws RjInvalidConfigurationException
	 */
	public static RServiNodeFactory createLocalNodeFactory(final String poolId, final RJContext context)
			throws RjInvalidConfigurationException {
		final ImList<String> libIds= LIB_IDS;
		context.searchRJLibs(libIds); // check
		
		return new LocalNodeFactory(poolId, context, libIds);
	}
	
	/**
	 * Creates an {@link RServiPoolManager RServi pool}.
	 * 
	 * @param poolId the id of the pool
	 * @param registry a handler for the RMI registry to use
	 * @return the pool manager
	 */
	public static RServiPoolManager createPool(final String poolId, final RMIRegistry registry) {
		return new PoolManager(poolId, registry);
	}
	
	/**
	 * Creates an {@link RServiNodeManager RServi node manager}.
	 * 
	 * @param id the id (like the poolId)
	 * @param registry a handler for the RMI registry to use
	 * @param factory the node factory to use to establish the node
	 * @return the manager for the RServi instance
	 */
	public static RServiNodeManager createNodeManager(final String id, final RMIRegistry registry,
			final RServiNodeFactory factory) {
		if (factory instanceof LocalNodeFactory) {
			return new LocalNodeManager(id, registry, (LocalNodeFactory) factory);
		}
		throw new UnsupportedOperationException(factory.getClass().getName());
	}
	
}