/*
 *  $Id: RestRequestListener.java 1250 2018-03-15 04:14:41Z tgutwin $
 *  $HeadURL: svn://svn.webarts.bc.ca/open/trunk/www/PowerEYE/WEB-INF/src/ca/bc/webarts/servlet/RestRequestListener.java $
 *  $Revision: 1250 $
 *  $LastChangedDate: 2018-03-14 21:14:41 -0700 (Wed, 14 Mar 2018) $
 *  $LastChangedBy: tgutwin $
 *  Copyright (c) 2014-2015 Tom B. Gutwin P.Eng. North Vancouver BC Canada
 *
 *  This program 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 3
 *  of the License, or any later version.
 *
 *  This program 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 this program; If not, see <http://www.gnu.org/licenses/>.
 */
package ca.bc.webarts.servlet;

import ca.bc.webarts.tools.Log;
import ca.bc.webarts.tools.eiscp.Eiscp;
import ca.bc.webarts.tools.eiscp.IscpCommands;
import ca.bc.webarts.tools.lednet.LedNetProxy;
import ca.bc.webarts.widgets.Util;
import ca.bc.webarts.widgets.ResultSetConverter;

import com.oreilly.servlet.ParameterParser;
import com.oreilly.servlet.ParameterNotFoundException;
import com.oreilly.servlet.ServletUtils;

import java.text.DecimalFormat;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.UnknownHostException;
import java.util.Calendar;
import java.util.Date;
import java.util.Enumeration;
import java.util.TimeZone;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;

import javax.servlet.*;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.*;

import javax.json.Json;

/**
 * This class is a listener, implemented as a servlet, for general messages that get http 'post'ed.
 * it gets mapped to listener at a URL like: http://localhost/powereye/eagle.<br /><br />I have also implemented
 * the doGet method to provide a way to receive commands back that will get sent back to the caller in the http
 * responses .<br /><br />This class is part of WebAPP and a number of classes to help
 * process the messages. See also ca.bc.webarts.tools.lednet.LedNetProxy<br />
 *
 * @author     tgutwin
 * @created    Jan 14, 2020
 */
public class RestRequestListener extends javax.servlet.http.HttpServlet
{
  // implements SingleThreadModel

  /** Class constant. **/
  protected static final String className_ = "RestRequestListener";
  private final static String SYSTEM_FILE_SEPERATOR = File.separator;
  /**  Version String.  */
  private final static String SERVLET_VERSION = Util.spacesToCapsInString("0.0.1");

  public static final String CLIENT_SETTING_NAME_VIEWPORTWIDTH = "clientSetting.viewPortWidth";
  public static final String CLIENT_SETTING_NAME_VIEWPORTHEIGHT = "clientSetting.viewPortHeight";
  public static final String CLIENT_SETTING_NAME_BROWSER_NAME = "clientSetting.browserName";
  public static final String CLIENT_SETTING_NAME_BROWSER_VERSION = "clientSetting.browserVersion";
  public static final String CLIENT_SETTING_NAME_DEVICE_TYPE = "clientSetting.deviceType";
  public static final int REST_TYPE_LED = 1;
  public static final int REST_TYPE_EISCP = 2;

  /**  Build String. (yymmddhhss)  */
  private final static String BUILD_TAG = "18032819";

  private static String webServerHostName_ = "localhost";

  /** The Helper classes. **/
  private LedNetProxy led_ = null;
  String ledenetIP_ = "";
  int ledenetPort_ = 0;
  int rest_type_ = 0;
  private static Eiscp eiscp_ =  new Eiscp(null, 0);
  private boolean debugOut_ = false;
  protected static Log log_= Log.getInstance();

  // parameters
  String rgbw_="0a0a0a00";

  /**
   *  Gets the ServletInfo attribute of the JavaMailServlet object
   *
   * @return    The ServletInfo value
   */
  public String getServletInfo()
  {
    final String methodName = "getServletInfo";
    return "WebARTS Design RestRequestListener servlet. Version:" + SERVLET_VERSION +
        "  Build:" + BUILD_TAG;
  }


  /**
   * The one time servlet init stuff goes here. It sets the derbyDBDir based on the following prioritized varables:
   * <ol><li>context init param: derbyDBDir</li><li>servlet init param (from web.xml): derbyDBDir</li>
   * <li>default hardcoded variable: derbyDBDir</li></ol>If defined in multiple places, the higher priority item will
   * be used.
   **/
  public void init()
  {
    System.out.println("\n~~~~~~~~\n~~~~~~~~\nInitializing webarts.servlet.RestRequestListener\n~~~~~~~~\n~~~~~~~~");

    boolean notFoundInit = true;
    boolean notFoundContext = true;
    java.util.Enumeration <String> initEnum = getInitParameterNames();
    for (; notFoundInit && initEnum.hasMoreElements();)
    {
      if(initEnum.nextElement().equals("ledenetIP"))
      {
        notFoundInit = false;
        /* Do something with the init param */
        ledenetIP_ = getInitParameter("ledenetIP");
        System.out.println("\n~~~~~~~~\n     INIT ServletParam: ledenetIP_="+ledenetIP_);
      }
      else if(initEnum.nextElement().equals("ledenetPort"))
      {
        notFoundInit = false;
        /* Do something with the init param */
        try
        {
          ledenetPort_ = Integer.parseInt(getInitParameter("ledenetPort_"));
          System.out.println("\n~~~~~~~~\n     INIT ServletParam: ledenetPort_="+ledenetPort_);
        }
        catch (Exception ex)
        { // use defaults
          System.out.println("\n~~~~~~~~\n     INIT ServletParam: ledenetPort_ parse ERROR");
        }
      }
    }

    //also check context
    initEnum = getServletConfig().getServletContext().getInitParameterNames();
    for (; notFoundContext && initEnum.hasMoreElements();)
    {
      if(initEnum.nextElement().equals("ledenetIP"))
      {
        notFoundContext = false;
        /* Do something with the init param */
        ledenetIP_ = getServletConfig().getServletContext().getInitParameter("ledenetIP");
        System.out.println("\n~~~~~~~~\n     INIT ContextParam: ledenetIP_="+ledenetIP_);
      }
      else if(initEnum.nextElement().equals("ledenetPort"))
      {
        notFoundInit = false;
        /* Do something with the init param */
        try
        {
          ledenetPort_ = Integer.parseInt(getInitParameter("ledenetPort_"));
          System.out.println("\n~~~~~~~~\n     INIT ServletParam: ledenetPort_="+ledenetPort_);
        }
        catch (Exception ex)
        { // use defaults
          System.out.println("\n~~~~~~~~\n     INIT ServletParam: ledenetPort_ parse ERROR");
        }
      }
    }

    if(notFoundInit && notFoundContext )
    {
      /* Set the default values */
      //eagleDBDir_ = pEye_.getDerbyDBDir();
    }

    try
    {
      webServerHostName_ = InetAddress.getLocalHost().getHostName();
    }
    catch (UnknownHostException ex)
    {
      webServerHostName_ = "localhost";
    }

    led_ = new LedNetProxy();// this inits the helper, which inits the EagleDB and retrieves its settings
    //eiscp_ = new Eiscp(null, 0);  // instantiate when needed because the connectionshould always be closed


  }


