/*

  *   SONEWS News Server

  *   see AUTHORS for the list of contributors

  *

  *   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

  *   (at your option) 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 org.sonews.web;

 import info.monitorenter.gui.chart.ITrace2D;

 import info.monitorenter.gui.chart.traces.Trace2DSimple;

 import java.io.IOException;

 import javax.servlet.http.HttpServletRequest;

 import javax.servlet.http.HttpServletResponse;

 /**

  * Servlet that creates chart images and returns them as raw PNG images.

  * @author Christian Lins

  * @since sonews/0.5.0

  */

 public class SonewsChartServlet extends AbstractSonewsServlet

 {

   private ITrace2D createProcessMails24(String title, String cmd)

     throws IOException

   {

     int[] data = read24Values(cmd);

     ITrace2D trace = new Trace2DSimple(title);

     trace.addPoint(0.0, 0.0); // Start

     for(int n = 0; n < 24; n++)

     {

       trace.addPoint(n, data[n]);

     }

     return trace;

   }

   @Override

   public void doGet(HttpServletRequest req, HttpServletResponse resp)

     throws IOException

   {

     synchronized(this)

     {

       MemoryBitmapChart chart = new MemoryBitmapChart();

       String name  = req.getParameter("name");

       String group = req.getParameter("group");

       ITrace2D trace;

       String   cmd = "XDAEMON LOG";

       if(name.equals("feedednewsyesterday"))

       {

         cmd = cmd + " TRANSMITTED_NEWS";

         cmd = group != null ? cmd + " " + group : cmd;

         trace = createProcessMails24(

           "To peers transmitted mails yesterday", cmd);

       }

       else if(name.equals("gatewayednewsyesterday"))

       {

         cmd = cmd + " GATEWAYED_NEWS";

         cmd = group != null ? cmd + " " + group : cmd;

         trace = createProcessMails24(

           "Gatewayed mails yesterday", cmd);

       }

       else

       {

         cmd = cmd + " POSTED_NEWS";

         cmd = group != null ? cmd + " " + group : cmd;

         trace = createProcessMails24(

           "Posted mails yesterday", cmd);

       }

       chart.addTrace(trace);

       resp.getOutputStream().write(chart.getRawData(500, 400));

       resp.setContentType(chart.getContentType());

       resp.setStatus(HttpServletResponse.SC_OK);

     }

   }

   private int[] read24Values(String command)

     throws IOException

   {

     int[] values = new int[24];

     connectToNewsserver();

     printlnToNewsserver(command);

     String line = readlnFromNewsserver();

     if(!line.startsWith("200 "))

       throw new IOException(command + " not supported!");

     for(int n = 0; n < 24; n++)

     {

       line = readlnFromNewsserver();

       values[n] = Integer.parseInt(line.split(" ")[1]);

     }

     line = readlnFromNewsserver(); // "."

     disconnectFromNewsserver();

     return values;

   }

 }