Laboratoire ICAR » Plateforme TXM

// Copyright © 2010-2013 ENS de Lyon.

// Copyright © 2007-2010 ENS de Lyon, CNRS, INRP, University of

// Lyon 2, University of Franche-Comté, University of Nice

// Sophia Antipolis, University of Paris 3.

// 

// The TXM platform is free software: you can redistribute it

// and/or modify it under the terms of the GNU General Public

// License as published by the Free Software Foundation,

// either version 2 of the License, or (at your option) any

// later version.

// 

// The TXM platform is distributed in the hope that it will be

// useful, but WITHOUT ANY WARRANTY; without even the implied

// warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR

// PURPOSE. See the GNU General Public License for more

// details.

// 

// You should have received a copy of the GNU General

// Public License along with the TXM platform. If not, see

// http://www.gnu.org/licenses.

// 

// 

// 

// $LastChangedDate:$

// $LastChangedRevision:$

// $LastChangedBy:$ 

//

package org.txm.statsengine.r.core;

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

import org.txm.utils.Watcher;

// TODO: Auto-generated Javadoc

/**

 * The Class RserveWatcher.

 */

//FIXME: not used ?

public class RserveWatcher extends Watcher	{

	/**

	 * Instantiates a new rserve watcher.

	 */

	public RserveWatcher()

	{

		this.processname = "RSERVE"; //$NON-NLS-1$

	}

	/* (non-Javadoc)

	 * @see org.txm.Watcher#check()

	 */

	@Override

	protected boolean check() {

		RWorkspace rw;

		try {

			rw = RWorkspace.getRWorkspaceInstance();

		} catch (RWorkspaceException e1) {

			System.out.println("Rserve watcher encounter an error: "+e1); //$NON-NLS-1$

			return false;

		}

		if (rw == null)

		{

			return false;

		}

		else

		{

			try {

				rw.eval("print(\"test\")"); //$NON-NLS-1$

			} catch (Exception e) {

				System.out.println("Rserve watcher encounter an error: "+e); //$NON-NLS-1$

				return false;

			}

		}

		return true;

	}

	/* (non-Javadoc)

	 * @see org.txm.Watcher#restart()

	 */

	@Override

	protected boolean restart() {

		return Toolbox.restartStatEngine(true);

	}

}

host *;               # allow access from any host (including localhost)

# users must login with name "anonymous" and explicit "" as password!