  /**  Override to close up the persister * */
  public void destroy()
  {
    super.destroy();
  }



  /**
   * Returns the value of debugOut_.
   */
  public boolean getDebugOut()
  {
    return debugOut_;
  }


  /**
   * Sets the value of debugOut_.
   * @param debugOut The value to assign debugOut_.
   */
  public void setDebugOut(boolean debugOut)
  {
    this.debugOut_ = debugOut;
    log_.setLogLevel((debugOut_?log_.DEBUG:log_.MINOR));
  }


  private void streamZIP(OutputStream servletOut, String dataName, InputStream dataStream)
  {
    String[] dataNames = {dataName};
    InputStream[] dataStreams = {dataStream};
    streamZIP(servletOut, dataNames,dataStreams);
  }


  /**
   * streams to a zipped out stream (without creating a file).
   * from: http://www.coderanch.com/t/276892/java-io/java/Stream-data-ZipOutputStream
   * @param servletOutput is the stream to zip into
   * @param dataNames are the pseudo fileNames that will get created in the zip (pseudo file) stream
   * @param dataStreams the data to zip
   **/
  private void streamZIP(OutputStream servletOut,
                        String[] dataNames,
                        InputStream[] dataStreams)
  {
    ZipOutputStream zos = new ZipOutputStream(servletOut);
    final int DATA_BLOCK_SIZE = 2048;
    int byteCount;
    byte[] data;

    try
    {
      for(int i = 0; i < dataNames.length; i++)
      {
        ZipEntry ze = new ZipEntry(dataNames[i]);
        zos.putNextEntry(ze);
        data = new byte[DATA_BLOCK_SIZE];

        while((byteCount = dataStreams[i].read(data, 0, DATA_BLOCK_SIZE)) != -1)
        {
          zos.write(data, 0, byteCount);
        }

        zos.flush();
        zos.closeEntry();
        dataStreams[i].close();
      }
      zos.close();
    }
    catch(Exception e)
    {
      System.err.println("Problem streaming zip data " + e.toString());
    }
  }


  private void parseParams(HttpServletRequest req)
  {
    ParameterParser parser = new ParameterParser(req);
    debugOut_ = parser.getBooleanParameter("debugOut", false);
    rgbw_ = parser.getStringParameter("rgbw", "");

    /*
    reInitCache =  parser.getIntParameter("reInitCache",0);
    shutdownDB = parser.getStringParameter("shutdownDB", "");
    restartDB = parser.getStringParameter("restartDB", "");
    sendFastPoll = parser.getStringParameter("setFastPoll", "");
    fastPollFreq =  parser.getIntParameter("fastPollFreq",0);
    fastPollDur =  parser.getIntParameter("fastPollDur",0);
    viewPortWidth =  parser.getIntParameter("viewPortWidth",0);
    viewPortHeight =  parser.getIntParameter("viewPortHeight",0);
    eagleDBDir = parser.getStringParameter("eagleDBDir","");
    browserName = parser.getStringParameter("clientBrowser","");
    browserVersion = parser.getStringParameter("clientBrowserVersion","");
    deviceType = parser.getStringParameter("clientDeviceType","");
    isyEnabled = parser.getStringParameter("isyEnabled", "");
    dstEnabled = parser.getStringParameter("dstEnabled", "");
    isyHostname = parser.getStringParameter("isyHostname","");
    isyLoginID = parser.getStringParameter("isyLoginID","");
    isyLoginPassword = parser.getStringParameter("isyLoginPassword","");
    notifyISY = parser.getStringParameter("notifyISY", "");
    requestLastEnergy = parser.getStringParameter("requestLastEnergy", "").trim();
    requestLastDemand = parser.getStringParameter("requestLastDemand", "").trim();
    requestRecentDemand = parser.getStringParameter("requestRecentDemand", "").trim();
    requestCurrentPrice = parser.getStringParameter("requestCurrentPrice", "").trim();
    isyDeviceOn = parser.getStringParameter("isyDeviceOn", "");
    isyDeviceOff = parser.getStringParameter("isyDeviceOff", "");
    isyDeviceToggle = parser.getStringParameter("isyDeviceToggle", "");
    */
   }


