/*
    * To change this template, choose Tools | Templates
    * and open the template in the editor.
    */
   package net.sf.atmodem4j.core;
   
   /*
    * #%L
    * ATModem4J Core
   * %%
   * Copyright (C) 2009 - 2014 atmodem4j
   * %%
   * atmodem4j - Drivers for the AT modem - http://atmodem4j.sourceforge.net/
   * Copyright (C) 2009-2014, atmodem4j.sf.net, and individual contributors as indicated
   * by the @authors tag. See the copyright.txt in the distribution for a
   * full listing of individual contributors.
   * 
   * This 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 software 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
   * Lesser General Public License for more details.
   * 
   * You should have received a copy of the GNU Lesser General Public
   * License along with this software; if not, write to the Free
   * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
   * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
   * #L%
   */
  
  import java.io.IOException;
  import java.io.InputStream;
  import java.io.OutputStream;
  import org.junit.After;
  import org.junit.AfterClass;
  import org.junit.Before;
  import org.junit.BeforeClass;
  import org.junit.Ignore;
  import org.junit.Test;
  import static org.junit.Assert.*;
  
  /**
   *
   * @author aploese
   */
  public class ItuV250ModemTest {
  
      public class TestModem {
  
          class CompareOutputStream extends OutputStream implements Runnable {
  
              byte[] request;
              int pos;
              long delay;
  
              private CompareOutputStream(String request, long delay) {
                  this.request = request.getBytes();
                  this.delay = delay;
              }
  
              @Override
              public void write(int b) throws IOException {
                  if (request[pos] == b) {
                      pos++;
                      if (pos == request.length) {
                          new Thread(this).start();
                      }
                  } else {
                      throw new RuntimeException(String.format("request mismatch! at pos: \"%d\" \"%s\" \"%s\"", pos, (char)request[pos], (char)b));
                  }
              }
  
              public void run() {
                  try {
                      Thread.sleep(delay);
                  } catch (InterruptedException ex) {
                      throw new RuntimeException(ex);
                  }
                  synchronized (this) {
                      notifyAll();
                  }
              }
          }
  
          class DelayedInputStream extends InputStream {
  
              byte[] replay;
              int pos;
              final Object lock;
  
              private DelayedInputStream(String response, Object lock) {
                  this.lock = lock;
                  replay = response.getBytes();
              }
  
             @Override
             public int read() throws IOException {
                 try {
                     if (pos == 0) {
                         synchronized (lock) {
                             lock.wait(1000);
                         }
                     }
                 } catch (InterruptedException ex) {
                     throw new RuntimeException(ex);
                 }
                 if (pos >= replay.length) {
                     return -1;
                 }
                 return replay[pos++];
             }
         }
         InputStream is;
         OutputStream os;
 
         private TestModem(String request, String response, long delay) {
             os = new CompareOutputStream(request, delay);
             is = new DelayedInputStream(response, os);
         }
     }
 
     public ItuV250ModemTest() {
     }
 
     @BeforeClass
     public static void setUpClass() throws Exception {
     }
 
     @AfterClass
     public static void tearDownClass() throws Exception {
     }
 
     @Before
     public void setUp() {
     }
 
     @After
     public void tearDown() {
     }
 
     Modem initModem(String request, String response, long delay) {
         TestModem testModem = new TestModem(request, response, delay);
         Modem atModem = new ItuV250Modem();
         atModem.setModemInputStream(testModem.is);
         atModem.setModemOutputStream(testModem.os);
         return atModem;
     }
 
     /**
      * Test of dial method, of class ATModem.
      * @throws Exception 
      */
     @Test
     @Ignore
     public void testDial() throws Exception {
         System.out.println("dial");
         String number = "";
         Modem instance = new ItuV250Modem();
         Connection expResult = null;
         Connection result = instance.dial(number);
         assertEquals(expResult, result);
         // TODO review the generated test code and remove the default call to fail.
         fail("The test case is a prototype.");
     }
 
     /**
      * Test of setSpeaker method, of class ATModem.
      */
     @Test
     @Ignore
     public void testSetSpeaker() {
         System.out.println("setSpeaker");
         Modem instance = new ItuV250Modem();
         instance.setSpeaker();
         // TODO review the generated test code and remove the default call to fail.
         fail("The test case is a prototype.");
     }
 
     /**
      * Test of reset method, of class ATModem.
      * @throws Exception 
      */
     @Test
     public void testReset() throws Exception {
         System.out.println("reset");
         Modem instance = initModem("ATZ\r", "ATZ\r\r\nOK\r\n", 100);
         assertTrue(instance.reset());
     }
 
     // Cant test because OK ist faster then send.... setup of testmodem....
     @Ignore
     @Test
     public void testPrompt() throws Exception {
         System.out.println("prompt");
         Modem instance = initModem("AT+CMGS=8\r00" + Modem.EOF, "AT+CMGS=8\r>00" + Modem.EOF + "\r\nOK\r\n", 100);
         assertTrue(instance.sendCommandLineWithPrompt("AT+CMGS=8", "00"));
     }
 
     /**
      * Test of reenterDataMode method, of class ATModem.
      */
     @Test
     @Ignore
     public void testReenterDataMode() {
         System.out.println("reenterDataMode");
         Modem instance = new ItuV250Modem();
         instance.reenterDataMode();
         // TODO review the generated test code and remove the default call to fail.
         fail("The test case is a prototype.");
     }
 
     /**
      * Test of sendHangUp method, of class ATModem.
      */
     @Test
     @Ignore
     public void testSendHangUp() throws Exception {
         System.out.println("sendHangUp");
         Modem instance = new ItuV250Modem();
         instance.hangUp();
         // TODO review the generated test code and remove the default call to fail.
         fail("The test case is a prototype.");
     }
 }