MessageQueueDtos.h

Go to the documentation of this file.

#ifndef MESSAGEQUEUEDTOS_H
#define MESSAGEQUEUEDTOS_H
#include <lintel/core/models/JsonSerializable.h>
#include <optional>
#include <vector>
 
#include "MessageQueueDto.h"
#include "lintel/features/base/models/Page.h"
 
namespace lintel {
class MessageQueueDtos : public JsonSerializable
{
private:
  std::vector<MessageQueueDto> m_messageQueueDtos;
 
public:
  MessageQueueDtos() = default;
 
  static std::vector<MessageQueueDto> build(const std::vector<std::pair<MessageQueueEntry, int32_t>> &pairs);
 
  MessageQueueDtos(const std::vector<std::pair<MessageQueueEntry, int32_t>> &messageQueueDtos);
 
  [[nodiscard]] const std::vector<MessageQueueDto> &getMessageQueueDtos() const;
 
  void serialize(rapidjson::Writer<rapidjson::StringBuffer> *writer) const override;
 
  void deserialize(const std::string &json) override;
};
 
class MessageQueuesPageDto : public JsonSerializable
{
private:
  std::vector<MessageQueueDto> m_messageQueueDtos;
  bool m_hasMore = false;
  std::optional<std::string> m_nextAfter;
 
  static struct Shapes
  {
    const char *const ITEMS = "items";
    const char *const HAS_MORE = "has_more";
    const char *const NEXT_AFTER = "next_after";
  } shape;
 
public:
  explicit MessageQueuesPageDto(const Page<MessageQueueEntry> &page);
 
  MessageQueuesPageDto() = default;
 
  void serialize(rapidjson::Writer<rapidjson::StringBuffer> *writer) const override;
 
  void deserialize(const std::string &json) override;
 
  [[nodiscard]] const std::vector<MessageQueueDto> &getMessageQueueDtos() const;
 
  [[nodiscard]] bool hasMore() const;
 
  [[nodiscard]] const std::optional<std::string> &getNextAfter() const;
};
 
}// namespace lintel
#endif// MESSAGEQUEUEDTOS_H