base.cpp

Go to the documentation of this file.

/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
#include "base.hpp"

namespace ndn {
namespace tools {
namespace autoconfig {

Base::Base(Face& face, KeyChain& keyChain, const NextStageCallback& nextStageOnFailure)
  : m_face(face)
  , m_keyChain(keyChain)
  , m_controller(face, keyChain)
  , m_nextStageOnFailure(nextStageOnFailure)
{
}

void
Base::connectToHub(const std::string& uri)
{
  FaceUri faceUri(uri);
  std::cerr << "About to connect to: " << uri << std::endl;

  faceUri.canonize(bind(&Base::onCanonizeSuccess, this, _1),
                   bind(&Base::onCanonizeFailure, this, _1),
                   m_face.getIoService(), time::seconds(4));

}


void
Base::onCanonizeSuccess(const FaceUri& canonicalUri)
{
  m_controller.start<ndn::nfd::FaceCreateCommand>(
    ControlParameters().setUri(canonicalUri.toString()),
    bind(&Base::onHubConnectSuccess, this, _1),
    bind(&Base::onHubConnectError, this, _1));
}

void
Base::onCanonizeFailure(const std::string& reason)
{
  BOOST_THROW_EXCEPTION(Error("FaceUri canonization failed: " + reason));
}

void
Base::onHubConnectSuccess(const ControlParameters& resp)
{
  std::cerr << "Successfully created face: " << resp << std::endl;

  static const Name TESTBED_PREFIX = "/ndn";
  registerPrefix(TESTBED_PREFIX, resp.getFaceId());

  static const Name LOCALHOP_NFD_PREFIX = "/localhop/nfd";
  registerPrefix(LOCALHOP_NFD_PREFIX, resp.getFaceId());
}

void
Base::onHubConnectError(const ControlResponse& response)
{
  std::ostringstream os;
  os << "Failed to create face: " << response.getText() << " (code: " << response.getCode() << ")";
  BOOST_THROW_EXCEPTION(Error(os.str()));
}

void
Base::registerPrefix(const Name& prefix, uint64_t faceId)
{
  // Register a prefix in RIB
  m_controller.start<ndn::nfd::RibRegisterCommand>(
    ControlParameters()
      .setName(prefix)
      .setFaceId(faceId)
      .setOrigin(ndn::nfd::ROUTE_ORIGIN_AUTOCONF)
      .setCost(100)
      .setExpirationPeriod(time::milliseconds::max()),
    bind(&Base::onPrefixRegistrationSuccess, this, _1),
    bind(&Base::onPrefixRegistrationError, this, _1));
}

void
Base::onPrefixRegistrationSuccess(const ControlParameters& commandSuccessResult)
{
  std::cerr << "Successful in name registration: " << commandSuccessResult << std::endl;
}

void
Base::onPrefixRegistrationError(const ControlResponse& response)
{
  BOOST_THROW_EXCEPTION(Error("Failed in name registration, " + response.getText() +
                              " (code: " + to_string(response.getCode()) + ")"));
}


} // namespace autoconfig
} // namespace tools
} // namespace ndn