RemotingWriter.hpp

 
//
//  Copyright PHOENIX CONTACT Electronics GmbH
//
#pragma once
#include "Arp/System/Core/Arp.h"
#include "Arp/System/Rsc/Services/Rsc.h"
 
// forwards
namespace CommonRemoting
{
class BinaryWriter2;
}
 
namespace Arp { namespace System { namespace Rsc { namespace Services
{
 
using namespace CommonRemoting;
 
//forwards
class RscWriter;
class RscClientContext;
 
class RemotingWriter
{
    friend class RscStream;
 
public: // construction
    RemotingWriter(BinaryWriter2& remotingWriter, RscWriter& rscWriter, RscClientContext* pRscClientContext = nullptr);
 
public: // getter
    RscWriter& GetRscWriter(void);
    bool HasDataTagging(void)const;
 
public: // methods
    void WriteDateTime(const DateTime& result);
    void WriteArrayLength(size_t value);
    void WriteDataInternal(const byte* pBuffer, size_t count);
    void WriteStringInternal(const char* pBuffer, size_t maxSize = (size_t) -1, RscStringEncoding encoding = RscStringEncoding::Utf8, bool writeTag = true);
    void WriteConfirmation(bool flush = false);
    void WriteEnumeratorTag(RscType tag);
    void BeginWriteStream(int maxPacketSize);
    void WriteStream(const byte* pBuffer, uint32 bufferCount, int maxPacketSize);
    void EndWriteStream(void);
    void WriteObjectType(RscType type);
    void WriteStringLength(size_t length);
    void WriteStringEncoding(RscStringEncoding encoding);
    void WriteObjectString(RscStringEncoding stringEncoding, const void* pString);
    void WriteError(const char* pResourceCatalogue, int errorResourceId, int errorCode);
    void WriteError(const char* pResourceCatalogue, int errorResourceId, const char* errorMsg);
    void WriteTag(RscType type);
    void WriteArrayTag(RscType elementType, size_t length);
    void WriteBeginStruct(size_t fieldCount);
    void WriteFieldCount(size_t fieldCount);
    void WriteSecurityToken(const SecurityToken& result, bool writeTag = true);
    void WriteArrayInformation(const RscArrayInformation& arrayInformation);
 
private: // fields
    BinaryWriter2&    binaryWriter;
    RscWriter&        rscWriter;
    RscClientContext* pRscClientContext = nullptr;
};
 
// inline methods of class RemotingWriter
inline RscWriter& RemotingWriter::GetRscWriter(void)
{
    return this->rscWriter;
}
 
 
}}}} // end of namespace Arp::System::Rsc::Services