/*
* 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:  Definition of the ClientFileSource class.
*
*/


#include <MCustomCommand.h>
#include <SourceControlObserver.h>
#include "ClientFileSource.h"
#include "EventNotifier.h"
#include "ErrorCode.h"


#define RETURN_IF_ERROR(x) if(x != KErrNone) return x

using namespace multimedia;

CClientFileSource::CClientFileSource()
:iMimeType(NULL),
iFileName(NULL)
    {
    // No Impl
    }

CClientFileSource::~CClientFileSource()
    {
    delete iMimeType;
    delete iFileName;
    delete iAsyncEventAO;
    delete iEventNotifier;
    }

TInt CClientFileSource::PostConstructor()
    {
    TInt status(KErrNone);
    TRAP(status, iAsyncEventAO = CAsyncAO::NewL(*this));
    RETURN_IF_ERROR( status );
    
    if ( !iEventNotifier )
        {
        TRAP(status, iEventNotifier = CEventNotifier::NewL());
        }

    return status;
    }

// From MControl begins
TInt CClientFileSource::AddObserver( MControlObserver& aObserver )
    {
    return iEventNotifier->AddObserver( aObserver );
    }

TInt CClientFileSource::RemoveObserver( MControlObserver& aObserver )
    {
    return iEventNotifier->RemoveObserver( aObserver );
    }

TUid CClientFileSource::Type()
    {
    return KFileSourceControl;
    }

TControlType CClientFileSource::ControlType()
    {
    return ESourceControl;
    }
// From MControl ends

// From MSourceControl begins
TInt CClientFileSource::GetSize( TUint& aSize )
    {
    TInt status(KErrUnknown);
    
    if(iServerSourceExists)
        {
        if(!iFileSize)
            {
            iEventPckg().iType = EFileSize;
            iCustomCommand->CustomCommandSync( iSourceHandle, EGetFileSourceEvent, iEventPckg, KNullDesC8, iEventPckg );
            aSize = iFileSize = iEventPckg().iFileSize;
            status = KErrNone;
            }
        else
            {
            aSize = iFileSize;
            status = KErrNone;    
            }
        }
     else
        {
        aSize = 0;
        status = KErrUnknown;
        }   
    
    return status;
    }

TInt CClientFileSource::GetMimeType( TDes8& aMimeType )
    {
    TInt status(KErrUnknown);
    if ( iMimeType )
        {
        aMimeType.Copy(*iMimeType);
        status = KErrNone;
        }
    return status;
    }

TInt CClientFileSource::Close()
    {
    delete iMimeType;
    iMimeType = NULL;
    delete iFileName;
    iFileName = NULL;
    iBitRate = 0;
    iFileSize = 0;
    return KErrNone;
    }

// From MSourceControl ends

// From MFileSource begins
TInt CClientFileSource::Open( TDesC& aFileName, TDesC8& aMimeType  )
    {
    TInt status(KErrAlreadyExists);
    Close();
    if ( aFileName.Ptr() != NULL )
        {
        if(aMimeType.Size())
            {
            TRAP( status, iMimeType = aMimeType.AllocL() );
            RETURN_IF_ERROR( status );
            }
        
        TRAPD(status,iFileName = HBufC::NewL(aFileName.Size()));
        
        if(!status)
            {
            TPtr des = iFileName->Des();
            des.Copy(aFileName);
            }
        else
            return status;   

        }
    return status;
    }

TInt CClientFileSource::GetBitRate( TUint& aRate )
    {
    TInt status(KErrNone);
    
    if(iServerSourceExists)
        {
        if(!iBitRate)
            {
            iEventPckg().iType = EFileBitRateChanged;
            iCustomCommand->CustomCommandSync( iSourceHandle, EGetFileSourceEvent, iEventPckg, KNullDesC8, iEventPckg );
            aRate = iBitRate = iEventPckg().iBitRate;
            status = KErrNone;
            }
        else
            {
            aRate = iBitRate;
            status = KErrNone;    
            }
        }
     else
        {
        aRate = 0;
        status = KErrUnknown;
        }   
    
    return status;
    }

TInt CClientFileSource::GetFileName(TPtr& aFileName)
    {
    TInt status(KErrNone);
    aFileName.Set(iFileName->Des());
    return status;
    }

// From MFileSource ends

// From CSourceBase begins
void CClientFileSource::ServerSourceCreated( MCustomCommand& aCustomCommand,
                            TMMFMessageDestination& aSourceHandle )
    {
    iServerSourceExists = ETrue;
    iCustomCommand = &aCustomCommand;
    iSourceHandle = aSourceHandle;

    

    
    // Subcribe for source event notifications
    iEventPckg().iType = EFileSourceStateChanged;
    iAsyncEventAO->SetActive();
    iCustomCommand->CustomCommandAsync( iSourceHandle,
                                        EGetFileSourceEvent,
                                        iEventPckg,
                                        KNullDesC8,
                                        iEventPckg,
                                        iAsyncEventAO->iStatus );
    }

void CClientFileSource::ServerSourceDeleted()
    {
    iServerSourceExists = EFalse;
    iCustomCommand = NULL;
    }

TBool CClientFileSource::IsEncrypted()
    {
    return EFalse;
    }

TUid CClientFileSource::GetSourceUid()
    {
    return KFileDataSourcePlugin;
    }

TInt CClientFileSource::GetHeaderData( TPtr& /*aPtr*/ )
    {
    return KErrNotSupported;
    }

// From CSourceBase ends

// From MAsyncAOObserver begins
void CClientFileSource::Event( TInt aError )
    {
    if ( aError == KErrNone )
        {
#ifdef _DEBUG
        RDebug::Print(_L("CClientFileSource::Event() Client State[%d] Type[%d]"), iEventPckg().iState, iEventPckg().iType);
#endif        
        switch (iEventPckg().iType)
            {
            case EFileBitRateChanged:
                DoBitRateChanged(iEventPckg().iBitRate);                
                break;
            case EFileSourceStateChanged:
                iState = iEventPckg().iState;
                break;

            default:
                break;
            };
        }

    // Subcribe for more source event notifications
    iEventPckg().iState = iState;
    
    if(iServerSourceExists)
        {
        iAsyncEventAO->SetActive();
        iCustomCommand->CustomCommandAsync( iSourceHandle,
                                            EGetFileSourceEvent,
                                            iEventPckg,
                                            KNullDesC8,
                                            iEventPckg,
                                            iAsyncEventAO->iStatus );
        }
    }

// From MAsyncAOObserver ends

void CClientFileSource::DoBitRateChanged( TUint aBitRate )
    {
    iBitRate = aBitRate;
    CErrorCode* event1 = new CErrorCode( KErrNone );       
    iEventNotifier->Event(this,MSourceControlObserver::KBitRateChangedEvent,event1);
    }

// End of file