RscClientContext.hpp

 
//
//  Copyright Phoenix Contact GmbH & Co. KG
//
#pragma once
#include "Arp/Base/Core/Arp.hpp"
#include "Arp/Base/Core/delegate.hxx"
#include "Arp/Base/Rsc/Commons/Rsc.hpp"
#include "Arp/Base/Rsc/Commons/Services/IRscServiceProxy.hpp"
#include "Arp/Base/Rsc/Commons/Services/RscClient.TransactionGuard.hpp" // do not remove, this is used in all proxies
 
namespace Arp::Base::Rsc::Commons::Services
{
 
class ARP_EXPORT RscClientContext
{
public: // usings
    using ReadDelegate = delegate<void(RscReader&)>;    
    using WriteDelegate = delegate<void(RscWriter&)>;   
 
public: // construction
    RscClientContext(IRscServiceProxy& serviceProxy, RscHandle methodHandle, const char* methodName);
 
    // canonical construction/destruction/assignment
    RscClientContext(const RscClientContext& arg) = delete;
    RscClientContext(RscClientContext&& arg)noexcept = delete;
    RscClientContext& operator=(const RscClientContext&) = delete;
    RscClientContext& operator=(RscClientContext&&)noexcept = delete;
    ~RscClientContext(void);
 
public: // getter
    RscReader& GetReader(void);
    RscWriter& GetWriter(void);
 
public: // operations
    void    SendRequest(WriteDelegate writeFunction);
    void    ReceiveResponse(ReadDelegate readFunction);
 
private: // methods
    IRscServiceProxy&   GetServiceProxy(void);
 
private: // fields
    IRscServiceProxy&   serviceProxy;
    RscHandle           methodHandle = 0;
    const char*         methodName = nullptr;
    SecurityToken       cachedSecurityToken;
};
 
} // end of namespace Arp::Base::Rsc::Commons::Services