123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214 |
- #ifndef __mqtt_server_response_h
- #define __mqtt_server_response_h
- #include "MQTTAsync.h"
- #include "mqtt/types.h"
- #include "mqtt/properties.h"
- #include <iostream>
- namespace mqtt {
- class server_response
- {
-
- properties props_;
- public:
-
- server_response() {}
-
- server_response(const properties& props)
- : props_(props) {}
-
- server_response(properties&& props)
- : props_(std::move(props)) {}
-
- virtual ~server_response() {}
-
- const properties& get_properties() const { return props_; }
- };
- class connect_response : public server_response
- {
-
- string serverURI_;
-
- int mqttVersion_;
-
- bool sessionPresent_;
- friend class token;
- connect_response(const MQTTAsync_successData5* rsp) :
- server_response(properties(rsp->properties)),
- serverURI_(string(rsp->alt.connect.serverURI)),
- mqttVersion_(rsp->alt.connect.MQTTVersion),
- sessionPresent_(to_bool(rsp->alt.connect.sessionPresent)) {
- }
- connect_response(const MQTTAsync_successData* rsp) :
- serverURI_(string(rsp->alt.connect.serverURI)),
- mqttVersion_(rsp->alt.connect.MQTTVersion),
- sessionPresent_(to_bool(rsp->alt.connect.sessionPresent)) {
- }
- public:
-
- string get_server_uri() const { return serverURI_; }
-
- int get_mqtt_version() const { return mqttVersion_; }
-
- bool is_session_present() const { return sessionPresent_; }
- };
- struct subscribe_response : public server_response
- {
-
- std::vector<ReasonCode> reasonCodes_;
- friend class token;
-
- subscribe_response(MQTTAsync_successData5* rsp)
- : server_response(properties(rsp->properties)) {
- if (rsp->alt.sub.reasonCodeCount < 2)
- reasonCodes_.push_back(ReasonCode(rsp->reasonCode));
- else if (rsp->alt.sub.reasonCodes) {
- for (int i=0; i<rsp->alt.sub.reasonCodeCount; ++i)
- reasonCodes_.push_back(ReasonCode(rsp->alt.sub.reasonCodes[i]));
- }
- }
-
- subscribe_response(size_t n, MQTTAsync_successData* rsp) {
- if (n < 2)
- reasonCodes_.push_back(ReasonCode(rsp->alt.qos));
- else if (rsp->alt.qosList) {
- for (size_t i=0; i<n; ++i)
- reasonCodes_.push_back(ReasonCode(rsp->alt.qosList[i]));
- }
- }
- public:
-
- const std::vector<ReasonCode>& get_reason_codes() const {
- return reasonCodes_;
- }
- };
- class unsubscribe_response : public server_response
- {
-
- std::vector<ReasonCode> reasonCodes_;
- friend class token;
- unsubscribe_response(MQTTAsync_successData5* rsp)
- : server_response(properties(rsp->properties)) {
- if (rsp->alt.unsub.reasonCodeCount < 2)
- reasonCodes_.push_back(ReasonCode(rsp->reasonCode));
- else if (rsp->alt.unsub.reasonCodes) {
- for (int i=0; i<rsp->alt.unsub.reasonCodeCount; ++i)
- reasonCodes_.push_back(ReasonCode(rsp->alt.unsub.reasonCodes[i]));
- }
- }
- unsubscribe_response(MQTTAsync_successData* /*rsp*/) {}
- public:
-
- const std::vector<ReasonCode>& get_reason_codes() const {
- return reasonCodes_;
- }
- };
- }
- #endif
|