/*

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

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of the License "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:  A task to update a Feed.

*

*/

#include "FeedHandler.h"

#include "FeedsServer.h"

#include "Logger.h"

#include "PackedFeed.h"

#include "UpdateFeedTask.h"

#include "UrlHandlerFactory.h"

// -----------------------------------------------------------------------------

// CUpdateFeedTask::NewL

//

// Two-phased constructor.

// -----------------------------------------------------------------------------

//

CUpdateFeedTask* CUpdateFeedTask::NewL(CFeedsServer& aFeedsServer, 

        const TDesC& aUrl,TInt aFeedId, MUpdateFeedTaskObserver& aObserver)

    {

    CUpdateFeedTask* self = new (ELeave) CUpdateFeedTask(aFeedsServer, aObserver);

    CleanupStack::PushL(self);

    self->ConstructL(aUrl,aFeedId);

    CleanupStack::Pop();

    return self;

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::NewL

//

// Two-phased constructor.

// -----------------------------------------------------------------------------

//

CUpdateFeedTask* CUpdateFeedTask::NewL(CFeedsServer& aFeedsServer, const TDesC& aUrl,TInt aFeedId,

        TDesC8* aFeedBuffer, MUpdateFeedTaskObserver& aObserver)

    {

    CUpdateFeedTask* self = new (ELeave) CUpdateFeedTask(aFeedsServer, aObserver);

    CleanupStack::PushL(self);

    self->ConstructL(aUrl,aFeedId);

    CleanupStack::Pop();

    self->iFileBuffer = aFeedBuffer;

    return self;

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::CUpdateFeedTask

// C++ default constructor can NOT contain any code, that

// might leave.

// -----------------------------------------------------------------------------

//

CUpdateFeedTask::CUpdateFeedTask(CFeedsServer& aFeedsServer, MUpdateFeedTaskObserver& aObserver):

        CTask(aFeedsServer), iLeakTracker(CLeakTracker::EUpdateFeedTask), iObserver(aObserver)

    {

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::ConstructL

// Symbian 2nd phase constructor can leave.

// -----------------------------------------------------------------------------

//

void CUpdateFeedTask::ConstructL(const TDesC& aUrl,TInt aFeedId)

    {

    BaseConstructL(ETrue);

    iFeedId = aFeedId;

    iUrl = aUrl.AllocL();        

    iPackedFeed = CPackedFeed::NewL();

    iIdle = CIdle::NewL(CActive::EPriorityIdle);

    }        

// -----------------------------------------------------------------------------

// CUpdateFeedTask::~CUpdateFeedTask

// Deconstructor.

// -----------------------------------------------------------------------------

//

CUpdateFeedTask::~CUpdateFeedTask()

    {

    delete iUrl;

    delete iIdle;

    delete iUrlHandler;

    delete iFileBuffer;

    delete iPackedFeed;

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::StartTaskL.

//

// Starts the task.

// -----------------------------------------------------------------------------

//

void CUpdateFeedTask::StartTaskL()

    {

    // If the feed was already provided then get ready to parse the buffer.

    if (iFileBuffer != NULL)

        {

        FEED_LOG(_L("Feeds"), _L("Feeds.log"), 

            EFileLoggingModeAppend, _L("Processing Feed: External Buffer"));

        // Parse the buffer, but to be consistent with the asynchronous 

        // behavior of using an UrlHandlers the buffer isn't parsed until 

        // after the callstack unrolls.

        iIdle->Start(TCallBack(DelayedParse, this));

        }

    // If the feed is coming from a UrlHandler, then start the load.

    else if (iUrl != NULL)

        {

        FEED_LOG1(_L("Feeds"), _L("Feeds.log"), 

            EFileLoggingModeAppend, _L("Processing Feed: %S"), iUrl);

        iUrlHandler = UrlHandlerFactory::NewUrlHandlerL( iObserver.HttpConnection(), *iUrl );

        iUrlHandler->LoadUrlL(*iUrl, *this);

        }

    // Otherwise, panic

    else

        {

        // TODO:

        }

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::StartWait

//

// Notifies the observer that the UrlHandler is about to start a lengthy operation.

// In response the observer could display somekind of status indicator.

// -----------------------------------------------------------------------------

//

void CUpdateFeedTask::StartWait()

    {

    iObserver.StartWait();

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::LoadCompleted

//

// Passes the status code and responseBody to the observer.  The observer

// adopts aResponseBody.

// -----------------------------------------------------------------------------

//

void CUpdateFeedTask::LoadCompleted(TInt aStatusCode, TDesC8* aResponseBody,

        const TDesC& aContentType, const TDesC& aCharSet)

    {

    TInt err;

    // Parse the buffer

    if (aResponseBody != NULL)

        {

        // TODO: Just pass iPackedFeed instead and remove the

        //         whole observer interface altogether.

        TRAP(err, iFeedsServer.FeedHandler().ParseL(*aResponseBody, 

                aContentType, aCharSet, *this));

        if (err != KErrNone)

            {

            delete iPackedFeed;

            iPackedFeed = NULL;

            TRAP_IGNORE(iFeedsServer.ResetXmlUtilsL());

            }

        else

            {

            iPackedFeed->Trim();

            }

        delete aResponseBody;

        // Pass the feed to the observer.

        iObserver.Completed(iPackedFeed, *iUrl,iFeedId, err);

        iPackedFeed = NULL;

        }

    // The load failed, exit cleanly.

    else

        {

        // Pass the status to the observer.

        iObserver.Completed(NULL, *iUrl,iFeedId, ((aStatusCode == KErrNone)? KErrCorrupt:aStatusCode));

        }

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::FeedBeginsL

//

// The beginning of a feed was found.

// -----------------------------------------------------------------------------

//

void CUpdateFeedTask::FeedBeginsL()

    {

    iPackedFeed->FeedBeginsL();

    // Add the oringal url too.  

    iPackedFeed->AddAttributeL(EFeedAttributeFeedUrl, *iUrl);

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::FeedEndsL

//

// The end of a feed was found.

// -----------------------------------------------------------------------------

//

void CUpdateFeedTask::FeedEndsL()

    {

    iPackedFeed->FeedEndsL();

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::ItemBeginsL

//

// The beginning of a item was found.

// -----------------------------------------------------------------------------

//

void CUpdateFeedTask::ItemBeginsL()

    {

    iPackedFeed->ItemBeginsL();

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::ItemEndsL

//

// The end of a item was found.

// -----------------------------------------------------------------------------

//

void CUpdateFeedTask::ItemEndsL()

    {

    iPackedFeed->ItemEndsL();

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::EnclosureBeginsL

//

// The beginning of a enclosure was found.

// -----------------------------------------------------------------------------

//

void CUpdateFeedTask::EnclosureBeginsL()

    {

    iPackedFeed->EnclosureBeginsL();

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::EnclosureEndsL

//

// The end of a enclosure was found.

// -----------------------------------------------------------------------------

//

void CUpdateFeedTask::EnclosureEndsL()

    {

    iPackedFeed->EnclosureEndsL();

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::AddAttributeL

//

// A attribute was found.  This attribute should be applied to

// the enclosing entity (Feed, Item, or Enclosure).

// -----------------------------------------------------------------------------

//

void CUpdateFeedTask::AddAttributeL(TInt aAttribute, const TDesC& aValue)

    {

    if (aValue.Length() > 0)

        {

        iPackedFeed->AddAttributeL(aAttribute, aValue);

        }

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::OtherTitleL

//

// An unimportant element was found.  The client can use this information for 

// feed validation.

// -----------------------------------------------------------------------------

//

void CUpdateFeedTask::OtherTitleL()

    {

    iPackedFeed->OtherTitleL();

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::OtherDescriptionL

//

// An unimportant element was found.  The client can use this information for 

// feed validation.

// -----------------------------------------------------------------------------

//

void CUpdateFeedTask::OtherDescriptionL()

    {

    iPackedFeed->OtherDescriptionL();

    }

// -----------------------------------------------------------------------------

// CUpdateFeedTask::OtherLinkL

//

// An unimportant element was found.  The client can use this information for 

// feed validation.

// -----------------------------------------------------------------------------

//

void CUpdateFeedTask::OtherLinkL()

    {

    iPackedFeed->OtherLinkL();

    }

// -----------------------------------------------------------------------------

// CFileHandler::DelayedParse

// 

// Parses the buffer to the observer now that the callstack has unrolled.

// -----------------------------------------------------------------------------

//

TInt CUpdateFeedTask::DelayedParse(TAny* aPtr)

    {

    CUpdateFeedTask*  self = static_cast<CUpdateFeedTask*>(aPtr);

    self->LoadCompleted(KErrNone, self->iFileBuffer, KNullDesC, KNullDesC);

    self->iFileBuffer = NULL;

    return EFalse;

    }