user anonymous "";

 org.txm.statsengine.r.rcp,

	/** The symbol. */

	private String symbol;

	/** The novoc. */

	protected static int novoc = 1;

	/** The prefix r. */

	protected static String prefixR = "Index"; //$NON-NLS-1$

	 * As r matrix.

	 *

	 * @return the string

	 * @throws RWorkspaceException the r workspace exception

	 */

	public String asRMatrix() throws RWorkspaceException {

		symbol = prefixR+novoc;

		ArrayList<String> colnames = new ArrayList<String>();

		colnames.add("F"); //$NON-NLS-1$

		if (partnames.size() > 1)

			for (int j = 0; j < partnames.size(); j++)

				colnames.add(partnames.get(j)); 

		//System.out.println("cols: "+colnames);

		String[] keywords = new String[this.lines.size()];

		int[] freq = new int[this.lines.size()];

		ArrayList<int[]> partfreqs = new ArrayList<int[]>(partnames.size());

		if (partnames.size() > 1)

			for (int j = 0; j < partnames.size(); j++)

				partfreqs.add(new int[this.lines.size()]);

		for (int i = 0 ; i < lines.size() ; i++) 

		{

			Line ligne = lines.get(i);

			freq[i] = ligne.getFrequency(); 

			keywords[i] = ligne.toString();

			if (partnames.size() > 1)

				for (int j = 0; j < partnames.size(); j++)

				{

					partfreqs.get(j)[i] = ligne.getFrequency(j);

				}

		}

		RWorkspace rw = RWorkspace.getRWorkspaceInstance();

		if (partnames.size() > 1)

			for (int j = 0; j < partnames.size(); j++)

				rw.addVectorToWorkspace("vocpartfreqs"+j, partfreqs.get(j)); //$NON-NLS-1$

		rw.addVectorToWorkspace("vocfreq", freq); //$NON-NLS-1$

		rw.addVectorToWorkspace("vockeywords", keywords); //$NON-NLS-1$

		rw.addVectorToWorkspace("voccolnames", colnames.toArray(new String[colnames.size()])); //$NON-NLS-1$

		int ncol = 1;

		if (partnames.size() > 1)

			ncol += partnames.size();

		int nrow = lines.size();

		String partscmd = ""; //$NON-NLS-1$

		if (partnames.size() > 1)

			for (int j = 0; j < partnames.size(); j++)

				partscmd +=", vocpartfreqs"+j; //$NON-NLS-1$

		rw.eval(symbol+ "<- matrix(data = c(vocfreq"+partscmd+"), nrow = "+nrow+", ncol = "+ncol+")"); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ //$NON-NLS-4$

		rw.eval("colnames("+symbol+" ) <- voccolnames"); //$NON-NLS-1$ //$NON-NLS-2$

		rw.eval("rownames("+symbol+" ) <- vockeywords"); //$NON-NLS-1$ //$NON-NLS-2$

		rw.eval(symbol+ "<- list(data="+symbol+")"); //$NON-NLS-1$ //$NON-NLS-2$

		novoc++;

		return symbol;

	}

	/**

	 * Gets the symbol.

	 *

	 * @return the symbol

	 */

	public String getSymbol()

	{

		return symbol;

	}

	/**

            defaultHandler="org.txm.statsengine.r.rcp.handlers.SendToR"

Export-Package: org.txm.statsengine.r.rcp.views

// Copyright © 2010-2013 ENS de Lyon.

// Copyright © 2007-2010 ENS de Lyon, CNRS, INRP, University of

// Lyon 2, University of Franche-Comté, University of Nice

// Sophia Antipolis, University of Paris 3.

// 

// The TXM platform is free software: you can redistribute it

// and/or modify it under the terms of the GNU General Public

// License as published by the Free Software Foundation,

// either version 2 of the License, or (at your option) any

// later version.

// 

// The TXM platform is distributed in the hope that it will be

// useful, but WITHOUT ANY WARRANTY; without even the implied

// warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR

// PURPOSE. See the GNU General Public License for more

// details.

// 

// You should have received a copy of the GNU General

// Public License along with the TXM platform. If not, see

// http://www.gnu.org/licenses.

// 

// 

// 

// $LastChangedDate:$

// $LastChangedRevision:$

// $LastChangedBy:$ 

//

package org.txm.statsengine.r.rcp;

import org.eclipse.jface.dialogs.MessageDialog;

import org.eclipse.swt.widgets.Display;

import org.txm.rcpapplication.Messages;

import org.txm.rcpapplication.views.corpora.CorporaView;

import org.txm.statsengine.r.core.RserveWatcher;

// TODO: Auto-generated Javadoc

/**

 * Watch if RServe is running

 */

@Deprecated

public class TXMRServeWatcher extends RserveWatcher{

	/** The parent. */

	private Display parent;

	/**

	 * Instantiates a new tXMR serve watcher.

	 *

	 * @param parent the parent

	 */

	TXMRServeWatcher(Display parent)

	{

		this.parent = parent;

	}

	/* (non-Javadoc)

	 * @see org.txm.RserveWatcher#restart()

	 */

	@Override

	public boolean restart()

	{

		parent.syncExec(new Runnable(){

		      @Override

			public void run(){

		    	  MessageDialog d =

					    new MessageDialog(

					      parent.getActiveShell(),

					      Messages.TXMRServeWatcher_0,

					      null,

					      Messages.TXMRServeWatcher_1,

					      MessageDialog.ERROR,

					      new String[] { Messages.TXMRServeWatcher_2 },

					      0);

					    d.open();

		      }

		    });

		boolean ret = super.restart();

		parent.syncExec(new Runnable(){

		      @Override

			public void run(){

		    	  MessageDialog d =

					    new MessageDialog(

					      parent.getActiveShell(),

					      Messages.TXMRServeWatcher_3,

					      null,

					      Messages.TXMRServeWatcher_4,

					      MessageDialog.ERROR,

					      new String[] { Messages.TXMRServeWatcher_2 },

					      0);

					    d.open();

		      }

		    });

		if (ret)

		{

			parent.syncExec(new Runnable(){

			      @Override

				public void run(){

			    	  CorporaView.reload();

			      }

			    });

		}

		return ret;

	}

}

