generalized-content.hpp

/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil -*- */
#ifndef NDN_GENERALIZED_CONTENT_HPP
#define NDN_GENERALIZED_CONTENT_HPP

#include <ndn-cpp/face.hpp>
#include <ndn-cpp/util/segment-fetcher.hpp>
#include <ndn-cpp/util/memory-content-cache.hpp>
#include "content-meta-info.hpp"

namespace ndntools {

class GeneralizedContent : public ndn::ptr_lib::enable_shared_from_this<GeneralizedContent> {
public:
  enum ErrorCode {
    // Repeat the error codes from SegmentFetcher.
    INTEREST_TIMEOUT = 1,
    DATA_HAS_NO_SEGMENT = 2,
    SEGMENT_VERIFICATION_FAILED = 3,

    META_INFO_DECODING_FAILED = 4
  };

  typedef ndn::func_lib::function<void
    (const ndn::ptr_lib::shared_ptr<ContentMetaInfo>& metaInfo,
     const ndn::Blob& content)> OnComplete;

  typedef ndn::func_lib::function<void
    (ErrorCode errorCode, const std::string& message)> OnError;

  static void
  publish
    (ndn::MemoryContentCache& contentCache, const ndn::Name& prefix,
     ndn::Milliseconds freshnessPeriod, ndn::KeyChain* signingKeyChain,
     const ndn::Name& signingCertificateName, const ContentMetaInfo& metaInfo,
     const ndn::Blob& content, size_t contentSegmentSize);

  static void
  fetch
    (ndn::Face& face, const ndn::Name& prefix, ndn::KeyChain* validatorKeyChain,
     const OnComplete& onComplete, const OnError& onError,
     ndn::Milliseconds interestLifetimeMilliseconds = 4000.0);

private:
  GeneralizedContent
    (ndn::Face& face, const ndn::Name& prefix, ndn::KeyChain* validatorKeyChain,
     const OnComplete& onComplete, const OnError& onError,
     ndn::Milliseconds interestLifetimeMilliseconds)
  : face_(face), prefix_(prefix), validatorKeyChain_(validatorKeyChain),
    onComplete_(onComplete), onError_(onError),
    interestLifetimeMilliseconds_(interestLifetimeMilliseconds)
  {
  }

  void
  fetchMetaInfo();

  void
  onMetaInfoReceived
    (const ndn::ptr_lib::shared_ptr<const ndn::Interest>& originalInterest,
     const ndn::ptr_lib::shared_ptr<ndn::Data>& data);

  void
  onMetaInfoTimeout(const ndn::ptr_lib::shared_ptr<const ndn::Interest>& interest);

  void
  onContentReceived(const ndn::Blob& content);

  void
  onSegmentFetcherError
    (ndn::SegmentFetcher::ErrorCode errorCode, const std::string& message);

  ndn::Face& face_;
  ndn::Name prefix_;
  ndn::KeyChain* validatorKeyChain_;
  OnComplete onComplete_;
  OnError onError_;
  ndn::Milliseconds interestLifetimeMilliseconds_;
  ndn::ptr_lib::shared_ptr<ContentMetaInfo> metaInfo_;
};

}

#endif