/*
* 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:  storageconnectionnative
*
*/


#include "com_nokia_mj_impl_storage_StorageConnection.h"
#include "commsmessage.h"
#include "javacommonutils.h"
#include "javadataaccess.h"
#include "javajniutils.h"
#include "javastorageexception.h"
#include "logger.h"

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

JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_storage_StorageConnection__1startSession
(JNIEnv *, jclass)
{
    JELOG2(EJavaStorage);
    JavaDataAccess* dataAccess = JavaDataAccess::createInstance();
    // Return handle to session. Utilize the fact that in Symbian
    // all pointer addresses are MOD 4 so the last 2 bits are 0
    // and can be shifted out. This way the returned handle is
    // always positive whereas Symbian error codes are always negative.
    return reinterpret_cast<TUint>(dataAccess)>>2;
}

JNIEXPORT void JNICALL Java_com_nokia_mj_impl_storage_StorageConnection__1closeSession
(JNIEnv *, jclass, jint aSessionHandle)
{
    JELOG2(EJavaStorage);
    JavaDataAccess* dataAccess =
        reinterpret_cast<JavaDataAccess*>(aSessionHandle<<2);

    delete dataAccess;
    dataAccess = NULL;
}

JNIEXPORT jstring JNICALL Java_com_nokia_mj_impl_storage_StorageConnection__1open
(JNIEnv *aEnv, jobject, jint aSessionHandle, jstring aHeaders, jstring aStorageName)
{
    JELOG2(EJavaStorage);
    JavaDataAccess* dataAccess =
        reinterpret_cast<JavaDataAccess*>(aSessionHandle<<2);

    CommsMessage receivedMessage;
    const char* tempHeaders = aEnv->GetStringUTFChars(aHeaders, 0);
    const char* tempStorageName = aEnv->GetStringUTFChars(aStorageName, 0);
    std::string headers(tempHeaders);
    std::string storageName(tempStorageName);

    aEnv->ReleaseStringUTFChars(aHeaders, tempHeaders);
    aEnv->ReleaseStringUTFChars(aStorageName, tempStorageName);

    try
    {
        dataAccess->open(headers, storageName, receivedMessage);
    }
    catch (JavaStorageException& jse)
    {
        JniUtils::throwNewException(
            aEnv,
            "com/nokia/mj/impl/storage/StorageException",
            jse.toString().c_str());

        // Return control to Java side. Otherwise JNI Error occur about
        // pending exception.
        return 0;
    }

    int statusCode = -1;
    receivedMessage>>statusCode;

    std::string responseBody = "";
    receivedMessage>>responseBody;

    if (statusCode < 0 || responseBody.length() == 0)
    {
        WLOG1(EJavaStorage, "Server error. ErrorCode: %d", statusCode);

        std::string statusStr = "Server error. ErrorCode: ";
        statusStr.append(JavaCommonUtils::intToString(statusCode));

        JniUtils::throwNewException(
            aEnv,
            "com/nokia/mj/impl/storage/StorageException",
            statusStr.c_str());

        // Return control to Java side. Otherwise JNI Error occur about
        // pending exception.
        return 0;
    }

    return aEnv->NewStringUTF(responseBody.c_str());
}

JNIEXPORT void JNICALL Java_com_nokia_mj_impl_storage_StorageConnection__1close
(JNIEnv *aEnv, jobject, jint aSessionHandle, jstring aHeaders)
{
    JELOG2(EJavaStorage);
    JavaDataAccess* dataAccess =
        reinterpret_cast<JavaDataAccess*>(aSessionHandle<<2);

    CommsMessage receivedMessage;
    const char* tempHeaders = aEnv->GetStringUTFChars(aHeaders, 0);
    std::string headers(tempHeaders);

    aEnv->ReleaseStringUTFChars(aHeaders, tempHeaders);

    try
    {
        dataAccess->close(headers, receivedMessage);
    }
    catch (JavaStorageException& jse)
    {
        JniUtils::throwNewException(
            aEnv,
            "com/nokia/mj/impl/storage/StorageException",
            jse.toString().c_str());

        // Return control to Java side. Otherwise JNI Error occur about
        // pending exception.
        return;
    }

    int statusCode = -1;
    receivedMessage>>statusCode;

    std::string responseBody = "";
    receivedMessage>>responseBody;

    if (statusCode < 0 || responseBody.length() == 0)
    {
        WLOG1(EJavaStorage, "Server error. ErrorCode: %d", statusCode);

        std::string statusStr = "Server error. ErrorCode: ";
        statusStr.append(JavaCommonUtils::intToString(statusCode));

        JniUtils::throwNewException(
            aEnv,
            "com/nokia/mj/impl/storage/StorageException",
            statusStr.c_str());

        // Return control to Java side. Otherwise JNI Error occur about
        // pending exception.
        return;
    }
}

JNIEXPORT jstring JNICALL Java_com_nokia_mj_impl_storage_StorageConnection__1execute
(JNIEnv *aEnv, jobject, jint aSessionHandle, jstring aHeaders, jstring aSqlStatement)
{
    JELOG2(EJavaStorage);

    JavaDataAccess* dataAccess =
        reinterpret_cast<JavaDataAccess*>(aSessionHandle<<2);

    CommsMessage receivedMessage;
    const char* tempHeaders = aEnv->GetStringUTFChars(aHeaders, 0);
    std::string headers(tempHeaders);

    aEnv->ReleaseStringUTFChars(aHeaders, tempHeaders);

    const jchar* sqlStmtTemp = aEnv->GetStringChars(aSqlStatement, 0);

    std::wstring sqlStatement(
        (wchar_t*)sqlStmtTemp, aEnv->GetStringLength(aSqlStatement));

    aEnv->ReleaseStringChars(aSqlStatement, sqlStmtTemp);

    // ########################################################################
    // LOG1WSTR(EJavaStorage, EInfo, "Java Sql: '%s'", sqlStatement);
    // ########################################################################

    try
    {
        dataAccess->execute(headers, sqlStatement, receivedMessage);
    }
    catch (JavaStorageException& jse)
    {
        ELOG(EJavaStorage, "Execute failed to storage exception.");

        JniUtils::throwNewException(
            aEnv,
            "com/nokia/mj/impl/storage/StorageException",
            jse.toString().c_str());

        // Return control to Java side. Otherwise JNI Error occur about
        // pending exception.
        return 0;
    }
    catch (...)
    {
        ELOG(EJavaStorage, "Execute failed to unexp exception.");

        JniUtils::throwNewException(
            aEnv,
            "com/nokia/mj/impl/storage/StorageException",
            "Internal error");

        // Return control to Java side. Otherwise JNI Error occur about
        // pending exception.
        return 0;

    }

    int statusCode = -1;
    receivedMessage>>statusCode;

    std::wstring responseBody = L"";
    receivedMessage>>responseBody;

    // ########################################################################
    // LOG1WSTR(EJavaStorage, EInfo, "Server response: '%s'", responseBody);
    // ########################################################################

    if (statusCode < 0 || responseBody.length() == 0)
    {
        WLOG1(EJavaStorage, "Server error. ErrorCode: %d", statusCode);

        std::string statusStr = "Server error. ErrorCode: ";
        statusStr.append(JavaCommonUtils::intToString(statusCode));

        JniUtils::throwNewException(
            aEnv,
            "com/nokia/mj/impl/storage/StorageException",
            statusStr.c_str());

        // Return control to Java side. Otherwise JNI Error occur about
        // pending exception.
        return 0;
    }

    return aEnv->NewString(
               (const jchar*)responseBody.c_str(), responseBody.length());
}