Laboratoire ICAR » Plateforme TXM

package org.txm.statsengine.r.core;

import java.util.HashMap;

import org.eclipse.core.runtime.IConfigurationElement;

import org.eclipse.core.runtime.IProgressMonitor;

import org.eclipse.core.runtime.RegistryFactory;

import org.txm.core.messages.TXMCoreMessages;

import org.txm.core.results.TXMResult;

import org.txm.statsengine.core.StatsEngine;

import org.txm.statsengine.r.core.exceptions.RWorkspaceException;

import org.txm.statsengine.r.core.messages.RCoreMessages;

import org.txm.statsengine.r.core.preferences.RPreferences;

import org.txm.utils.logger.Log;

/**

 *

 */

public class RStatsEngine extends StatsEngine {

	/** The state of the stats engine. */

	private static boolean started = false;

	private static boolean mandatory = false;

	public RStatsEngine() {

		// no instantiation

	}

	/**

	 * Starts the stats engine if the engine is not remote then launch RServe.

	 *

			if (monitor != null) {

				monitor.subTask("Starting Statistics Engine...");

			}

			if (RPreferences.getInstance().getBoolean(RPreferences.DISABLE)) {

				Log.severe("Warning, Statistics Engine is disabled.");

				return false;

			}

			// try launching R server and connecting to it

			int port = RPreferences.getInstance().getInt(RPreferences.PORT);

			String user = RPreferences.getInstance().getString(RPreferences.USER);

			boolean remote = RPreferences.getInstance().getBoolean(RPreferences.REMOTE);

			boolean debug = RPreferences.getInstance().getBoolean(RPreferences.DEBUG);

			mandatory = RPreferences.getInstance().getBoolean(RPreferences.IS_MANDATORY);

			Log.fine(RCoreMessages.bind(RCoreMessages.info_startingStatsEngine, new Object[] { user, remote, port, debug }));

			// System.out.println("test remote :" + R_PATH_TO_EXECUTABLE + ":" + properties.getProperty(R_PATH_TO_EXECUTABLE));

			if (!remote) {

						debug,

						RPreferences.getInstance().getString(RPreferences.RARGS),

						RPreferences.getInstance().getString(RPreferences.RSERVEARGS));

				if (started) { // try connecting to R witout login

					started = RWorkspace.connect("127.0.0.1", port); //$NON-NLS-1$

				}

			else { // try connecting to R, with login and password

				started = RWorkspace.connect(RPreferences.getInstance().getString(RPreferences.SERVER_ADDRESS), port, user, password);

			}

			if (started) { // post configuration of R

				String rPackagesPath = RPreferences.getInstance().getString(RPreferences.PACKAGES_PATH);

				started = RWorkspace.getRWorkspaceInstance().postConfiguration(rPackagesPath);

			}

			// System.out.println("try to set R_FILE_TRANSFERT to " + RPreferences.getInstance().getBoolean(RPreferences.R_FILE_TRANSFERT));

			RWorkspace.setUseFileCommunication(RPreferences.getInstance().getBoolean(RPreferences.FILE_TRANSFERT));

			// System.out.println("success");

			// System.out.println("file transfert ? "+RWorkspace.isFileTranfert());

			loadRTransformers();

		}

		catch (RWorkspaceException e) {

			Log.severe(RCoreMessages.error_connectionFailed);

			started = false;

		}

		return started;

	}

	public HashMap<String, RTransformer<? extends TXMResult>> getTransformers() {

		return transformers;

	}

	HashMap<String, RTransformer<? extends TXMResult>> transformers = new HashMap<>();

	private void loadRTransformers() {

		transformers.clear();

		IConfigurationElement[] contributions = RegistryFactory.getRegistry().getConfigurationElementsFor(RTransformer.class.getName());

		Log.fine(TXMCoreMessages.bind("Looking for R transformers contributions with extension point id ''{0}''...", RTransformer.class.getName())); //$NON-NLS-1$

		Log.fine(TXMCoreMessages.bind("{0} transformers(s) found.", contributions.length)); //$NON-NLS-1$

		for (int i = 0; i < contributions.length; i++) {

			try {

				@SuppressWarnings("unchecked")

				RTransformer<? extends TXMResult> transformer = (RTransformer<? extends TXMResult>) contributions[i].createExecutableExtension("class"); //$NON-NLS-1$

				Log.finer(TXMCoreMessages.bind("Registering R transformer: {0}...", transformer));

				transformers.put(contributions[i].getAttribute("type"), transformer);

			}

			catch (Exception e) {

			}

		}

	}

	@Override

	public boolean stop() {

		try {

		}

		return true;

	}

	/**

	 * kill Rserve process.

	 */

	public static void kill() {

		if (!RPreferences.getInstance().getBoolean(RPreferences.REMOTE)) {

			try {

				if (StartRserve.rProcess != null) {

					Log.finest("Quitting R process...");

				// TODO Auto-generated catch block

				e1.printStackTrace();

			}

			// FIXME: SJ: became useless ?

			// FIXME: SJ, later: actually it seems R and RTerm are not always terminated on Windows, need to check again before removing this code

			// // Windows OS

		}

	}

	/**

	 * Returns the running state of the stats engine.

	 */

	public static boolean isStarted() {

		return started;

	}

	/**

	 * Checks if the engine is mandatory.

	 * 

	public static boolean isMandatory() {

		return mandatory;

	}

	@Override

	public boolean isRunning() {

		return started;

	}

	@Override

	public boolean initialize() {

		return true;

	}

	@Override

	public String getName() {

		return "R";