// Copyright © 2010-2013 ENS de Lyon.

// Copyright © 2007-2010 ENS de Lyon, CNRS, INRP, University of

// Lyon 2, University of Franche-Comté, University of Nice

// Sophia Antipolis, University of Paris 3.

// 

// The TXM platform is free software: you can redistribute it

// and/or modify it under the terms of the GNU General Public

// License as published by the Free Software Foundation,

// either version 2 of the License, or (at your option) any

// later version.

// 

// The TXM platform is distributed in the hope that it will be

// useful, but WITHOUT ANY WARRANTY; without even the implied

// warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR

// PURPOSE. See the GNU General Public License for more

// details.

// 

// You should have received a copy of the GNU General

// Public License along with the TXM platform. If not, see

// http://www.gnu.org/licenses.

// 

// 

// 

// $LastChangedDate:$

// $LastChangedRevision:$

// $LastChangedBy:$ 

//

package org.txm.statsengine.r.rcp.handlers;

import java.util.List;

import org.eclipse.core.commands.ExecutionEvent;

import org.eclipse.core.commands.ExecutionException;

import org.eclipse.core.runtime.IProgressMonitor;

import org.eclipse.core.runtime.IStatus;

import org.eclipse.core.runtime.Status;

import org.eclipse.jface.viewers.IStructuredSelection;

import org.eclipse.ui.IEditorPart;

import org.eclipse.ui.IEditorReference;

import org.eclipse.ui.IWorkbenchPage;

import org.eclipse.ui.IWorkbenchWindow;

import org.eclipse.ui.handlers.HandlerUtil;

import org.eclipse.ui.internal.Workbench;

import org.txm.ca.core.functions.CA;

import org.txm.cooccurrence.core.functions.Cooccurrence;

import org.txm.cooccurrence.rcp.editors.CooccurrencesEditor;

import org.txm.functions.concordances.Concordance;

import org.txm.functions.referencer.Referencer;

import org.txm.index.core.functions.Index;

import org.txm.index.rcp.editors.IndexEditor;

import org.txm.lexicaltable.core.statsengine.data.LexicalTable;

import org.txm.lexicaltable.rcp.editors.LexicalTableEditor;

import org.txm.lexicaltable.rcp.editors.LexicalTableEditor2;

import org.txm.lexicon.core.corpusengine.cqp.Lexicon;

import org.txm.progression.core.functions.Progression;

import org.txm.rcp.handlers.BaseAbstractHandler;

import org.txm.rcpapplication.JobsTimer;

import org.txm.rcpapplication.commands.editor.CustomizableEditor;

import org.txm.rcpapplication.editors.concordances.ConcordancesEditor;

import org.txm.rcpapplication.editors.referencer.ReferencerEditor;

import org.txm.rcpapplication.utils.JobHandler;

import org.txm.rcpapplication.views.corpora.CorporaView;

import org.txm.searchengine.cqp.corpus.Corpus;

import org.txm.specificities.core.functions.SpecificitesResult;

import org.txm.specificities.rcp.editors.SpecificitiesTableEditor;

import org.txm.statsengine.core.data.Vector;

import org.txm.statsengine.r.rcp.messages.RUIMessages;

import org.txm.statsengine.r.rcp.views.RVariablesView;

// TODO: Auto-generated Javadoc

/**

 * Delete the selection: TXMObjects and results code for the results must be

 * added manually here @ author mdecorde.

 */

public class SendToR extends BaseAbstractHandler {

	/* (non-Javadoc)

	 * @see org.eclipse.core.commands.AbstractHandler#execute(org.eclipse.core.commands.ExecutionEvent)

	 */

	@Override

