/*

* Copyright (c) 2008 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:  ?Description

 *

*/

#include <errno.h>

#include "logger.h"

#include "mmsconnection.h"

#include "mmsserverconnectionfactory.h"

namespace java

{

namespace wma

{

MmsConnection::MmsConnection(bool aServerConnection,std::wstring aUri)

        :mUri(aUri),

        mIsServerConnection(aServerConnection),

        mReceiveOperation(aServerConnection),

        mServerConn(0),

        mMessageMonitor(0),

        mServerConnectionFactory(0),

        mMmsPlatformService(0)

{

    JELOG2(EWMA);

}

void MmsConnection::initialize(JNIEnv& aJni, jobject aPeer)

{

    JELOG2(EWMA);

    if (mIsServerConnection)

    {

        mServerConnectionFactory = &MmsServerConnectionFactory::getFactory();

        mServerConn = reinterpret_cast<MmsServerConnection*>

                      (mServerConnectionFactory->create(mUri));

        mServerConn->setOpen();

        mMessageMonitor = java::util::Monitor::createMonitor();

    }

    mMmsPlatformService = MMSPlatformService::getInstance(aJni, aPeer,

                          mIsServerConnection, mUri, this);

}

void MmsConnection::msgArrived(const std::wstring&)

{

    JELOG2(EWMA);

    mMessageMonitor->notify();

}

void MmsConnection::error(const std::wstring& /*aUri*/, int /*aErrCode*/,

                          const std::string& /*aErrText*/)

{

    // This is not handled

}

void MmsConnection::open(JNIEnv& aJni, jobject aPeer)

{

    JELOG2(EWMA);

    int status =0;

    int messages = 0;

    int newMessages = 0;

    int messagesNotified = 0;

    jclass sessionClass = aJni.FindClass(

                              "com/nokia/mj/impl/mms/MMSConnectionImpl");

    jmethodID receiveCallBackMethodId = aJni.GetMethodID(sessionClass,

                                        "messageReceiveCallback", "(I)I");

    // Keep notifying the java side about incoming messages till

    // the connection is closed

    while (mReceiveOperation && (0 == status))

    {

        // waits for the notification from server connection

        mMessageMonitor->wait();

        // check whether its a message notification or connection close

        // notification

        if (mReceiveOperation)

        {

            // Get no of messages available in store

            messages = mMmsPlatformService->getNumberOfMessages();

            // Calculate no of new messages to be notified to java

            newMessages = messages - messagesNotified;

            messagesNotified = messages;

            if (newMessages > 0)

            {

                status = aJni.CallIntMethod(aPeer, receiveCallBackMethodId,

                                            newMessages);

            }

            newMessages = 0;

        }

    }

}

void MmsConnection::close(JNIEnv& aJni, jobject aPeer)

{

    JELOG2(EWMA);

    if (mIsServerConnection)

    {

        mReceiveOperation = false;

        if (0 != mMessageMonitor)

        {

            mMessageMonitor->notify();

        }

        if ((0 != mServerConnectionFactory) && (0 != mServerConn))

        {

            mServerConnectionFactory->releaseConnection(mUri);

            mServerConnectionFactory = 0;

            mServerConn = 0;

        }

    }

    if (0 != mMmsPlatformService)

    {

        mMmsPlatformService->closeConnection(aJni, aPeer);

    }

}

jint MmsConnection::sendMMS(JNIEnv& aJni, jbyteArray aMsg, jint aOffset,

                            jint aMsgLenght, jstring aAddress)

{

    JELOG2(EWMA);

    return mMmsPlatformService->send(aJni, aMsg, aOffset, aMsgLenght, aAddress);

}

jbyteArray MmsConnection::retrieveMMSMessage(JNIEnv& aJni)

{

    JELOG2(EWMA);

    return mMmsPlatformService->retrieveMessage(aJni);

}

MmsConnection::~MmsConnection()

{

    JELOG2(EWMA);

    delete mMmsPlatformService;

    delete mMessageMonitor;

}

} //namespace wma

} //namespace java