/*

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

 import java.io.IOException;

 import java.lang.reflect.InvocationTargetException;

 import java.lang.reflect.Method;

 import java.nio.channels.SocketChannel;

 import junit.framework.TestCase;

 import org.sonews.daemon.NNTPConnection;

 import org.sonews.daemon.command.ArticleCommand;

 import org.sonews.daemon.command.CapabilitiesCommand;

 import org.sonews.daemon.command.GroupCommand;

 import org.sonews.daemon.command.UnsupportedCommand;

 /**

  * Unit test for class NNTPConnection.

  * @author Christian Lins

  * @since sonews/0.5.0

  */

 public class NNTPConnectionTest extends TestCase

 {

   public void testLineReceived()

     throws NoSuchMethodException, IllegalAccessException, InvocationTargetException

   {

     NNTPConnection conn = null;

     try

     {

       try

       {

         conn = new NNTPConnection(null);

         fail("Should have raised an IllegalArgumentException");

       }

       catch(IOException ex) {ex.printStackTrace();}

     }

     catch(IllegalArgumentException ex){}

     try

     {

       conn = new NNTPConnection(SocketChannel.open());

     }

     catch(IOException ex)

     {

       ex.printStackTrace();

     }

     assertNotNull(conn);

     // Make interesting methods accessible

     Class  clazz           = conn.getClass();

     Method methTryReadLock = clazz.getDeclaredMethod("tryReadLock", null);

     methTryReadLock.setAccessible(true);

     Method methLineReceived = clazz.getDeclaredMethod("lineReceived", new byte[0].getClass());

     methLineReceived.setAccessible(true);

     try

     {

       // conn.lineReceived(null);

       methLineReceived.invoke(conn, null);

       fail("Should have raised an IllegalArgumentException");

     }

     catch(IllegalArgumentException ex){}

     try

     {

       // conn.lineReceived(new byte[0]);

       methLineReceived.invoke(conn, new byte[0]);

       fail("Should have raised IllegalStateException");

     }

     catch(InvocationTargetException ex){}

     boolean tryReadLock = (Boolean)methTryReadLock.invoke(conn, null);

     assertTrue(tryReadLock);

     // conn.lineReceived("MODE READER".getBytes());

     methLineReceived.invoke(conn, "MODE READER".getBytes());

     // conn.lineReceived("sdkfsdjnfksjfdng ksdf gksjdfngk nskfng ksndfg ".getBytes());

     methLineReceived.invoke(conn, "sdkfsdjnfksjfdng ksdf ksndfg ".getBytes());

     // conn.lineReceived(new byte[1024]); // Too long

     methLineReceived.invoke(conn, new byte[1024]);

     Method mpcmdl = conn.getClass().getDeclaredMethod("parseCommandLine", String.class);

     mpcmdl.setAccessible(true);

     Object result = mpcmdl.invoke(conn, "");

     assertNotNull(result);

     assertTrue(result instanceof UnsupportedCommand);

     result = mpcmdl.invoke(conn, "aRtiCle");

     assertNotNull(result);

     assertTrue(result instanceof ArticleCommand);

     result = mpcmdl.invoke(conn, "capAbilItIEs");

     assertNotNull(result);

     assertTrue(result instanceof CapabilitiesCommand);

     result = mpcmdl.invoke(conn, "grOUp");

     assertNotNull(result);

     assertTrue(result instanceof GroupCommand);

   }

 }