CoreTest.cpp

Go to the documentation of this file.

/***************************** License **********************************

 Copyright (C) 2008 by Communicative Machines
 http://www.cmlabs.com   All rights reserved.

 This library is free software; you can redistribute it and/or
 modify it under the terms of the GNU Lesser General Public
 License as published by the Free Software Foundation; either
 version 2.1 of the License, or (at your option) any later version.

 This library 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 library; if not, write to the Free Software
 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA

************************************************************************/
// CoreTest.cpp : Defines the entry point for the console application.
//

#include "CoreTest.h"

#ifdef WIN32
//   #define _CRTDBG_MAP_ALLOC
//   #include <stdlib.h>
//   #include <crtdbg.h>
#endif

namespace cmlabs {

int debugLevel = 0;
int verboseness = 1;


bool runSystemTest(int testport) {
   return true;
}

void runTests(int cnsport, JString testlib) {

        srand( (unsigned)time( NULL ) );
        printf("\n\n*** Welcome to the Generic Core Test %d ***\n\n", cnsport);

//      testCommunicationRecorder();
//      return;

//      testMediaServer(new MediaServer("Test Media Server"), cnsport+200);
//      return;

        test(new DataSample());
        test(new XMLParser());

        testCommunicationRecorder();
        test(new InfoItem());
        test(new JString());
        test(new Message());
        test(new Dictionary());
        test(new ObjectDictionary());
        test(new Collection());
        test(new ObjectCollection());
        test(new SortedCollection());
        test(new SortedDictionary());
        test(new SortedObjectCollection());
        test(new SortedObjectDictionary());
        test(new ObjectTable());

        test(new Parameter("TestParameter", "Integer"));
        test(new JTime(""));
        test(new OSCommand());
        test(new DotString(""));

        if (testlib.length() > 0) {
                DynamicLoader* loader = new DynamicLoader();
                loader->setTestLib(testlib);
                test(loader);
        }

        test(new Queue()); 
        test(new RequestQueue());
        test(new ObjectRequestQueue());

        testJThread(new JThread());
        test(new TimerManager());

        testSockets(new SocketTester(cnsport+1));
        testNetwork(new Network(), cnsport+100);
        testMediaServer(new MediaServer("Test Media Server"), cnsport+200);

        printf("\n*** Generic Core Test complete ***\n\n");
}

JString runTest(int c) {

        //try {

                switch(c) {

/*                      case 0:
                                return testTextSockets(new SocketTester(20001));
                                break;  
                        case 1:
                                return testTextNetwork(new Network(), 20002);
                                break;  
                        case 2:
                                return testTextMediaServer(new MediaServer("Test Media Server"), 20003);
                                break;  */

                        case 0:
                                return testText(new JTime());
                                break;  
                        case 1:
                                return testText(new DotString());
                                break;  
                        case 2:
                                return testText(new Dictionary());
                                break;  
                        case 3:
                                return testText(new Queue());
                                break;
                        case 4:
                                return testText(new XMLParser());
                                break;  
                        case 5:
                                return testTextThread(new JThread());
                                break;  
                        case 6:
                                return testText(new ObjectDictionary());
                                break;  
                        case 7:
                                return testText(new Collection());
                                break;  
                        case 8:
                                return testText(new SortedCollection());
                                break;  
                        case 9:
                                return testText(new Queue());
                                break;  
                        case 10:
                                return testText(new RequestQueue());
                                break;  
                        case 11:
                                return testText(new ObjectRequestQueue());
                                break;  
                        case 12:
                                return testText(new Parameter("TestParameter", "Integer"));
                                break;  
                        case 13:
                                return testText(new TimerManager());
                                break;  
                        case 14:
                                return testTextSockets(new SocketTester(20001));
                                break;  
                        case 15:
                                return testTextNetwork(new Network(), 20002);
                                break;  
                        case 16:
                                return testTextMediaServer(new MediaServer("Test Media Server"), 20003);
                                break;  
                                
                }
                
                return "";

        //}
        //catch(...) {
        //}
        return JString::format("Exception during Test %d...", c);
}

void test(Object* obj) {

   JString str = obj->getClass() + " Unit Test:                                                                                    ";

   printf("%.70s ", (char*) str);
   // Run UnitTest...
   if (obj->unitTest())
      printf("PASSED\n");
   else {
      printf("FAILED\n");
      printf("Test log:\n%s", (char*) obj->getUnitTestLog());
   }
   obj->getUnitTestLog();
   delete(obj);
}

JString testText(Object* obj) {
        JString str = obj->getClass() + " Unit Test:                                                   ";
        str = str.getFirst(30) + "\t";


        // Run UnitTest...
        if (obj->unitTest())
                str += "PASSED";
        else {
                str += JString::format("FAILED\nTest log:\n%s", (char*) obj->getUnitTestLog());
        }
        obj->getUnitTestLog();
        delete(obj);
        return str;
}

void testJThread(JThread* obj) {

//   obj->run();
   
   JString str = "Threading Unit Test:                                                                                 ";
//   JString str = obj->getClass() + " Unit Test:                                                   ";

   printf("%.70s ", (char*) str);
   // Run UnitTest...
   if (obj->unitTest())
      printf("PASSED\n");
   else {
      printf("FAILED\n");
      printf("Test log:\n%s", (char*) obj->unitTestString);
   }
   delete(obj);
}

JString testTextThread(JThread* obj) {

        JString str = "Threading Unit Test:                                                   ";
        str = str.getFirst(30) + "\t";

        // Run UnitTest...
        if (obj->unitTest())
                str += "PASSED";
        else {
                str += JString::format("FAILED\nTest log:\n%s", (char*) obj->unitTestString);
        }
        delete(obj);
        return str;
}

void testNetwork(Network* network, int testport) {

   JString str = "Network Unit Test:                                                                                ";
   printf("%.70s ", (char*) str);

   if (!network->init(testport)) {
      delete(network);
      printf("FAILED\n");
      printf("  Network failed to get port %d\n", testport);
      return;
   }
   network->start();
   network->wait(100);
   if (network->unitTest()) 
      printf("PASSED\n");
   else {
      printf("FAILED\n");
      printf("Test log:\n%s", (char*) network->getUnitTestLog());
   }
//   network->wait(100000);
   network->getUnitTestLog();
   delete(network);

}

JString testTextNetwork(Network* network, int testport) {

        JString str = "Network Unit Test:                                                   ";
        str = str.getFirst(30) + "\t";

        if (!network->init(testport)) {
                delete(network);
                str += JString::format("FAILED\nNetwork failed to get port %d\n", testport);
                return str;
        }
        network->start();
        network->wait(100);
        if (network->unitTest()) 
                str += "PASSED";
        else {
                str += JString::format("FAILED\nTest log:\n%s", (char*) network->getUnitTestLog());
        }
        network->getUnitTestLog();
        delete(network);
        return str;
}

void testSockets(SocketTester* obj) {

        obj->start();

        JString str = "Sockets Unit Test:                                                                                    ";

        // Run UnitTest...
        if (obj->unitTest()) {
                printf("%.70s ", (char*) str);
                printf("PASSED\n");
        }
        else {
                printf("%.70s ", (char*) str);
                printf("FAILED\n");
                printf("Test log:\n%s", (char*) obj->getUnitTestLog());
        }
        obj->getUnitTestLog();
        //   obj->terminate();
        delete(obj);
}

JString testTextSockets(SocketTester* obj) {

        obj->start();

        JString str = "Sockets Unit Test:                                                   ";
        str = str.getFirst(30) + "\t";

        // Run UnitTest...
        if (obj->unitTest())
                str += "PASSED";
        else {
                JString slog = "*";
                if (obj->server != NULL)
                        slog = obj->server->getUnitTestLog();
                str += JString::format("FAILED\nTest log:\n'%s'\n%s", (char*) obj->getUnitTestLog(), (char*) slog);
        }
        obj->getUnitTestLog();
        delete(obj);
        return str;
}

void testMediaServer(MediaServer* obj, int testport) {

        JString str = "MediaServer Unit Test:                                                                                      ";
        printf("%.70s ", (char*) str);

        if (!obj->init(testport)) {
                delete(obj);
                printf("FAILED\n");
                printf("  MediaServer failed to get port %d\n", testport);
                return;
        }

        obj->start();


        // Run UnitTest...
        if (obj->unitTest()) {
                printf("PASSED\n");
        }
        else {
                printf("%.70s ", (char*) str);
                printf("FAILED\n");
                printf("Test log:\n%s", (char*) obj->getUnitTestLog());
        }
        obj->getUnitTestLog();
        //   obj->terminate();
        delete(obj);
}

JString testTextMediaServer(MediaServer* obj, int testport) {

        JString str = "MediaServer Unit Test:                                                   ";
        str = str.getFirst(30) + "\t";

        if (!obj->init(testport)) {
                delete(obj);
                str += JString::format("FAILED\nMediaServer failed to get port %d\n", testport);
                return str;
        }
        obj->start();

        // Run UnitTest...
        if (obj->unitTest())
                str += "PASSED";
        else {
                str += JString::format("FAILED\nTest log:\n'%s'\n%s", (char*) obj->getUnitTestLog());
        }
        obj->getUnitTestLog();
        delete(obj);
        return str;
}


void testCommunicationRecorder() {

        JString str = "CommunicationRecorder Unit Test:                                                                                      ";
        printf("%.70s ", (char*) str);

        JString dir = "ComRecorderTest";
        CommunicationRecorder* comWriter = new CommunicationRecorder(dir, true);
        if (!comWriter->initWriting()) {
                delete(comWriter);
                printf("FAILED\n");
                printf("  CommunicationRecorder Writer failed to initialise\n");
                return;
        }
        comWriter->start();

        // Run UnitTest...
        if (comWriter->unitTest()) {
                printf("PASSED\n");
        }
        else {
                printf("FAILED\n");
                printf("Test log:\n%s", (char*) comWriter->getUnitTestLog());
        }
        comWriter->getUnitTestLog();
        delete(comWriter);
        JFile::deleteADir(dir, true);
}



} // namespace cmlabs

---