ippClientServerSpyTestCase.cpp

Go to the documentation of this file.

// 
// DISCLAIMER: 
//  This software was produced by the National Institute of Standards 
//  and Technology (NIST), an agency of the U.S. government, and by statute is 
//  not subject to copyright in the United States.  Recipients of this 
//  software assume all responsibility associated with its operation,
//  modification,maintenance, and subsequent redistribution. 
//
//  See NIST Administration Manual 4.09.07 b and Appendix I. 
//
#define _CRT_SECURE_NO_DEPRECATE

#include "ippdme/winsock.h"
#include "ippClientServerSpyTestCase.h"
#include "ippMemoryLeakDetector.h"

#include "ippdme/Server/ippSimpleServer.h"
#include "ippdme/Server/ippSimpleClient.h"
#include "ippdme/Spy/ippClientServerSpy.h"
#include "ippdme/Server/ippLogger.h"
#include "ippdme/assert.h"






CXXTEST_ENUM_TRAITS( ippSimpleServer::STATE,
                     CXXTEST_ENUM_MEMBER( ippSimpleServer::uninitialized )
                     CXXTEST_ENUM_MEMBER( ippSimpleServer::listening )
                     CXXTEST_ENUM_MEMBER( ippSimpleServer::connected ));



CXXTEST_ENUM_TRAITS( ippSimpleClient::STATE,
                     CXXTEST_ENUM_MEMBER( ippSimpleClient::disconnected )
                     CXXTEST_ENUM_MEMBER( ippSimpleClient::trying_to_connect )
                     CXXTEST_ENUM_MEMBER( ippSimpleClient::connected ));


class ippCommand;
//-----------------------------------------------------------------------------
#define HEARTBEAT server.HeartBeat();client.HeartBeat();spy.HeartBeat();server.HeartBeat();client.HeartBeat();

void ippClientServerSpyTestCase::testSpy()
{
   ippSimpleServer server;
   IPP_UTEST_ASSERT_EQUALS(server.GetState() , ippSimpleServer::uninitialized );
   server.PowerOn(33333);
   IPP_UTEST_ASSERT_EQUALS(server.GetState() , ippSimpleServer::listening );
  
   ippClientServerSpy spy;
   spy.Start(44444,"localhost",33333);

   ippSimpleClient client;
   IPP_UTEST_ASSERT_EQUALS(client.GetState(),ippSimpleClient::disconnected );
  
   client.Connect("localhost",44444);
   HEARTBEAT;   HEARTBEAT;   HEARTBEAT;
   IPP_UTEST_ASSERT_EQUALS(client.GetState() , ippSimpleClient::connected );


   client.SendCommand("00001 StartSession()");
   HEARTBEAT;   HEARTBEAT;   HEARTBEAT;
   IPP_UTEST_ASSERT(server.InSession());
   IPP_UTEST_ASSERT(!client.NeedToSendClearAllErrors());
   IPP_UTEST_ASSERT(client.ReadyToSend());

   client.SendCommand("00002 CRAPCRAP()");
   HEARTBEAT;   HEARTBEAT;   HEARTBEAT;
   IPP_UTEST_ASSERT(server.InSession());
   IPP_UTEST_ASSERT(client.NeedToSendClearAllErrors());
   IPP_UTEST_ASSERT(client.ReadyToSend());
   client.ClearAllErrors();
   HEARTBEAT;   HEARTBEAT;   HEARTBEAT;
   IPP_UTEST_ASSERT(!client.NeedToSendClearAllErrors());
   IPP_UTEST_ASSERT(client.ReadyToSend());

   client.SendCommand("00002 EndSession()");
   HEARTBEAT;   HEARTBEAT;   HEARTBEAT;
   IPP_UTEST_ASSERT(!server.InSession());


   client.Disconnect();
   HEARTBEAT;   HEARTBEAT;   HEARTBEAT;
   IPP_UTEST_ASSERT(!server.InSession());
   IPP_UTEST_ASSERT_EQUALS(client.GetState(),ippSimpleClient::disconnected );

   // the server , however stays connected as the spy is connected to it
   IPP_UTEST_ASSERT_EQUALS(server.GetState(),ippSimpleServer::connected );

   // verifies that reconnection can happen
   client.Connect("localhost",44444);
   HEARTBEAT;   HEARTBEAT;   HEARTBEAT;
   IPP_UTEST_ASSERT_EQUALS(client.GetState() , ippSimpleClient::connected );

   client.SendCommand("00001 StartSession()");
   HEARTBEAT;   HEARTBEAT;   HEARTBEAT;
   IPP_UTEST_ASSERT(server.InSession());
   IPP_UTEST_ASSERT(!client.NeedToSendClearAllErrors());
   IPP_UTEST_ASSERT(client.ReadyToSend());

   client.SendCommand("00002 EndSession()");
   HEARTBEAT;   HEARTBEAT;   HEARTBEAT;
   IPP_UTEST_ASSERT(!server.InSession());


   client.Disconnect();
   IPP_UTEST_ASSERT(!server.InSession());
   IPP_UTEST_ASSERT_EQUALS(client.GetState(),ippSimpleClient::disconnected );
}

#undef  HEARTBEAT
#define HEARTBEAT server.HeartBeat();;spy.HeartBeat();server.HeartBeat();

#include "ippMockExecutor.h"


void ippClientServerSpyTestCase::testSpy_with_uncompliant_client1()
{
  // special test that verifies that the spy is 
  // not getting upset by multiple commands being send and not acknowledged.

  ippMockExecutor executor;
  ippSimpleServer server(&executor);
  IPP_UTEST_ASSERT_EQUALS(server.GetState() , ippSimpleServer::uninitialized );

  server.PowerOn(33333);
  IPP_UTEST_ASSERT_EQUALS(server.GetState() , ippSimpleServer::listening );

  ippClientServerSpy spy;
  spy.Start(44444,"localhost",33333);


  ippSocket fautly_client;
  fautly_client.Create();
  fautly_client.Connect("localhost",44444);
  HEARTBEAT;   HEARTBEAT;   HEARTBEAT;

  // client send a few commands without waiting for acknowledgment
  fautly_client.Write("00001 StartSession()\r\n00002 GetDMEVersion()\r\n00003 GetDMEVersion()\r\n00004 GetDMEVersion()\r\n");
  HEARTBEAT;   HEARTBEAT;   HEARTBEAT;
  IPP_UTEST_ASSERT(server.InSession());

  fautly_client.Write("00100 IsHomed()\r\n");

  fautly_client.Write("99999 EndSession()\r\n");
  HEARTBEAT;   HEARTBEAT;   HEARTBEAT;
  IPP_UTEST_ASSERT(!server.InSession());
  
  IPP_UTEST_ASSERT_EQUALS(3,executor.GetDMEVersionCounter());


  fautly_client.Close();
  HEARTBEAT;   HEARTBEAT;   HEARTBEAT;
  IPP_UTEST_ASSERT(!server.InSession());
  IPP_UTEST_ASSERT(!fautly_client.IsValid() );

  // the server , however stays connected as the spy is connected to it
  IPP_UTEST_ASSERT_EQUALS(server.GetState(),ippSimpleServer::connected );


}

---