/*

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

*

*/

#ifndef PUSHCONTROLLERSTARTERIMPL_H

#define PUSHCONTROLLERSTARTERIMPL_H

#include <memory>

#include <list>

#include <string>

#include <exception>

#include "comms.h"

#include "commslistener.h"

#include "pushcontrollerstarter.h"

#include "pushconstant.h"

#include "serverconnectionfactory.h"

#include "connectionlistener.h"

#include "pendingconnectionlistener.h"

#include "dynamiclibloader.h"

#include "pushserverconnpluginmanager.h"

#include "pushregistry.h"

#include "javauid.h"

#include "monitor.h"

namespace java

{

namespace runtime

{

class ApplicationBasicInfo;

class RuntimeInfo;

}

namespace comms

{

class CommsMessage;

class CommsClientEndpoint;

}

namespace util

{

class Uid;

}

namespace push

{

class PushServerConnection;

/**

 * This class provides implementation for PushControllerStarter and PushRegistry

 * interfaces.

 */

class PushControllerStarterImpl : public PushControllerStarter, public ConnectionListener,

        public java::comms::CommsListener, public PushRegistry,

        public PushControllerErrorHandlerInterface,

        public PendingConnectionListener,

        public ConnManagedInterface

{

public:

    PushControllerStarterImpl();

    virtual ~PushControllerStarterImpl();

    //Method of PushControllerStarter.

    virtual void startListen(const java::util::Uid& aUid,

                             java::runtime::MidpStarterPushSupport* aAppStateController);

    virtual void updatePushRegs(const java::util::Uid& aUid,

                                java::runtime::MidpStarterPushSupport* aAppStateController);

    virtual void close();

    //Methhod of ConnectionListener.

    virtual void msgArrived(const std::wstring& aInfo);

    virtual void error(const std::wstring& aUri, int aErrCode, const std::string& aErrText);

    //Methods of CommsListener.

    virtual void processMessage(java::comms::CommsMessage& aMessage);

    //Implementation methods of PushRegistry java class.

    /**

     * See comments from PushRegistry::registerDynamicPushConn() operation.

     */

    virtual void registerDynamicPushConn(const std::wstring& aUri,

                                         const std::wstring& aMidlet,

                                         const std::wstring& aFilter,

                                         const java::util::Uid& aUid,

                                         bool aIsUidOfThisMidlet);

    /**

     * See comments from PushRegistry::listConnections() operation.

     */

    virtual void listConnections(bool aAvailable,const java::util::Uid& aUid,

                                 std::list<std::wstring>& aUriList);

    /**

     * See comments from PushRegistry::getFilter() operation.

     */

    virtual std::wstring getFilter(const std::wstring& aUri,

                                   const java::util::Uid& aSuiteUid);

    /**

     * See comments from PushRegistry::getClassNameOfMidlet() operation.

     */

    virtual std::wstring getClassNameOfMidlet(const std::wstring& aUri,

            const java::util::Uid& aSuiteUid);

    /**

     * See comments from PushRegistry::isPushConnection() operation.

     */

    virtual bool isPushConnection(const std::wstring& aUri,const java::util::Uid& aUid);

    /**

     * See comments from PushRegistry::isPushConnection() operation.

     */

    virtual void unregisterDynamicPushConn(const std::wstring& aUri,

                                           const java::util::Uid& aUid,

                                           bool aIsUidOfThisMidlet);

    /**

     * @param aMidlet validation of this argument must be done in the java side.

     */

    virtual long long registerAlarm(const long long& aAlarmTimeInMilliSecs,

                                    const java::util::Uid& aSuiteUid,

                                    const std::wstring& aClassNameOfMidlet,

                                    bool aIsUidOfThisMidlet);

    //Methods of PushControllerErrorHandlerInterface interface.

    virtual void sendAllConnsFailedMsg();

    virtual void closeRuntime();

    //Method of PendingConnectionListener interface.

    virtual void setPendingStatus(const std::wstring& aUri,bool aMsgIsWaitingHandling);

    //Method of ConnManagedInterface.

    virtual void connCompleted(const std::wstring& aUri);

private:

    enum EState

    {

        INITIAL_STATE = 0,

        LOADING_PUSH_CONNS,

        PUSH_CONNS_LOADED

    };

    //Datamembers.

    std::auto_ptr<PushServerConnPluginManager> mSrvConnPluginMgr;

    java::util::Uid mUid;

    java::runtime::MidpStarterPushSupport* mAppStateController;

    EState mState;

    pthread_t mThreadId;

    mutable java::util::ScopedMutex mMutex;

    std::auto_ptr<java::util::Monitor> mMonitor;

    std::auto_ptr<java::util::Monitor> mConnCompletedMonitor;

    bool mIsUpdate;

    int mNumOfPendingUpdates;

    //Internal operations.

    bool sendGetAllPushRegsMsg(bool aThrowingExceptionAllowed);

    void handleListOfAllPushRegistrationsMsg(java::comms::CommsMessage& aMessage);

    java::comms::CommsClientEndpoint& getComms();

    void validateUid(const java::util::Uid& aUid,java::comms::CommsMessage& aMessage,

                     const std::string& aFile,const std::string& aFunction,int aLine);

    void checkErrorParamsOfCommsMsg(java::comms::CommsMessage& aMessage);

    void validateCommonParamsOfReplyCommsMsg(int aRetValue,int aMsgId,

            java::comms::CommsMessage& aMsg,

            const java::util::Uid& aUid);

    void loadPushConns(const java::util::Uid& aUid);

    std::wstring sendPushDataQuery(const std::wstring& aUri,

                                   const java::util::Uid& aSuiteUid,

                                   const EPushInfoQueryParams& aQueryCondition);

    void sendRegDynPushConnMsg(const std::wstring& aUri,

                               const std::wstring& aMidlet,

                               const std::wstring& aFilter,

                               const java::util::Uid& aUid,

                               int aIsUidOfThisMidlet);

    PushServerConnPluginManager& getPushServerConnPluginManager();

    void setState(const EState& aState);

    EState getState() const;

    void registerCommsListener();

    void updatePushRegs2(const java::util::Uid& aUid,

                         java::runtime::MidpStarterPushSupport* aAppStateController,

                         bool aThrowingExceptionAllowed);

    void startToWaitCompletionOfOper();

    //Not implemented.

    PushControllerStarterImpl(const PushControllerStarterImpl &x);

    PushControllerStarterImpl &operator=(const PushControllerStarterImpl &x);

};

}//end namespace push

}//end namespace java

#endif // PUSHCONTROLLERSTARTERIMPL_H