/*
* Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License as published by
* the Free Software Foundation, version 2.1 of the License.
* 
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
* GNU Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with this program.  If not, 
* see "http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html/".
*
* Description:  Symbian implementation for IPC server
*
*/

#include "xqservicelog.h"

#include "xqserviceipcserver_apasymbianserver.h"
#include "xqserviceipcserver_apasymbiansession.h"

#include <xqserviceutil.h>
#include <xqpublishandsubscribeutils.h>
#include <xqsettingskey.h> 
#include <xqapplicationmanager.h>

namespace QtService
{
// Server Security Policy
const TUint KServerRangeCount = 2;
const TInt KServerRanges[KServerRangeCount] = { 
                0, //range is [0-1)
                2 //range is [2-KMaxTInt] 
                };
const TUint8 KSeverElementsIndex[KServerRangeCount] = { 
                0,
                CPolicyServer::ENotSupported };

const CPolicyServer::TPolicyElement KServerPolicyElements[] = { {
                _INIT_SECURITY_POLICY_C1(ECapabilityWriteDeviceData),
                CPolicyServer::EFailClient } };

const CPolicyServer::TPolicy KServerPolicy = {
                CPolicyServer::EAlwaysPass, //specifies all connect attempts should pass
                KServerRangeCount, KServerRanges, KSeverElementsIndex,
                KServerPolicyElements };

enum
{
    EServerPriority = CActive::EPriorityStandard
};

// ======== MEMBER FUNCTIONS ========

/*!
    \class CApaSymbianServer
    \brief Symbian client server implementation
*/

/*!
    Constructor.
*/
CApaSymbianServer::CApaSymbianServer() :
   settingsManager(),
   stateNotifyKey(0)
/*CPolicyServer( EServerPriority,  KServerPolicy)*/                                                 
{
    XQSERVICE_DEBUG_PRINT("CApaSymbianServer::CApaSymbianServer");
    SetPriority(EServerPriority);
}

/*!
    2nd phased constructor
*/
void CApaSymbianServer::ConstructL()
{
}

/*!
    Two phased constructor
*/
CApaSymbianServer* CApaSymbianServer::NewL()
{
    XQSERVICE_DEBUG_PRINT("CApaSymbianServer::NewL");
    CApaSymbianServer* self = new( ELeave ) CApaSymbianServer;
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);
    return self;
}

/*!
    Destructor
*/
CApaSymbianServer::~CApaSymbianServer()
{
    XQSERVICE_DEBUG_PRINT("CApaSymbianServer::~CApaSymbianServer");
    delete stateNotifyKey;
}

/*!
    Start listening for new service requests.
    \param aServerName name of the server.
    \return true if successful.
*/
bool CApaSymbianServer::listen( const QString& aServerName )
{
    XQSERVICE_DEBUG_PRINT("CApaSymbianServer::listen");
    XQSERVICE_DEBUG_PRINT("aServerName: %s", qPrintable(aServerName));
    bool listening(true);

    // Needs to be here becuase Q_Ptr isonly set after constructor of public
    iObserver = Observer();
    TPtrC serverName(reinterpret_cast<const TUint16*> (aServerName.utf16()));
    TInt err=0;
    TRAP( err, StartL(serverName) );
    XQSERVICE_DEBUG_PRINT("listen status=%d", err);
    if (err != KErrNone) {
        listening = false;
    } else {
	    QString normalizedServerName = aServerName.toLower();
	    quint32 id = XQServiceUtil::serviceIdFromName(normalizedServerName.toLatin1().data());
	    
	    delete stateNotifyKey;
	    
	    RProcess currentProcess;
	    const TSecureId secureId = currentProcess.SecureId();
	    
	    stateNotifyKey = new XQPublishAndSubscribeSettingsKey(secureId.iId, id);

	    XQPublishAndSubscribeUtils utils(settingsManager); 
	    if (!utils.defineProperty(*stateNotifyKey, XQSettingsManager::TypeInt) && (settingsManager.error() != XQSettingsManager::AlreadyExistsError)) {
				XQSERVICE_WARNING_PRINT("CApaSymbianServer::listen: property for service UID:%s could not be created. Notifications may not work.", stateNotifyKey->uid());
	    } else {
			settingsManager.writeItemValue(*stateNotifyKey, static_cast<int>(XQApplicationManager::ServiceStarted));
		}
	}
    // Complete the server rendezvous that th client started
    XQSERVICE_DEBUG_PRINT("CApaSymbianServer::Rendezvouz");
    RProcess::Rendezvous(KErrNone);
    XQSERVICE_DEBUG_PRINT("CApaSymbianServer::Rendezvouz done");
    XQSERVICE_DEBUG_PRINT("listening: %d", listening);
    return listening;
}

/*!
    Shutdown the server and stop serving clients.
*/
void CApaSymbianServer::disconnect()
{
    XQSERVICE_DEBUG_PRINT("CApaSymbianServer::disconnect");
    // Symbian Servers do not have disconnect, 
    // the process has to exit
    
    if (stateNotifyKey != 0) {
        settingsManager.writeItemValue(*stateNotifyKey, QVariant(XQApplicationManager::ServiceStopped));
    }
    
    delete stateNotifyKey;
    stateNotifyKey = 0;
}

/*!
    Create a new session, derived from CPolicyServer.
    \param aVersion Version of the server.
    \param aMessage Message object.
*/
CSession2* CApaSymbianServer::NewSessionL(const TVersion& aVersion,
                                          const RMessage2& aMessage) const
{
    XQSERVICE_DEBUG_PRINT("CApaSymbianServer::NewSessionL");
    TVersion v(1, 0, 0);
    if (!User::QueryVersionSupported(v, aVersion)) {
        XQSERVICE_DEBUG_PRINT("Not supported version");
        User::Leave(KErrNotSupported);
    }

    // Create a new Symbian Session for the client
  return CApaServerSymbianSession::NewL(iObserver);
}

CPolicyServer::TCustomResult CApaSymbianServer::CreateServiceSecurityCheckL
                                    ( TUid /*aServiceType*/, 
                                      const RMessage2& /*aMsg*/, 
                                      TInt& /*aAction*/,
                                      TSecurityInfo& /*aMissing*/ )
{
    XQSERVICE_DEBUG_PRINT("CApaSymbianServer::CreateServiceSecurityCheckL");
    return CPolicyServer::EPass;
}

}

// END OF FILE