/*

* Copyright (c) 2010 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "Eclipse Public License v1.0"

* which accompanies this distribution, and is available

* at the URL "http://www.eclipse.org/legal/epl-v10.html".

*

* Initial Contributors:

* Nokia Corporation - initial contribution.

*

* Contributors:

*

* Description: 

*

*/

#include <stdio.h>

#include <wchar.h>

#include <glib.h>

#include <algorithm>

#include <functional>

#include <memory>

#include "cpixinit.h"

#include "config.h"

#include "randomtest.h"

#include "itk.h"

#include <iostream>

#include <fstream>

#ifdef __GCCE__

#include <staticlibinit_gcce.h>

#endif

using namespace Itk; 

Itk::TesterBase * CreatePartialSmsTests();

Itk::TesterBase * CreateDeletionTests();

Itk::TesterBase * CreateWhiteBoxTests();

Itk::TesterBase * CreateDestructiveTests(); 

Itk::TesterBase * CreatePrematureQryTests();

Itk::TesterBase * CreateCLuceneErrorTests(); // also from destructive.cpp

Itk::TesterBase * CreateStemTests();

Itk::TesterBase * CreateAggregateTests();

Itk::TesterBase * CreateGeoTests();

Itk::TesterBase * CreateMultiVolumeTests();

Itk::TesterBase * CreateDomainSelectionTests();

Itk::TesterBase * CreateUtf8Tests();

Itk::TesterBase * CreateUtf8PathTests();

Itk::TesterBase * CreateAnalysisTests();

Itk::TesterBase * CreateMapsTests();

Itk::TesterBase * CreateDocumentTests();

Itk::TesterBase * CreateTermSearchTests();

Itk::TesterBase * CreatePdfSearchTests();

Itk::TesterBase * CreateQueryTests();

Itk::TesterBase * CreateFlushTests();

Itk::TesterBase * CreateHeartbeatTests();

Itk::TesterBase * CreateNegativeTests();

// Clucene Qry

Itk::TesterBase * CreateClQryHierarchy();

Itk::TesterBase * CreateASyncTests();

Itk::TesterBase * CreateMiscTests();

// Avoid media Testcases if MDS not present. 

#ifdef MDS_PRESENT

// Spi 

Itk::TesterBase * CreateExifTests();

Itk::TesterBase * CreateId3Tests();

Itk::TesterBase * CreateSpiHierarchy() 

{

	using namespace Itk; 

	// "spi"

    SuiteTester

        * spi = new SuiteTester("spi");

    spi->add(CreateExifTests());  

    spi->add(CreateId3Tests()); 

    return spi; 

}

#endif

Itk::TesterBase * CreateTestHierarchy()

{

    using namespace Itk;

    // "all"

    SuiteTester

        * all = new SuiteTester("all");

    all->add(CreateSuiteTesterRandom()); 

    all->add(CreateDestructiveTests());

    all->add(CreatePrematureQryTests());

    // TODO enable when CLuceneErorr bug is found and fixed

    //all->add(CreateCLuceneErrorTests());  

    all->add(CreatePartialSmsTests()); 

    all->add(CreateDeletionTests());  

    all->add(CreateWhiteBoxTests()); 

    all->add(CreateAggregateTests()); 

	all->add(CreateNegativeTests());

    all->add(CreateMultiVolumeTests()); 	

    all->add(CreateDomainSelectionTests()); 

    all->add(CreateUtf8Tests());			

    all->add(CreateUtf8PathTests());

    all->add(CreateAnalysisTests());		

    all->add(CreatePdfSearchTests());

    all->add(CreateDocumentTests());		

    all->add(CreateFlushTests());			

    all->add(CreateHeartbeatTests());	    

    all->add(CreateTermSearchTests()); 		

    // TODO enable later Itk::TesterBase * CreateClQryHierarchy();

    all->add(CreateASyncTests());			

#ifdef MDS_PRESENT

    //all->add(CreateStemTests());    //Commented for STEMMER 

    //all->add(CreateGeoTests());     //Comment for GEO

    //all->add(CreateMapsTests());    //Comment for MAP	

    // all->add(CreateSpiHierarchy());  // Commented for JPG/EXIF files checks

#endif

	all->add(CreateQueryTests()); 

	all->add(CreateMiscTests());

    // add more top level test suites here

    // ...

    return all;

}

// required for heartbeat tests

const size_t       MaxIdleSec = 5;

#ifdef __SYMBIAN32__

#include "e32std.h" // For heap marks

#endif

int main(int          argc,

         const char * argv[])

