/*

* Copyright (c) 2006, 2007 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:  This class defines and implements the API for UI engine. 

*

*/

#include <e32base.h>

#include <dps.rsg>

#include <f32file.h>

#include <barsc.h>

#include <barsread.h>

#include <bautils.h>

#include <pathinfo.h>

#include "pictbridge.h"

#include "dpsdefs.h"

#include "dpsxmlstring.h"

#include "dpsconst.h"

#include "dpsstatemachine.h"

#include "dpsscriptreceiver.h"

#include "dpsusbnotifier.h"

#include "dpsparam.h"

#include "dpsscriptsender.h"

#include "dpstransaction.h"

#include "dpsfile.h"

const TInt KResource = 32;

const TInt KDriver = 3;

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

// 

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

//

EXPORT_C CDpsEngine* CDpsEngine::GetEngineL()

    {

    CDpsEngine* me;

    me = static_cast<CDpsEngine*>(Dll::Tls());

    if (!me)

        {

        CDpsEngine* self = new(ELeave) CDpsEngine();

        CleanupStack::PushL(self);

        self->ConstructL();

        CleanupStack::Pop();

        return self;	

        }

    else

        {

        return me;	

        }			    

    }

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

// 

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

//	

EXPORT_C void CDpsEngine::Delete()

    {

    CDpsEngine *me; me = static_cast<CDpsEngine*>(Dll::Tls());

    if (me)

        {

        delete me;

        Dll::SetTls(NULL);

        }

    }

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

// 

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

//	

void CDpsEngine::ConstructL()	

    {

    iDpsParameters = TDpsXmlString::NewL();

    iDpsOperator = CDpsStateMachine::NewL(this);

    }

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

// 

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

//	

CDpsEngine::~CDpsEngine()

	{

    delete iDpsOperator;

    iDpsOperator = NULL;

    delete iUsbNotifier;

    iUsbNotifier = NULL;

    if (iDpsOperationRequest)

        {

        User::RequestComplete(iDpsOperationRequest, KErrCancel);

        }

    if (iDpsEventRequest)

        {

        User::RequestComplete(iDpsEventRequest, KErrCancel);

        }    

    if (iPrinterConnectRequest)

        {

        User::RequestComplete(iPrinterConnectRequest, KErrCancel);

        }	    

    delete iDpsParameters;

    iDpsParameters = NULL;

    iPtp.Close();

	}

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

// 

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

//

EXPORT_C void CDpsEngine::SetPrintMode(TRequestStatus& aStatus)

    {

    iPrinterConnectRequest = &aStatus;

    *iPrinterConnectRequest = KRequestPending;		

    iUsbNotifier->WaitForPrinterNotify();

	}

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

// 

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

//	

EXPORT_C void CDpsEngine::CancelPrintMode()

    {

    iUsbNotifier->CancelPrinterNotify();				

    }

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

// 

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

//

EXPORT_C void CDpsEngine::ConnectStateNotify(TRequestStatus& aStatus)

    {

    // SetPrintMode must be finished

    if (!iUsbNotifier->IsSetPrintModeIssued())

        {

        TRequestStatus* status = &aStatus;

        User::RequestComplete(status, KErrNotReady);

        return;

        }

    iPrinterConnectRequest = &aStatus;

    *iPrinterConnectRequest = KRequestPending;		

    iUsbNotifier->ConnectNotify();

    }

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

// 

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

//	

EXPORT_C void CDpsEngine::DoDpsRequestL(TMDpsOperation* aRequest, 

                                       TRequestStatus& aStatus)

    {

    // the ptp printer must be connected and registered for the dps event

    if (!iUsbNotifier->IsConfigured() || !iDpsEventRequest)

        {

        TRequestStatus* status = &aStatus;

        User::RequestComplete(status, KErrNotReady);

        return;

        }

    // there is a request from the host received and the reply has been

    // sending out, but the host has not received it yet. we can not send

    if (iDpsOperator->CurState() != iDpsOperator->IdleState())

        {

        TRequestStatus* status = &aStatus;

        User::RequestComplete(status, KErrInUse);        

        return;

        }

    iDpsOperator->StartTransactionL(aRequest);

    iDpsOperationRequest = &aStatus;

	}

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

// 

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

//	