  /**
   *  This method handles the "GET" submission - SHOULD NEVER be called by the Eagle it is used for Ajax calls to set
   * webApp parameters using JQuery
   * and to send commands back to the eagle on next message posted.
   *
   * @param  req                   Description of the Parameter
   * @param  res                   Description of the Parameter
   * @exception  ServletException  Description of the Exception
   * @exception  IOException       Description of the Exception
   */
  public void doGet(HttpServletRequest req, HttpServletResponse res) throws ServletException, IOException
  {
    parseParams(req);

    ServletOutputStream out = res.getOutputStream();
    String conPath = req.getContextPath();
    String restPath = req.getPathInfo();  // basically anything added to the end of the URL is considered a RESt request

    boolean ajaxCall = false;
    boolean restRequest = false;
    String ajaxResponse = "";
    String restResponse = null;

    res.setStatus(HttpServletResponse.SC_OK);  // default ids OK,, set again lower downif NOT

    ajaxResponse = checkForAjaxRequest(req);
    if (!ajaxResponse.equals("")) ajaxCall=true;

    if(!ajaxCall) restResponse = checkForRestRequest(req);
    System.out.println("  **** checkForRestRequest: restResponse="+(restResponse!=null?restResponse:"null"));
    if (restResponse!=null && !restResponse.equals("")) restRequest=true;

    /* * * * * *  * * * * * EMPTY * * * * *  * * * * *  */
    /* ***********************************************  */
    if( !ajaxCall && !restRequest) // EMPTY query and NO parms... it was *NOT* a JQuery Ajax call or a REST call, so just present some status back to user
    {
      sendAdminPage(req, res);
    }

    res.setContentType("text/plain");
    if(ajaxCall)
    {
      if(rest_type_==REST_TYPE_LED) res.setContentType("application/xml");
      else if(rest_type_==REST_TYPE_EISCP) res.setContentType("application/json");
      if(out!=null  )
      {
        if (debugOut_)
          System.out.println("AJAX REPLY("+ajaxResponse.length()+")="+ajaxResponse);
        out.print(ajaxResponse);
      }
      else
        System.out.println("HttpServletResponse.ServletOutputStream is NOT ready");
    }
    else if(restRequest)
    {
      if(rest_type_==REST_TYPE_LED) res.setContentType("application/xml");
      else if(rest_type_==REST_TYPE_EISCP) res.setContentType("application/json");
      if(restResponse!=null && !restResponse.equals(""))
      {
        res.setStatus(HttpServletResponse.SC_OK);
      }
      else
      {
        res.setStatus(HttpServletResponse.SC_NOT_FOUND);
        //restResponse = "<RestResponse succeeded=\"false\"><status>404</status></RestResponse>";
        String respStr = "404";
        restResponse = "{\n \"success\": false,\n \"status\": \""+respStr+"\"\n}";

      }
      if(out!=null  )
      {
        if (debugOut_)
          System.out.println("REST REPLY("+restResponse.length()+")="+restResponse);
        out.print(restResponse);
      }
      else
        System.out.println("HttpServletResponse.ServletOutputStream is NOT ready");
    }
    out.flush();
    res.flushBuffer();
  }


  /**
   *  This method handles the "POST" submission - the default way the a listener works.
   * send a MessageCommand in the body of the reply to send a command back to the Eagle.
   * You can tell this servlet to send a command by calling it using a parameter:<br />
   * setFastPoll=true/false
   * getFastPoll=true/false
   * getHistoryData=true/false
   * getProfileData=true/false
   * setPollInterval=IntegerSeconds
   *
   * @param  req                   Description of Parameter
   * @param  res                   Description of Parameter
   * @exception  ServletException  Description of Exception
   * @exception  IOException       Description of Exception
   */
  public void doPost(HttpServletRequest req, HttpServletResponse res) throws ServletException, IOException
  {

    StringBuffer postBody = new StringBuffer("");
    String line = null;
   // try
   // {
      BufferedReader reader = req.getReader();
      while ((line = reader.readLine()) != null)
        postBody.append(line+"\n");

      // Do something with the posted message
      // send it to the led_
      String helperReply = "";   //  do something with the postBody    //led_.sendOnOffCommand(postBody.toString());

      // send back an empty reply
      if ((helperReply==null || helperReply.equals("")) )
      {
        // send back a 200 with an empty body
        res.setStatus(HttpServletResponse.SC_OK);
        res.setContentLength(0);
        helperReply = "";
        if (debugOut_) System.out.println("RestRequestListener.doPost:emptyreply from newMessage");
      }
      else
      {
        // send back the pEyeReply as the body
        res.setStatus(HttpServletResponse.SC_OK);
        res.setContentLength(helperReply.length());
        if (debugOut_) System.out.println("RestRequestListener.doPost: led_ helper reply existed");
      }

      helperReply = "\n"+helperReply;
      res.setContentType("application/xml");
      res.setStatus(HttpServletResponse.SC_OK);
      res.setContentLength(helperReply.length());

      ServletOutputStream out = res.getOutputStream();
      if(out!=null  )
      {
        if (debugOut_) System.out.println("Attempting to HttpServletResponse REPLY("+helperReply.length()+")="+helperReply);
        out.print(helperReply);
        out.flush();
      }
      else
        System.out.println("HttpServletResponse.ServletOutputStream is NOT ready");

      res.flushBuffer();

      /*
    }
    catch (Exception e)
    {
      //report an error
      e.printStackTrace();
    }
    */
  }


