/*

* Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU Lesser General Public License as published by

* the Free Software Foundation, version 2.1 of the License.

* 

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

* GNU Lesser General Public License for more details.

*

* You should have received a copy of the GNU Lesser General Public License

* along with this program.  If not, 

* see "http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html/".

*

* Description:  Symbian client side implementation for APA SERVER IPC

*

*/

#ifndef C_XQSERVICEIPC_APASYMBIAN_H

#define C_XQSERVICEIPC_APASYMBIAN_H

#include <xqserviceipc_p.h>

#include <xqsharablefile.h>

#include "xqserviceipc_apasymbiansession.h"

namespace QtService {

    // Sharable file utility

    bool TransferSharableFile(TIpcArgs *args, const XQSharableFile *file);

    class CApaSymbianIPC : public CActive, public ServiceFwIPCPrivate,

                           public MApaServerAppExitObserver

        {

    public:

        virtual ~CApaSymbianIPC();

        static CApaSymbianIPC* NewL();

        // From ServiceFwIPCPrivate

    protected:

        bool connect(const QString& aServerName);

        void disconnect();

        bool startServer(const QString& aServerName, const QString& aExeName, quint64& processId, int options = 0);

        bool sendSync(const QString& aRequestType, const QByteArray& aData);

        void sendAsync(const QString& aRequestType, const QByteArray& aData);

        void readAll(QByteArray& aArray);

        QByteArray readAll();

        bool waitForRead();

        // From CActive

    protected:

        void RunL();

        TInt RunError(TInt err);

        void DoCancel();

        // From MApaServerAppExitObserver

    protected:

        /**

        * HandleServerAppExit

        * Gets called when server application exits

        */

        void HandleServerAppExit( int aReason );   

    private:

        enum TState

            {

            ESend,

            ERead,

            EDone

            };

        void doReadAllL(QByteArray& aArray);

        QByteArray doReadAllL();

        int doMapErrors( TInt aError );

    private:

        CApaSymbianIPC();

        void ConstructL();

        void StartExitMonitor();

    private:

        RApaIPCSession iSession;

        HBufC8* iAsyncData;  // member variable to keep alive any data for async ops

        TPtrC8 iAsyncDataPtr;

        HBufC* iRequestData;

        TPtrC  iRequestDataPtr;

        TInt iDataSize;

        TState iState;

        /**

        * Exit monitor

        */

        CApaServerAppExitMonitor* iServerExitMonitor; 

        QByteArray* iArray; //not owed

        RBuf8 iBuf;

    };

}

#endif // C_XQSERVICEIPC_APASYMBIAN_H