open_source / mqtt-cpp

  /****************************************************************************
   * COpyright (c) 2023 Open Systems Development B.V.
   ****************************************************************************/
  
  #include <gmock/gmock.h>
  #include <gtest/gtest.h>
  #include <string>
  #include <memory>
  
  #include "mqttclient.h"
  
  using namespace osdev::components::mqtt;
  using namespace osdev::components::log;
  
  /****************************************************************************
   *                      H E L P E R   C L A S S E S
   ****************************************************************************/

  class Publisher

  {

  public:
      Publisher() : m_mqtt_client("TopicTester"){}
      virtual ~Publisher() {}
  
      void    connect(const std::string &hostname,
                   int portnumber = 1883,
                   const std::string &username = std::string(),
                   const std::string &password = std::string(),
                   const std::string &lwt_topic = std::string(),
                   const std::string &lwt_message = std::string()
                   )
      {
          m_mqtt_client.connect(hostname, portnumber,
                                osdev::components::mqtt::Credentials(username, password),
                                osdev::components::mqtt::mqtt_LWT(lwt_topic, lwt_message),
                                true,
                                osdev::components::log::LogSettings
                                {
                                    osdev::components::log::LogLevel::Debug,
                                    osdev::components::log::LogMask::None
                                });
      }

      void    publish(const std::string &message_topic, const std::string &message_payload)
      {
          osdev::components::mqtt::MqttMessage message(message_topic, true, false, message_payload);
          osdev::components::mqtt::Token t_result = m_mqtt_client.publish(message, 0);
      }

  private:
      osdev::components::mqtt::MqttClient     m_mqtt_client;

  };
  

  /// @brief  class to generate a cumulative topic..
  class TopicTester

  {
      public:

          TopicTester(std::shared_ptr<Publisher> publisher) : m_publisher(publisher){}
          virtual ~TopicTester(){}

          void    RunTopicTester(int max_number_of_chars)
          {
              for(int nCount = 1; nCount < max_number_of_chars; nCount++)
              {
                  std::string subtopic(nCount, 'a');
                  std::string topic = std::string("topics/" + subtopic);
                  std::string message(std::to_string(topic.size()));

                  m_publisher->publish(topic, message);
              }
          }

  
      private:

          std::shared_ptr<Publisher>  m_publisher;

  };

  
  /*****************************************************************************
   *                      T H E   A C T U A L   T E S T S
   *****************************************************************************/
  /// TopicTester
  TEST(topictest, TopicLengthTest)
  {
      std::shared_ptr<Publisher> pPublisher = std::make_shared<Publisher>();
      pPublisher->connect("127.0.0.1", 1883);
  
      TopicTester oTester(pPublisher);
  
      oTester.RunTopicTester(101);
  }