  /** Parses the passed in request and performs any requested services.  **/
  private synchronized String checkForRestRequest(HttpServletRequest req) throws ServletException, IOException
  {
    String restResponse = null;
    String servletPath = req.getServletPath();
    String restPath = req.getPathInfo();  // basically anything added to the end of the URL is considered a RESt request
    String pre = "/";
    String preLedENet = "/led";
    String preEiscp = "/eiscp";

    System.out.println("\ncheckForRestRequest:  servletPath="+servletPath);
    System.out.println("checkForRestRequest:  restPath="+restPath);

    DecimalFormat dfp = new DecimalFormat( "##0" );
    DecimalFormat dfe = new DecimalFormat( "###0.000" );

    if (servletPath.equals(preLedENet) && restPath!=null && !restPath.equals("") )
    {
      rest_type_=REST_TYPE_LED;
      if(restPath.equals("/colour/red"))
      {
        restResponse = "<RestResponse succeeded=\"true\"><colour r=\"255\" g=\"0\" b=\"0\" w=\"0\" >"+
                        led_.sendColourCommand(255,0,0,0,false,true)+
                        "</colour></RestResponse>";
      }
      else if(restPath.equals("/colour/blue"))
      {
        restResponse = "<RestResponse succeeded=\"true\"><colour r=\"0\" g=\"0\" b=\"255\" w=\"0\" >"+
                        led_.sendColourCommand(0,0,255,0,false,true)+
                        "</colour></RestResponse>";
      }
      else if(restPath.startsWith("/colour/green"))
      {
        restResponse = "<RestResponse succeeded=\"true\"><colour r=\"0\" g=\"255\" b=\"0\" w=\"0\" >"+
                        led_.sendColourCommand(0,255,0,0,false,true)+
                        "</colour></RestResponse>";
      }
      else if(restPath.startsWith("/colour/purple"))
      {
        restResponse = "<RestResponse succeeded=\"true\"><colour r=\"5\" g=\"0\" b=\"10\" w=\"0\" >"+
                        led_.sendColourCommand(5,0,10,0,false,true)+
                        "</colour></RestResponse>";
      }
      else if(restPath.startsWith("/rgbw"))
      {
        rgbw_ = restPath.substring("/rgbw/".length());
        System.out.println("\nRGBW="+rgbw_);
        System.out.println(" r="+rgbw_.substring(0,2) +" = "+led_.convertHexToString(rgbw_.substring(0,2),true));

        int r = 0;int g = 0;int b = 0;int w = 0;
        try { r = Integer.parseInt(led_.convertHexToString(rgbw_.substring(0,2),true));}catch (Exception ex) {} // use defaults
        try { g = Integer.parseInt(led_.convertHexToString(rgbw_.substring(2,4),true));}catch (Exception ex) {} // use defaults
        try { b = Integer.parseInt(led_.convertHexToString(rgbw_.substring(4,6),true));}catch (Exception ex) {} // use defaults
        try { if(rgbw_.length()>7) w= Integer.parseInt(led_.convertHexToString(rgbw_.substring(6,8),true));}
        catch (Exception ex) {} // use defaults

        if(!"".equals(rgbw_))
        {

          restResponse = "<RestResponse succeeded=\"true\"><rgbw r=\""+r+"\" g=\""+g+"\" b=\""+b+"\" w=\""+w+"\" >"+
                          led_.sendColourCommand(r,g,b,w,false,true)+
                          "</rgbw></RestResponse>";
        }
      }

      else if(restPath.startsWith("/on"))
      {
        restResponse = "<RestResponse succeeded=\"true\"><on>"+
                        led_.sendOnOffCommand(true,true)+
                        "</on></RestResponse>";
      }
      else if(restPath.startsWith("/off"))
      {
        restResponse = "<RestResponse succeeded=\"true\"><off>"+
                        led_.sendOnOffCommand(false,true)+
                        "</off></RestResponse>";
      }
    }
    /* Now the eISCP requests */
    /* ********************** */
    else if (servletPath.equals(preEiscp) && restPath!=null && !restPath.equals("") )
    {
      rest_type_=REST_TYPE_EISCP;

      // Parse the command
      int command = -1;
      String commandNameStr = restPath.substring(1, (restPath.indexOf("/",1) !=-1? restPath.indexOf("/",1) : restPath.length())).toUpperCase();
      System.out.println("EISCP command: "+commandNameStr);
      String commandParamStr = "";
      String queryResponse = "";
      String resp = "";

      //eiscp_ = new Eiscp(null, 0);
      connectToEiscp();   // gets a new connection and waits if needed
      IscpCommands iscp = IscpCommands.getInstance();

      // Fix a few alias short rest requests
      if(commandNameStr.toUpperCase().equalsIgnoreCase("ON") || commandNameStr.toUpperCase().equalsIgnoreCase("OFF"))
        commandNameStr="POWER_"+commandNameStr;

      command = iscp.getCommand(commandNameStr);  //returns -1 if not found

      if (commandNameStr.equalsIgnoreCase("MULTIPLE"))
      {
        /* Special case command needs to parse a parameter. */
        // for example  /eiscp/MULTIPLE/5/VOLUME_DOWN
        // the volume parameter gets interpretted as a HEX value, so sending a 45 means 36
        String paramStr = restPath.toUpperCase().substring(("/MULTIPLE/").length());  //   "45";  //parse out a parameter
        System.out.println("EISCP MULTIPLE restPath: "+restPath.toUpperCase());
        System.out.println("               paramStr: "+paramStr);
        int mult = Integer.parseInt(paramStr.substring(0, paramStr.indexOf("/",1)));

        commandNameStr = paramStr.substring(paramStr.indexOf("/",1)+1);
        command = iscp.getCommand(commandNameStr);

        System.out.println("       MULTIPLE ["+mult+"] command: "+commandNameStr +" ("+iscp.getCommandStr(command)+")");
        eiscp_.sendCommandMultipleTimes(command, mult, false);   //true);
      }
      /* Special case VOLUME_SET command needs to parse a parameter. */
      //    /eiscp/VOLUME_SET/45
      else if ( command == iscp.VOLUME_SET )
      {
        String paramStr = restPath.substring(("/VOLUME_SET/").length());  //   "45";  //parse out a parameter
        eiscp_.setVolume(Integer.parseInt(paramStr));
        resp=queryResponse.trim();
        System.out.println("   ="+ iscp.getCommandName(resp));
        restResponse = "<RestResponse succeeded=\"true\"><eiscp command=\""+commandNameStr+"\" param=\""+paramStr+"\" >"+
                        resp+
                        "</eiscp></RestResponse>";
        // Switch to Using JSON
        restResponse = "{\n \"success\": true,\n \"eiscpCommand\": \""+commandNameStr+"\",\n"+
                       " \"param\": "+paramStr+","+
                       " \"response\": \""+resp+"\"\n}";

      }
      // NETUSB
      else if( commandNameStr.toUpperCase().startsWith("NETUSB_"))
      {
         // NETUSB  Queries
        if(commandNameStr.toUpperCase().endsWith("QUERY") )
        {
          //send the command and get the response
          queryResponse = eiscp_.sendQueryCommand(command, false, false); // false means DON't return all
          resp=queryResponse.trim();
          System.out.print("\nNETUSB_ quries Responses: \n  " +resp);
          if (resp!=null && !resp.equals(""))
          {
              restResponse = "{\n \"success\": true,\n \"eiscpCommand\": \""+commandNameStr+"\",\n"+
                             " \"response\": \""+resp+"\"\n}";
              System.out.println("restResponse:   \n"+restResponse+"\n");
          }
        }
        else   // any of the other NETUSB stuff
        {
          //send the command and
          // FOR now get the response
          queryResponse = eiscp_.sendQueryCommand(command, false, true); // last true means return all packet results
          //resp=queryResponse.trim();
          resp=eiscp_.decipherNetUsbResponse(command, queryResponse);
          System.out.print("\nNETUSB_ Responses: \n  " +resp);
          if (resp!=null && !resp.equals(""))
          {
              restResponse = "{\n \"success\": true,\n \"eiscpCommand\": \""+commandNameStr+"\",\n"+
                             " \"response\": "+resp+"\n}";
              System.out.println("restResponse:   \n"+restResponse+"\n");
          }
        }
      }
      /* It is a query command so send AND parse response */
      else if(   commandNameStr.toUpperCase().endsWith("QUERY")
              || commandNameStr.toUpperCase().endsWith("TOGGLE")
             )
      {
        //send the command and get the response
        queryResponse = eiscp_.sendQueryCommand(command, false, false);  // false means DON't return all
        resp=queryResponse.trim();
        System.out.print("\neiscp QUERYorTOGGLE RestResponses: \n  " +resp);
        if (resp!=null && !resp.equals(""))
        {
          if (command==iscp.VOLUME_QUERY)
          {
            System.out.println("Deciphered:   "+eiscp_.decipherVolumeResponse(resp));
            System.out.println("   ="+ iscp.getCommandName(resp));
            // Switch to Using JSON
            restResponse = "{\n \"success\": true,\n \"eiscpCommand\": \""+commandNameStr+"\",\n"+
                           " \"response\": \""+eiscp_.deciherVolumeResponseToDecimal(resp)+"\"\n}";
            System.out.println("restResponse:   \n"+restResponse+"\n");
          }
          else if (command==iscp.SOURCE_QUERY )
          {
            System.out.println("   ="+ iscp.getCommandName(resp));
            System.out.println("SOURCE_QUERY SOURCE_QUERY SOURCE_QUERY SOURCE_QUERY SOURCE_QUERY SOURCE_QUERY ");
            restResponse = "{\n \"success\": true,\n \"eiscpCommand\": \""+commandNameStr+"\",\n"+
                           " \"source\": \""+iscp.getCommandName(resp)+"\"\n}";
          }
          else if (command==iscp.LISTEN_MODE_QUERY ||
                   command==iscp.AUDIO_INFO_QUERY ||
                   command==iscp.MUTE_QUERY ||
                   command==iscp.VIDEO_INFO_QUERY ||
                   command==iscp.VIDEO_WIDE_QUERY ||
                   command==iscp.TUNING_DIRECT_QUERY ||
                   command==iscp.TUNING_PRESET_QUERY||
                   command==iscp.MUTE_TOGGLE
                 )
          {
            System.out.println("   ="+ iscp.getCommandName(resp));
            restResponse = "{\n \"success\": true,\n \"eiscpCommand\": \""+commandNameStr+"\",\n"+
                           //" \"param\":"+paramStr+"\"\n"+
                           " \"response\": \""+resp+"\"\n}";
          }
          else
          {
            System.out.println("   ="+ iscp.getCommandName(resp));
            restResponse = "{\n \"success\": true,\n \"eiscpCommand\": \""+commandNameStr+"\",\n"+
                           //" \"param\":"+paramStr+"\"\n"+
                           " \"response\": \""+resp+"\"\n}";
          }
        }
        else
          System.out.println("\nEMPTY");
      }
      else if( commandNameStr.toUpperCase().startsWith("DUMP"))
      {
        resp = eiscp_.getCommandList();
        restResponse = "<RestResponse succeeded=\"true\"><eiscp command=\""+commandNameStr+"\" >"+
                        //"<![CDATA["+resp+"]]>"+
                        resp+
                        "</eiscp></RestResponse>";
            restResponse = "{\n \"success\": true,\n \"eiscpCommand\": \""+commandNameStr+"\",\n"+
                           //" \"param\":"+paramStr+"\"\n"+
                           " \"response\": \""+resp+"\"\n}";
      }
      else   //if(commandNameStr.equalsIgnoreCase("POWER_ON") || commandNameStr.equals("POWER_OFF"))
      {
        /* It is a basic change setting command (with no response) */
        resp="none";
        eiscp_.sendCommand(command);
        restResponse = "<RestResponse succeeded=\"true\"><eiscp command=\""+commandNameStr+"\" >"+
                        resp+
                        "</eiscp></RestResponse>";
        restResponse = "{\n \"success\": true,\n \"eiscpCommand\": \""+commandNameStr+"\",\n"+
                           //" \"param\":"+paramStr+"\"\n"+
                           " \"response\": \""+resp+"\"\n}";
      }
      //eiscp_.closeSocket();
    } //eiscp rest
    else
    {
      System.out.println(" ....  RestRequestListener: BAD request");
      if (servletPath.equals(preEiscp))
      {
        restResponse = "{\n \"success\": false,\n \"eiscpCommand\": \""+(restPath!=null?restPath:"none")+"\",\n"+
                           " \"response\": \""+"none"+"\"\n}";
      }
    }

    return restResponse;
  }


