// Copyright (c) 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 <f32file.h>

#include <e32base.h>

#include <mtp/mtpprotocolconstants.h>

#include "mtppictbridgedpconst.h"

#include "cptpreceivedmsghandler.h"

#include "cmtppictbridgeprinter.h"

#include "cptpserver.h"

#include "ptpdef.h"

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

// CPtpReceivedMsgHandler::NewL()

// 

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

//

CPtpReceivedMsgHandler* CPtpReceivedMsgHandler::NewL(CPtpServer* aServerP)

    {

    CPtpReceivedMsgHandler* self = new (ELeave) CPtpReceivedMsgHandler(aServerP);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self); 

    return self;

    }

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

// CPtpReceivedMsgHandler::CPtpReceivedMsgHandler()

// 

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

//

CPtpReceivedMsgHandler::CPtpReceivedMsgHandler(CPtpServer* aServerP) : iServerP(aServerP)

    {

    Initialize();

    }

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

// CPtpReceivedMsgHandler::ConstructL()

// 

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

//    

void CPtpReceivedMsgHandler::ConstructL()

    {

    __FLOG_OPEN(KMTPSubsystem, KPtpServerLog);

    }

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

// CPtpReceivedMsgHandler::~CPtpReceivedMsgHandler()

// C++ destructor.

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

//

CPtpReceivedMsgHandler::~CPtpReceivedMsgHandler()

    {

    __FLOG(_L8("CPtpReceivedMsgHandler::~"));

    iReceiveQ.Close();

    __FLOG_CLOSE;

    }

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

// CPtpReceivedMsgHandler::Initialize()

// 

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

//    

void CPtpReceivedMsgHandler::Initialize()

    {

    iReceiveHandle = 0;

    iExtension.Zero();

    iTransactionID = 0;

    iReceiveQ.Reset();

    }

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

// CPtpReceivedMsgHandler::RegisterReceiveObjectNotify()

// 

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

//

void CPtpReceivedMsgHandler::RegisterReceiveObjectNotify(const TDesC& aExtension)

    {

    __FLOG(_L8(">>>PtpMsgHandler::RegisterReceiveObjectNotify"));

    iExtension.Copy(aExtension);

    __FLOG_VA((_L8("***the Receiving Que msg count: %d"), iReceiveQ.Count()));

    for ( TUint index = 0; index < iReceiveQ.Count(); ++index )

        {

        if ( ObjectReceived( iReceiveQ[index] ) )

            {

            iReceiveQ.Remove(index);

            break;

            }

        }

    __FLOG_VA((_L8("***the Receiving Que msg count:%d"), iReceiveQ.Count()));

    __FLOG(_L8("<<<PtpMsgHandler::RegisterReceiveObjectNotify"));    

    }

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

// 

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

//

TBool CPtpReceivedMsgHandler::ObjectReceived(TUint32 aHandle)

    {

    __FLOG_VA((_L8(">>>CPtpReceivedMsgHandler::ObjectReceived 0x%x"), aHandle));    

    TBuf<KFileNameAndPathLength> file;

    TInt err=KErrNone;

    TRAP( err, iServerP->GetObjectNameByHandleL(file, aHandle));

    __FLOG_VA((_L16("---after GetObjectNameByHandleL err(%d) file is %S"), err, &file));    

    if (err == KErrNone)

        {

        TFileName fileName; 

        TBuf<KFileExtLength> extension;

        TParse p;

        err = p.Set(file,NULL,NULL);

        __FLOG_VA((_L8("---after Set err(%d)"), err));            

        if (err == KErrNone)

            {

            fileName = p.FullName();

            extension = p.Ext();

            __FLOG_VA((_L16("---after parse file is %S ext is %S comparing it to %S"), &fileName, &extension, &iExtension));

            if (!iExtension.CompareF(extension))

                {

                iServerP->Printer()->ObjectReceived(fileName);

                // deregister notification

                DeRegisterReceiveObjectNotify();

                return ETrue; 

                }

            else

                {

                // we keep the coming file in a "queue" so that later 

                // registry for this file will be informed

                if(KErrNotFound == iReceiveQ.Find(aHandle))

                    {

                    iReceiveQ.Append(aHandle);

                    }

                __FLOG_VA((_L8("*** Que length is %d err is %d"), iReceiveQ.Count(), err));

                }

            }   

        }

    __FLOG_VA((_L8("<<<CPtpReceivedMsgHandler::ObjectReceived %d"), err));

    return EFalse;

    }

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

// CPtpReceivedMsgHandler::DeRegisterReceiveObjectNotify()

// Deregisters observer for Object receive notification

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

//    

void CPtpReceivedMsgHandler::DeRegisterReceiveObjectNotify()       

    {

    __FLOG(_L8("CPtpReceivedMsgHandler::DeRegisterReceivObjectNotify"));        

    iExtension.Zero();

    iReceiveHandle = 0;

    }