AttachmentFetcher.hpp

#ifndef _DITTO_ATTACHMENT_FETCHER_
#define _DITTO_ATTACHMENT_FETCHER_
 
#include "AttachmentFetchEvent.hpp"
#include "AttachmentToken.hpp"
#include "Ditto.hpp"
#include "Observer.hpp"
 
#include <functional>
#include <memory>
 
namespace ditto {
class DittoHandleWrapper;

struct AttachmentFetcherEventHandler {
  std::function<void(std::unique_ptr<AttachmentFetchEvent>)> fn;
};

class AttachmentFetcher
    : public Observer,
      public std::enable_shared_from_this<AttachmentFetcher> {
  friend class Collection;
  friend class Store;
 
public:
  ~AttachmentFetcher(); // required by pimpl.
  AttachmentFetcher(AttachmentFetcher &&);
  AttachmentFetcher &operator=(AttachmentFetcher &&);
 
  struct ArcCtx;
 
private:
  void on_stop() override;
  void ffi_cancel();
  // Non-trivial dtor requires manual swap for assignment operators.
  static void swap(AttachmentFetcher &lhs, AttachmentFetcher &rhs) noexcept;
 
  AttachmentFetcher(
      bool owned_by_store, std::shared_ptr<AttachmentToken> const &token,
      AttachmentFetcherEventHandler &&on_fetch_event,
      std::weak_ptr<Ditto::Fields> const &weak_ditto_fields,
      std::shared_ptr<DittoHandleWrapper> const &ditto_handle_wrapper);
 
  std::unique_ptr<ArcCtx> ctx; // pimpl.
  std::weak_ptr<Ditto::Fields> weak_ditto_fields;
};
 
} // namespace ditto
#endif