ippClientServerSpy.h

Go to the documentation of this file.

#pragma once
#include "ippdme/ippdme.h"
#include "ippdme/Server/ippEngine.h"


class IPPDME_EXT_CLASS ippSpyServer;
class IPPDME_EXT_CLASS ippSpyClient;
class IPPDME_EXT_CLASS ippClientServerSpy;

class IPPDME_EXT_CLASS ippSpyServer : public ippEngine
{
public:
  enum STATE
  {
     uninitialized,
     listening,
     connected, 
  };
  ippSpyServer();
  virtual ~ippSpyServer();
  bool PowerOn(int portNumber);
  bool PowerOff();
  virtual void HeartBeat();
  void WriteToSocket(const char* line);
  void setParent(ippClientServerSpy*);

  STATE getStatus() const { return _state; }
protected:
  virtual void ProcessLine(const char* inputline);
  virtual void ProcessMisformedLine(const char* inputline);
  void PerformListening();
  void OnClientConnected();
  void OnClientDisconnected();
  virtual void OnConnectionLost();
private:
  STATE _state;
  ippSocket   _listenSocket;
  int _portNumber;
  ippClientServerSpy* _parent;
  ippSpyServer(const ippSpyServer&);
  void operator=(const ippSpyServer&);
};

class IPPDME_EXT_CLASS ippSpyClient : public ippEngine
{
public:
   enum STATE{
    disconnected,
    trying_to_connect,
    connected,
  };
 ippSpyClient();
 virtual ~ippSpyClient();

 void setParent(ippClientServerSpy* parent);

 void Connect(
    const char* hostname,
   int port
 );
  
  void Disconnect();
  void SendCommand(const char* command);
  STATE getStatus() const { return _state; }

 virtual void HeartBeat();
protected:
  virtual void ProcessLine(const char* inputline);
  virtual void ProcessMisformedLine(const char* inputline);

private:
  STATE _state;
  ippClientServerSpy* _parent;

  ippSpyClient(const ippSpyClient&);
  void operator=(const ippSpyClient&);

};



class IPPDME_EXT_CLASS ippClientServerSpy 
{
public:
  enum STATE {
     disconnected,
     trying_to_connect_to_remote_server,
     listening,
     connected,
  };  
  ippClientServerSpy();
  virtual ~ippClientServerSpy();

  bool Start(int listening_port,const char* server_ip, int server_port);

  void HeartBeat();
  void Stop();

  virtual void SendCommandLine(const char* inputline,bool bwellFormed);
  virtual void SendResponseLine(const char* inputline,bool bwellFormed);
  virtual void OnStatusChanged(STATE) {}
  ippLogger* GetLogger() const;
  void setLogger(ippLogger* logger);
  
  STATE getStatus() const;

private:
  ippSpyServer _server;
  ippSpyClient _client;
  ippSpyClient::STATE _oldClientState;
  ippSpyServer::STATE _oldServerState;
  STATE _state;
  int _listening_port;
  ippLogger* _logger;
  // prohibited copy operator
  ippClientServerSpy(const ippClientServerSpy&);
  void operator=(const ippClientServerSpy&);
  ippSpyClient::STATE getClientStatus() const;
  ippSpyServer::STATE getServerStatus() const;

};

---