SNode.C
Loading...
Searching...
No Matches
String.h
Go to the documentation of this file.
1/*
2 * SNode.C - a slim toolkit for network communication
3 * Copyright (C) Volker Christian <me@vchrist.at>
4 * 2020, 2021, 2022, 2023, 2024, 2025
5 *
6 * This program is free software: you can redistribute it and/or modify
7 * it under the terms of the GNU Lesser General Public License as published
8 * by the Free Software Foundation, either version 3 of the License, or
9 * (at your option) any later version.
10 *
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU Lesser General Public License for more details.
15 *
16 * You should have received a copy of the GNU Lesser General Public License
17 * along with this program. If not, see <http://www.gnu.org/licenses/>.
18 */
19
20#ifndef IOT_MQTT_TYPES_STRING_H
21#define IOT_MQTT_TYPES_STRING_H
22
23#include "iot/mqtt/types/TypeBase.h"
24#include "iot/mqtt/types/UInt16.h"
25
26#ifndef DOXYGEN_SHOULD_SKIP_THIS
27
28#include <cstddef>
29#include <string>
30
31#endif // DOXYGEN_SHOULD_SKIP_THIS
32
33namespace iot::mqtt::types {
34
35 class String : public TypeBase<std::string> {
36 public:
37 String();
38 explicit String(const std::string& value);
39 String(const String&) = default;
40 String(String&&) noexcept = default;
41
42 ~String() override;
43
44 String& operator=(const String&) = default;
45 String& operator=(String&&) noexcept = default;
46
47 std::size_t deserialize(iot::mqtt::MqttContext* mqttContext) override;
48 std::vector<char> serialize() const override;
49
50 String& operator=(const std::string& newValue);
51 operator std::string() const;
52
53 bool operator==(const std::string& rhsValue) const;
54 bool operator!=(const std::string& rhsValue) const;
55
56 void reset(std::size_t size = 0) override;
57
58 private:
59 UInt16 stringLength;
60 };
61
62 extern template class TypeBase<std::string>;
63
64} // namespace iot::mqtt::types
65
66#endif // IOT_MQTT_TYPES_STRING_H
#define SUBSCRIBTION_MAX_QOS
Definition Broker.h:40
Session & operator=(const Session &)=default
std::set< uint16_t > publishPacketIdentifierSet
Definition Session.h:63
virtual nlohmann::json toJson() const
Definition Session.cpp:37
Session(const nlohmann::json &json)
Definition Session.cpp:33
bool isCleanSession() const
Session(const Session &)=default
virtual ~Session()=default
void fromJson(const nlohmann::json &json)
Definition Session.cpp:67
std::set< uint16_t > pubrelPacketIdentifierSet
Definition Session.h:60
virtual core::socket::stream::SocketContext * create(core::socket::stream::SocketConnection *socketConnection, std::shared_ptr< iot::mqtt::server::broker::Broker > broker)=0
core::socket::stream::SocketContext * create(core::socket::stream::SocketConnection *socketConnection) final
void restartSession(const std::string &clientId)
Definition Broker.cpp:187
uint8_t subscribe(const std::string &clientId, const std::string &topic, uint8_t qoS)
Definition Broker.cpp:142
bool hasActiveSession(const std::string &clientId)
Definition Broker.cpp:165
static std::shared_ptr< Broker > instance(uint8_t maxQoS)
Definition Broker.cpp:119
bool isActiveSession(const std::string &clientId, const Mqtt *mqtt)
Definition Broker.cpp:173
iot::mqtt::server::broker::RetainTree retainTree
Definition Broker.h:81
void publish(const std::string &originClientId, const std::string &topic, const std::string &message, uint8_t qoS, bool retain)
Definition Broker.cpp:134
bool hasSession(const std::string &clientId)
Definition Broker.cpp:161
void appear(const std::string &clientId, const std::string &topic, uint8_t qoS)
Definition Broker.cpp:125
void unsubscribe(const std::string &clientId, const std::string &topic)
Definition Broker.cpp:157
Session * renewSession(const std::string &clientId, iot::mqtt::server::Mqtt *mqtt)
Definition Broker.cpp:183
void deleteSession(const std::string &clientId)
Definition Broker.cpp:199
void unsubscribe(const std::string &clientId)
Definition Broker.cpp:129
bool hasRetainedSession(const std::string &clientId)
Definition Broker.cpp:169
iot::mqtt::server::broker::SubscribtionTree subscribtionTree
Definition Broker.h:80
Session * newSession(const std::string &clientId, iot::mqtt::server::Mqtt *mqtt)
Definition Broker.cpp:177
void sendPublish(const std::string &clientId, Message &message, uint8_t qoS, bool retain)
Definition Broker.cpp:204
void retainSession(const std::string &clientId)
Definition Broker.cpp:195
void setMessage(const std::string &message)
Definition Message.cpp:56
const std::string & getOriginClientId() const
Definition Message.cpp:40
nlohmann::json toJson() const
Definition Message.cpp:72
const std::string & getTopic() const
Definition Message.cpp:44
void setTopic(const std::string &topic)
Definition Message.cpp:48
const std::string & getMessage() const
Definition Message.cpp:52
Message & operator=(const Message &)=default
Message(const Message &message)=default
Message(const std::string &originClientId, const std::string &topic, const std::string &message, uint8_t qoS, bool originRetain)
Definition Message.cpp:31
Message & fromJson(const nlohmann::json &json)
Definition Message.cpp:83
void retain(const Message &message, std::string topic)
void appear(const std::string &clientId, uint8_t clientQoS)
TopicLevel(iot::mqtt::server::broker::Broker *broker)
TopicLevel & fromJson(const nlohmann::json &json)
void appear(const std::string &clientId, std::string topic, uint8_t qoS)
void appear(const std::string &clientId, const std::string &topic, uint8_t qoS)
void fromJson(const nlohmann::json &json)
RetainTree(iot::mqtt::server::broker::Broker *broker)
void sendPublish(iot::mqtt::server::broker::Message &message, uint8_t qoS, bool retain)
Definition Session.cpp:44
std::deque< Message > messageQueue
Definition Session.h:62
nlohmann::json toJson() const final
Definition Session.cpp:99
Session(iot::mqtt::server::Mqtt *mqtt)
Definition Session.cpp:40
void fromJson(const nlohmann::json &json)
Definition Session.cpp:109
Session * renew(iot::mqtt::server::Mqtt *mqtt)
Definition Session.cpp:81
bool isOwnedBy(const iot::mqtt::server::Mqtt *mqtt) const
Definition Session.cpp:95