EXPORT_C void CDpsEngine::CancelDpsRequest()

    {

    if (iDpsOperationRequest)

        {

        iDpsOperator->ScriptSender()->Cancel();

        User::RequestComplete(iDpsOperationRequest, KErrCancel);

        }

    iDpsOperator->Initialize();

    }

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

// 

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

//   

EXPORT_C void CDpsEngine::DpsEventNotify(TDpsEvents& aParam,

                                         TRequestStatus& aStatus)

    {

    // the PTP printer must be connected and registered for the disconnect

    if (!iUsbNotifier->IsConfigured() || !iPrinterConnectRequest)

        {

        TRequestStatus* status = &aStatus;

        User::RequestComplete(status, KErrNotReady);

        return;

        }

    iOutEvent = &aParam;

    iDpsEventRequest = &aStatus;

    *iDpsEventRequest = KRequestPending;

    iDpsOperator->ScriptReceiver()->WaitForReceive();

    }

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

// 

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

//       

EXPORT_C void CDpsEngine::CancelDpsEventNotify()

    {

    if (iDpsEventRequest)

        {

        User::RequestComplete(iDpsEventRequest, KErrCancel);

        iDpsOperator->ScriptReceiver()->Cancel();

        }  

    }

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

// 

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

//     

EXPORT_C void CDpsEngine::GetDpsConfigL(TDpsConfigPrintReq& aConfig)

    {

    RFs fs = iDpsOperator->Trader()->FileHandle()->FileSession();

    RResourceFile resource;

    TBuf<KResource> resourceFile(PathInfo::RomRootPath());

    TBuf<KResource> length(KDpsResource);    

    resourceFile.SetLength(KDriver + length.Length());

    resourceFile.Replace(KDriver, length.Length(), KDpsResource);

    resource.OpenL(fs, resourceFile);

    CleanupClosePushL(resource);

    resource.ConfirmSignatureL(KDpsResourceVersion);

    HBufC8* id = resource.AllocReadLC(DPS_CONFIG);

    TResourceReader reader;

    reader.SetBuffer(id);

    TInt count = static_cast<TInt>(reader.ReadUint8());

    for (TInt i = 0; i < count; i++)

        {

        TDpsVersion version;

        version.iMajor = static_cast<TInt>(reader.ReadUint8());

        version.iMinor = static_cast<TInt>(reader.ReadUint8());

        aConfig.iDpsVersions.Append(version); 

        }

    TPtrC vendorString = reader.ReadTPtrC(); 

    aConfig.iVendorName.Copy(vendorString);

    TDpsVersion vendorVersion;

    vendorVersion.iMajor = static_cast<TInt>(reader.ReadUint8());

    vendorVersion.iMinor = static_cast<TInt>(reader.ReadUint8());

    aConfig.iVendorVersion = vendorVersion;

    TPtrC productString = reader.ReadTPtrC();

    aConfig.iProductName.Copy(productString);

    TPtrC SerialNo = reader.ReadTPtrC();

    aConfig.iSerialNo.Copy(SerialNo);

    CleanupStack::PopAndDestroy(id); 

    CleanupStack::PopAndDestroy(&resource);

    }

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

// 

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

//

EXPORT_C const TDesC& CDpsEngine::DpsFolder() const

    {

    return iDpsFolder;

    }

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

// 

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

//

TDpsEvents* CDpsEngine::Event() const

    {

    return iOutEvent;

    }

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

// 

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

//         

RPtp& CDpsEngine::Ptp()

    {

    return iPtp;

    }

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

// 

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

//         

TDpsXmlString* CDpsEngine::DpsParameters() const

    {

    return iDpsParameters;

    }

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

// 

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

//    

TRequestStatus*& CDpsEngine::EventRequest()

    {

    return iDpsEventRequest;

    }

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

// 

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

//            

TRequestStatus*& CDpsEngine::OperationRequest()

    {

    return iDpsOperationRequest;

    }

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

// 

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

//                

TRequestStatus*& CDpsEngine::PrinterConnectRequest()

    {

    return iPrinterConnectRequest;

    }

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

// 

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

//               

void CDpsEngine::SetDpsFolder(const TDesC& aFolder)

    {

    iDpsFolder.Copy(aFolder);

    }