/*

* Copyright (c) 2006 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:   ?Description

*

*/

// Class for testing the asynchronous api of CObjectExchange client

#include "OsmObexSender.h"

#include "ObjectExchangeClient.h"

COsmObexSender* COsmObexSender::NewL( MOsmObexSenderObserver& aObserver )

{

    COsmObexSender* self = NewLC( aObserver );

    CleanupStack::Pop(self);

    return self;

}

COsmObexSender* COsmObexSender::NewLC( MOsmObexSenderObserver& aObserver )

{

    COsmObexSender* self = new (ELeave) COsmObexSender( aObserver );

    CleanupStack::PushL(self);

    self->ConstructL();

    return self;

}

COsmObexSender::COsmObexSender( MOsmObexSenderObserver& aObserver ) : 

    CActive(CActive::EPriorityStandard),

    iState(EWaitingToConnect),  // Set initial state. Waiting for StartL function call

    iObserver( aObserver )

{

    CActiveScheduler::Add(this);

}

void COsmObexSender::ConstructL()

{

    iObexClient = CObjectExchangeClient::NewL();

}

COsmObexSender::~COsmObexSender()

{

    Cancel();

    delete iObexClient;

}

void COsmObexSender::DoCancel()

{

    if (iState != EWaitingToConnect && iObexClient)

    {

        iObexClient->Cancel(); // NOTE: following could do this?

    }

	iState = EWaitingToConnect;  // Return to initial state

}

void COsmObexSender::RunL()

{

    // add proper implementations for these:

    if( iStatus != KErrNone )

    {

        switch( iState )

        {

        case EWaitingToConnect:          

            iObserver.ObexDisconnected( iStatus.Int(), EWaitingToConnect );

            iState = EWaitingToConnect;

            break;

        case EConnecting: 

            iObserver.ObexDisconnected( iStatus.Int(), EConnecting );

            iState = EWaitingToConnect;

            break;

        case ESending:

            iObserver.ObexDisconnected( iStatus.Int(), ESending );

            iState = EWaitingToConnect;

            break;

        case EDisconnecting:

            iObserver.ObexDisconnected( iStatus.Int(), EDisconnecting );

            iState = EWaitingToConnect;

            break;

        default:

            // should panic here?

            break;

        }

    }

    else 

    {

        switch( iState )

        {

        case EWaitingToConnect: 

            break;

        case EConnecting: 

            iState = ESending;

            iObexClient->SendObjectL( iFileName, iStatus );

            SetActive(); 

            break;        

        case ESending:

            iState = EDisconnecting;

            iObexClient->DisconnectL( iStatus );

            SetActive();

            break;

        case EDisconnecting:

            iState = EWaitingToConnect;

            iObserver.ObexFileSent();

            // Sent successfully

            break;

        default:

            // should panic here?

            break;

        };

    }

}

void COsmObexSender::SendFileL( TOsmConnectionType aConnectionType, const TDesC& aFileName )

{

    iFileName.Copy( aFileName );

    if (iState == EWaitingToConnect)

    {

        iState = EConnecting;

        if( aConnectionType == EOsmConnectionBT )

        {

            iObexClient->ConnectL( iStatus );

        }

        else

        {

//            iObexClient->ConnectIrL( iStatus );

        }

        SetActive();

    }

}

void COsmObexSender::StopL()

{

    iObexClient->StopL();

    /* Implementation for this?? */

    /*

    if (iClient && iClient->IsConnected())

    {

        iClient->Abort();

        iState = EWaitingToGetDevice;

    }

    */

}