/*
* 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 BLUETOOTHCLIENTCONNECTION_H
#define BLUETOOTHCLIENTCONNECTION_H

#include <e32base.h>
#include <bt_sock.h>
#include <btsdp.h>

#include "monitor.h"
#include "bluetoothfunctionserver.h"
#include "bluetoothconsts.h"

#include <sys/time.h>

//#define LAUNCH_TYPE_PUSH                     3
//#define LAUNCH_TYPE_JSR                      4

#define DEFAULT_MTU    672
namespace java
{
namespace bluetooth
{

const TInt KReceivedBufferSize = 512;

/**
 * BluetoothClientConnection manages all Bluetooth Client operations.
 * Responsible for send/receive data.
 *
 *
 */
class BluetoothClientConnection: public MBluetoothSocketNotifier
{
public:
    OS_IMPORT BluetoothClientConnection(BluetoothFunctionServer* server);

    /**
     * Constructor to be used by Server Side connections.
     * @param[in] aSocket: Socket got as a result of acceptAndOpen call.
     * @param[in] aServer: Handle to the Function Server in the context of which
     *                   aSocket has to be used. Since RObjects are not sharable
     *                   across threads, we need to do this.
     * @param[in] aProtocol: Protocol to which the Socket belongs to.
     *                     PROTOCOL_L2CAP or PROTOCOL_RFCOMM
     *
     * @see Call void init() after construction of the object.
     */
    OS_IMPORT BluetoothClientConnection(CBluetoothSocket* aSocket,
                                        BluetoothFunctionServer* aServer);

    OS_IMPORT ~BluetoothClientConnection();

    /**
     * To be used after creating a ClientConnection object from the Server
     * implementation. Since the RSocket passed is already initialized during
     * connection open, all we do here is to add the object to Active Scheduler.
     */
    OS_IMPORT
    void initialize(int protocol, TInt64 aRemoteAddr, 
        int aReceiveMtu, int aTransmitMtu);

    /**
     * Used to Initialize the protocol specific options of the Bluetooth Socket.
     * This needs to be called before a call to Connect is made.
     * @param[in] integer value representing the Protocol.
     *            Defined in BluetoothConsts: PROTOCOL_L2CAP and PROTOCOL_RFCOMM
     * @return error code.
     */
    OS_IMPORT int init(int protocol);

    /**
     * Used to Connect to a remote Bluetooth device.
     * The same call serves for both L2CAP and RFCOMM. Just need to make sure we
     * call init before making call to connect. With protocol specified.
     *
     * @param[in] btAddress: Address of the remote device to connect to.
     * @param[in] channel: The port at which the remote device is waiting.
     * @param[in] authenticate: Indicates if authenticate has to be switched on.
     * @param[in] encrypt: Indicates if encryption has to be enabled on socket.
     * @param[in] receiveMTU: In case of L2CAP connections, indicates the
     *                      Receive MTU value to be set. For RFCOMM Connections,
     *                      nothing needs to be passed.
     * @param[in] transmitMTU: In case of L2CAP connections, indicates the
     *                      Transmit MTU value to be set. For RFCOMM Connections,
     *                      nothing needs to be passed.
     *
     * @return error code.
     */
    OS_IMPORT
    int connect(long long btAddress, int channel, bool authenticate,
                bool encrypt, int receiveMTU = 0, int transmitMTU = 0);


    /**
     * Receive is used to read data from Bluetooth Socket
     * Returns immediately when some data is available in the socket.
     * @param[out]  inBuf: Pointer to a byte array containing data received from
     *                   the socket. Memory needed will be allocated within
     *                   receive based on the amount of data received.
     * @return Number of bytes received. 0 if EOF and -<error> in case of error.
     */
    OS_IMPORT int receive(char* &inBuf);

    /**
     * Send data to Bluetooth Socket
     * Returns immediately when data is sent through the socket.
     * @param[in]  data: Data that has to be sent through the socket.
     * @param[in]  length: Length of data that needs to be sent over.
     * @return Number of bytes successfully sent. -<error> in case of error.
     */
    OS_IMPORT int send(const char* data, int length);

    /**
     * Closes the current connection with remote device.
     */
    OS_IMPORT void close();
    /**
     * Retrieves the remote address of the device the currently connected to.
     * @return address of the remote device.
     */
    OS_IMPORT long long getRemoteAddress();

    /**
     * Retreives the Transmit MTU of the Connection. This is valid only in case
     * of L2CAP Connections.
     * @return transmit MTU value.
     */
    OS_IMPORT int getTransmitMTU();

    /**
     * Retreives the Receive MTU of the Connection. This is valid only in case
     * of L2CAP Connections.
     * @return Receive MTU value.
     */
    OS_IMPORT int getReceiveMTU();

    /**
     * returns available data.
     */

    OS_IMPORT long available();

    OS_IMPORT void registerCallback(JNIEnv* ajni, jobject peer);

public:
    // Methods from MBluetoothSocketNotifier
    //Notification of an accept complete event
    void HandleAcceptCompleteL(TInt err);

    // Notification of a baseband event
    void HandleActivateBasebandEventNotifierCompleteL(TInt aErr,
            TBTBasebandEventNotification &aEventNotification);

    //Notification of a connection complete event
    void HandleConnectCompleteL(TInt err);

    //Notification of a ioctl complete event
    void HandleIoctlCompleteL(TInt err);

    //Notification of a receive complete event
    void HandleReceiveCompleteL(TInt err);

    //Notification of a send complete event
    void HandleSendCompleteL(TInt err);

    //Notification of a shutdown complete event
    void HandleShutdownCompleteL(TInt err);

private:
    BluetoothClientConnection();

    //Used in case of L2CAP Connection
    TInt Connect(TInt64 btAddress, TInt channel, TInt authenticate,
                 TInt encrypt, TInt receiveMTU, TInt transmitMTU);

    TInt ReceiveData();
    TInt SendData(const TDesC8& aData);
    void InitL(TInt protocol);
    void CloseFs();

    void makeReadCompleteCallback();

private:
    // Function Server handle within which the Socket operations have to be
    // performed.
    BluetoothFunctionServer* mServer;

    // Client socket
    CBluetoothSocket *mSocket;

    // Monitor used to Notify on completion of Shutdown.
    java::util::Monitor* mShutdownNotifyMonitor;

    // Monitor used to Notify on completion of read.
    java::util::Monitor* mReadNotifyMonitor;

    //Holds the read status value. Needed in case of errors
    int mReadStatus;

    // Buffer holding received data.
    TPtr8 mBuffer;

    // Monitor used to Notify on completion of send.
    java::util::Monitor* mSendNotifyMonitor;

    TInt mRequestedRMtu;
    TInt mRequestedTMtu;
    //Holds the read status value
    int mWriteStatus;

    // Knows which protocol the object relates to
    int mProtocol;

private:
    int mNegotiatedReceiveMtu;

    int mNegotiatedTransmitMtu;

    TInt64 mRemoteBTAddr;

    // Length of received data
    TSockXfrLength mLen;

    // Socket server handle.
    RSocketServ mSocketServ;

    TSockXfrLength mSockXfrLength;

    // Monitor used to notify completion of async operations to BlueCoveS60.
    java::util::Monitor* mConnectNotifyMonitor;

    TInt mConnectError;
    TBool mMakeJavaCallbackOnRead;

    TBool mReadPending;

    TBool mBufferInitialized;
    jmethodID mReadCompleteCallback;
};

} //end namespace bluetooth
} //end namespace java
#endif // BLUETOOTHCLIENTCONNECTION_H