/*

 * Copyright (c) 2009 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 "testsmsplugin.h"

#include <QtTest/QtTest>

#include "debugtraces.h"

#include <QTimer>

#include <QSignalSpy>

#include "convergedmessage.h"

#include "TestMsg.h"

#include "convergedmessageid.h"

#include "unieditorsmsplugin.h"

#include "messageserviceaction.h"

//---------------------------------------------------------------

// TestSmsPlugin::initTestCase

//---------------------------------------------------------------

void TestSmsPlugin::initTestCase()

{

    msgPlugin = new UniEditorSmsPlugin();

    testMsg = new TestMsg();

  //  QVERIFY(msgPlugin != 0);

    smsId = -1;

    mmsId = -1;

}

//---------------------------------------------------------------

// TestSmsPlugin::cleanupTestCase

//---------------------------------------------------------------

void TestSmsPlugin::cleanupTestCase()

{

    delete msgPlugin;

    delete testMsg;

}

//---------------------------------------------------------------

// TestSmsPlugin::init

//---------------------------------------------------------------

void TestSmsPlugin::init()

{

}

//---------------------------------------------------------------

// TestSmsPlugin::cleanup

//---------------------------------------------------------------

void TestSmsPlugin::cleanup()

{

}

//---------------------------------------------------------------

// TestSmsPlugin::testSendSMS

//---------------------------------------------------------------

void TestSmsPlugin::testSendReceiveSMS()

{ 

    testMsg->createSCSettings();

    testMsg->initSimTsyL();

    //TODO: Should uncomment the watcher code below while executing the test case in text shell mode. 

    //Also the watcher code should be commented while executing in UI mode.

  /*  RProcess watcherProcess;

    _LIT(KWatcherExe, "z:\\system\\libs\\watcher.exe");

    User::LeaveIfError(watcherProcess.Create(KWatcherExe, KNullDesC));

    watcherProcess.Resume();

    QTest::qWait(5000);*/

    TBool result = msgPlugin->validateService(ETrue);

    result = msgPlugin->validateService(EFalse);

    result = msgPlugin->isServiceValid();

    createAndSend(msgPlugin->messageType());

    testReceived(msgPlugin->messageType());

}

//---------------------------------------------------------------

// TestSmsPlugin::createAndSend

//---------------------------------------------------------------

void TestSmsPlugin::createAndSend(int type)

{

    ConvergedMessage message;

    message.setMessageType((ConvergedMessage::MessageType) type);

    message.setBodyText(QString(TEST_MSG_BODY));

    ConvergedMessageAddress address1;

    address1.setAddress(QString(TEST_MSG_TO3));

    message.addToRecipient(address1);

    message.setPriority(ConvergedMessage::Normal);

    if (type == ConvergedMessage::Mms)

    {

        ConvergedMessageAddress address2;

        address2.setAddress(QString(TEST_MSG_FROM2));

        address2.setAlias(QString(TEST_MSG_ALIAS2));

        message.addCcRecipient(address2);

        message.addBccRecipient(address2);

        message.setSubject(QString(TEST_MSG_SUBJECT));

        message.setPriority(ConvergedMessage::Normal);

    }

    int ret = -1;

    QBENCHMARK 

    {

    long int id = msgPlugin->convertTo(&message);

    msgPlugin->send(id);

    }

}

//---------------------------------------------------------------

// TestSmsPlugin::testReceived

//---------------------------------------------------------------

void TestSmsPlugin::testReceived(int type)

{

MessageServiceAction* messageAction = new MessageServiceAction(this);    

    QVERIFY(messageAction != 0);

    //register user defined object to meta system.

    qRegisterMetaType<ConvergedMessage*>("ConvergedMessage*");

    //signal spy.

    //listen to added event

    QSignalSpy spyAdd( messageAction,

            SIGNAL(messageAdded(ConvergedMessage*, QString)));

    //signal spy.

    //listen to updated event

        QSignalSpy spyUpdate( messageAction,

                SIGNAL(messageUpdated(ConvergedMessage*, QString)));

    //will force stub_clientmanager to emit messageUpdated.

    messageAction->registerForNotification();

    //register user defined object to meta system.

    // wait for the response to come

    QTest::qWait(5000);

    //check signals

    int countAdd = -1;

    countAdd = spyAdd.count();

    ConvergedMessage* message = 0;

    QString serviceId("");

    if (countAdd)

    {

        //verify added event

        void * temp = const_cast<void*> (spyAdd.at(0).at(0).data());

        message = *reinterpret_cast<ConvergedMessage*(*)> (temp);

        serviceId = spyAdd.at(0).at(1).toString();

        QVERIFY(message != 0);

        validateMsg(*message, serviceId);

    }

    int countUpdate = -1;

    countUpdate = spyUpdate.count();

    message = 0;

    for (int i = countUpdate; i > 0; --i)

    {

        //verify updated event

        void * temp = const_cast<void*> (spyUpdate.at(i-1).at(0).data());

        message = *reinterpret_cast<ConvergedMessage*(*)> (temp);

        if (ConvergedMessage::Inbox == message->location())

        {

            serviceId = spyUpdate.at(i-1).at(1).toString();

            break;

        }

    }

    if (message)

    {

        validateMsg(*message, serviceId);

    }

    delete message;

}

//---------------------------------------------------------------

// TestSmsPlugin::validateMsg

//---------------------------------------------------------------

void TestSmsPlugin::validateMsg(const ConvergedMessage& message,

                                const QString& serviceId)

{

#ifdef _DEBUG_TRACES_

		qDebug() << "....message received.....";

#endif

    //process incoming messages

    if (message.location() == ConvergedMessage::Inbox)

    {

        int msgId;

        if (message.id())

        {

            msgId = message.id()->getId();

        }

        ConvergedMessageAddressList array = message.toAddressList();

        if (array.count() > 0)

        {

            if (array[0])

                QCOMPARE(array[0]->address(),QString(TEST_MSG_FROM1));

        }

        ConvergedMessageAddress *fromAddr = message.fromAddress();

        if (fromAddr)

        {

            QCOMPARE(fromAddr->address(),QString(TEST_MSG_FROM1));

        }

        QCOMPARE(serviceId,QString(TEST_SERVICE_ID));

        if (message.messageType() == ConvergedMessage::Mms)

        {

            mmsId = msgId;

            QCOMPARE(message.subject(), QString(TEST_MSG_SUBJECT));

        }

        else if (message.messageType() == ConvergedMessage::Sms)

        {

            smsId = msgId;

            QCOMPARE(message.bodyText(), QString(TEST_MSG_BODY));

        }

    }

    else if (message.location() == ConvergedMessage::Sent)

    {

        ConvergedMessageAddressList array = message.toAddressList();

        if (array.count() > 0)

        {

            if (array[0])

                QCOMPARE(array[0]->address(),QString(TEST_MSG_FROM1));

        }

        QCOMPARE(serviceId,QString(TEST_SERVICE_ID));

        if (message.messageType() == ConvergedMessage::Mms)

        {

            QCOMPARE(message.subject(), QString(TEST_MSG_SUBJECT));

        }

        else if (message.messageType() == ConvergedMessage::Sms)

        {

            QCOMPARE(message.bodyText(), QString(TEST_MSG_BODY));

        }

    }

}