	public Object execute(ExecutionEvent event) throws ExecutionException {

		if(!super.checkStatsEngine())	{

			return null;

		}

		IStructuredSelection selection = (IStructuredSelection) HandlerUtil.getCurrentSelection(event);

		final List list = selection.toList();

		JobHandler jobhandler = new JobHandler(RUIMessages.SendToR_0+ list) {

				@Override

				protected IStatus run(IProgressMonitor monitor) {

					this.runInit(monitor);

					try {

						JobsTimer.start();

						monitor.beginTask(RUIMessages.SendToR_0+ list, 100);

						int delta = 100 / list.size();

						//System.out.println(selection.toList());

						for(Object o : list)

							try {

								monitor.subTask(RUIMessages.SendToR_0+ o);

								this.acquireSemaphore();

								send(o);

								this.releaseSemaphore();

								monitor.worked(delta);

							} catch (Exception e) {

								// TODO Auto-generated catch block

								org.txm.rcpapplication.utils.Logger.printStackTrace(e);

							}

						monitor.subTask(RUIMessages.SendToR_3);

						this.syncExec(new Runnable() {

							@Override

							public void run() {

								CorporaView.refresh();

								RVariablesView.reload();

							}

						});

					} catch (ThreadDeath td) {

						return Status.CANCEL_STATUS;

					} finally {

						monitor.done();

						JobsTimer.stopAndPrint();

					}

					return Status.OK_STATUS;

				}

			};

			jobhandler.startJob();

			return null;

	}

	/**

	 * Send.

	 *

	 * @param o the o

	 * @throws Exception the exception

	 */

	public static void send(Object o) throws Exception {

		if (o instanceof Lexicon) 

		{

			Lexicon lex = (Lexicon) o;

			Vector v = lex.asVector();

			lex.setSymbol(v.getSymbol());

			System.out.println(lex.getName()+" >> "+lex.getSymbol()); //$NON-NLS-1$

		}  else if (o instanceof Corpus) {

			Corpus corpus = (Corpus) o;

			String symbol = corpus.SendToR();

			System.out.println(corpus.getName()+" >> "+symbol); //$NON-NLS-1$

		} else if (o instanceof Concordance) {

			Concordance conc = (Concordance) o;

			String symbol = conc.asRMatrix();

			System.out.println(conc.getName()+" >> "+conc.getSymbol()); //$NON-NLS-1$

		} else if (o instanceof Referencer) {

			Referencer referencer = (Referencer) o;

			String symbol = referencer.asRMatrix();

			System.out.println(referencer.getName()+" >> "+referencer.getSymbol()); //$NON-NLS-1$

		} else if (o instanceof Cooccurrence) {

			Cooccurrence cooc = (Cooccurrence) o;

			String symbol = cooc.asRMatrix();

			System.out.println(cooc.getName()+" >> "+cooc.getSymbol()); //$NON-NLS-1$

		} else if (o instanceof Index) {

			Index voc = (Index) o;

			voc.asRMatrix();

			System.out.println(voc.getName()+" >> "+voc.getSymbol()); //$NON-NLS-1$

		}

	}

	/**

	 * Close the editors which uses an Object.

	 *

	 * @param o the object used by an editor

	 */

	// FIXME: this method should only contains one test on TXMEditor.getResult() and moved to non-R code/plug-in

	public static void closeEditorOfSelection(Object o)

