package org.autoplot.datasource.jython; import java.beans.ExceptionListener; import java.io.BufferedReader; import java.io.File; import java.io.FileInputStream; import java.io.FileReader; import java.io.IOException; import java.io.InputStream; import java.net.URI; import java.net.URL; import java.util.ArrayList; import java.util.HashMap; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.logging.Level; import java.util.logging.Logger; import java.util.regex.Matcher; import java.util.regex.Pattern; import org.das2.util.monitor.NullProgressMonitor; import org.das2.util.monitor.ProgressMonitor; import org.python.core.Py; import org.python.core.PyException; import org.python.core.PyList; import org.python.core.PyStringMap; import org.python.util.PythonInterpreter; import org.autoplot.datasource.AbstractDataSourceFactory; import org.autoplot.datasource.CompletionContext; import org.autoplot.datasource.DataSetURI; import org.autoplot.datasource.DataSource; import org.autoplot.datasource.LogNames; import org.autoplot.datasource.URISplit; import org.autoplot.datasource.capability.TimeSeriesBrowse; import static org.autoplot.datasource.jython.JythonDataSource.PARAM_SCRIPT; import org.autoplot.jythonsupport.JythonRefactory; import org.autoplot.jythonsupport.JythonUtil; import org.autoplot.jythonsupport.PyQDataSet; /** * * @author jbf */ public class JythonDataSourceFactory extends AbstractDataSourceFactory { private static final Logger logger= Logger.getLogger( LogNames.APDSS_JYDS ); @Override public DataSource getDataSource(URI uri) throws Exception { JythonDataSource result = new JythonDataSource(uri,this); return result; } /** * get the name of the script, which is non-trivial since it can be in either the resourceURI or script= * @return */ private static String getScript(String suri) { String jythonScript; // script to run. URISplit split= URISplit.parse(suri); Map params= URISplit.parseParams(split.params); if ( params.get( PARAM_SCRIPT )!=null ) { // getFile( resourceURI ) //TODO: since we don't getFile(resourceURI), we can't use filePollUpdating. Also, why do we have local variable? jythonScript= params.get( PARAM_SCRIPT ); } else { jythonScript= split.resourceUri.toString(); } return jythonScript; } private Map getNames(URI uri, ProgressMonitor mon) throws Exception { URISplit split= URISplit.parse(uri); Map paramsl= URISplit.parseParams(split.params); // abstract datasource params don't update. PythonInterpreter interp = JythonUtil.createInterpreter(true); JythonUtil.setupInterp( interp, split.path, split.resourceUri.toString(), paramsl, mon ); File src = DataSetURI.getFile(uri, new NullProgressMonitor()); try { mon.setLabel("Executing script to get names."); // warn of this slow, inefficient, and risky behavior. InputStream in = new FileInputStream(src); in= JythonRefactory.fixImports(in); interp.execfile(in,src.getName()); PyStringMap map = ((PyStringMap) interp.getLocals()); PyList list = map.keys(); HashMap result = new HashMap(); for (int i = 0; i < list.__len__(); i++) { String key = (String) list.get(i); Object o = map.get(Py.newString(key)); if (o instanceof PyQDataSet) { result.put(key, o); } } return result; } finally { if ( !mon.isFinished() ) mon.finished(); } } protected static Map getParams( String suri, Map current, ProgressMonitor mon ) throws IOException, PyException { String furi= getScript( suri ); File src = DataSetURI.getFile(furi, mon ); try (FileReader reader = new FileReader(src)) { String script= JythonUtil.readScript( new BufferedReader( reader ) ); List r2= JythonUtil.getGetParams( script, current ); Map result= new LinkedHashMap(); for ( JythonUtil.Param r : r2 ) { result.put( r.name, r ); } return result; } } protected static Map getParams( URI uri, Map current, ProgressMonitor mon ) throws IOException, PyException { return getParams( uri.toString(), current, mon ); } protected static Map getParams( URI uri, ProgressMonitor mon ) throws IOException, PyException { return getParams( uri.toString(), new HashMap(), mon ); } @Override public List getCompletions(CompletionContext cc, ProgressMonitor mon) throws Exception { List result = new ArrayList<>(); if ( cc.context==CompletionContext.CONTEXT_PARAMETER_NAME ) { String ext= DataSetURI.fromUri(cc.resourceURI); int i= ext.lastIndexOf("."); if ( i!=-1 ) ext= ext.substring(i+1); if ( ext.equals("jyds" ) || ext.equals("jy") || ext.equals("py") ) { Map po = getNames( cc.resourceURI, mon); for (String n : po.keySet()) { result.add(new CompletionContext(CompletionContext.CONTEXT_PARAMETER_NAME, n, this, "arg_0", null, null)); } Map po2= getParams( cc.resourceURI, new NullProgressMonitor() ); for ( Entry e: po2.entrySet() ) { String n= e.getKey(); JythonUtil.Param parm= e.getValue(); if ( parm.doc==null ) parm.doc=""; if ( !parm.name.equals(parm.label) ) { parm.doc+= " (named "+parm.label+" in the script)"; } result.add( new CompletionContext( CompletionContext.CONTEXT_PARAMETER_NAME, n+"=", n + " default is '"+ po2.get(n).deft + "'", po2.get(n).doc ) ); } } else { result.add(new CompletionContext(CompletionContext.CONTEXT_PARAMETER_NAME, "script=", "the name of the python script to run")); } } else if ( cc.context==CompletionContext.CONTEXT_PARAMETER_VALUE ) { String paramName = CompletionContext.get(CompletionContext.CONTEXT_PARAMETER_NAME, cc); if ( paramName.equals("script") ) { //TODO: filesystem completions. } else { Map po2= getParams( cc.resourceURI, new NullProgressMonitor() ); JythonUtil.Param pp= po2.get(paramName); if ( pp!=null ) { if ( pp.deft instanceof Number ) { result.add( new CompletionContext( CompletionContext.CONTEXT_PARAMETER_VALUE, String.valueOf(pp.deft), paramName + " default is '"+ pp.deft + "'", pp.doc ) ); } else { result.add( new CompletionContext( CompletionContext.CONTEXT_PARAMETER_VALUE, String.format( "'%s'", pp.deft ), paramName + " default is '"+ pp.deft + "'", pp.doc ) ); } } } } return result; } /** * Reject when: * - the URI doesn't contain a timerange but the data source has TimeSeriesBrowse * @param surl * @param problems * @param mon * @return */ @Override public boolean reject(String surl, List problems, ProgressMonitor mon) { URISplit split= URISplit.parse(surl); Map uriParams= URISplit.parseParams(split.params); try { Map parms= getParams( surl, new HashMap(), mon); if ( parms.containsKey( JythonDataSource.PARAM_TIMERANGE ) && !uriParams.containsKey(JythonDataSource.PARAM_TIMERANGE) ) { problems.add(TimeSeriesBrowse.PROB_NO_TIMERANGE_PROVIDED); return true; } } catch ( IOException | PyException ex ) { String s= ex.toString(); if ( s.startsWith("Traceback (innermost last):\n File \"\", ") ) { s= s.substring(47); } problems.add(s); return true; } if (surl.contains("?")) { return split.params.length() <= 0; } else { try { if ( split.scheme!=null && split.scheme.equals("inline") ) { return false; } URL url= DataSetURI.getURL(surl); if ( url==null ) { return true; } File src = DataSetURI.getFile( url, new NullProgressMonitor() ); boolean haveResult; try (BufferedReader reader = new BufferedReader(new FileReader(src))) { String s = reader.readLine(); haveResult = false; while (s != null) { if (s.trim().startsWith("result")) { haveResult = true; break; } if (s.trim().startsWith("data")) { haveResult = true; break; } s = reader.readLine(); } } if ( !haveResult ) problems.add("there must be a line that starts with \"data\" or \"result\""); return !haveResult; } catch (IOException ex) { logger.log(Level.SEVERE, ex.getMessage(), ex); return true; } } } /** * Scrape through the Jython script looking for assignments. Ideally, this would just be a list of plottable * result parameters, but that's impossible without actually running the script. * @param surl * @param mon * @return * @throws IOException */ protected static Map getResultParameters( String surl, ProgressMonitor mon ) throws IOException { File src = DataSetURI.getFile(DataSetURI.getURL(surl),mon); Map result; try (BufferedReader reader = new BufferedReader(new FileReader(src))) { String s = reader.readLine(); Pattern assignPattern= Pattern.compile("\\s*([_a-zA-Z][_a-zA-Z0-9]*)\\s*=(.*)(#(.*))?"); Pattern tuplePattern= Pattern.compile("\\s*\\(?\\s*([_a-zA-Z][_a-zA-Z0-9\\s*,\\s*]*)\\s*\\)?\\s*=(.*)(#(.*))?"); Pattern defPattern= Pattern.compile("def .*"); boolean inDef= false; result = new LinkedHashMap<>(); // from ID to description while (s != null) { if ( inDef==false ) { Matcher defm= defPattern.matcher(s); if ( defm.matches() ) { inDef= true; } } else { if ( s.length()>0 && !Character.isWhitespace(s.charAt(0)) ) { Matcher defm= defPattern.matcher(s); inDef= defm.matches(); } } if ( !inDef ) { Matcher m= assignPattern.matcher(s); if ( m.matches() ) { String rhs= m.group(2); if ( rhs.contains("getParam(") ) { // reject } else { if ( m.group(4)!=null ) { result.put(m.group(1), m.group(4) ); } else { result.put(m.group(1), s ); } } } else { m= tuplePattern.matcher(s); if ( m.matches() ) { String tuple= m.group(1); String rhs= m.group(2); if ( rhs.contains("getParam(") ) { // reject } else { String[] ss= tuple.split(","); for ( String s1 : ss ) { if (m.group(4)!=null) { result.put( s1, m.group(4)); } else { result.put( s1, s ); } } } } } } s = reader.readLine(); } } return result; } ExceptionListener listener; /** * provide the script panel with a method for getting errors when they * occur, so it can mark where they have occurred. * @param listener */ public void addExeceptionListener( ExceptionListener listener ) { this.listener= listener; } @Override public T getCapability(Class clazz) { if ( clazz==TimeSeriesBrowse.class ) { return (T)new JythonDataSourceTimeSeriesBrowse("file:///"); } else { return super.getCapability(clazz); } } /** * this is a non-trivial problem, and for now we will * assume any .jyds has local references and therefore cannot * be run from a remote .vap file from the server. Further, it's * probably better to look into creating a sandboxed thread on which * to run the script. * * @param uri * @return true if the jyds has local resource references */ public static boolean jydsHasLocalReferences( URI uri ) { return true; } }