/*
* Copyright (c) 2002 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of the License "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:  class implementation
*
*/

#include <AccessoryConnection.h>

#include "sysinfoservice.h"
#include "sysaccessoryrequest.h"
#include "entitykeys.h"
#include "sysrequest.h"

using namespace SysInfo;

// --------------------------------------------------------------------
// CAccessory::CAccessory()
// C++ default constructor.
// --------------------------------------------------------------------
//
CAccessory::CAccessory( TSysRequest::TRequestType aReqType, TInt32 aTransID,
                    ISystemObserver* aObsrvr ): CActiveRequest(
                    aReqType, aTransID, aObsrvr), iAccCountOld(0),
                    iAccState(CAccessoryInfo::EDisconnected)
    {
    }

// --------------------------------------------------------------------
// CAccessory::~CAccessory()
// destructor.
// --------------------------------------------------------------------
//
CAccessory::~CAccessory()
    {
    Cancel();
    iAccessoryConnection.CloseSubSession();
    iAccSrv.Disconnect();
    }

// --------------------------------------------------------------------
// CAccessory::NewL()
// Two-phased constructor, returns instance of this class.
// --------------------------------------------------------------------
//
CAccessory* CAccessory::NewL(const TSysRequest& aRequest)
    {
    CAccessory* self;
    self = new (ELeave) CAccessory(aRequest.RequestType(),
                            aRequest.TransactionID(), aRequest.Observer());

    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);
    return self;
    }
	
// --------------------------------------------------------------------
// CAccessory::ConstructL()
// 2nd Phase constructor to allocate required resources for this obj.
// --------------------------------------------------------------------
//
void CAccessory::ConstructL()
    {
    //Supportes Only Notifications.
    if( TSysRequest::ENotification != RequestType())
        User::Leave(KErrNotSupported);

    User::LeaveIfError(iAccSrv.Connect());
    TInt err = iAccessoryConnection.CreateSubSession(iAccSrv);
    if( err )
        {
        iAccSrv.Disconnect();
        User::Leave(err);
        }
    }
	
// --------------------------------------------------------------------
// CAccessory::Request()
// Issues accesssory request.
// --------------------------------------------------------------------
//
TInt CAccessory::Request()
    {
    if(!iAccCountOld)
        {
        // get all connected accessories into iGenIdArrayOld.
        iAccessoryConnection.GetAccessoryConnectionStatus(iGenIdArrayOld);
        //Store Connection Count.
        iAccCountOld = iGenIdArrayOld.Count();
        }

    //Issue request.
    if( !IsActive() )
        {
        iAccessoryConnection.NotifyAccessoryConnectionStatusChanged(iStatus, 
                                                                iGenIdArrayCur);
        SetActive ();
        }
    return KErrNone;
    }
	
// --------------------------------------------------------------------
// CAccessory::RunL()
// Gets called in event of request completion or error situation.
// --------------------------------------------------------------------
//
void CAccessory::RunL()
    {
    TSysRequest::TRequestType ReqType = RequestType();
    TInt32 transId = this->TransactionID();

    // get accessory count.
    iAccCountCur = iGenIdArrayCur.Count();
    iAccCountOld = iGenIdArrayOld.Count();

    // Check if it a was a connect or a disconnect
    if( iAccCountCur > iAccCountOld )
        iAccState = CAccessoryInfo::EConnected;
    else
        iAccState = CAccessoryInfo::EDisconnected;

    TInt error(iStatus.Int());
    
    if(error == KErrNone)
        {
        CAccessoryInfo* accInfo = NULL;
        //newly connected accessory will be at index '0'.
        if(iAccState == CAccessoryInfo::EConnected)
            {
            TAccPolGenericID ConnectedID;
            ConnectedID = iGenIdArrayCur.GetGenericIDL(0);
            accInfo = CAccessoryInfo::NewL(ConnectedID,iAccState);
            }
        else
            {
            TAccPolGenericID DisConnectedID;
            //get DisConnected accessory ID.
            DisConnectedAccessoryL(DisConnectedID);
            accInfo = CAccessoryInfo::NewL(DisConnectedID,iAccState);
            }

        CleanupStack::PushL(accInfo);
        TRAP_IGNORE(SystemObserver()->HandleResponseL(KGeneral, KAccessoryStatus,
                                        accInfo, transId, RequestType(), error));
        CleanupStack::Pop(accInfo);
        //Re-Issue request
        Request();
        }
    else
        {
        TRAP_IGNORE(SystemObserver()->HandleResponseL(KGeneral, KAccessoryStatus, 
                                        NULL, transId, RequestType(), error));
        }
    //copy current list to old list.
    iGenIdArrayOld = iGenIdArrayCur;
    }

// --------------------------------------------------------------------
// CAccessory::DoCancel()
// Gets called in event of request completion or error situation.
// --------------------------------------------------------------------
//
void CAccessory::DoCancel()
    {
    if(IsActive())
        iAccessoryConnection.CancelNotifyAccessoryConnectionStatusChanged();
    }
	
// --------------------------------------------------------------------
// CAccessory::DisConnectedAccessoryL()
// retruns disconnected accessory GenericID.
// --------------------------------------------------------------------
//
void CAccessory::DisConnectedAccessoryL(TAccPolGenericID& aGenId)
    {
    for(TInt i=0; i<iAccCountOld; i++)
        {
        TAccPolGenericID DisConnected;
        //Take a GenericID in old list and search for it in cur list.
        //if present, continue with next.
        DisConnected = iGenIdArrayOld.GetGenericIDL(i);
        aGenId= DisConnected;

        for(TInt j=0; j<iAccCountCur;j++)
            {
            //stop searching when a missing entry in old list is found.
            if( DisConnected.UniqueID() != 
                        (iGenIdArrayCur.GetGenericIDL(j)).UniqueID() )
                {
                return;
                }
            }
        }
    }

// End of file.