/*

  *   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.daemon.command;

 import java.io.IOException;

 import java.util.List;

 import org.sonews.util.Log;

 import org.sonews.daemon.NNTPConnection;

 import org.sonews.storage.Article;

 import org.sonews.storage.ArticleHead;

 import org.sonews.storage.Headers;

 import org.sonews.storage.StorageBackendException;

 import org.sonews.util.Pair;

 /**

  * Class handling the OVER/XOVER command.

  * 

  * Description of the XOVER command:

  * <pre>

  * XOVER [range]

  *

  * The XOVER command returns information from the overview

  * database for the article(s) specified.

  *

  * The optional range argument may be any of the following:

  *              an article number

  *              an article number followed by a dash to indicate

  *                 all following

  *              an article number followed by a dash followed by

  *                 another article number

  *

  * If no argument is specified, then information from the

  * current article is displayed. Successful responses start

  * with a 224 response followed by the overview information

  * for all matched messages. Once the output is complete, a

  * period is sent on a line by itself. If no argument is

  * specified, the information for the current article is

  * returned.  A news group must have been selected earlier,

  * else a 412 error response is returned. If no articles are

  * in the range specified, a 420 error response is returned

  * by the server. A 502 response will be returned if the

  * client only has permission to transfer articles.

  *

  * Each line of output will be formatted with the article number,

  * followed by each of the headers in the overview database or the

  * article itself (when the data is not available in the overview

  * database) for that article separated by a tab character.  The

  * sequence of fields must be in this order: subject, author,

  * date, message-id, references, byte count, and line count. Other

  * optional fields may follow line count. Other optional fields may

  * follow line count. These fields are specified by examining the

  * response to the LIST OVERVIEW.FMT command. Where no data exists,

  * a null field must be provided (i.e. the output will have two tab

  * characters adjacent to each other). Servers should not output

  * fields for articles that have been removed since the XOVER database

  * was created.

  *

  * The LIST OVERVIEW.FMT command should be implemented if XOVER

  * is implemented. A client can use LIST OVERVIEW.FMT to determine

  * what optional fields  and in which order all fields will be

  * supplied by the XOVER command. 

  *

  * Note that any tab and end-of-line characters in any header

  * data that is returned will be converted to a space character.

  *

  * Responses:

  *

  *   224 Overview information follows

  *   412 No news group current selected

  *   420 No article(s) selected

  *   502 no permission

  *

  * OVER defines additional responses:

  *

  *  First form (message-id specified)

  *    224    Overview information follows (multi-line)

  *    430    No article with that message-id

  *

  *  Second form (range specified)

  *    224    Overview information follows (multi-line)

  *    412    No newsgroup selected

  *    423    No articles in that range

  *

  *  Third form (current article number used)

  *    224    Overview information follows (multi-line)

  *    412    No newsgroup selected

  *    420    Current article number is invalid

  *

  * </pre>

  * @author Christian Lins

  * @since sonews/0.5.0

  */

 public class OverCommand implements Command

 {

   public static final int MAX_LINES_PER_DBREQUEST = 200;

   @Override

   public String[] getSupportedCommandStrings()

   {

     return new String[]{"OVER", "XOVER"};

   }

   @Override

   public boolean hasFinished()

   {

     return true;

   }

   @Override

   public boolean isStateful()

   {

     return false;

   }

   @Override

   public void processLine(NNTPConnection conn, final String line, byte[] raw)

     throws IOException, StorageBackendException

   {

     if(conn.getCurrentChannel() == null)

     {

       conn.println("412 no newsgroup selected");

     }

     else

     {

       String[] command = line.split(" ");

       // If no parameter was specified, show information about

       // the currently selected article(s)

       if(command.length == 1)

       {

         final Article art = conn.getCurrentArticle();

         if(art == null)

         {

           conn.println("420 no article(s) selected");

           return;

         }

         conn.println(buildOverview(art, -1));

       }

       // otherwise print information about the specified range

       else

       {

         long artStart;

         long artEnd   = conn.getCurrentChannel().getLastArticleNumber();

         String[] nums = command[1].split("-");

         if(nums.length >= 1)

         {

           try

           {

             artStart = Integer.parseInt(nums[0]);

           }

           catch(NumberFormatException e) 

           {

             Log.get().info(e.getMessage());

             artStart = Integer.parseInt(command[1]);

           }

         }

         else

         {

           artStart = conn.getCurrentChannel().getFirstArticleNumber();

         }

         if(nums.length >=2)

         {

           try

           {

             artEnd = Integer.parseInt(nums[1]);

           }

           catch(NumberFormatException e) 

           {

             e.printStackTrace();

           }

         }

         if(artStart > artEnd)

         {

           if(command[0].equalsIgnoreCase("OVER"))

           {

             conn.println("423 no articles in that range");

           }

           else

           {

             conn.println("224 (empty) overview information follows:");

             conn.println(".");

           }

         }

         else

         {

           for(long n = artStart; n <= artEnd; n += MAX_LINES_PER_DBREQUEST)

           {

             long nEnd = Math.min(n + MAX_LINES_PER_DBREQUEST - 1, artEnd);

             List<Pair<Long, ArticleHead>> articleHeads = conn.getCurrentChannel()

               .getArticleHeads(n, nEnd);

             if(articleHeads.isEmpty() && n == artStart

               && command[0].equalsIgnoreCase("OVER"))

             {

               // This reply is only valid for OVER, not for XOVER command

               conn.println("423 no articles in that range");

               return;

             }

             else if(n == artStart)

             {

               // XOVER replies this although there is no data available

               conn.println("224 overview information follows");

             }

             for(Pair<Long, ArticleHead> article : articleHeads)

             {

               String overview = buildOverview(article.getB(), article.getA());

               conn.println(overview);

             }

           } // for

           conn.println(".");

         }

       }

     }

   }

   private String buildOverview(ArticleHead art, long nr)

   {

     StringBuilder overview = new StringBuilder();

     overview.append(nr);

     overview.append('\t');

     String subject = art.getHeader(Headers.SUBJECT)[0];

     if("".equals(subject))

     {

       subject = "<empty>";

     }

     overview.append(escapeString(subject));

     overview.append('\t');

     overview.append(escapeString(art.getHeader(Headers.FROM)[0]));

     overview.append('\t');

     overview.append(escapeString(art.getHeader(Headers.DATE)[0]));

     overview.append('\t');

     overview.append(escapeString(art.getHeader(Headers.MESSAGE_ID)[0]));

     overview.append('\t');

     overview.append(escapeString(art.getHeader(Headers.REFERENCES)[0]));

     overview.append('\t');

     String bytes = art.getHeader(Headers.BYTES)[0];

     if("".equals(bytes))

     {

       bytes = "0";

     }

     overview.append(escapeString(bytes));

     overview.append('\t');

     String lines = art.getHeader(Headers.LINES)[0];

     if("".equals(lines))

     {

       lines = "0";

     }

     overview.append(escapeString(lines));

     overview.append('\t');

     overview.append(escapeString(art.getHeader(Headers.XREF)[0]));

     // Remove trailing tabs if some data is empty

     return overview.toString().trim();

   }

   private String escapeString(String str)

   {

     String nstr = str.replace("\r", "");

     nstr = nstr.replace('\n', ' ');

     nstr = nstr.replace('\t', ' ');

     return nstr.trim();

   }

 }