/*

* 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 <iostream>

#include <algorithm>

#include "cpixfstools.h"

#include "itk.h"

#include "cpixidxdb.h"

#include "config.h"

#include "suggestion.h"

#include "testutils.h"

#include "testcorpus.h"

#include "setupsentry.h"

#include "std_log_result.h"

class DeletionContext : public Itk::ITestContext

{

private:

    SmsIdxUtil         * util_;

    cpix_Analyzer      * analyzer_;

    cpix_QueryParser   * queryParser_;

    cpix_Query         * query_;

public:

    virtual void setup() throw (Itk::PanicExc)

    {

        SetupSentry

            ss(*this);

        cpix_Result

            result;

        cpix_IdxDb_dbgScrapAll(&result);

        if (cpix_Failed(&result))

            {

                ITK_PANIC("Could not dbg scrapp all indexes");

            }

        util_ = new SmsIdxUtil;

        util_->init();

        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 ~DeletionContext()

    {

        cleanup();

    }

    //

    // public operations

    //

    DeletionContext()

        : util_(NULL),

          analyzer_(NULL),

          queryParser_(NULL),

          query_(NULL)

    {

        ;

    }

    //

    // Test Member Function

    //

    void testAdd_00(Itk::TestMgr * testMgr)

    {

        testAddSms(testMgr,

                   1,

                   L"This is a happy message");

        util_->flush();

        testSearch(testMgr);

    }

    void testAdd_01(Itk::TestMgr * testMgr)

    {

        testAddSms(testMgr,

                   2,

                   L"This is another happy message");

        util_->flush();

        testSearch(testMgr);

    }

    void testFlush_02(Itk::TestMgr * testMgr)

    {

        testFlush(testMgr);

    }

    void testAdd_03(Itk::TestMgr * testMgr)

    {

        testAddSms(testMgr,

                   3,

                   L"This is a 3rd happy message");

        util_->flush();

        testSearch(testMgr);

    }

    void testDelete_04(Itk::TestMgr * testMgr)

    {

        testDeleteSms(3,

                      testMgr);

        util_->flush();

        testSearch(testMgr);

    }

    void testDelete_05(Itk::TestMgr * testMgr)

    {

        testDeleteSms(1,

                      testMgr);

        util_->flush();

        testSearch(testMgr);

    }

    void testReOpenIdx_06(Itk::TestMgr * testMgr)

    {

        testReOpenIdxDb(testMgr);

        testSearch(testMgr);

    }

    void testAdd_07(Itk::TestMgr * testMgr)

    {

        testAddSms(testMgr,

                   4,

                   L"This is the 4th happy message");

        util_->flush();

        testSearch(testMgr);

    }

    void testAdd_08(Itk::TestMgr * testMgr)

    {

        testAddSms(testMgr,

                   5,

                   L"This is the 5th happy message");

        util_->flush();

        testSearch(testMgr);

    }

    void testDelete_09(Itk::TestMgr * testMgr)

    {

        testDeleteSms(2,

                      testMgr);

        util_->flush();

        testSearch(testMgr);

    }

    void testDelete_10(Itk::TestMgr * testMgr)

    {

        testDeleteSms(4,

                      testMgr);

        util_->flush();

        testSearch(testMgr);

    }

    void testReOpenIdx_11(Itk::TestMgr * testMgr)

    {

        testReOpenIdxDb(testMgr);

        testSearch(testMgr);

    }

private:

    //

    // private methods

    //

    void cleanup()

    {

        delete util_;

        util_ = NULL;

        cpix_Analyzer_destroy(analyzer_);

        analyzer_ = NULL;

        cpix_Query_destroy(query_);

        query_ = NULL;

        cpix_QueryParser_destroy(queryParser_);

        queryParser_ = NULL;

    }

    void testReOpenIdxDb(Itk::TestMgr *)

    {

        delete util_;

        util_ = NULL;

        util_ = new SmsIdxUtil;

        util_->init(false); // don't create

    }

    void testAddSms(Itk::TestMgr  * testMgr,

                    size_t          docUid,

                    const wchar_t * body)

    {

        using namespace Itk;

        util_->indexSms(docUid,

                        body,

                        analyzer_,

                        testMgr);

    }

    void testFlush(Itk::TestMgr * testMgr)

    {

        cpix_IdxDb_flush(util_->idxDb());

        ITK_EXPECT(testMgr,

                   cpix_Succeeded(util_->idxDb()),

                   "Could not flush idx");

    }

    void testDeleteSms(size_t         docUid,

                       Itk::TestMgr * testMgr)

    {

        util_->deleteSms(docUid,

                         testMgr);

    }

    void testSearch(Itk::TestMgr * testMgr)

    {

        using namespace Itk;

        cpix_Hits

            * hits = cpix_IdxDb_search(util_->idxDb(),

                                       query_);

        if (cpix_Failed(util_->idxDb()))

            {

                ITK_EXPECT(testMgr,

                           false,

                           "Failed to search");

                cpix_ClearError(util_->idxDb());

            }

        else

            {

                util_->printHits(hits,

                                 testMgr);

                cpix_Hits_destroy( hits ); 

            }

    }

};

Itk::TesterBase * CreateDeletionTests()

{

    using namespace Itk;

    DeletionContext

        * context = new DeletionContext;

    ContextTester

        * contextTester = new ContextTester("deletion",

                                            context);

#define TEST "00_add"

    contextTester->add(TEST,

                       context,

                       &DeletionContext::testAdd_00,

                       TEST);

#undef TEST

#define TEST "01_add"

    contextTester->add(TEST,

                       context,

                       &DeletionContext::testAdd_01,

                       TEST);

#undef TEST

#define TEST "02_flush"

    contextTester->add(TEST,

                       context,

                       &DeletionContext::testFlush_02);

#undef TEST

#define TEST "03_add"

    contextTester->add(TEST,

                       context,

                       &DeletionContext::testAdd_03,

                       TEST);

#undef TEST

#define TEST "04_delete"

    contextTester->add(TEST,

                       context,

                       &DeletionContext::testDelete_04,

                       TEST);

#undef TEST

#define TEST "05_delete"

    contextTester->add(TEST,

                       context,

                       &DeletionContext::testDelete_05,

                       TEST);

#undef TEST

#define TEST "06_reopen"

    contextTester->add(TEST,

                       context,

                       &DeletionContext::testReOpenIdx_06,

                       TEST);

#undef TEST

#define TEST "07_add"

    contextTester->add(TEST,

                       context,

                       &DeletionContext::testAdd_07,

                       TEST);

#undef TEST

#define TEST "08_add"

    contextTester->add(TEST,

                       context,

                       &DeletionContext::testAdd_08,

                       TEST);

#undef TEST

#define TEST "09_delete"

    contextTester->add(TEST,

                       context,

                       &DeletionContext::testDelete_09,

                       TEST);

#undef TEST

#define TEST "10_delete"

    contextTester->add(TEST,

                       context,

                       &DeletionContext::testDelete_10,

                       TEST);

#undef TEST

#define TEST "11_reopen"

    contextTester->add(TEST,

                       context,

                       &DeletionContext::testReOpenIdx_11,

                       TEST);

#undef TEST

    return contextTester;

}