KaaTcpResponseProcessor.hpp

Go to the documentation of this file.

#ifndef KAATCPRESPONSEPROCESSOR_HPP_
#define KAATCPRESPONSEPROCESSOR_HPP_

#include "kaa/kaatcp/KaaTcpCommon.hpp"
#include "kaa/kaatcp/KaaSyncResponse.hpp"
#include "kaa/kaatcp/ConnackMessage.hpp"
#include "kaa/kaatcp/DisconnectMessage.hpp"
#include "kaa/kaatcp/KaaTcpParser.hpp"
#include "kaa/IKaaClientContext.hpp"
#include <functional>

namespace kaa
{

class KaaTcpResponseProcessor
{
public:
    KaaTcpResponseProcessor(IKaaClientContext &context): parser_(context), context_(context) { }
    ~KaaTcpResponseProcessor() { }

    void processResponseBuffer(const char *buf, std::uint32_t size);

    void registerConnackReceiver(std::function<void (const ConnackMessage&)> onConnack) { onConnack_ = onConnack; }
    void registerKaaSyncReceiver(std::function<void (const KaaSyncResponse&)> onKaaSync) { onKaaSyncResponse_ = onKaaSync; }
    void registerDisconnectReceiver(std::function<void (const DisconnectMessage&)> onDisconnect) { onDisconnect_ = onDisconnect; }
    void registerPingResponseReceiver(std::function<void ()> onPing) { onPingResp_ = onPing; }

    void flush() { parser_.resetParser(); }

private:
    std::function<void (const ConnackMessage&)> onConnack_;
    std::function<void (const KaaSyncResponse&)> onKaaSyncResponse_;
    std::function<void (const DisconnectMessage&)> onDisconnect_;
    std::function<void ()> onPingResp_;

    KaaTcpParser parser_;
    IKaaClientContext &context_;
};

}




#endif /* KAATCPRESPONSEPROCESSOR_HPP_ */