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

#include <e32base.h>
#include <obexconstants.h>

#include "simpleObexServer.h"
#include "simpleObexApp.h"
#include "obexAppConstants.h"


/**
 * Constructor.
 */
CObexServerHandler::CObexServerHandler(CActiveConsole* aParent)
:iAcceptPuts(ETrue)
    {
	iParent = aParent;
    iServer    = NULL;
    iObject    = NULL;
    }



/**
 * NewL function
 */
CObexServerHandler* CObexServerHandler::NewL(CActiveConsole* aParent, TTransport aTransport)
    {
    CObexServerHandler* self = new (ELeave) CObexServerHandler(aParent);

    CleanupStack::PushL(self);
    self->ConstructL(aTransport);
    CleanupStack::Pop();
    return (self);
    }


/**
 * 2nd phase constructor. This function performs the initial steps needed in 
 * creating a new CObexServer object. It then creates the CObexServer object for the specified
 * transport.
 *
 */
void CObexServerHandler::ConstructL(TTransport aTransport)
    {
	iTransportLayer = aTransport;
	if (aTransport == EBluetooth)
		{
		// Start bluetooth socket and set security
		RSocketServ socketServ;
		socketServ.Connect();
		RSocket listen;
		TInt test = listen.Open(socketServ, KRFCOMMDesC);

		if (test == KErrNone)
			{
			iParent->Console()->Printf(_L("Socket Open ... Success\n"));	
			}

		TBTSockAddr addr;
		// Auto bind to RFComm port
		addr.SetPort(KRfcommPassiveAutoBind);
		
		TBTServiceSecurity serviceSecurity;
			
		serviceSecurity.SetUid(KUidServiceSDP);
		serviceSecurity.SetAuthentication(EFalse);
		serviceSecurity.SetEncryption(EFalse);
		serviceSecurity.SetAuthorisation(EFalse);
		serviceSecurity.SetDenied(EFalse);
		addr.SetSecurity(serviceSecurity);
			
		TInt error;	
		// Set bluetooth protocol info
		TObexBluetoothProtocolInfo info;
		info.iAddr.SetPort(KObexTestPort);
		info.iTransport = KRFCOMMDesC;
		TRAP(error,iServer  = CObexServer::NewL(info));
		if (error)
			{
			iParent->Console()->Printf(_L("\r\n Could not create obex server! : error %d \r\n"),error);
			iParent->iMode = E_Inactive;
			iParent->iMode = E_Server;
			iParent->Cancel(); // cancel request for key
			}
		// Add services to the Service discovery database
			
		User::LeaveIfError(iSdp.Connect());
		User::LeaveIfError(iSdpdb.Open(iSdp));
		
		TSdpServRecordHandle ftphandle;

		iSdpdb.CreateServiceRecordL(ftpUuid, ftphandle);
		iSdpdb.UpdateAttributeL(ftphandle, KSdpAttrIdServiceName, KServerDesC);
				
		iProtDescList = CSdpAttrValueDES::NewDESL(0);

			iProtDescList
			->StartListL()
				->BuildDESL()
				->StartListL()
					->BuildUUIDL(KL2CAPUUID) 
				->EndListL()
				->BuildDESL()
				->StartListL()
					->BuildUUIDL(KRfcommUuid) 
						->BuildUintL(TSdpIntBuf<TInt8>(KObexTestPort))
				->EndListL()
				->BuildDESL()
				->StartListL()
					->BuildUUIDL(KObexProtocolUuid) 
				->EndListL()
			->EndListL();
		// Update attribute
		iSdpdb.UpdateAttributeL(ftphandle, KProtocolDescriptorListUUID, *iProtDescList); // put into both records
		delete iProtDescList;
			
		User::LeaveIfError(listen.Bind(addr)); 
			
		TInt queueSize=2;
		User::LeaveIfError(listen.Listen(queueSize));
	
		iParent->Console()->Printf(_L("\n.....Now Listening.....\n"));
		
		}

	else if (aTransport == EIrda)
		{
		
		//creating the transport info
		TObexIrProtocolInfo transportInfo;
		transportInfo.iAddr.SetPort(KAutoBindLSAP);//default obex server for now
		transportInfo.iTransport = KObexIrTTPProtocol; 
		transportInfo.iClassName      = KIrdaClassName;					
		transportInfo.iAttributeName = KIrdaTransportAttrName;

  		iServer = CObexServer::NewL (transportInfo);
		
		}
	
    else if (aTransport == EWin32Usb)
		{
		// Create transport info
		TObexUsbProtocolInfo aInfo;
		aInfo.iTransport = KObexWin32UsbProtocol;
        aInfo.iInterfaceStringDescriptor = KServerInterfaceDescriptor;
		iServer = CObexServer::NewL (aInfo);
		
		}
   
   // Now that the transport has been selected and Obex Server started
   // We need to do some initialisation with Obex Objects so that we are 
   // prepared to deal with Put/Get requests from the client
    
    iObject  = CObexBufObject::NewL (NULL);

    iBuf = CBufFlat::NewL(KServerBufExpandSize);
  	
	iBuf->ResizeL(KServerBufExpandSize);// Resize the buffer

	iObject = CObexBufObject::NewL(NULL);
	iObject->SetDataBufL(iBuf);
	//Create the RFile to be used
	User::LeaveIfError(iFs.Connect());
	User::LeaveIfError(iFs.CreatePrivatePath(EDriveC));
	User::LeaveIfError(iFs.SetSessionToPrivate(EDriveC));
	User::LeaveIfError(iFs.SessionPath( iSessionPath ));
	// Start the server
	User::LeaveIfError(iServer->Start (this)); 
    
    }




