// Copyright (c) 2003-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:

//

/**

 @file

 @publishedAll

 @released

*/

#ifndef __OBEXCLIENT_H

#define __OBEXCLIENT_H

#include <obextypes.h>

#include <obexbase.h>

class CObexPacket;

class MObexFinalPacketObserver;

class CObexPacketSignaller;

class CObexPacketTimer;

class CObexErrorEngine;

/**

Client side functionality. Connection based.

Supports ...

- Opening IrDA TTP sockets for the OBEX session.

- Opening an OBEX session over a connected socket

- Standard OBEX (spec. version 1.2) operations.

This class is not designed for user derivation.

@publishedAll

@released

*/

NONSHARABLE_CLASS(CObexClient) : public CObex

	{

public:

	IMPORT_C ~CObexClient();

	IMPORT_C static CObexClient* NewL(TObexProtocolInfo& aObexProtocolInfoPtr);

	IMPORT_C static CObexClient* NewL(TObexProtocolInfo& aObexProtocolInfoPtr, TObexProtocolPolicy& aObexProtocolPolicy);

	IMPORT_C static CObexClient* NewL(TObexTransportInfo& aObexTransportInfo);

	IMPORT_C void Connect(TRequestStatus& aStatus);

	IMPORT_C void Connect(CObexBaseObject& aObject, TRequestStatus& aStatus);	

	IMPORT_C void ConnectL(CObexBaseObject& aObject, const TDesC& aPassword, TRequestStatus& aStatus);

	IMPORT_C void ConnectL(const TDesC& aPassword, TRequestStatus& aStatus);

	IMPORT_C void Disconnect(TRequestStatus& aStatus);						

	IMPORT_C void Put(CObexBaseObject& aObject, TRequestStatus& aStatus);

	IMPORT_C void Get(CObexBaseObject& aObject, TRequestStatus& aStatus);		

	IMPORT_C void SetPath(TSetPathInfo& aPathInfo, TRequestStatus& aStatus);

	IMPORT_C void Abort();					

	IMPORT_C void UserPasswordL( const TDesC& aPassword);

	IMPORT_C const CObexHeaderSet& GetPutFinalResponseHeaders();

	IMPORT_C void SetFinalPacketObserver(MObexFinalPacketObserver* aObserver);

	IMPORT_C TObexResponse LastServerResponseCode() const;

	IMPORT_C void SetCommandTimeOut(TTimeIntervalMicroSeconds32 aTimeOut);

	IMPORT_C TAny* ExtensionInterface(TUid aUid);

public:	// Called from CObexNotifyExtendClient

	void SignalPacketProcessEvent(TInt aEvent);

	void TimeOutCompletion();

private:

	CObexClient();

	void ConstructL(TObexTransportInfo& aObexTransportInfo);

	TBool AlreadyActive(TRequestStatus& aStatus);

	void ClientCommandL(TOperation aOp, TAny* aParam, TRequestStatus& aStatus);

	// Implementation of CObex Events

	virtual void OnPacketReceive(CObexPacket& aPacket);

	virtual void OnError(TInt aError);

	virtual void OnTransportUp();

	virtual void OnTransportDown();

	void SetRequest(TRequestStatus& aStatus, TOperation aOperation);

	void CompleteRequest(const TInt aCompletion);

	TInt PrepareConnectPacket(CObexPacket& aPacket);	// Should be members of TConnectInfo

	TInt ParseConnectPacket(CObexPacket& aPacket);	

	void ResetConnectionID();

	void SetConnectionID(TUint32 aConnectionID);

	void EmptyHeaderSet();

	void SendRequestPacket();

	void SendRequestPacket(TObexOpcode aObexOpcode);

private: 

	TRequestStatus* iPendingRequest;

	CObexBaseObject* iCurrentObject;

	TUint32 iConnectionID; 

	TBool iConnectionIdSet;

	CObexHeaderSet* iHeaderSet;

	CObexHeader* iHeader;

	CObexPacketSignaller* iPacketProcessSignaller;

	TObexResponse iLastReceivedResponseOpcode;

	CObexErrorEngine* iErrorEngine;

	TBool iIsLastErrorSet;

	TTimeIntervalMicroSeconds32 iCmdTimeOutDuration;

	CObexPacketTimer* iPacketTimer;

	};

#endif // __OBEXCLIENT_H