  private void connectToEiscp()
  {
    //if(eiscp_.isConnected()) Util.sleep(250);
    eiscp_.connectSocket();
  }


  private String checkForAjaxRequest(HttpServletRequest req) throws ServletException, IOException
  {
    String ajaxResponse = "";
        // was  it a JQuery Ajax call for info...  (such as eagleDBDir_)
    /*
    if (eagleDBDir!=null &&!eagleDBDir.equals("") )
    {
      eagleDBDir_=eagleDBDir;
      // do something with the passed parms
      pEye_.setDerbyDBDir(eagleDBDir_);
      ajaxResponse = eagleDBDir_;
    }
    else if (reInitCache>0 )
    {
        reInitCache_ = reInitCache;
        pEye_.initReadingsCache(reInitCache_);
        System.out.println("PowerEYEListener.doGet - reInitCache_="+reInitCache_);
        ajaxResponse = ""+reInitCache_;
    }
    else if (debugOut!=null &&!debugOut.equals("") )
    {
        debugOut_ =  Boolean.parseBoolean(debugOut);
        setDebugOut(debugOut_);
        pEye_.setDebugOut(debugOut_);
        System.out.println("PowerEYEListener.doGet - debugOut_="+debugOut_);
        ajaxResponse = ""+debugOut_;
    }
    else if (isyEnabled!=null &&!isyEnabled.equals("") )
    {
        isyEnabled_ =  Boolean.parseBoolean(isyEnabled);
        pEye_.setIsyEnabled(isyEnabled_);
        if (isyEnabled_) pEye_.initISY();
        System.out.println("PowerEYEListener.doGet - isyEnabled_="+isyEnabled_);
        ajaxResponse = (pEye_.isIsyConnected()?pEye_.getIsyConfigNameIdStr():"not configured");
    }
    else if (dstEnabled!=null &&!dstEnabled.equals("") )
    {
        dstEnabled_ =  Boolean.parseBoolean(dstEnabled);
        pEye_.setForceDSTAdjustment(dstEnabled_);
        System.out.println("PowerEYEListener.doGet - dstEnabled_="+dstEnabled_);
        ajaxResponse = ""+dstEnabled_;
    }
    else if (shutdownDB!=null &&!shutdownDB.equals("") )
    {
        shutdownDB_ =  Boolean.parseBoolean(shutdownDB);
        System.out.println("PowerEYEListener.doGet - shutdownDB_="+shutdownDB_);
        pEye_.closePersister();
        ajaxResponse = ""+shutdownDB_;
    }
    else if (restartDB!=null &&!restartDB.equals("") )
    {
        restartDB_ =  Boolean.parseBoolean(restartDB);
        System.out.println("PowerEYEListener.doGet - restartDB_="+restartDB_);
        if(restartDB_) pEye_.restartDerbyDB();
        ajaxResponse = ""+restartDB_;
    }
    else if (sendFastPoll!=null &&!sendFastPoll.equals("") )
    {
        sendFastPoll_ =  Boolean.parseBoolean(sendFastPoll);
        System.out.println("PowerEYEListener.doGet - sendFastPoll_="+sendFastPoll_);
        ajaxResponse = ""+sendFastPoll_;
    }
    else if (notifyISY!=null &&!notifyISY.equals("") )
    {
        notifyISY_ =  Boolean.parseBoolean(notifyISY);
        setDebugOut(notifyISY_);
        pEye_.setNotifyISY(notifyISY_);
        System.out.println("PowerEYEListener.doGet - notifyISY_="+notifyISY_);
        ajaxResponse = ""+notifyISY_;
    }
    else if (isyHostname!=null &&!isyHostname.equals("") )
    {
      pEye_.setIsyEnabled(true);
        isyHostname_ =  isyHostname.trim();
        System.out.println("PowerEYEListener.doGet - > > > > > > isyHostname_="+isyHostname_);
        pEye_.setIsyHostname(isyHostname_);
        ajaxResponse = (pEye_.isIsyConnected()?pEye_.getIsyConfigNameIdStr():"not configured");
    }
    else if (isyLoginID!=null &&!isyLoginID.equals("") )
    {
      pEye_.setIsyEnabled(true);
        isyLoginID_ =  isyLoginID.trim();
        System.out.println("PowerEYEListener.doGet - > > > > > > isyLoginID_="+isyLoginID_);
        pEye_.setIsyLoginID(isyLoginID_);
        ajaxResponse = ""+(pEye_.isIsyConnected()?pEye_.getIsyConfigNameIdStr():"not configured");
    }
    else if (isyLoginPassword!=null &&!isyLoginPassword.equals("") )
    {
      pEye_.setIsyEnabled(true);
        isyLoginPassword_ =  isyLoginPassword.trim();
        System.out.println("PowerEYEListener.doGet - > > > > > > isyLoginPassword_="+isyLoginPassword_);
        pEye_.setIsyLoginPassword(isyLoginPassword_);
        ajaxResponse = (pEye_.isIsyConnected()?pEye_.getIsyConfigNameIdStr():"not configured");
    }
    else if (isyDeviceOff!=null &&!isyDeviceOff.equals("") )
    {
        isyDeviceOff_ =  isyDeviceOff.trim();
        System.out.println("PowerEYEListener.doGet - isyDeviceOff_="+isyDeviceOff_);
        pEye_.sendIsyDeviceOff(isyDeviceOff_);
        ajaxResponse = ""+isyDeviceOff_;
    }
    else if (isyDeviceOn!=null &&!isyDeviceOn.equals("") )
    {
        isyDeviceOn_ =  isyDeviceOn.trim();
        System.out.println("PowerEYEListener.doGet - isyDeviceOn_="+isyDeviceOn_);
        pEye_.sendIsyDeviceOn(isyDeviceOn_);
        ajaxResponse = ""+isyDeviceOn_;
    }
    else if (isyDeviceToggle!=null &&!isyDeviceToggle.equals("") )
    {
        isyDeviceToggle_ =  isyDeviceToggle.trim();
        System.out.println("PowerEYEListener.doGet - isyDeviceToggle_="+isyDeviceToggle_);
        pEye_.sendIsyDeviceToggle(isyDeviceToggle_);
        ajaxResponse = ""+isyDeviceToggle_;
    }
    else if (viewPortWidth!=0 )
    {
      // do something with the passed parms
      viewPortWidth_=viewPortWidth;
      req.getSession().setAttribute(CLIENT_SETTING_NAME_VIEWPORTWIDTH, viewPortWidth);
      ajaxResponse = ""+viewPortWidth_;
    }
    else if (viewPortHeight!=0 )
    {
      // do something with the passed parms
      viewPortHeight_=viewPortHeight;
      req.getSession().setAttribute(CLIENT_SETTING_NAME_VIEWPORTHEIGHT, viewPortHeight);
      ajaxResponse = ""+viewPortHeight_;
    }
    else if (browserName!=null &&!browserName.equals("") )
    {
      req.getSession().setAttribute(CLIENT_SETTING_NAME_BROWSER_NAME, browserName);
      ajaxResponse = ""+browserName;
    }
    else if (browserVersion!=null &&!browserVersion.equals("") )
    {
      req.getSession().setAttribute(CLIENT_SETTING_NAME_BROWSER_VERSION, browserVersion);
      ajaxResponse = ""+browserVersion;
    }
    else if (deviceType!=null &&!deviceType.equals("") )
    {
      req.getSession().setAttribute(CLIENT_SETTING_NAME_DEVICE_TYPE, deviceType);
      ajaxResponse = ""+deviceType;
    }
    else if (requestLastEnergy!=null &&!requestLastEnergy.equals("") && requestLastEnergy.equals("true") )
    {
      DecimalFormat dfe = new DecimalFormat( "0.00" );
      double meterReading  = pEye_.getCurrentMeterRead();
      ajaxResponse = dfe.format(meterReading);
    }
    else if (requestLastDemand!=null &&!requestLastDemand.equals("") && requestLastDemand.equals("true") )
    {
      DecimalFormat dfp = new DecimalFormat( "0" );
      double lastDemandReading  = pEye_.getCurrentDemand();
      ajaxResponse = dfp.format(lastDemandReading);
    }
    else if (requestCurrentPrice!=null &&!requestCurrentPrice.equals("") && requestCurrentPrice.equals("true") )
    {
      DecimalFormat dfp = new DecimalFormat( "0.00" );
      double currentPrice  = pEye_.getCurrentPrice();
      ajaxResponse = dfp.format(currentPrice);
    }
    else if (maxSqlResultSetRows!=null &&!maxSqlResultSetRows.equals("") )
    {
      int maxRows = Integer.parseInt(maxSqlResultSetRows);
      pEye_.maxSqlResultSetRows_ = maxRows;
      System.out.println("PowerEYEListener.doGet AJAX - maxSqlResultSetRows_="+pEye_.maxSqlResultSetRows_);
      ajaxResponse = ""+maxRows;
    }

    */
    return ajaxResponse;
  }