/**
 * This function stops the OBEX server
 */
void CObexServerHandler::Stop()
    {
	if (iServer)
		{
		iServer->Stop();
		}
    }


/**
 * Destructor.
 */
CObexServerHandler::~CObexServerHandler ()
    {
    Stop();
	
	iSdpdb.Close();
	iSdp.Close();

	delete iObject;
    delete iBuf;
    delete iServer;
    }

/**
 * This function enables authentication on the OBEX server.
 * The password is defined in source.
 */
void CObexServerHandler::EnableAuthenticationL()
	{
	iChallengePassword = KAuthPassword;
	iServer->SetChallengeL(iChallengePassword);
	iIsAuthenticationEnabled = ETrue;
	}

/**
 * This function disables authentication on the server.
 */
void CObexServerHandler::DisableAuthentication()
	{
	iServer->ResetChallenge();
	iIsAuthenticationEnabled = EFalse;
	}





// MObexServerNotify interface functions

/**
 * Called if an OBEX protocol error occurs.
 */
void CObexServerHandler::ErrorIndication (TInt aError)
    {
    iParent->Console()->Printf(_L("Obex Server error %d"), aError);
    }

/**
 * Called when the underlying transport connection is made from a remote client to the server.
 */
void CObexServerHandler::TransportUpIndication ()
    {
    iParent->Console()->Printf(_L("\nTransport started\n"));
    }

/**
 * Called when the transport connection is dropped (by either party).
 */
void CObexServerHandler::TransportDownIndication ()
    {
    iParent->Console()->Printf(_L("\nTransport down\n"));
    }

/**
 * Called when an OBEX connection is made from a remote client.
 */
TInt CObexServerHandler::ObexConnectIndication(const TObexConnectInfo& aRemoteInfo, const TDesC8& /*aInfo*/)
    {
    
    iParent->Console()->Printf(_L("\r\nCObexServerHandler::ObexConnectIndication"));
	iParent->Console()->Printf(_L("\r\nConnected to machine with OBEX version %d.%d\r\n"), 
		     aRemoteInfo.VersionMajor (), aRemoteInfo.VersionMinor ());

     return (KErrNone);
    
    }

/**
 * Called on a (graceful) OBEX disconnection by the client.
 */
void CObexServerHandler::ObexDisconnectIndication (const TDesC8& /*aInfo*/)
    {
    iParent->Console()->Printf(_L("\r\nObex Disconnected\r\n\r\n"));
    }


/**
 * Called on receipt of the first packet of a (valid) put request.
 */
CObexBufObject* CObexServerHandler::PutRequestIndication ()
    {
    iParent->Console()->Printf(_L("Receiving object...\r\n"));
    iObject->Reset ();

	if ( iAcceptPuts)
		return (iObject);
	else
		return (NULL);
    }

/**
 * Called on receipt of every packet of an OBEX PUT operation.
 */
TInt CObexServerHandler::PutPacketIndication ()
    {
    
    TUint length = iObject->Length();

	TUint received = iObject->BytesReceived();
	TUint8 percent = 0;
    if (length > 0)
		{
		percent = TUint8((100 * received) / length);
		iParent->Console()->Printf(_L("\r%d %%      "), percent);
		}
    else
		{
		iParent->Console()->Printf(_L("\r%d      "), iObject->BytesReceived ());
		}
    return (KErrNone);
    
    }

/**
 * Called after the final put packet has been successfully received and parsed.
 */