	{

		if (o != null) {

			//get all editors

			//check editor class

			//test if object used dispose editor if necessary

			if (o instanceof Concordance)

			{

				for(IWorkbenchPage page : getPages())

				{

					for(IEditorReference editorref : page.getEditorReferences())

					{

						IEditorPart editor = editorref.getEditor(false);

						if (editor instanceof ConcordancesEditor)

							if (((Concordance)o).equals(((ConcordancesEditor)editor).getConcordance()))

								editor.getEditorSite().getPage().closeEditor(editor, true);

					}

				}

			}

			else if (o instanceof Cooccurrence)

			{

				for(IWorkbenchPage page : getPages())

				{

					for(IEditorReference editorref : page.getEditorReferences())

					{

						IEditorPart editor = editorref.getEditor(false);

						if (editor instanceof CooccurrencesEditor)

							if (o.equals(((CooccurrencesEditor)editor).getCooc()))

								editor.getEditorSite().getPage().closeEditor(editor, true);

					}

				}

			}

			else if (o instanceof CA)

			{

				for(IWorkbenchPage page : getPages())

				{

					for(IEditorReference editorref : page.getEditorReferences())

					{

						IEditorPart editor = editorref.getEditor(false);

						if (editor instanceof CAEditor)

							if (o.equals(((CAEditor)editor).getCA()))

								editor.getEditorSite().getPage().closeEditor(editor, true);

					}

				}

			}

			else if (o instanceof SpecificitesResult)

			{

				for(IWorkbenchPage page : getPages())

				{

					for(IEditorReference editorref : page.getEditorReferences())

					{

						IEditorPart editor = editorref.getEditor(false);

						if (editor instanceof SpecificitiesTableEditor)

							if (o.equals(((SpecificitiesTableEditor)editor).getSpecificitiesResult()))

								editor.getEditorSite().getPage().closeEditor(editor, true);

					}

				}

			}

			else if (o instanceof Index)

			{

				for(IWorkbenchPage page : getPages())

				{

					for(IEditorReference editorref : page.getEditorReferences())

					{

						IEditorPart editor = editorref.getEditor(false);

						if (editor instanceof IndexEditor)

						{

							if (o.equals(((IndexEditor)editor).getIndex()))

								editor.getEditorSite().getPage().closeEditor(editor, true);

						}

					}

				}

			}

			else if (o instanceof LexicalTable)

			{

				for(IWorkbenchPage page : getPages())

				{

					for(IEditorReference editorref : page.getEditorReferences())

					{

						IEditorPart editor = editorref.getEditor(false);

						if (editor instanceof LexicalTableEditor)

							if (o.equals(((LexicalTableEditor2)editor).getLexicalTable()))

								editor.getEditorSite().getPage().closeEditor(editor, true);

					}

				}

			}

			else if (o instanceof Referencer)

			{

				for(IWorkbenchPage page : getPages())

				{

					for(IEditorReference editorref : page.getEditorReferences())

					{

						IEditorPart editor = editorref.getEditor(false);

						if (editor instanceof ReferencerEditor)

							if (o.equals(((ReferencerEditor)editor).getReferencer()))

								editor.getEditorSite().getPage().closeEditor(editor, true);

					}

				}

			} 

			else if (o instanceof Progression) 

			{

				Progression rep = (Progression)o;

				for(IWorkbenchPage page : getPages())

				{

					for(IEditorReference editorref : page.getEditorReferences())

					{

						IEditorPart editor = editorref.getEditor(false);

						if (editor instanceof CustomizableEditor)

						{	

							Object source = ((CustomizableEditor)editor).getSource();

							if (source != null && source instanceof Progression)

								if (rep.equals(source))

									editor.getEditorSite().getPage().closeEditor(editor, true);

						}

					}

				}

			}

		}

	}

	/**

	 * Gets the pages.

	 *

	 * @return the pages

	 */

	private static IWorkbenchPage[] getPages()

	{

		for(IWorkbenchWindow win : Workbench.getInstance().getWorkbenchWindows())

		{

			return win.getPages();

		}

		return new IWorkbenchPage[0];

	}

}

//FIXME: this interface has been created to manage the result baed on interface AND implementation, for example: interface LexicalTable.

import org.kohsuke.args4j.*

import org.txm.searchengine.cqp.corpus.*

import org.txm.utils.logger.Log;

import org.txm.stat.engine.r.RWorkspace

import org.txm.Toolbox

import org.txm.stat.StatException

import org.txm.functions.specificities.*

import org.kohsuke.args4j.*

import groovy.transform.Field

import org.txm.rcpapplication.swt.widget.parameters.*

import org.txm.stat.engine.r.RWorkspace

import org.txm.stat.engine.r.RWorkspace

import org.rosuda.REngine.REXP;

import org.txm.Toolbox;

import org.txm.stat.engine.r.RWorkspace;

import groovy.transform.Field

import org.txm.rcpapplication.commands.*

import org.txm.Toolbox

import org.txm.stat.engine.r.RWorkspace