src/management/nfd-controller.cpp

/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil -*- */
/**
 * Copyright (C) 2013 Regents of the University of California.
 * See COPYING for copyright and distribution information.
 */

#include "common.hpp"
#include "../face.hpp"

#include "nfd-controller.hpp"
#include "nfd-fib-management-options.hpp"
#include "nfd-face-management-options.hpp"
#include "nfd-strategy-choice-options.hpp"
#include "nfd-control-response.hpp"

namespace ndn {
namespace nfd {

Controller::Controller(Face& face)
  : m_face(face)
{
}

void
Controller::selfRegisterPrefix(const Name& prefixToRegister,
                               const SuccessCallback& onSuccess,
                               const FailCallback&    onFail)
{
  fibAddNextHop(prefixToRegister, 0, 0, bind(onSuccess), onFail);
}

void
Controller::selfDeregisterPrefix(const Name& prefixToDeRegister,
                                 const SuccessCallback& onSuccess,
                                 const FailCallback&    onFail)
{
  fibRemoveNextHop(prefixToDeRegister, 0, bind(onSuccess), onFail);
}

void
Controller::fibAddNextHop(const Name& prefix, uint64_t faceId, int cost,
                          const FibCommandSucceedCallback& onSuccess,
                          const FailCallback& onFail)
{
  startFibCommand("add-nexthop",
                  FibManagementOptions()
                    .setName(prefix)
                    .setFaceId(faceId)
                    .setCost(cost),
                  onSuccess, onFail);
}

void
Controller::fibRemoveNextHop(const Name& prefix, uint64_t faceId,
                             const FibCommandSucceedCallback& onSuccess,
                             const FailCallback& onFail)
{
  startFibCommand("remove-nexthop",
                  FibManagementOptions()
                    .setName(prefix)
                    .setFaceId(faceId),
                  onSuccess, onFail);
}

void
Controller::startFibCommand(const std::string& command,
                            const FibManagementOptions& options,
                            const FibCommandSucceedCallback& onSuccess,
                            const FailCallback& onFail)
{
  Name fibCommandInterestName("/localhost/nfd/fib");
  fibCommandInterestName
    .append(command)
    .append(options.wireEncode());

  Interest fibCommandInterest(fibCommandInterestName);
  m_commandInterestGenerator.generate(fibCommandInterest);

  m_face.expressInterest(fibCommandInterest,
                         bind(&Controller::processFibCommandResponse, this, _2,
                              onSuccess, onFail),
                         bind(onFail, "Command Interest timed out"));
}

void
Controller::processFibCommandResponse(Data& data,
                                      const FibCommandSucceedCallback& onSuccess,
                                      const FailCallback& onFail)
{
  /// \todo Add validation of incoming Data

  try
    {
      ControlResponse response(data.getContent().blockFromValue());
      if (response.getCode() != 200)
        return onFail(response.getText());

      FibManagementOptions options(response.getBody());
      return onSuccess(options);
    }
  catch(ndn::Tlv::Error& e)
    {
      if (static_cast<bool>(onFail))
        return onFail(e.what());
    }
}

void
Controller::startFaceCommand(const std::string& command,
                             const FaceManagementOptions& options,
                             const FaceCommandSucceedCallback& onSuccess,
                             const FailCallback& onFail)
{
  Name faceCommandInterestName("/localhost/nfd/faces");
  faceCommandInterestName
    .append(command)
    .append(options.wireEncode());

  Interest faceCommandInterest(faceCommandInterestName);
  m_commandInterestGenerator.generate(faceCommandInterest);

  m_face.expressInterest(faceCommandInterest,
                         bind(&Controller::processFaceCommandResponse, this, _2,
                              onSuccess, onFail),
                         bind(onFail, "Command Interest timed out"));
}
  
void
Controller::processFaceCommandResponse(Data& data,
                                       const FaceCommandSucceedCallback& onSuccess,
                                       const FailCallback& onFail)
{
  /// \todo Add validation of incoming Data
  
  try
  {
    ControlResponse response(data.getContent().blockFromValue());
    if (response.getCode() != 200)
      return onFail(response.getText());
    
    FaceManagementOptions options(response.getBody());
    return onSuccess(options);
  }
  catch(ndn::Tlv::Error& e)
  {
    if (static_cast<bool>(onFail))
      return onFail(e.what());
  }
}

void
Controller::startStrategyChoiceCommand(const std::string& command,
                                       const StrategyChoiceOptions& options,
                                       const StrategyChoiceCommandSucceedCallback& onSuccess,
                                       const FailCallback& onFail)
{
  Name strategyChoiceCommandInterestName("/localhost/nfd/strategy-choice");
  strategyChoiceCommandInterestName
    .append(command)
    .append(options.wireEncode());
  
  Interest strategyChoiceCommandInterest(strategyChoiceCommandInterestName);
  m_commandInterestGenerator.generate(strategyChoiceCommandInterest);
  
  m_face.expressInterest(strategyChoiceCommandInterest,
                         bind(&Controller::processStrategyChoiceCommandResponse, this, _2,
                              onSuccess, onFail),
                         bind(onFail, "Command Interest timed out"));
}
void
Controller::processStrategyChoiceCommandResponse(
    Data& data,
    const StrategyChoiceCommandSucceedCallback& onSuccess,
    const FailCallback& onFail)
{
  /// \todo Add validation of incoming Data
  
  try
  {
    ControlResponse response(data.getContent().blockFromValue());
    if (response.getCode() != 200)
      return onFail(response.getText());
    
    StrategyChoiceOptions options(response.getBody());
    return onSuccess(options);
  }
  catch (ndn::Tlv::Error& error)
  {
    if (static_cast<bool>(onFail))
      return onFail(error.what());
  }
}

  
} // namespace nfd
} // namespace ndn