  private void sendAdminPage(HttpServletRequest req, HttpServletResponse res) throws ServletException, IOException
  {
    ServletOutputStream out = res.getOutputStream();
    ServletContext context = getServletContext();
    java.util.Properties sysProps = System.getProperties();
    TimeZone localTz = Calendar.getInstance().getTimeZone();
    int offset = localTz.getRawOffset();
    // shift Daylight savings hour if needed
    Date dateNow = new Date();
    boolean dst = localTz.inDaylightTime(dateNow) ;
    int dstOffset = localTz.getDSTSavings();
    //if(dst) offset = offset + dstOffset;

    String prop = "";

      // Send Back a response to be presented to the users browser
      res.setContentType("text/html");
      out.println("<!DOCTYPE html>\n");
      out.println("<html>\n");
      out.println("<head>\n");
      out.println("<title>Rest Request Listener - Servlet Console</title>\n");
      out.println("<meta charset=\"UTF-8\">");

      out.println("<link rel=\"icon\"");
      out.println("     type=\"image/png\"");
      out.println("     href=\"images/20x20/Eagle_sml.png\" />");
      out.println("<style>");
      out.println("H1 { font-weight: bolder; background-color: #000033; color: #ffffbb;  font-size: 200%}");
      out.println("H2 { font-weight: bolder; color: #ffff99;  font-size: 160%; text-decoration: underline}");
      out.println("H3 { font-weight: bolder; color: #ffff44;  font-size: 140%}");
      out.println("H4, H5 { color: #ffffff }");
      out.println("A { color: #ffaadd }");
      out.println("DT { font-weight: bolder }");
      out.println("LI { line-height: 125% }");
      out.println("BODY { background-color: #101066; color: #ffff44; font-size: 100%; line-height: 110% }");
      out.println(".val { color: #ffffff; font: \"Lucida Console\", Monaco, monospace  }");
      out.println("");
      out.println("");
      out.println("");
      out.println("</style>");

      //out.println("<META HTTP-EQUIV=\"refresh\" content=\"2;URL=\"javascript:history.go(-2);\">\n");
      out.println("</head>\n");
      out.println("<body>");
      out.println("<h1>RestRequestListener API Listener</h1><h2>Servlet Console</h2>");
      out.println("<a href=\""+req.getContextPath()+"\">REST WebAPP</a><br />");
      out.println(" <h3>Parameters</h3>");
      out.println("  <ul>");
      out.println("    <li>debug          = <span class=\"val\">"+debugOut_+"</span></li>");
      out.println("<br />");
      out.println("    <li>Servlet Init Params:");
      out.println("        <ul>");

      java.util.Enumeration <String> initEnum = getInitParameterNames();
      String currParamName = "";
      for (; initEnum.hasMoreElements();)
      {
        currParamName = initEnum.nextElement();
        out.print("            <li>");
        out.print(currParamName+" = <span class=\"val\">"+getInitParameter(currParamName));
        out.println("</span></li>");
      }
      out.println("       </ul>");
      out.println("    </li>"); // servlet init params

      out.println("<br />");
      out.println("    <li>Context Params for "+context.getServletContextName()+":");
      out.println("        <ul>");
        out.print("          <li>");
        out.print("ContextPath"+" = <span class=\"val\">"+req.getContextPath());
        out.println("</span></li>");
        out.print("          <li>");
        out.print("Real Path For Context Root"+" = <span class=\"val\">"+context.getRealPath("/"));
        out.println("</span></li>");
      out.println("       </ul>");
      out.println("  </li>"); // CONTEXT  params

      out.println("<br />");
      out.println("  <li>Context <b>Init</b> Params:");
      out.println("      <ul>");
      initEnum = context.getInitParameterNames();
      currParamName = "";
      for (; initEnum.hasMoreElements();)
      {
        currParamName = initEnum.nextElement();
        out.print("          <li>");
        out.print(currParamName+" = <span class=\"val\">"+context.getInitParameter(currParamName));
        out.println("</span></li>");
      }
      out.println("       </ul>");
      out.println("    </li>"); // context init params

      out.println("  </ul>");

      out.println("<br /><br />");
      out.println("<h3>Server Status</h3>");
      out.println("  <ul>");
      out.println("    <li>Server name = <span class=\"val\">"+req.getServerName()+" ("+req.getLocalAddr()+")</span></li>");
      out.println("    <li>Server port = <span class=\"val\">"+req.getServerPort()+"</span></li>");
      out.println("    <li>WebApp Engine = <span class=\"val\">"+context.getServerInfo()+"</span></li>");
      out.println("    <li>Supported Servlet Version = <span class=\"val\">"+context.getMajorVersion()+"."+context.getMinorVersion()+"</span>");

      if(context.getMajorVersion()>2 && context.getMinorVersion()>-1)
          out.println("      <ul><li>Effective Version = <span class=\"val\">"+
                      context.getEffectiveMajorVersion()+"."+context.getEffectiveMinorVersion()+"</span></li></ul>");
      out.println("      </li>");
      if(context.getMajorVersion()>2 && context.getMinorVersion()>0)
      {
        try {
          out.println("    <li>Logical Hostname = <span class=\"val\">"+context.getVirtualServerName()+"</span></li>");
        } catch (Exception ex) {}
      }

      out.println("    <li>System Properties\n      <ul>");
      prop = "java.vendor";
      out.println("       <li>"+prop+" = <span class=\"val\">"+sysProps.getProperty(prop)+"</span></li>");
      prop = "java.runtime.version";
      out.println("       <li>"+prop+" = <span class=\"val\">"+sysProps.getProperty(prop)+"</span></li>");
      prop = "java.version";
      out.println("       <li>"+prop+" = <span class=\"val\">"+sysProps.getProperty(prop)+"</span></li>");
      prop = "os.arch";
      out.println("       <li>"+prop+" = <span class=\"val\">"+sysProps.getProperty(prop)+"</span></li>");
      prop = "os.name";
      out.println("       <li>"+prop+" = <span class=\"val\">"+sysProps.getProperty(prop)+"</span></li>");
      prop = "os.version";
      out.println("       <li>"+prop+" = <span class=\"val\">"+sysProps.getProperty(prop)+"</span></li>");

      out.println("      <li>Test Links<span class=\"val\">"+context.getServerInfo()+"</span></li>");

      out.println("      </ul>\n      </li>");

      out.println("    <li>Time Details\n      <ul>");
      out.println("        <li>Time = <span class=\"val\">"+(dateNow).toString()+"</span></li>");
      out.println("        <li>Timezone = <span class=\"val\">"+localTz.getDisplayName()+"</span></li>");
      out.println("        <li>Timezone Offset from UTC (hrs)= <span class=\"val\">"+(offset/60/60/1000)+"</span></li>");// in milliseconds offset
      out.println("        <li>Within Daylight Savings period? = <span class=\"val\">"+dst+"</span></li>");
      out.println("        <li>Additional Daylight Savings offest (hrs) = <span class=\"val\">"+(dstOffset/60/60/1000)+"</span></li>");
      out.println("        <li>Total offest from UTC (hrs) = <span class=\"val\">"+((offset+dstOffset)/60/60/1000)+"</span></li>");
      out.println("      </ul>\n      </li>");

      out.println("      <li>Test Links\n      <ul>");
      out.println("       <li><a href=\""+req.getContextPath()+"/rest/energy/calculated\">Calculated Energy Data</a></li>");
      out.println("        </ul>\n      </li>");

      out.println("  </ul>");

      out.println("<br /><br />");
      out.println("<h3>Client Request</h3>");
      out.println("  <ul>");
      out.println("    <li>Client/proxy Host = <span class=\"val\">"+req.getRemoteHost()+" ("+req.getRemoteAddr()+")</span></li>");
      out.println("    <li>Client/proxy port = <span class=\"val\">"+req.getRemotePort()+"</span></li>");
      out.println("    <li>Protocol = <span class=\"val\">"+req.getProtocol()+"</span></li>");
      out.println("  </ul>");

      out.println("<br /><br />");
      out.println("<h3>Client Parms Status</h3>");
      out.println("  <ul>");
      out.println("    <li>Browser = <span class=\"val\">"+req.getSession().getAttribute(CLIENT_SETTING_NAME_BROWSER_NAME)+" v"+
                  req.getSession().getAttribute(CLIENT_SETTING_NAME_BROWSER_VERSION)+"</span></li>");
      out.println("    <li>Device Type = <span class=\"val\">"+req.getSession().getAttribute(CLIENT_SETTING_NAME_DEVICE_TYPE)+"</span></li>");
      out.println("    <li>viewport.width = <span class=\"val\">"+req.getSession().getAttribute(CLIENT_SETTING_NAME_VIEWPORTWIDTH)+"</span></li>");
      out.println("    <li>viewport.height= <span class=\"val\">"+req.getSession().getAttribute(CLIENT_SETTING_NAME_VIEWPORTHEIGHT)+"</span></li>");
      out.println("  </ul>");
      out.println("<br /><br />");
      out.println("\n</body>\n</html>");
  }
}