TInt CObexServerHandler::PutCompleteIndication ()
    {
    TPtrC name=iObject->Name();
	TBuf<100> type;
	type.Copy(iObject->Type());
	iParent->Console()->Printf(_L("\r\nSuccessfully received '%S'\r\nType[%d]: '%S'\r\n"), &name, type.Length(), &type);

	TInt err = KErrNone;
	TBuf<80> filename(iSessionPath);
	filename.Append(iObject->Name());
	err = iObject->WriteToFile(filename);
    if (err == KErrAlreadyExists)
    	{
       	iParent->Console()->Printf(_L("\r\nWrite failed, File Already Exists\n"));
        }
    
	iObject->Reset ();
    return (err);
    }


/**
 * Called when a full get request has been received from the client.
 */
CObexBufObject* CObexServerHandler::GetRequestIndication (CObexBaseObject* aRequiredObject)
    {

	TRAPD(err,SetUpGetObjectL(aRequiredObject));
	if (err != KErrNone)
		{
		iParent->Console()->Printf(_L("\nSetUpGetObjectL() returned %d.\n"), err);
		return NULL;
		}
		
	return (iObject);
	
	}
	
	
/**
 * Called for every packet of get reply sent by the server back to the client.
 */
TInt CObexServerHandler::GetPacketIndication ()
    {
    if (iObject->Length () > 0)
		iParent->Console()->Printf(_L("\r%d %%      "), 
			 100 * iObject->BytesSent () / iObject->Length ());
    else
		iParent->Console()->Printf(_L("\r%d Bytes      "), iObject->BytesSent ());
    return (KErrNone);
    }

/**
 * Called when the final packet of the object has been returned to the client.
 */
TInt CObexServerHandler::GetCompleteIndication ()
    {
    iParent->Console()->Printf(_L("Obex Get Complete\r\n"));
    iObject->Reset ();
	return (KErrNone);
    }
    
    
    
/**
 * Called when an OBEX SETPATH command is received by the server.
 *
 */
TInt CObexServerHandler::SetPathIndication (const CObex::TSetPathInfo& aPathInfo, const TDesC8& /*aInfo*/)
    {
    iParent->Console()->Printf(_L("Obex SetPath request:\r\n"));
    iParent->Console()->Printf(_L("   --- Flags = '%d' - Constants = '%d' - "), aPathInfo.iFlags, aPathInfo.iConstants);
    
    if (aPathInfo.iNamePresent)
		iParent->Console()->Printf(_L("Name = %S\r\n"), &aPathInfo.iName);
	else
		iParent->Console()->Printf(_L("> No Name Present <\r\n"));
	
	iParent->Console()->Printf(_L("\nReturning success...!\n"));
	return (KErrNone);
    
    }

/**
 * Called when an abort packet is received from the client.
 */
void CObexServerHandler::AbortIndication ()
    {
    iParent->Console()->Printf(_L("Obex Operation aborted\r\n"));
    if(iObject)
		{
		// Determine if we have recieved any amount of the object
		// Return without notifing user if we haven't.
		if(!iObject->BytesReceived())
		    return;
		iParent->Console()->Printf(_L("\r\nWe have received part of an Obex object\r\n\r\n"));

		iObject->Reset();
		}
	}


/**
 * This is the function that sets up an object ready for a Get.
 * It takes as a parameter the requested object and then examines it's
 * name and if a filename matches then the object it setup from that file.
 */
void CObexServerHandler::SetUpGetObjectL(CObexBaseObject *aRequestedObject)
	{
	// Get the name of the requested object
	TBuf<200> name (aRequestedObject->Name ());
	if(name.Length())
		{
		iParent->Console()->Printf(_L("Obex Get Request for name '%s'\r\n"), name.PtrZ ());
		}

	else
		{
		iParent->Console()->Printf(_L("Obex Get Request unknown details\r\n"));
		User::Leave(KErrNotSupported);
		}
	iObject->Reset();

	RFs fs;
	RFile f;
	// Attempt to open the specified file
	if ((fs.Connect () != KErrNone) || 
		(f.Open (fs, name, EFileShareReadersOnly | EFileRead) != KErrNone))
		{
		iParent->Console()->Printf(_L("\r\nError reading '%S'."), &name);
		User::Leave(KErrNotFound);
		}
	// We can now proceed in setting up the object using the file retrieved
	
	TInt size = 0;
	// Set size of file
	User::LeaveIfError(f.Size (size));
	// Resize buffer object
	iBuf->ResizeL(size);
	// Get a pointer to represent the data
	TInt bufStart=0;
	TPtr8 data (iBuf->Ptr(bufStart));
	// Read data from file,
	f.Read (data);
	if (iBuf->Size() < size)
		User::Leave(KErrGeneral);
	// Set name of the object
	iObject->SetNameL(name);
	// Set length
	iObject->SetLengthL(size);
	TTime time;
	if (f.Modified(time) == KErrNone)
		iObject->SetTimeL(time);
	}