/*
* 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 <wchar.h>
#include <stddef.h>
#include <unistd.h>

#include <memory>
#include <iostream>
#include <list>
#include <map>
#include <vector>

#include "cpixfstools.h"

#include "itk.h"

#include "cpixidxdb.h"
#include "cpixsearch.h"
#include "idxdbmgr.h" // from private folder: whitebox testing

#include "config.h"
#include "suggestion.h"
#include "testutils.h"
#include "testcorpus.h"
#include "setupsentry.h"

//
// these constants are set so that a cpix_XXX entity should be
// eligible for internal (transparent) release between the 2nd and 3rd
// period (sleep)
//
const unsigned int SleepSec   = 2;
const char         LastAccessedPattern[] = "(last accessed: ";


class HeartbeatContext : public Itk::ITestContext
{
    cpix_Analyzer            * analyzer_;
    cpix_QueryParser         * queryParser_;
    cpix_Query               * query_;

    LineTestCorpusRef          corpus_;
    SmsIdxUtil               * smsIdxUtil_;
    FileIdxUtil              * fileIdxUtil_;
    cpix_IdxSearcher         * searcher_;

    cpix_LogLevel              oldLogLevel_;


public:
    virtual void setup() throw (Itk::PanicExc)
    {
        SetupSentry
            ss(*this);

        cpix_Result
            result;

        oldLogLevel_ = cpix_setLogLevel(CPIX_LL_TRACE);

        cpix_IdxDb_dbgScrapAll(&result);

        if (cpix_Failed(&result))
            {
                ITK_PANIC("Could not dbg scrapp all indexes");
            }

        analyzer_ = cpix_CreateSimpleAnalyzer(&result);

        if (analyzer_ == NULL)
            {
                ITK_PANIC("Could not create analyzer");
            }

        queryParser_ = cpix_QueryParser_create(&result,
                                               LBODY_FIELD,
                                               analyzer_);
        if (queryParser_ == NULL)
            {
                ITK_PANIC("Could not create query parser");
            }

        query_ = cpix_QueryParser_parse(queryParser_,
                                        L"happy");
        if (cpix_Failed(queryParser_)
            || query_ == NULL)
            {
                ITK_PANIC("Could not parse query string");
            }

        ss.setupComplete();
    }

    virtual void tearDown() throw()
    {
        cleanup();
    }


    virtual ~HeartbeatContext()
    {
        cleanup();
    }


    //
    // public operations
    //
    HeartbeatContext()
        : analyzer_(NULL),
          queryParser_(NULL),
          query_(NULL),
          corpus_(DEFAULT_TEST_CORPUS_PATH),
          smsIdxUtil_(NULL),
          fileIdxUtil_(NULL),
          searcher_(NULL)
          
    {
        ;
    }


    //
    // public (test) operations
    //
    void testCreateFileIdxDb(Itk::TestMgr * testMgr)
    {
        using namespace std;

        doCommonJobs(testMgr,
                     false);

        auto_ptr<FileIdxUtil>
            fiu(new FileIdxUtil);
        fiu->init(true);

        fileIdxUtil_ = fiu.release();
    }


    void testCreateSmsIdxDb(Itk::TestMgr * testMgr)
    {
        using namespace std;

        doCommonJobs(testMgr);

        auto_ptr<SmsIdxUtil>
            siu(new SmsIdxUtil);
        siu->init(true);
        
        smsIdxUtil_ = siu.release();
    }
    

    void testAddSomeSms(Itk::TestMgr * testMgr)
    {
        using namespace std;

        doCommonJobs(testMgr);

        for (size_t i = 0; i < 5; ++i)
            {
                std::wstring
                    body = corpus_.item(i);
                smsIdxUtil_->indexSms(i,
                                      body.c_str(),
                                      analyzer_,
                                      testMgr);
                if ((i % 5) == 0)
                    {
                        ITK_DBGMSG(testMgr,
                                   ".");
                    }
            }
    }


    void testIdle(Itk::TestMgr * testMgr)
    {
        doCommonJobs(testMgr);
    }


    void testUseMultiSearcher(Itk::TestMgr * testMgr)
    {
        doCommonJobs(testMgr);

        if (searcher_ == NULL)
            {
                cpix_Result
                    result;

                searcher_ = cpix_IdxSearcher_openDb(&result,
                                                    "root");
                                     
                if (searcher_ == NULL)
                    {
                        ITK_ASSERT(testMgr,
                                   false,
                                   "Could not create multi searcher");
                    }
            }

        cpix_Hits
            * hits = cpix_IdxSearcher_search(searcher_,
                                             query_);
        ITK_EXPECT(testMgr,
                   cpix_Succeeded(query_),
                   "Could not search with multisearcher");
        if (hits != NULL)
            {
                PrintHits(hits,
                          testMgr);

                cpix_Hits_destroy(hits);
            }
    }

    
    void testAddSomeFile(Itk::TestMgr * testMgr)
    {
        doCommonJobs(testMgr);

        fileIdxUtil_->indexFile(FILE_TEST_CORPUS_PATH "\\en\\1.txt",
                                analyzer_,
                                testMgr);
    }

    
    void testReleaseAll(Itk::TestMgr * testMgr)
    {
        doCommonJobs(testMgr);

        delete fileIdxUtil_;
        fileIdxUtil_ = NULL;

        delete smsIdxUtil_;
        smsIdxUtil_ = NULL;

        cpix_IdxSearcher_releaseDb(searcher_);
        searcher_ = NULL;
    }
    

private:
    //
    // private methods
    //
    void cleanup()
    {
        delete smsIdxUtil_;
        smsIdxUtil_ = NULL;

        delete fileIdxUtil_;
        fileIdxUtil_ = NULL;

        cpix_IdxSearcher_releaseDb(searcher_);
        searcher_ = NULL;

        cpix_Analyzer_destroy(analyzer_);
        analyzer_ = NULL;

        cpix_Query_destroy(query_);
        query_ = NULL;

        cpix_QueryParser_destroy(queryParser_);
        queryParser_ = NULL;
        

        cpix_setLogLevel(oldLogLevel_);
    }
    

    void doCommonJobs(Itk::TestMgr * testMgr,
                      bool           doSleep = true)
    {
        if (doSleep)
            {
                printf("Sleeping %d seconds...\n",
                       SleepSec);
                ITK_EXPECT(testMgr,
                           sleep(SleepSec) == 0,
                           "Could not sleep");
                printf("... slept.\n");
            }

        cpix_doHousekeeping();

        printf("Housekept.\n");

        // TODO
        // measure memory consumption (not tested by I/O)

        cpix_dbgDumpState();
    }

};


Itk::TesterBase * CreateHeartbeatTests()
{
    using namespace Itk;

    HeartbeatContext
        * heartbeatContext = new HeartbeatContext();
    ContextTester
        * contextTester = new ContextTester("heartbeat",
                                            heartbeatContext);
#define TEST "00_createFileIdxDb"
    contextTester->add(TEST,
                       heartbeatContext,
                       &HeartbeatContext::testCreateFileIdxDb,
                       TEST,
                       LastAccessedPattern);
#undef TEST

#define TEST "01_createSmsIdxDb"
    contextTester->add(TEST,
                       heartbeatContext,
                       &HeartbeatContext::testCreateSmsIdxDb,
                       TEST,
                       LastAccessedPattern);
#undef TEST

#define TEST "02_addSomeSms"
    contextTester->add(TEST,
                       heartbeatContext,
                       &HeartbeatContext::testAddSomeSms,
                       TEST,
                       LastAccessedPattern);
#undef TEST

#define TEST "03_idle"
    contextTester->add(TEST,
                       heartbeatContext,
                       &HeartbeatContext::testIdle,
                       TEST,
                       LastAccessedPattern);
#undef TEST

#define TEST "04_idle"
    contextTester->add(TEST,
                       heartbeatContext,
                       &HeartbeatContext::testIdle,
                       TEST,
                       LastAccessedPattern);
#undef TEST

#define TEST "05_idle"
    contextTester->add(TEST,
                       heartbeatContext,
                       &HeartbeatContext::testIdle,
                       TEST,
                       LastAccessedPattern);
#undef TEST

#define TEST "06_useMultiSearcher"
    contextTester->add(TEST,
                       heartbeatContext,
                       &HeartbeatContext::testUseMultiSearcher,
                       TEST,
                       LastAccessedPattern);
#undef TEST

#define TEST "07_addSomeFile"
    contextTester->add(TEST,
                       heartbeatContext,
                       &HeartbeatContext::testAddSomeFile,
                       TEST,
                       LastAccessedPattern);
#undef TEST

#define TEST "08_idle"
    contextTester->add(TEST,
                       heartbeatContext,
                       &HeartbeatContext::testIdle,
                       TEST,
                       LastAccessedPattern);
#undef TEST

#define TEST "09_idle"
    contextTester->add(TEST,
                       heartbeatContext,
                       &HeartbeatContext::testIdle,
                       TEST,
                       LastAccessedPattern);
#undef TEST

#define TEST "10_idle"
    contextTester->add(TEST,
                       heartbeatContext,
                       &HeartbeatContext::testIdle,
                       TEST,
                       LastAccessedPattern);
#undef TEST

#define TEST "11_useMultiSearcher"
    contextTester->add(TEST,
                       heartbeatContext,
                       &HeartbeatContext::testUseMultiSearcher,
                       TEST,
                       LastAccessedPattern);
#undef TEST

#define TEST "12_releaseAll"
    contextTester->add(TEST,
                       heartbeatContext,
                       &HeartbeatContext::testReleaseAll,
                       TEST,
                       LastAccessedPattern);
#undef TEST


#define TEST "13_idle"
    contextTester->add(TEST,
                       heartbeatContext,
                       &HeartbeatContext::testIdle,
                       TEST,
                       LastAccessedPattern);
#undef TEST

    // ... add more

    return contextTester;
}