/*

* 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 <stdio.h>

#include <string>

#include "TestHarness.h"

#include "servertestutils.h"

#include "commsmessage.h"

#include "javastoragemessage.h"

#include "javacommonutils.h"

#include "javastorageexception.h"

using namespace std;

using namespace java::comms;

using namespace java::storage;

using namespace java::util;

TEST_GROUP(TestConcurrentConnections)

{

    ServerTestUtils* ctu;

    TEST_SETUP()

    {

        ctu = new ServerTestUtils();

    }

    TEST_TEARDOWN()

    {

        if (ctu)

        {

            delete ctu;

            ctu = NULL;

        }

    }

};

/**

 * Test storageserver.cpp.

 *

 * 1. Send four open messages and check the session IDs, send one duplicate open message for already open session

 * 2. Close one session and check that session ID has been removed from server

 * 3. Use closed sessions ID to send a read statement, will fail

 * 4. Use third session to write in to DB and close session

 * 5. Check that third session isn't still found from server by sending a read statement

 * 6. Read the inserted data (see 4. part) from DB using the first session

 * 7. Remove inserted data (see 4. part) from DB using the fourth session

 * 8. Close the remaining sessions

 */

TEST(TestConcurrentConnections, TestConcurrentConnections)

{

    CHECK(ctu->connect());

    // 1. Send four open messages and check the session IDs, send one duplicate open message for already open session

    CommsMessage sendMessage;

    CommsMessage receivedMessage;

    string sessionID1 = "";

    string sessionID2 = "";

    string sessionID3 = "";

    string sessionID4 = "";

    string sessionID5 = "";

    sendMessage.setMessageId(IPC_JS_CONN_REG);

    string msgID = JavaCommonUtils::intToString(JavaStorageMessage::EOpen);

    string msgIDSize = JavaCommonUtils::intToString(msgID.size());

    string headers;

    string jsDBName = "JavaStorage";

    headers.insert(0, msgIDSize);

    headers.insert(1, msgID);

    sendMessage<<headers;

    // Pass also the JavaStorage DB name so DB gets initialized

    sendMessage<<jsDBName;

    // Open first

    CHECK(ctu->sendReceive(sendMessage, receivedMessage));

    int responseCode = -1;

    receivedMessage>>responseCode;

    receivedMessage>>sessionID1;

    // Open second

    CHECK(ctu->sendReceive(sendMessage, receivedMessage));

    responseCode = -1;

    receivedMessage>>responseCode;

    receivedMessage>>sessionID2;

    // Open third

    CHECK(ctu->sendReceive(sendMessage, receivedMessage));

    responseCode = -1;

    receivedMessage>>responseCode;

    receivedMessage>>sessionID3;

    // Open fourth

    CHECK(ctu->sendReceive(sendMessage, receivedMessage));

    responseCode = -1;

    receivedMessage>>responseCode;

    receivedMessage>>sessionID4;

    sendMessage.reset();

    receivedMessage.reset();

    // Open first again by passing the session ID and check that server returns the same session ID

    string headersFirstSession = sessionID1;

    headersFirstSession.insert(0, msgIDSize);

    headersFirstSession.insert(1, msgID);

    sendMessage<<headersFirstSession;

    sendMessage<<jsDBName;

    CHECK(ctu->sendReceive(sendMessage, receivedMessage));

    responseCode = -1;

    receivedMessage>>responseCode;

    receivedMessage>>sessionID5;

    CHECK(sessionID1 == sessionID5);

    sendMessage.reset();

    receivedMessage.reset();

    // 2. Close one session and check that session ID has been removed from server

    string msgIDClose = JavaCommonUtils::intToString(JavaStorageMessage::EClose);

    string msgIDCloseSize = JavaCommonUtils::intToString(msgIDClose.size());

    string headers2 = "";

    headers2 = sessionID2;

    headers2.insert(0, msgIDSize);

    headers2.insert(1, msgIDClose);

    sendMessage<<headers2;

    CHECK(ctu->sendReceive(sendMessage, receivedMessage));

    sendMessage.reset();

    receivedMessage.reset();

    // 3. Use closed sessions ID to send a read statement, will fail

    string msgIDRead = JavaCommonUtils::intToString(JavaStorageMessage::ERead);

    string msgIDReadSize = JavaCommonUtils::intToString(msgIDRead.size());

    string headersRead = "";

    headersRead = sessionID2;

    headersRead.insert(0, msgIDReadSize);

    headersRead.insert(1, msgIDRead);

    string selectStmt = "SELECT ID FROM APPLICATION_PACKAGE;";

    sendMessage<<headersRead;

    sendMessage<<selectStmt;

    CHECK(ctu->sendReceive(sendMessage, receivedMessage));

    int resultID = 0;

    string resultMessage = "";

    receivedMessage>>resultID;

    receivedMessage>>resultMessage;

    CHECK(resultID == EInvalidConnection);

    CHECK(resultMessage == "Invalid sessionID");

    sessionID2 = "";

    sendMessage.reset();

    receivedMessage.reset();

    // 4. Use third session to write in to DB and close session

    string msgIDWrite = JavaCommonUtils::intToString(JavaStorageMessage::EWrite);

    string msgIDWriteSize = JavaCommonUtils::intToString(msgIDWrite.size());

    string headersWrite = "";

    headersWrite = sessionID3;

    headersWrite.insert(0, msgIDWriteSize);

    headersWrite.insert(1, msgIDWrite);

    string writeStmt = "INSERT INTO APPLICATION_PACKAGE (ID) VALUES ('SuperGame');";

    sendMessage<<headersWrite;

    sendMessage<<writeStmt;

    CHECK(ctu->sendReceive(sendMessage, receivedMessage));

    sendMessage.reset();

    receivedMessage.reset();

    string headers3 = sessionID3;

    headers3.insert(0, msgIDCloseSize);

    headers3.insert(1, msgIDClose);

    sendMessage<<headers3;

    CHECK(ctu->sendReceive(sendMessage, receivedMessage));

    sendMessage.reset();

    receivedMessage.reset();

    // 5. Check that third session isn't still found from server by sending a read statement

    headersRead = "";

    headersRead = sessionID3;

    headersRead.insert(0, msgIDReadSize);

    headersRead.insert(1, msgIDRead);

    sendMessage<<headersRead;

    sendMessage<<selectStmt;  // selectStmt declared in 3. part of the test

    CHECK(ctu->sendReceive(sendMessage, receivedMessage));

    resultID = 0;

    resultMessage = "";

    receivedMessage>>resultID;

    receivedMessage>>resultMessage;

    CHECK(resultID == EInvalidConnection);

    CHECK(resultMessage == "Invalid sessionID");

    sessionID3 = "";

    sendMessage.reset();

    receivedMessage.reset();

    // 6. Read the inserted data (see 4. part) from DB using the first session

    headersRead = "";

    headersRead = sessionID1;

    headersRead.insert(0, msgIDReadSize);

    headersRead.insert(1, msgIDRead);

    sendMessage<<headersRead;

    sendMessage<<selectStmt;

    CHECK(ctu->sendReceive(sendMessage, receivedMessage));

    resultID = 0;

    resultMessage = "";

    receivedMessage>>resultID;

    receivedMessage>>resultMessage;

    CHECK(resultID == 0);

    CHECK(resultMessage == ";#\n;ID=SuperGame;\n;");

    sendMessage.reset();

    receivedMessage.reset();

    // 7. Remove inserted data (see 4. part) from DB using the fourth session

    string msgIDRemove = JavaCommonUtils::intToString(JavaStorageMessage::ERemove);

    string msgIDRemoveSize = JavaCommonUtils::intToString(msgIDRemove.size());

    string headersRemove = "";

    headersRemove = sessionID4;

    headersRemove.insert(0, msgIDRemoveSize);

    headersRemove.insert(1, msgIDRemove);

    string removeStmt = "DELETE FROM APPLICATION_PACKAGE WHERE ID='SuperGame';";

    sendMessage<<headersRemove;

    sendMessage<<removeStmt;

    CHECK(ctu->sendReceive(sendMessage, receivedMessage));

    resultID = 0;

    resultMessage = "";

    receivedMessage>>resultID;

    receivedMessage>>resultMessage;

    sendMessage.reset();

    receivedMessage.reset();

    // 8. Close the remaining sessions

    string headers1 = sessionID1;

    headers1.insert(0, msgIDCloseSize);

    headers1.insert(1, msgIDClose);

    sendMessage<<headers1;

    CHECK(ctu->sendReceive(sendMessage, receivedMessage));

    sendMessage.reset();

    receivedMessage.reset();

    string headers4 = sessionID4;

    headers4.insert(0, msgIDCloseSize);

    headers4.insert(1, msgIDClose);

    sendMessage<<headers4;

    CHECK(ctu->sendReceive(sendMessage, receivedMessage));

    sendMessage.reset();

    receivedMessage.reset();

    CHECK(ctu->disconnect());

}