/*
* Copyright (c) 2010 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: 
*
*/
#include <e32std.h>
#include <e32svr.h>

#include <stfeventsystemdefs.h>
#include "stfeventsystem.h"
#include <stfasynceventactive.h>

// Implementation of session class

/**
Connects to event server.
*/
EXPORT_C TInt REventSystem::Connect()
    {
    //RDebug::Print(_L("STF [ESC]: REventSystem::Connect start"));
    TInt err;
    
    // Check if server is not running
    err = CreateSession(KEventSystemServName, Version());
    //RDebug::Print(_L("STF [ESC]: REventSystem::Connect session creation [%d]"), err);
    
    if(err == KErrNotFound) //Server is not yet started
        {
        RProcess p;
        err = p.Create(KEventSystemServNameExe, KEventSystemServNameExe);
        RDebug::Print(_L("STF [ESC]: REventSystem::Connect process creation [%d]"), err);
        if(err == KErrNone)
            {
            p.Resume();
            
            TRequestStatus eventServerStartup;
            p.Rendezvous(eventServerStartup);
            User::WaitForRequest(eventServerStartup);
            RDebug::Print(_L("STF [ESC]: REventSystem::Connect randezvous with server [%d]"), eventServerStartup.Int());
            p.Close();

            err = CreateSession(KEventSystemServName, Version());
            //RDebug::Print(_L("STF [ESC]: REventSystem::Connect session creation [%d]"), err);
            }
        }
    else if(err != KErrNone)
        {
        return err;
        }
    //RDebug::Print(_L("STF [ESC]: REventSystem::Connect end"));
    return err; 
    }

/**
Closes connection.
*/
EXPORT_C void REventSystem::Close()
    {
    //RDebug::Print(_L("STF [ESC]: REventSystem::Close()"));
    if(Handle())
        {
        SendReceive(EEventSystemServCloseSession);
        RHandleBase::Close();
        }
    //RDebug::Print(_L("STF [ESC]: REventSystem::Close end"));
    }

/**
Returns version of event system.
*/
EXPORT_C TVersion REventSystem::Version(void) const
    {
    return TVersion(KEventSystemServMajorVersionNumber, KEventSystemServMinorVersionNumber, KEventSystemServBuildVersionNumber);
    }

/**
Set indication event.
*/
EXPORT_C void REventSystem::SetIndicationEventL(const TDesC& aEventName)
    {
    SetIndicationEventL(aEventName, NULL);
    }

/**
Set indication event.
*/
EXPORT_C void REventSystem::SetIndicationEventL(const TDesC& aEventName, TRequestStatus *aStatus)
    {
    RDebug::Print(_L("STF [ESC]: REventSystem::SetIndicationEventL"));
    if(aStatus)
        *aStatus = KRequestPending;

    User::LeaveIfError(Connect());
    TIpcArgs args(&aEventName);
    TInt ret = SendReceive(EEventSystemSetIndicationEvent, args);
    RDebug::Print(_L("STF [ESC]: REventSystem::SetIndicationEventL completed with [%d]"), ret);
    Close();
    
    if(aStatus)
        User::RequestComplete(aStatus, ret);

    User::LeaveIfError(ret);
    }

/**
Wait for event
*/
EXPORT_C void REventSystem::WaitEventL(const TDesC& aEventName, const TInt aOwner)
    {    
    RDebug::Print(_L("STF [ESC]: REventSystem::WaitEventL eventname=[%S]"), &aEventName);
    User::LeaveIfError(Connect());
    TIpcArgs args(&aEventName, aOwner);
    TInt ret = SendReceive(EEventSystemWaitEvent, args);
    RDebug::Print(_L("STF [ESC]: REventSystem::WaitEventL completed with [%d]"), ret);
    Close();
    User::LeaveIfError(ret);
    }

/**
Set state event.
*/
EXPORT_C void REventSystem::SetEventL(const TDesC& aEventName)
    {
    SetEventL(aEventName, NULL);
    }

/**
Request event
*/
EXPORT_C void REventSystem::RequestEventL(const TDesC& aEventName, const TInt aOwner)
    {    
    RDebug::Print(_L("STF [ESC]: REventSystem::RequestEventL eventname=[%S]"), &aEventName);
    User::LeaveIfError(Connect());
    TIpcArgs args(&aEventName, aOwner);
    TInt ret = SendReceive(EEventSystemRequestEvent, args);
    RDebug::Print(_L("STF [ESC]: REventSystem::RequestEventL completed with [%d]"), ret);
    Close();
    User::LeaveIfError(ret);
    }

/**
Release event
*/
EXPORT_C void REventSystem::ReleaseEventL(const TDesC& aEventName, const TInt aOwner)
    {    
    RDebug::Print(_L("STF [ESC]: REventSystem::ReleaseEventL eventname=[%S]"), &aEventName);
    User::LeaveIfError(Connect());
    TIpcArgs args(&aEventName, aOwner);
    TInt ret = SendReceive(EEventSystemReleaseEvent, args);
    RDebug::Print(_L("STF [ESC]: REventSystem::ReleaseEventL completed with [%d]"), ret);
    Close();
    User::LeaveIfError(ret);
    }

/**
Set state event.
*/
EXPORT_C void REventSystem::SetEventL(const TDesC& aEventName, TRequestStatus *aStatus)
    {
    RDebug::Print(_L("STF [ESC]: REventSystem::SetStateEventL eventname=[%S]"), &aEventName);
    
    if(aStatus)
        *aStatus = KRequestPending;
    
    User::LeaveIfError(Connect());
    TIpcArgs args(&aEventName);
    TInt ret = SendReceive(EEventSystemSetEvent, args);
    RDebug::Print(_L("STF [ESC]: REventSystem::SetStateEventL completed with [%d]"), ret);
    Close();
    
    if(aStatus)
        User::RequestComplete(aStatus, ret);
        
    User::LeaveIfError(ret);
    }
    
/**
Unset state event.
*/
EXPORT_C void REventSystem::UnsetEventL(const TDesC& aEventName)
    {
    UnsetEventL(aEventName, NULL);
    }
    
/**
Unset state event.
*/
EXPORT_C void REventSystem::UnsetEventL(const TDesC& aEventName, TRequestStatus* aStatus)
    {
    RDebug::Print(_L("STF [ESC]: REventSystem::UnsetStateEventL eventname=[%S]"), &aEventName);
    
    if(aStatus)
        *aStatus = KRequestPending;
            
    User::LeaveIfError(Connect());
    TIpcArgs args(&aEventName);
    TInt ret = SendReceive(EEventSystemUnsetEvent, args);
    RDebug::Print(_L("STF [ESC]: REventSystem::UnsetStateEventL completed with [%d]"), ret);
    Close();
    
    if(aStatus)
        User::RequestComplete(aStatus, ret);
    
    User::LeaveIfError(ret);
    }

/**
Cancel (remove) all requested events of given owner.
*/
EXPORT_C TInt REventSystem::RemoveInRequestedState(const TInt aOwner)
    {
    RDebug::Print(_L("STF [ESC]: REventSystem::RemoveInRequestedState"));

    User::LeaveIfError(Connect());
    TIpcArgs args(aOwner);
    TInt ret = SendReceive(EEventSystemRemoveInRequestedState, args);
    RDebug::Print(_L("STF [ESC]: REventSystem::RemoveInRequestedState completed with [%d]"), ret);
    Close();
    
    return ret;    
    }
    
// EOF