RscServerContext.hpp

 
//
//  Copyright PHOENIX CONTACT Electronics GmbH
//
#pragma once
#include "Arp/System/Core/Arp.h"
#include "Arp/System/Rsc/Services/Rsc.h"
#include "Arp/System/Rsc/Services/RscReader.hpp"
#include "Arp/System/Rsc/Services/RscWriter.hpp"
#include "Arp/System/Rsc/Services/RscChannelInfo.hpp"
#include "Arp/System/Security/SecurityToken.hpp"
#include "Arp/System/Security/SecurityContext.hpp"
 
namespace CommonRemoting
{
 
class RemotingServerContext;
 
}
 
namespace Arp { namespace System { namespace Security { namespace Services
{
 
class PasswordConfigurationService2Impl;
class PasswordAuthenticationServiceImpl;
 
}}}} // end of namespace Arp::System::Security::Services
 
 
namespace Arp { namespace System { namespace Rsc { namespace Services
{
 
using namespace CommonRemoting;
 
class RscServerContext
{
    friend class Arp::System::Security::Services::PasswordConfigurationService2Impl;
    friend class Arp::System::Security::Services::PasswordAuthenticationServiceImpl;
 
public: // typedefs
    typedef  Arp::System::Security::SecurityToken      SecurityToken;
    typedef  Arp::System::Security::SecurityContext    SecurityContext;
 
public: // construction/destruction
    RscServerContext(RemotingServerContext& remotingServerContext);
    RscServerContext(const RscServerContext& arg) = default;
    RscServerContext& operator=(const RscServerContext& arg) = default;
    ~RscServerContext(void);
 
public: // static operations
    static bool                 HasCurrent(void);
    static RscServerContext&    GetCurrent(void);
 
public: // setter/getter operations
    bool                    IsSecure(void)const;
    const RscChannelInfo&   GetChannelInfo(void)const;
    SecurityToken           GetSecurityToken(void)const;
    RscReader&              GetReader();
    RscWriter&              GetWriter();
 
public: // operations
    void AbortRequest(RscErrors errorCode, const char* errorMessage = NULL);
    void AbortConnection(RscErrors errorCode, const char* errorMessage = NULL);
    void AbortInvocation(RscErrors errorCode, const char* errorMessage = NULL);
 
private: // security methods used by PasswordConfigurationService2Impl
    bool    HasSecurityContext(void);
    bool    HasSessionSecurityToken(const SecurityToken& token);
    bool    AddSessionSecurityToken(const SecurityToken& token, uint32 initialTimeoutMs);
    bool    RemoveSessionSecurityToken(const SecurityToken& token);
 
private: // fields
    RemotingServerContext&  remotingServerContext;
    RscChannelInfo          channelInfo;
    SecurityToken           securityToken; // never remove this, it is passed and stored as ref to security context
    SecurityContext         securityContext;
    RscReader               rscReader;
    RscWriter               rscWriter;
 
private: // static fields
    static thread_local RscServerContext*   pCurrentServerContext;
};
 
// inline methods of class RscServerContext
inline const RscChannelInfo& RscServerContext::GetChannelInfo(void)const
{
    return this->channelInfo;
}
 
inline RscReader& RscServerContext::GetReader()
{
    return this->rscReader;
}
 
inline RscWriter& RscServerContext::GetWriter()
{
    return this->rscWriter;
}
}}}} // end of namespace Arp::System::Rsc::Services