{	

#ifdef __SYMBIAN32__

    __UHEAP_MARK;

#endif 

	using namespace std;

	int

		rv = 0;

	{

		cpix_Result

			result;

                cpix_InitParams

                    * initParams = cpix_InitParams_create(&result);

                if (cpix_Failed(&result))

                    {

                        printf("Failed to initialize Cpix\n");

                        return -1;

                    }

//                /* Added for decision coverage Test case */

                const char *cpix_Dir = cpix_InitParams_getCpixDir(initParams);

                const char *logFilebase = cpix_InitParams_getLogFileBase(initParams);

                size_t logSizeLimit = cpix_InitParams_getLogSizeLimit(initParams);

                size_t logSizeRecurrency = cpix_InitParams_getLogSizeCheckRecurrency(initParams);

                size_t maxIdleSec = cpix_InitParams_getMaxIdleSec(initParams);

                //size_t maxInsertBufferSize = cpix_InitParams_getMaxInsertBufSize(initParams);

                //cpix_InitParams_setMaxInsertBufferSize(initParams, maxInsertBufferSize);

                size_t insertBufMaxDocs = cpix_InitParams_getInsertBufMaxDocs(initParams);

                cpix_InitParams_setInsertBufMaxDocs(initParams, insertBufMaxDocs);

                size_t idxJobQueueSize = cpix_InitParams_getIdxJobQueueSize(initParams);

                cpix_InitParams_setIdxJobQueueSize(initParams, idxJobQueueSize);

                size_t qryJobQueueSize = cpix_InitParams_getQryJobQueueSize(initParams);

                cpix_InitParams_setQryJobQueueSize(initParams, qryJobQueueSize);

                int idxThreadPriorityDelta = cpix_InitParams_getIdxThreadPriorityDelta(initParams);

                cpix_InitParams_setIdxThreadPriorityDelta(initParams, idxThreadPriorityDelta);

                int qryThreadPriorityDelta = cpix_InitParams_getQryThreadPriorityDelta(initParams);

                size_t clHitsPageSize = cpix_InitParams_getClHitsPageSize(initParams);

                cpix_InitParams_setClHitsPageSize(initParams, clHitsPageSize);

                cpix_InitParams_setMaxIdleSec(initParams,

                                              MaxIdleSec);

                if (cpix_Failed(initParams))

                    {

                        printf("Failed to set max idle sec\n");

                        return -1;

                    }

                cpix_InitParams_setQryThreadPriorityDelta(initParams,

                                                          10);

                if (cpix_Failed(initParams))

                    {

                        printf("Failed to increase thread priority\n");

                        return -1;

                    }

		cpix_init(&result,

                          initParams);

		if (cpix_Failed(&result))

			{

				wchar_t

					buffer[128];

				cpix_Error_report(result.err_,

                                                  buffer,

                                                  sizeof(buffer)/sizeof(wchar_t));

				printf("Failed to initialize CPix: %S\n",

					   buffer);

				return -1;

			}

                cpix_InitParams_destroy(initParams);

                cpix_dbgForceLogs();

		// cpix_setLogLevel(CPIX_LL_DEBUG);

		auto_ptr<TesterBase>

			testCase(CreateTestHierarchy());

		bool

			help = false;

		const char

			* focus = NULL;

		if (argc == 2)

			{ if (strcmp(argv[1], "h") == 0)

					{

						help = true;

					}

				else

					{

						focus = argv[1];

					}

			}

		if (help)

			{

				cout << "Test hierarchy:" << endl;

				testCase->printHierarchy(cout);

			}

		else

			{

				auto_ptr<Itk::CompositeTestRunObserver>

					observer(new Itk::CompositeTestRunObserver());

				observer->add(new Itk::TestRunConsole(std::cout));

				// do this only if you need a way to

				// confirm that the process is running

				// on the phone without proper std IO

				// console OBS observer->add(new

				// Itk::ProgressFsDisplayer());

				// this observer will dump every event

				// to a file, so it slows down

				// everything, but when things crash,

				// at least you get partial results on

				// the file system

				observer->add(new Itk::ProgressDumper("c:\\data\\cpixunittest\\dump.txt"));

				Itk::TestMgr 

					testMgr(observer.get(),

						   "c:\\data\\cpixunittest\\");

				rv = testMgr.run(testCase.get(),

								focus);

				testMgr.generateSummary(std::cout);

				ofstream

					ofs("c:\\data\\cpixunittest\\report.txt");

				if (ofs)

					{

						testMgr.generateSummary(ofs);

					}

			}

		cpix_shutdown();

		int

			c = getchar();

	}

#ifdef __SYMBIAN32__

    __UHEAP_MARKEND; 

#endif 

	return rv;

}