SubscribeManager.h

/*
  Copyright © CloudBackend AB 2022-2023.
*/
 
#ifndef INCLUDE_CBE_SUBSCRIBE_MANAGER_H_
#define INCLUDE_CBE_SUBSCRIBE_MANAGER_H_
 
#include <vector>
 
#include "cbe/Subscribe.h"
#include "cbe/Types.h"
 
#include "cbe/delegate/SubscribeDelegate.h"
#include "cbe/delegate/GetSubscriptionsDelegate.h"
 
#include "cbe/delegate/Error.h"
#include "cbe/util/ErrorInfo.h"
#include "cbe/util/Exception.h"
#include "cbe/util/Optional.h"
 
namespace CBI {
class SubscribeManager;
} // namespace CBI
 
namespace cbe {
class SubscribeManager {
public:
  using GetSubscriptionsDelegatePtr = delegate::GetSubscriptionsDelegatePtr;
  void getSubscriptions(GetSubscriptionsDelegatePtr subscribeDelegate);
#ifndef CBE_NO_SYNC
  using GetSubscriptionsException = delegate::GetSubscriptionsDelegate::Exception;
  delegate::GetSubscriptionsDelegate::Success getSubscriptions();
 
  using GetSubscriptionsError = delegate::GetSubscriptionsDelegate::ErrorInfo;
  cbe::util::Optional<delegate::GetSubscriptionsDelegate::Success> 
  getSubscriptions(GetSubscriptionsError&           error);
#endif // #ifndef CBE_NO_SYNC
  // - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
 
  using SubscribeDelegatePtr = delegate::SubscribeDelegatePtr;
 
  void subscribe(cbe::UserId          sharingUserId,
                 std::string          sharingUserName,
                 cbe::PublishId       publishId,
                 std::string          publishName,
                 std::string          password,
                 std::string          subscribeName,
                 SubscribeDelegatePtr subscribeDelegate);
#ifndef CBE_NO_SYNC
  using SubscribeException = delegate::SubscribeDelegate::Exception;
  delegate::SubscribeDelegate::Success subscribe(cbe::UserId    sharingUserId,
                                                 std::string    sharingUserName,
                                                 cbe::PublishId publishId,
                                                 std::string    publishName,
                                                 std::string    password,
                                                 std::string    subscribeName);
 
  using SubscribeError = delegate::SubscribeDelegate::ErrorInfo;
  cbe::util::Optional<delegate::SubscribeDelegate::Success> subscribe(
                                              cbe::UserId     sharingUserId,
                                              std::string     sharingUserName,
                                              cbe::PublishId  publishId,
                                              std::string     publishName,
                                              std::string     password,
                                              std::string     subscribeName,
                                              SubscribeError& error);
#endif // #ifndef CBE_NO_SYNC
  // - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
 
 
  void subscribe(std::string          sharingUserName,
                 std::string          publishName,
                 SubscribeDelegatePtr subscribeDelegate) {
    subscribe(0, sharingUserName, 0, publishName, "", publishName,
              subscribeDelegate);
  }
 
  void subscribe(cbe::UserId          sharingUserId,
                 cbe::PublishId       publishId,
                 std::string          subscribeName,
                 SubscribeDelegatePtr subscribeDelegate) {
    subscribe(sharingUserId, "", publishId, "", "", subscribeName,
              subscribeDelegate);
  }
 
  SubscribeManager(cbe::DefaultCtor);
  ~SubscribeManager();
 
  explicit operator bool() const;
private:
  struct Impl;
  std::shared_ptr<Impl> pImpl{};
 
  friend class CloudBackend;
  SubscribeManager(CBI::SubscribeManager& cbiPeer);
  CBI::SubscribeManager& getCbiPeer() const;
}; // class SubscribeManager
 
} // namespace cbe
 
#endif  // INCLUDE_CBE_SUBSCRIBE_MANAGER_H_