package org.autoplot.server;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintStream;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.autoplot.jythonsupport.JythonRefactory;
import org.python.core.Py;
import org.python.core.PyDictionary;
import org.python.util.PythonInterpreter;
import org.autoplot.ApplicationModel;
import org.autoplot.JythonUtil;
import org.autoplot.ScriptContext;
import org.autoplot.scriptconsole.LogConsole;

/**
 * Handles requests coming in from the server.
 * @author jbf
 */
public class RequestHandler {

    private static final Logger logger= org.das2.util.LoggerManager.getLogger("autoplot.server");

    public RequestHandler() {
    }

    /**
     * this is a hook to remind myself we want to filter the stream to ensure
     * a secure sandbox.  This will be done by removing import statements and
     * exec/eval statements, but note the formatDataSet command could be used to
     * write files.
     * 
     * Since connections are only allowed from the localhost, so the restriction
     * on import is being removed.  https://sourceforge.net/p/autoplot/bugs/2448/
     *
     * @param in
     * @return null if the command should not be executed.
     */
    private String untaint( String in, OutputStream out ) {
        return in;
    }
    
    /**
     * process the python code in data.  
     * return null or in the future the data to send back.
     * @param in
     * @param model
     * @param out
     * @param rlistener the 
     * @return 
     */
    public String handleRequest( InputStream in, ApplicationModel model, OutputStream out, RequestListener rlistener) {
        try {
            PythonInterpreter interp = JythonUtil.createInterpreter(true, false);
            interp.setOut( out );
            interp.set("dom", model.getDocumentModel() );
            interp.set("params", new PyDictionary());
            interp.set("resourceURI", Py.None );
            
            model.setPrompt("autoplot> "); // always reset the prompt.
            
            ScriptContext.getInstance()._setOutputStream(out); // TODO: this is very kludgy and will surely cause problems
            
            BufferedReader reader= new BufferedReader( new InputStreamReader(in) );
            
            boolean echo= true;
            if ( echo ) out.write( model.getPrompt().getBytes());
            String s;
            while ( (s=reader.readLine())!=null ) {
                s= untaint(s,out);
                if ( s!=null ) {
                    s= LogConsole.maybeRemovePrompts(s);
                    logger.log(Level.FINE, "executing command: \"{0}\"", s);
                    if ( s.equals("quit") || !rlistener.isListening() ) {
                        rlistener.stopListening();
                        break;
                    }
                    try {
                        echo = !s.trim().endsWith(";");
                        interp.exec(JythonRefactory.fixImports(s));
                    } catch ( RuntimeException ex ) {
                        ex.printStackTrace( new PrintStream( out ) );
                        ex.printStackTrace();
                    }
                }
                try {
                    if ( echo ) out.write( model.getPrompt().getBytes());
                } catch ( IOException ex ) {
                    // client didn't stick around to get response.
                }
            }
                        
            return null;
            
        } catch (IOException ex) {
            logger.log(Level.SEVERE, ex.getMessage(), ex);
            return null;
        }
    }
}