/*
    * AI Soccer Project - network gaming environment for AI warriors.
    * Copyright (C) 2001-2004  Marcin Werla, Pawel Widera
    *
    * 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 2
    * 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, you can find it here:
   * http://www.gnu.org/licenses/gpl.html
   */
  
  package snifos.communication.test;
  
  import org.apache.log4j.Logger;
  
  import org.custommonkey.xmlunit.Diff;
  
  import org.dom4j.Document;
  import org.dom4j.DocumentException;
  import org.dom4j.DocumentHelper;
  
  import org.xml.sax.SAXException;
  
  import snifos.common.UserId;
  
  import snifos.common.test.DummyMessages;
  
  import snifos.communication.CommModule;
  
  import snifos.server.Server;
  import snifos.server.SnifosServer;
  
  import java.io.IOException;
  
  import java.util.Properties;
  import java.util.Random;
  
  import javax.xml.parsers.ParserConfigurationException;
  
  
  /***
   * Dummy implementation of communication module. It just simulates connections
   * from few users, sends dummy messages from them and checks if responses are
   * the responses which were expected.
   * @version $Id: DummyCommModule.java,v 1.3 2004/05/08 21:55:31 mwerla Exp $
   */
  public class DummyCommModule implements CommModule {
      private static Logger logger = Logger.getLogger(DummyCommModule.class);
      private String name = "UNSET";
      private Server server;
      private int id;
      int responseCounter = 0;
  
      /***
       *
       */
      public DummyCommModule() {
          logger.info("Comm module created.");
      }
  
      /***
       * @see CommModule#configure(Properties, int)
       */
      public void configure(Properties configuration, int commModuleId) {
          this.name = configuration.getProperty("name");
          this.id = commModuleId;
          logger.info("Comm module nr " + id + " configured");
      }
  
      /***
       * @see CommModule#setServer(Server)
       */
      public void setServer(Server server) {
          this.server = server;
          logger.info("Server set in comm module");
      }
  
      /***
       * @see CommModule#sendMessage(UserId, Document)
       */
      public void sendMessage(UserId userId, Document message) {
          logger.info("Sending message \"" + message.asXML() + "\" to user " +
              userId + " from comm module nr " + id);
  
          try {
              //Diff d = 
              new Diff(message.asXML(),
                  DocumentHelper.parseText(
                      DummyMessages.responses[responseCounter++]).asXML());
  
              //assert d.identical();
         } catch (SAXException e) {
             e.printStackTrace();
         } catch (IOException e) {
             e.printStackTrace();
         } catch (ParserConfigurationException e) {
             e.printStackTrace();
         } catch (DocumentException e) {
             e.printStackTrace();
         }
     }
 
     /***
      * @see CommModule#disconnectUser(UserId)
      */
     public void disconnectUser(UserId userId) {
         logger.info("User " + userId + " disconnected from comm module nr " +
             id);
     }
 
     /***
      * @see CommModule#shutdown()
      */
     public void shutdown() {
         //Method not needed for now
     }
 
     /***
      * @see java.lang.Runnable#run()
      */
     public void run() {
         logger.info("Hello from comm module nr " + id + " with name " + name);
 
         Random r = new Random();
 
         for (int j = 1; j < 7; j++) {
             responseCounter = 0;
 
             UserId userId = new UserId(id, j);
 
             try {
                 for (int i = 0; i < DummyMessages.requests.length; i++) {
                     Thread.sleep(r.nextInt(3000) + 3000);
                     server.receiveMessage(userId,
                         DocumentHelper.parseText(DummyMessages.requests[i]));
                 }
 
                 Thread.sleep(100);
             } catch (Exception e) {
                 throw new RuntimeException(e);
             }
 
             server.unregisterUser(userId);
 
             if (responseCounter != 2) {
                 throw new RuntimeException("Wrong number of responses! : " +
                     responseCounter + " (" + userId + ")");
             }
         }
 
         if (((SnifosServer) server).isWait()) {
             synchronized (server) {
                 server.notify();
             }
         }
     }
 }