source: code/branches/netp3/src/network/Client.cc @ 3050

/*
 *   ORXONOX - the hottest 3D action shooter ever to exist
 *                    > www.orxonox.net <
 *
 *
 *   License notice:
 *
 *   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, write to the Free Software
 *   Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
 *
 *   Author:
 *      Oliver Scheuss
 *   Co-authors:
 *      ...
 *
 */

//
// C++ Implementation: Client
//
// Description:
//
//
// Author:  Oliver Scheuss, (C) 2007
//
// Copyright: See COPYING file that comes with this distribution
//
//

#include <cassert>
#include <enet/enet.h>

#include "Client.h"
#include "Host.h"
#include "synchronisable/Synchronisable.h"
#include "core/Clock.h"
#include "core/CoreIncludes.h"
#include "packet/Packet.h"
#include "FunctionCallManager.h"

// #include "packet/Acknowledgement.h"

namespace orxonox
{
//   SetConsoleCommandShortcut(Client, chat);


  /**
  * Constructor for the Client class
  * initializes the address and the port to default localhost:NETWORK_PORT
  */
  Client::Client(): client_connection(NETWORK_PORT,"127.0.0.1"){
    // set server address to localhost
    isConnected=false;
    isSynched_=false;
    gameStateFailure_=false;
  }

  /**
  * Constructor for the Client class
  * @param address the server address
  * @param port port of the application on the server
  */
  Client::Client(const std::string& address, int port) : client_connection(port, address){
    isConnected=false;
    isSynched_=false;
    gameStateFailure_=false;
  }

  /**
  * Constructor for the Client class
  * @param address the server address
  * @param port port of the application on the server
  */
  Client::Client(const char *address, int port) : client_connection(port, address){
    isConnected=false;
    isSynched_=false;
    gameStateFailure_=false;
  }

  Client::~Client(){
    if(isConnected)
      closeConnection();
  }

  /**
  * Establish the Connection to the Server
  * @return true/false
  */
  bool Client::establishConnection(){
    Synchronisable::setClient(true);
    isConnected=client_connection.createConnection();
    if(!isConnected)
      COUT(1) << "could not create connection laber" << std::endl;
    return isConnected;
  }

  /**
  * closes the Connection to the Server
  * @return true/false
  */
  bool Client::closeConnection(){
    isConnected=false;
    return client_connection.closeConnection();
  }

  bool Client::queuePacket(ENetPacket *packet, int clientID){
    return client_connection.addPacket(packet);
  }

  bool Client::processChat(const std::string& message, unsigned int playerID){
//    COUT(1) << "Player " << playerID << ": " << message << std::endl;
    return true;
  }

  /**
   * This function implements the method of sending a chat message to the server
   * @param message message to be sent
   * @return result(true/false)
   */
  bool Client::chat(const std::string& message){
    packet::Chat *m = new packet::Chat(message, Host::getPlayerID());
    return m->send();
  }


  /**
   * Processes incoming packets, sends a gamestate to the server and does the cleanup
   * @param time
   */
  void Client::update(const Clock& time){
    //this steers our network frequency
    timeSinceLastUpdate_+=time.getDeltaTime();
    if(timeSinceLastUpdate_>=NETWORK_PERIOD){
      timeSinceLastUpdate_ -= static_cast<unsigned int>( timeSinceLastUpdate_ / NETWORK_PERIOD ) * NETWORK_PERIOD;
      //     COUT(3) << ".";
      if(client_connection.isConnected() && isSynched_){
        COUT(4) << "popping partial gamestate: " << std::endl;
        packet::Gamestate *gs = gamestate.getGamestate();
        assert(gs);
        if(gs){
          COUT(4) << "client tick: sending gs " << gs << std::endl;
          if( !gs->send() )
            COUT(3) << "Problem adding partial gamestate to queue" << std::endl;
        // gs gets automatically deleted by enet callback
        }
        FunctionCallManager::sendCalls();
      }
      ENetEvent *event;
    // stop if the packet queue is empty
      while(!(client_connection.queueEmpty())){
        event = client_connection.getEvent();
        COUT(5) << "tick packet size " << event->packet->dataLength << std::endl;
        packet::Packet *packet = packet::Packet::createPacket(event->packet, event->peer);
      // note: packet commits suicide here except for the GameState. That is then deleted by a GamestateHandler
        bool b = packet->process();
        assert(b);
      }
      if(gamestate.processGamestates())
      {
        if(!isSynched_)
          isSynched_=true;
      }
      gamestate.cleanup();
    }

    return;
  }

}