--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/ipsservices/ipssosaoplugin/src/IpsSosAOPopAgent.cpp	Thu Dec 17 08:39:21 2009 +0200
@@ -0,0 +1,485 @@
+/*
+* Copyright (c) 2008 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: 
+*     Contains pop specified sync logic
+*
+*/
+
+
+
+#include "emailtrace.h"
+#include <cemailaccounts.h>
+#include <pop3cmds.h>
+#include <miutset.h>
+#include <popcmtm.h>
+#include <AlwaysOnlineManagerCommon.h>
+
+#include "IpsSosAOPopAgent.h"
+#include "IpsSosAOImapPopLogic.h"
+
+
+// from settings
+#include "ipssetutilsconsts.h"
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+CIpsSosAOPopAgent::CIpsSosAOPopAgent(             
+    CMsvSession& aSession,
+    MIpsSosAOAgentOperationResponse& aOpResponse,
+    TMsvId aServiceId ) : CIpsSosAOBaseAgent(), 
+    iSession(aSession), iOpResponse(aOpResponse),
+    iServiceId( aServiceId ), 
+    iSyncStartedSignaled( EFalse ),
+    iState( EStateIdle ), iDoNotDisconnect( EFalse )
+    {
+    FUNC_LOG;
+    
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+CIpsSosAOPopAgent::~CIpsSosAOPopAgent()
+    {
+    FUNC_LOG;
+    Cancel();
+    SignalSyncCompleted( iServiceId, iError );
+    ClearSignaledFlags();
+    delete iPopSettings;
+    delete iOngoingOp;
+    delete iSelection;
+    delete iPopClientMtm;
+    delete iMtmReg;
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+CIpsSosAOPopAgent* CIpsSosAOPopAgent::NewL( 
+    CMsvSession& aSession,
+    MIpsSosAOAgentOperationResponse& aOpResponse,
+    TMsvId aServiceId  )
+    {
+    FUNC_LOG;
+    CIpsSosAOPopAgent* self = new (ELeave) CIpsSosAOPopAgent( 
+            aSession,  aOpResponse, aServiceId );
+    CleanupStack::PushL( self );
+    self->ConstructL();
+    CleanupStack::Pop( self );
+    return self;
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+void CIpsSosAOPopAgent::ConstructL()
+    {
+    FUNC_LOG;
+    CActiveScheduler::Add(this);
+    
+    iMtmReg = CClientMtmRegistry::NewL( iSession );
+    CBaseMtm* bmtm = iMtmReg->NewMtmL( KUidMsgTypePOP3 );
+    iPopClientMtm = static_cast<CPop3ClientMtm*>(bmtm);
+    iSelection = new ( ELeave ) CMsvEntrySelection();
+    iState = EStateIdle; 
+    }
+ 
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+void CIpsSosAOPopAgent::DoCancel()
+    {
+    FUNC_LOG;
+    if (iOngoingOp )
+        {
+        iOngoingOp->Cancel();
+        }
+    delete iOngoingOp;
+    iOngoingOp = NULL;
+    SignalSyncCompleted( iServiceId, iError );
+    ClearSignaledFlags();
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+void CIpsSosAOPopAgent::RunL()
+    {
+    FUNC_LOG;
+    if ( iOngoingOp )
+        {
+        // errors are not tolerated atm
+        if (  iOngoingOp->iStatus.Int() != KErrNone )
+            {
+            iError = iOngoingOp->iStatus.Int();
+            SignalSyncCompleted( iServiceId, iError );
+            CancelAllAndDisconnectL();
+            }
+        delete iOngoingOp;
+        iOngoingOp = NULL;
+        }
+    
+    switch( iState )
+         {
+         case EStateConnectAndSync:
+             iState = EStatePopulateAll;
+             SetActiveAndCompleteThis();
+             break;
+         case EStateConnectAndSyncOnHold:
+             StartSyncL();
+             break;
+         case EStatePopulateAll:
+             PopulateAllL();
+             break;
+         case EStatePopulateOnHold:
+             PopulateAllL();
+             break;
+         case EStateFetchOngoing:
+             break;
+         case EStateFetchOnHold:
+             break;
+         case EStateDisconnect:
+             if ( !iDoNotDisconnect )
+                 {
+                 CancelAllAndDisconnectL();
+                 }
+             else
+                 {
+                 iState = EStateCompleted;
+                 SetActiveAndCompleteThis();
+                 }
+             break;
+         case EStateCompleted:
+             TRAP_IGNORE( iOpResponse.OperationCompletedL( iError ) );
+             SignalSyncCompleted( iServiceId, iError );
+             ClearSignaledFlags();
+             iError = KErrNone;
+             iState = EStateIdle;
+             iSyncStartedSignaled = EFalse;
+             break;
+         case EStateIdle:
+             break;
+         default:
+         break;
+  
+         }
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+TInt CIpsSosAOPopAgent::RunError( TInt aError )
+    {
+    FUNC_LOG;
+    iError = aError;
+    if ( IsConnected() && iState != EStateDisconnect )
+        {
+        TRAP_IGNORE( CancelAllAndDisconnectL() );
+        }
+    else if ( IsConnected() && iState == EStateDisconnect )
+        {
+        iSession.StopService( iServiceId );
+        iState = EStateCompleted;
+        SetActiveAndCompleteThis();
+        }
+    else
+        {
+        iState = EStateCompleted;
+        SetActiveAndCompleteThis();
+        }
+    return KErrNone;
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+void CIpsSosAOPopAgent::GetServerAddress( 
+        TBuf<KIpsSosAOTextBufferSize>& aIncomingServer ) const
+    {
+    FUNC_LOG;
+    if ( !iPopSettings )
+        {
+        return;
+        }
+    TPtrC addr = iPopSettings->ServerAddress();
+    __ASSERT_DEBUG( ( 
+            addr.Length() <= KIpsSosAOTextBufferSize ), 
+            User::Panic( KIpsSosAOPanicLit, KErrGeneral) );
+    
+    if ( addr.Length() <= KIpsSosAOTextBufferSize )
+        {
+        aIncomingServer.Copy( addr );
+        }
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+void CIpsSosAOPopAgent::GetUsername( 
+        TBuf8<KIpsSosAOTextBufferSize>& aUsername ) const
+    {
+    FUNC_LOG;
+    if ( !iPopSettings )
+        {
+        return;
+        }
+    TPtrC8 usrn = iPopSettings->LoginName();
+    __ASSERT_DEBUG( ( 
+            usrn.Length() <= KIpsSosAOTextBufferSize ), 
+            User::Panic( KIpsSosAOPanicLit, KErrGeneral) );
+    
+    if ( usrn.Length() <= KIpsSosAOTextBufferSize )
+        {
+        aUsername.Copy( usrn );
+        }
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+TBool CIpsSosAOPopAgent::IsConnected() const
+    {
+    FUNC_LOG;
+    TMsvEntry tentry;
+    TMsvId service;
+    iSession.GetEntry( iServiceId, service, tentry );
+    return tentry.Connected();
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+CIpsSosAOBaseAgent::TAgentState CIpsSosAOPopAgent::GetState() const
+    {
+    FUNC_LOG;
+    return iState;
+    }
+
+// ----------------------------------------------------------------------------
+// ---------------------------------------------------------------------------- 
+void CIpsSosAOPopAgent::StartSyncL()
+    {
+    FUNC_LOG;
+    if ( iOngoingOp )
+        {
+        User::Leave( KErrNotReady );
+        }
+    LoadSettingsL( );
+    if ( !IsConnected() )
+        {
+        TBuf8<1> dummy;
+        // connect and synchronise starts background sync or idle
+        iSelection->ResizeL(0);
+        iSelection->AppendL( iServiceId );
+        iPopClientMtm->SwitchCurrentEntryL( iServiceId );
+        iOngoingOp = iPopClientMtm->InvokeAsyncFunctionL(
+                KPOP3MTMConnect, *iSelection, dummy, iStatus);
+        SetActive();
+        iState = EStateConnectAndSync;
+        }
+    else
+        {
+        iState = EStateCompleted;
+        iError = KErrCancel;
+        SetActiveAndCompleteThis();
+        }
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+void CIpsSosAOPopAgent::StartFetchMessagesL( 
+        const RArray<TMsvId>& /*aFetchMsgArray*/ )
+    {
+    FUNC_LOG;
+    
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+void CIpsSosAOPopAgent::CancelAllAndDisconnectL()
+    {
+    FUNC_LOG;
+    iDoNotDisconnect = EFalse;
+    iState = EStateCompleted;
+    if ( IsActive() )
+        {
+        Cancel();
+        }
+
+    if ( IsConnected() )
+        {
+        TBuf8<1> dummy;
+        iSelection->ResizeL(0);
+        iSelection->AppendL( iServiceId );
+        iPopClientMtm->SwitchCurrentEntryL( iServiceId );
+        TRAPD( error, iOngoingOp = iPopClientMtm->InvokeAsyncFunctionL(
+            KPOP3MTMDisconnect, 
+            *iSelection, dummy, iStatus) );
+        
+        if ( error == KErrNone )
+            {
+            SetActive();
+            }
+        else
+            {
+            iSession.StopService( iServiceId );
+            SetActiveAndCompleteThis();
+            }
+        }
+    else
+        {
+        SetActiveAndCompleteThis();
+        }
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+void CIpsSosAOPopAgent::CancelAllAndDoNotDisconnect()
+    {
+    FUNC_LOG;
+    iDoNotDisconnect = ETrue;
+    if ( IsActive() )
+        {
+        Cancel();
+        }
+    SignalSyncCompleted( iServiceId, iError );
+    iState = EStateCompleted;
+    SetActiveAndCompleteThis();
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+void CIpsSosAOPopAgent::DoNotDisconnect()
+    {
+    FUNC_LOG;
+    iDoNotDisconnect = ETrue;
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+void CIpsSosAOPopAgent::ClearDoNotDisconnect()
+    {
+    FUNC_LOG;
+    iDoNotDisconnect = EFalse;
+    iSyncStartedSignaled = EFalse;
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+void CIpsSosAOPopAgent::HoldOperations()
+    {
+    FUNC_LOG;
+    if ( IsActive() )
+        {
+        Cancel();
+        }
+    
+    if ( iState == EStatePopulateAll )
+        {
+        iState = EStatePopulateOnHold;
+        }
+    else if ( iState == EStateFetchOngoing )
+        {
+        iState = EStateFetchOnHold;
+        }
+    else if ( iState == EStateConnectAndSync )
+        {
+        iState = EStateConnectAndSyncOnHold;
+        }
+    else 
+        {
+        iState = EStateIdle;
+        }
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+void CIpsSosAOPopAgent::ContinueHoldOperations()
+    {
+    FUNC_LOG;
+    SetActiveAndCompleteThis();
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+void CIpsSosAOPopAgent::PopulateAllL()
+    {
+    FUNC_LOG;
+    if ( !IsConnected() )
+        {
+        SignalSyncCompleted( iServiceId, iError );
+        CancelAllAndDisconnectL();
+        }
+    else if ( iPopulateLimit > 0 )
+        {
+        TImPop3PopulateOptions pop3GetMailInfo;
+        // NOTE: SetMaxEmailSize and PopulationLimit are basicly same thing.
+        // Populate limit using TOP and size is just bytes,
+        pop3GetMailInfo.SetMaxEmailSize( KMaxTInt32 ); 
+        pop3GetMailInfo.SetPopulationLimit( iPopulateLimit );
+        TPckg<TImPop3PopulateOptions> params( pop3GetMailInfo );
+    
+        iSelection->ResizeL(0);
+        iSelection->AppendL(iServiceId);
+        iPopClientMtm->SwitchCurrentEntryL( iServiceId );
+        iOngoingOp = iPopClientMtm->InvokeAsyncFunctionL(
+                KPOP3MTMPopulateAll, *iSelection, params, iStatus);
+        SetActive();
+        iState = EStateDisconnect;
+        SignalSyncStarted( iServiceId );
+        }
+    else
+        {
+        SetActiveAndCompleteThis();
+        iState = EStateDisconnect;
+        SignalSyncStarted( iServiceId );
+        }
+
+    }
+
+// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+void CIpsSosAOPopAgent::LoadSettingsL( )
+    {
+    FUNC_LOG;
+    delete iPopSettings;
+    iPopSettings = NULL;
+    iPopSettings = new ( ELeave ) CImPop3Settings();
+    CEmailAccounts* accounts = CEmailAccounts::NewLC();
+    TPopAccount popAcc;
+    accounts->GetPopAccountL(iServiceId, popAcc );
+    accounts->LoadPopSettingsL( popAcc, *iPopSettings );
+    CleanupStack::PopAndDestroy( accounts );
+    
+    iPopulateLimit = iPopSettings->PopulationLimit();
+    if ( iPopulateLimit > 0 )
+        {
+        iPopulateLimit = ( iPopulateLimit * 1024 ) / 75;
+        }
+    else if ( iPopulateLimit == KIpsSetDataHeadersOnly )    
+        {
+        iPopulateLimit = 0;
+        }
+    else
+        {
+        iPopulateLimit = KMaxTInt;
+        }
+    
+    
+    }
+
+// ----------------------------------------------------------------------------
+// inline
+// ----------------------------------------------------------------------------
+void CIpsSosAOPopAgent::SetActiveAndCompleteThis()
+    {
+    FUNC_LOG;
+    if ( !IsActive() )
+        {
+        SetActive();
+        }
+    TRequestStatus* status = &iStatus;
+    User::RequestComplete(status, KErrNone);
+    }
+