/**
 * This work was created by participants in the DataONE project, and is
 * jointly copyrighted by participating institutions in DataONE. For
 * more information on DataONE, see our web site at http://dataone.org.
 *
 *   Copyright ${year}
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 * $Id$
 */

package org.dataone.integration.webTest;

import java.io.IOException;
import java.io.InputStream;
import java.io.Writer;
import java.util.ArrayList;
import java.util.Map;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.io.IOUtils;
import org.junit.runner.Description;
import org.junit.runner.notification.Failure;
import org.junit.runner.notification.RunListener;

public class MavenTestRunnerHttpServlet extends HttpServlet
{
    private boolean debug = true;

    private void debug(String string) {
        if (debug)
            System.out.println(string);
    }


    /**
     * Handles the get call to the servlet and triggers the junit tests run
     */
    public void doGet(HttpServletRequest req, HttpServletResponse rsp)
            throws ServletException, IOException {


        if (req.getParameter("mNodeUrl") != null) {
            executeJUnitRun(req.getParameter("mNodeUrl"), rsp.getWriter());
        } else {
            // return error message, because we can't run
            rsp.sendError(HttpServletResponse.SC_BAD_REQUEST,"Missing required parameter 'mNodeUrl'");
        }
    }


    private void executeJUnitRun(String mNodeBaseUrl, Writer out)
    //	throws IOException
    {

        System.setProperty("mNodeUrl", mNodeBaseUrl);

        // to test that system properties are being received
        if (debug)
            System.setProperty("testSysProp", "setFromServlet");

        String mavenDir = "/WEB-INF/";

        // run the maven task
        try {
            //			ProcessBuilder pb = new ProcessBuilder("mvn", "--help");
            ProcessBuilder pb = new ProcessBuilder("mvn",
                    "-Dcontext.mn.baseurl=http://cn-dev.dataone.org/knb/d1/mn",
                    "verify");
            //			File runDir = new File(mavenDir);
            //			pb.directory(runDir);

            Map<String, String> env = pb.environment();
            //			env.put("testEvnProp", "setFromServletToo");

            System.out.println("user: " + env.get("USER"));

            Process p = pb.start();
            InputStream is  = p.getInputStream();

            // for now just dump to sysout
            System.out.println(IOUtils.toString(is));

        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        //		File mavenReportDir = new File(mavenDir + "/target");

        //		TestStartListener listener = new TestStartListener();
        //		junit.addListener(listener);
        //
        //		Result result = junit.run(org.dataone.integration.webTest.SystemPropertyTest.class);
        //
        //		ArrayList<String> testList = listener.getTestList();
        //		for(String test : testList) {
        //			writeln(out, test);
        //		}
        //		writeln(out, "\nRun Statistics");
        //
        //	    writeln(out, "runTime = " + result.getRunTime() + "\n");
        //	    writeln(out,"runCount = " + result.getRunCount());
        //	    writeln(out,"failureCount = " + result.getFailureCount());
        //	    writeln(out,"ignoreCount = " + result.getIgnoreCount());
        //	    writeln(out,"\nFailures");
        //	    for (Failure f: result.getFailures()) {
        //	    	writeln(out,"  TestHeader = " + f.getTestHeader());
        //	    	writeln(out,"    Message = " + f.getMessage());
        //	    	writeln(out,"    Description = " + f.getDescription());
        //	    	writeln(out,"    Exception = " + f.getException());
        //	    }
        //	    out.flush();
    }

    private void write(Writer w, String s) throws IOException {
        w.write(s);
    }

    private void writeln(Writer w, String s) throws IOException {
        w.write(s + "\n");
        w.flush();
    }

    class TestStartListener extends RunListener
    {
        ArrayList<String> testList = new ArrayList<String>();
        //		public void testRunStarted(Description d) {
        //			testList.add(d.getClassName() + ":" + d.getMethodName());
        //		}
        public void testStarted(Description d) {
            testList.add("Started: " + d.getClassName() + ":" + d.getMethodName());
        }
        public void testIgnored(Description d) {
            testList.add("Ignored: " + d.getClassName() + ":" + d.getMethodName());
        }
        public void testFailure(Failure f) {
            testList.add("Header: " + f.getTestHeader() +
                    "\nMessage: " + f.getMessage() +
                    "\nDescription: " + f.getDescription() +
                    "\nException: " + f.getException() +
                    "\nTrace: " + f.getTrace());
        }


        public ArrayList<String> getTestList() {
            return testList;
        }

    }
}