--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/ncdengine/provider/protocol/src/ncdprotocoldefaultobserverimpl.cpp Thu Dec 17 08:51:10 2009 +0200
@@ -0,0 +1,407 @@
+/*
+* 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: MNcdProtocolDefaultObserverImpl implementation
+*
+*/
+
+
+#include <s32mem.h>
+#include <e32property.h>
+
+#include "catalogsdebug.h"
+#include "catalogsconstants.h"
+#include "catalogscontext.h"
+#include "ncd_cp_actionrequest.h"
+#include "ncd_cp_clientconfiguration.h"
+#include "ncd_cp_detail.h"
+#include "ncd_cp_query.h"
+#include "ncd_cp_serverdetails.h"
+#include "ncd_pp_error.h"
+#include "ncd_pp_datablock.h"
+#include "ncd_pp_information.h"
+#include "ncd_pp_subscription.h"
+#include "ncdprotocoldefaultobserverimpl.h"
+#include "ncdconfigurationmanager.h"
+#include "ncd_cp_cookie.h"
+#include "ncdserverdetails.h"
+#include "ncdproviderdefines.h"
+#include "ncdsubscriptionmanagerimpl.h"
+
+// Action targets
+_LIT( KNcdActionTargetMasterServerUri, "masterServerUri" );
+_LIT( KNcdActionTargetSkin, "skin" );
+_LIT( KNcdActionTargetClient, "client" );
+
+
+
+CNcdProtocolDefaultObserver* CNcdProtocolDefaultObserver::NewL(
+ MCatalogsContext& aContext,
+ MNcdConfigurationManager& aConfigurationManager,
+ CNcdSubscriptionManager& aSubscriptionManager,
+ const TDesC& aServerUri )
+ {
+ CNcdProtocolDefaultObserver* self = new(ELeave)
+ CNcdProtocolDefaultObserver( aContext,
+ aConfigurationManager, aSubscriptionManager );
+ CleanupStack::PushL( self );
+ self->ConstructL( aServerUri );
+ CleanupStack::Pop( self );
+ return self;
+ }
+
+CNcdProtocolDefaultObserver::CNcdProtocolDefaultObserver(
+ MCatalogsContext& aContext,
+ MNcdConfigurationManager& aConfigurationManager,
+ CNcdSubscriptionManager& aSubscriptionManager )
+ : iContext( aContext ),
+ iConfigurationManager( aConfigurationManager ),
+ iSubscriptionManager( aSubscriptionManager )
+ {
+ }
+
+CNcdProtocolDefaultObserver::~CNcdProtocolDefaultObserver()
+ {
+ delete iServerUri;
+ }
+
+
+void CNcdProtocolDefaultObserver::ConstructL( const TDesC& aServerUri )
+ {
+ iServerUri = aServerUri.AllocL();
+ }
+
+//*****************************************************************************
+// MNcdParserConfigurationProtocolObserver
+//*****************************************************************************
+
+void CNcdProtocolDefaultObserver::ConfigurationBeginL( const TDesC& /*aVersion*/,
+ TInt /*aExpirationDelta*/ )
+ {
+ DLTRACEIN((""));
+ }
+
+void CNcdProtocolDefaultObserver::ConfigurationQueryL(
+ MNcdConfigurationProtocolQuery* aQuery )
+ {
+ DLTRACEIN((""));
+ // The queries by now should be handled by other interested parties.
+ // Do nothing.
+ delete aQuery;
+ }
+
+void CNcdProtocolDefaultObserver::ClientConfigurationL(
+ MNcdConfigurationProtocolClientConfiguration* aConfiguration )
+ {
+ DLTRACEIN((""));
+ CleanupDeletePushL( aConfiguration );
+
+ // Should interpret details to grab master server validity information,
+ // for example
+
+ // pass cookies to cookie handler
+ TInt cookieCount = aConfiguration->CookieCount();
+ DLINFO(("cookie count=%d",cookieCount));
+
+ // Get SSID
+ const TDesC8& ssid( iConfigurationManager.SsidL( iContext ) );
+
+ MNcdServerDetails& details(
+ iConfigurationManager.ServerDetailsL( iContext,
+ *iServerUri,
+ NcdProviderDefines::KConfigNamespace ));
+
+
+ for ( TInt i = 0; i < cookieCount; ++i )
+ {
+ const MNcdConfigurationProtocolCookie& cookie(
+ aConfiguration->CookieL( i ) );
+ details.AddCookieL( cookie, ssid );
+ }
+
+ CleanupStack::PopAndDestroy( aConfiguration );
+ DLTRACEOUT((""));
+ }
+
+void CNcdProtocolDefaultObserver::ConfigurationDetailsL(
+ CArrayPtr<MNcdConfigurationProtocolDetail>* aDetails )
+ {
+ DLTRACEIN((""));
+ aDetails->ResetAndDestroy();
+ delete aDetails;
+ }
+
+void CNcdProtocolDefaultObserver::ConfigurationActionRequestL(
+ MNcdConfigurationProtocolActionRequest* aActionRequest )
+ {
+ DLTRACEIN((""));
+
+ CleanupDeletePushL( aActionRequest );
+
+ if( aActionRequest->Type() == MNcdConfigurationProtocolActionRequest::ETypeUpdate &&
+ aActionRequest->UpdateDetails() )
+ {
+ DLTRACE(( "Update" ));
+
+ DLINFO(( _L("Target: %S"), &aActionRequest->Target() ));
+ DLINFO(( _L("Id: %S"), &aActionRequest->UpdateDetails()->Id() ));
+ DLINFO(( _L("Version: %S"), &aActionRequest->UpdateDetails()->Version() ));
+ DLINFO(( _L("Uri: %S"), &aActionRequest->UpdateDetails()->Uri() ));
+ DLINFO(( "Forced: %d", aActionRequest->Force() ));
+
+ DLINFO(( "Client SID %08x", iContext.SecureId().iId ));
+
+ if ( aActionRequest->Target() == KNcdActionTargetMasterServerUri &&
+ aActionRequest->UpdateDetails()->Uri().Length() )
+ {
+ const TDesC& currentMaster( iConfigurationManager.MasterServerAddressL(
+ iContext ) );
+
+ // Ensure that request was received from the master server
+ if ( *iServerUri == currentMaster )
+ {
+ /**
+ * @ Improve this check to notice missing '/' at the end of the URIs
+ */
+ if ( aActionRequest->UpdateDetails()->Uri() != currentMaster )
+ {
+ DLINFO(("Updating MasterServerUri"));
+
+ iConfigurationManager.SetMasterServerAddressL( iContext,
+ aActionRequest->UpdateDetails()->Uri(), 0 );
+ }
+ else
+ {
+ DLINFO(("MasterServerUri didn't change"));
+ }
+ }
+ else
+ {
+ DLERROR(( _L("Invalid update request source! Request source: %S"),
+ iServerUri ));
+ }
+ }
+ else if( aActionRequest->Target() == KNcdActionTargetSkin ||
+ aActionRequest->Target() == KNcdActionTargetClient )
+ {
+ HBufC* msgQueueName = HBufC::NewLC( KCatalogsUpdateQueueNameFormat().Length() + 8 );
+ msgQueueName->Des().Format( KCatalogsUpdateQueueNameFormat, iContext.SecureId().iId );
+
+ DLINFO(( _L("Opening client's update message queue: %S"), msgQueueName ));
+ RMsgQueueBase queue;
+
+ TInt err = queue.OpenGlobal( *msgQueueName );
+ if( err == KErrNone )
+ {
+ CleanupClosePushL( queue );
+ TInt msgSize = queue.MessageSize();
+
+ // Prepare a buffer to write to update information P&S variable.
+ CBufFlat* buffer = CBufFlat::NewL( KCatalogsUpdateInformationMaxSize + msgSize );
+ CleanupStack::PushL( buffer );
+
+ // Externalize the info to the buffer.
+ RBufWriteStream stream( *buffer );
+ CleanupClosePushL( stream );
+ stream << (TInt32)(aActionRequest->Target().Size() +
+ aActionRequest->UpdateDetails()->Id().Size() +
+ aActionRequest->UpdateDetails()->Version().Size() +
+ aActionRequest->UpdateDetails()->Uri().Size() +
+ sizeof( TInt32 ));
+ stream << aActionRequest->Target();
+ stream << aActionRequest->UpdateDetails()->Id();
+ stream << aActionRequest->UpdateDetails()->Version();
+ stream << aActionRequest->UpdateDetails()->Uri();
+ stream << (TInt32)aActionRequest->Force();
+
+ // Write the update information to the client's update message queue.
+ TInt bytesToSend = buffer->Size();
+ for( TInt sendPos = 0; sendPos < bytesToSend; sendPos += msgSize )
+ {
+ const TUint8* sendPtr = buffer->Ptr( sendPos ).Ptr();
+ queue.SendBlocking( sendPtr, msgSize );
+ }
+
+ DLINFO(( "Update information sent to message queue" ));
+
+ CleanupStack::PopAndDestroy( 3, &queue ); // stream-close, buffer, queue
+ }
+
+ // Clean up the local info buffer.
+ CleanupStack::PopAndDestroy( msgQueueName );
+ }
+ else
+ {
+ DLINFO(("Unknown Action target"));
+ }
+ }
+ // Action request no longer needed, delete it.
+ CleanupStack::PopAndDestroy( aActionRequest );
+ }
+
+
+void CNcdProtocolDefaultObserver::ConfigurationServerDetailsL(
+ MNcdConfigurationProtocolServerDetails* aServerDetails )
+ {
+ DLTRACEIN((""));
+ DASSERT( aServerDetails );
+ DASSERT( iServerUri );
+ DLINFO(("Server supports %d capabilities",
+ aServerDetails->CapabilityCount() ));
+
+ CleanupDeletePushL( aServerDetails );
+
+ if ( aServerDetails->CapabilityCount() )
+ {
+ DLTRACE(("Adding capabilities to server details"));
+ MNcdServerDetails& details(
+ iConfigurationManager.ServerDetailsL( iContext,
+ *iServerUri,
+ NcdProviderDefines::KConfigNamespace ));
+
+ // Clear old caps so that we don't just keep on adding them.
+ // AddCapabilityL does NOT check for duplicates
+ details.ClearCapabilitiesL();
+
+ for ( TInt i = 0; i < aServerDetails->CapabilityCount(); ++i )
+ {
+ details.AddCapabilityL( aServerDetails->CapabilityL( i ) );
+ }
+ iConfigurationManager.SaveConfigurationToDbL( iContext );
+ }
+ CleanupStack::PopAndDestroy( aServerDetails );
+ }
+
+void CNcdProtocolDefaultObserver::ConfigurationErrorL(
+ MNcdConfigurationProtocolError* aError )
+ {
+ DLTRACEIN((""));
+ delete aError;
+ }
+
+void CNcdProtocolDefaultObserver::ConfigurationEndL()
+ {
+ DLTRACEIN((""));
+ }
+
+
+//*****************************************************************************
+// MNcdParserInformationObserver
+//*****************************************************************************
+
+void CNcdProtocolDefaultObserver::InformationL(
+ MNcdPreminetProtocolInformation* aData )
+ {
+ DLTRACEIN(( _L("Namespace: %S"), &aData->Namespace() ));
+ CleanupDeletePushL( aData );
+
+
+ TInt cookieCount = aData->CookieCount();
+ DLINFO(("cookie count=%d",cookieCount));
+
+ MNcdServerDetails& details(
+ iConfigurationManager.ServerDetailsL( iContext, *iServerUri,
+ aData->Namespace() ));
+
+
+ // Get SSID
+ const TDesC8& ssid( iConfigurationManager.SsidL( iContext ) );
+
+ for ( TInt i = 0; i < cookieCount; ++i )
+ {
+ const MNcdConfigurationProtocolCookie& cookie( aData->CookieL( i ) );
+ details.AddCookieL( cookie, ssid );
+ }
+
+
+ // Handle server capabilities
+ DLTRACE(("Handle server capabilities"));
+ const MNcdConfigurationProtocolServerDetails* serverDetails =
+ aData->ServerDetails();
+
+ DLTRACE(("ServerDetails-ptr: %x", serverDetails ));
+
+ if ( serverDetails && serverDetails->CapabilityCount() )
+ {
+ // Clear old caps so that we don't just keep on adding them.
+ // AddCapabilityL does NOT check for duplicates
+ details.ClearCapabilitiesL();
+
+ DLINFO(("Capabilities: %d", serverDetails->CapabilityCount() ));
+ DLTRACE(("Adding capabilities to server details"));
+
+ for ( TInt i = 0; i < serverDetails->CapabilityCount(); ++i )
+ {
+ details.AddCapabilityL( serverDetails->CapabilityL( i ) );
+ }
+
+ }
+ iConfigurationManager.SaveConfigurationToDbL( iContext );
+ CleanupStack::PopAndDestroy( aData );
+ DLTRACEOUT(("Protocol information handled"));
+ }
+
+//*****************************************************************************
+// MNcdParserDataBlocksObserver
+//*****************************************************************************
+
+void CNcdProtocolDefaultObserver::DataBlocksL(
+ CArrayPtr<MNcdPreminetProtocolDataBlock>* aData )
+ {
+ DLTRACEIN((""));
+ aData->ResetAndDestroy();
+ delete aData;
+ }
+
+//*****************************************************************************
+// MNcdParserErrorObserver
+//*****************************************************************************
+
+void CNcdProtocolDefaultObserver::ErrorL( MNcdPreminetProtocolError* aData )
+ {
+ DLTRACEIN((""));
+ delete aData;
+ }
+
+
+//*****************************************************************************
+// MNcdParserQueryObserver
+//*****************************************************************************
+
+void CNcdProtocolDefaultObserver::QueryL( MNcdConfigurationProtocolQuery* aData )
+ {
+ DLTRACEIN((""));
+ delete aData;
+ }
+
+//*****************************************************************************
+// MNcdParserSubscriptionObserver
+//*****************************************************************************
+
+void CNcdProtocolDefaultObserver::ValidSubscriptionL(
+ MNcdPreminetProtocolSubscription* aData )
+ {
+ DLTRACEIN((""));
+ iSubscriptionManager.InternalizeSubscriptionL(
+ iContext.FamilyId(), *iServerUri, *aData, &iContext, NULL );
+ delete aData;
+ }
+
+void CNcdProtocolDefaultObserver::OldSubscriptionL(
+ MNcdPreminetProtocolSubscription* aData )
+ {
+ DLTRACEIN((""));
+ iSubscriptionManager.InternalizeSubscriptionL(
+ iContext.FamilyId(), *iServerUri, *aData, &iContext, NULL );
+ delete aData;
+ }