/*
* Copyright (c) 2008-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:  JavaDataAccessImpl
*
*/


#include "commsclientendpoint.h"
#include "commsmessage.h"
#include "javacommonutils.h"
#include "javadataaccessimpl.h"
#include "javastorageexception.h"
#include "javastoragemessage.h"
#include "logger.h"

using namespace java::comms;
using namespace java::storage;
using namespace java::util;
using namespace std;

JavaDataAccessImpl::JavaDataAccessImpl() throw(JavaStorageException)
        : mConnOpen(false), mCachedSessionID("")
{
    JELOG2(EJavaStorage);
    mConnOpen = false;
    mCliConn.reset(new CommsClientEndpoint());
    int resultCode = mCliConn->connect(IPC_ADDRESS_JAVA_STORAGE_C);

    if (resultCode != 0)
    {
        ELOG1(EJavaStorage, "Cannot connect via comms: %d", resultCode);
        throw JavaStorageException(resultCode, "Comms failure",
                                   __FILE__, __FUNCTION__, __LINE__);
    }
}

OS_EXPORT JavaDataAccessImpl::~JavaDataAccessImpl()
{
    JELOG2(EJavaStorage);

    // If intance is deleted prior connection is closed do close which triggers
    // rollback on server side.
    if (mConnOpen)
    {
        string msgID = JavaCommonUtils::intToString(JavaStorageMessage::EClose);
        string msgIDSize = JavaCommonUtils::intToString(msgID.size());
        string requestHeaders = msgIDSize + msgID + mCachedSessionID;
        CommsMessage message;
        close(requestHeaders, message);
    }

    int resultCode = mCliConn->disconnect();

    if (resultCode != 0)
    {
        LOG1(EJavaStorage, EInfo,
             "Comms disconnect result code: %d", resultCode);
    }
}

OS_EXPORT void JavaDataAccessImpl::open(
    const std::string& aHeaders,
    const std::string& aStorageName,
    CommsMessage& aReceivedMessage) throw(JavaStorageException)
{
    JELOG2(EJavaStorage);

    CommsMessage sendStorageMessage;
    sendStorageMessage.setMessageId(IPC_JS_CONN_REG);

    // Headers contain MsgIdentifier,SessionId
    sendStorageMessage<<aHeaders;
    sendStorageMessage<<aStorageName;

    sendReceiveMessage(sendStorageMessage, aReceivedMessage);
    // SessionID is cached for the case that client deleted storage instance
    // with open connection. SessionID is required to close open connection.
    int resultCode = 0;
    aReceivedMessage>>resultCode;
    if (resultCode >= 0)
    {
        aReceivedMessage>>mCachedSessionID;
        aReceivedMessage.begin();
        mConnOpen = true;
    }
}

OS_EXPORT void JavaDataAccessImpl::close(const std::string& aHeaders,
        CommsMessage& aReceivedMessage)
throw(JavaStorageException)
{
    JELOG2(EJavaStorage);

    CommsMessage sendStorageMessage;
    sendStorageMessage.setMessageId(IPC_JS_CONN_REG);

    // Headers contain MsgIdentifier,SessionId
    sendStorageMessage<<aHeaders;
    sendStorageMessage<<"";

    sendReceiveMessage(sendStorageMessage, aReceivedMessage);
    mConnOpen = false;
}

OS_EXPORT void JavaDataAccessImpl::execute(const std::string& aHeaders,
        const std::wstring& aSqlStatement,
        CommsMessage& aReceivedMessage)
throw(JavaStorageException)
{
    JELOG2(EJavaStorage);

    CommsMessage sendStorageMessage;
    sendStorageMessage.setMessageId(IPC_JS_CONN_REG);

    // Headers contain MsgIdentifier,SessionId
    sendStorageMessage<<aHeaders;
    // Data is pure sqlstatement
    sendStorageMessage<<aSqlStatement;

    sendReceiveMessage(sendStorageMessage, aReceivedMessage);
}

void JavaDataAccessImpl::sendReceiveMessage(CommsMessage& aSendMessage,
        CommsMessage& aReceivedMessage)
throw(JavaStorageException)
{
    JELOG2(EJavaStorage);

    int resultCode = -1;

    aSendMessage.setReceiver(IPC_ADDRESS_JAVA_STORAGE_C);
    aSendMessage.setModuleId(PLUGIN_ID_JAVASTORAGE_CLIENT_C);

    resultCode = mCliConn->sendReceive(aSendMessage, aReceivedMessage, 10);

    if (resultCode != 0)
    {
        ELOG1(EJavaStorage, "Comms result code: %d", resultCode);

        throw JavaStorageException(resultCode, "Comms failure",
                                   __FILE__, __FUNCTION__, __LINE__);
    }
}