blob: 733ca36cf21dad50d37e8078da34011e0178c922 [file] [log] [blame]
Alexander Afanasyevc169a812014-05-20 20:37:29 -04001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
Alexander Afanasyeve289b532014-02-09 22:14:44 -08002/**
Alexander Afanasyev73e30042015-09-17 17:09:51 -07003 * Copyright (c) 2013-2015 Regents of the University of California.
Alexander Afanasyevdfa52c42014-04-24 21:10:11 -07004 *
5 * This file is part of ndn-cxx library (NDN C++ library with eXperimental eXtensions).
Alexander Afanasyevdfa52c42014-04-24 21:10:11 -07006 *
Alexander Afanasyevc169a812014-05-20 20:37:29 -04007 * ndn-cxx library is free software: you can redistribute it and/or modify it under the
8 * terms of the GNU Lesser General Public License as published by the Free Software
9 * Foundation, either version 3 of the License, or (at your option) any later version.
10 *
11 * ndn-cxx library is distributed in the hope that it will be useful, but WITHOUT ANY
12 * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
13 * PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
14 *
15 * You should have received copies of the GNU General Public License and GNU Lesser
16 * General Public License along with ndn-cxx, e.g., in COPYING.md file. If not, see
17 * <http://www.gnu.org/licenses/>.
18 *
19 * See AUTHORS.md for complete list of ndn-cxx authors and contributors.
Alexander Afanasyeve289b532014-02-09 22:14:44 -080020 */
21
Alexander Afanasyeve289b532014-02-09 22:14:44 -080022#include "nfd-controller.hpp"
Alexander Afanasyeve289b532014-02-09 22:14:44 -080023#include "nfd-control-response.hpp"
24
25namespace ndn {
26namespace nfd {
27
Junxiao Shi5de006b2014-10-26 20:20:52 -070028const uint32_t Controller::ERROR_TIMEOUT = 10060;
29const uint32_t Controller::ERROR_SERVER = 500;
30const uint32_t Controller::ERROR_LBOUND = 400;
31
Junxiao Shi70911652014-08-12 10:14:24 -070032Controller::Controller(Face& face, KeyChain& keyChain)
33 : m_face(face)
34 , m_keyChain(keyChain)
35{
36}
37
38void
39Controller::startCommand(const shared_ptr<ControlCommand>& command,
40 const ControlParameters& parameters,
41 const CommandSucceedCallback& onSuccess,
42 const CommandFailCallback& onFailure,
Junxiao Shi5de006b2014-10-26 20:20:52 -070043 const CommandOptions& options)
44{
45 Name requestName = command->getRequestName(options.getPrefix(), parameters);
46 Interest interest(requestName);
47 interest.setInterestLifetime(options.getTimeout());
Junxiao Shic6acc7a2015-06-23 10:03:56 -070048 m_keyChain.sign(interest, options.getSigningInfo());
Junxiao Shi5de006b2014-10-26 20:20:52 -070049
50 m_face.expressInterest(interest,
51 bind(&Controller::processCommandResponse, this, _2,
52 command, onSuccess, onFailure),
53 bind(onFailure, ERROR_TIMEOUT, "request timed out"));
54}
55
56void
Junxiao Shi7b6b79d2014-03-26 20:59:35 -070057Controller::processCommandResponse(const Data& data,
58 const shared_ptr<ControlCommand>& command,
59 const CommandSucceedCallback& onSuccess,
60 const CommandFailCallback& onFailure)
61{
62 /// \todo verify Data signature
63
Junxiao Shi7b6b79d2014-03-26 20:59:35 -070064 ControlResponse response;
65 try {
66 response.wireDecode(data.getContent().blockFromValue());
67 }
Junxiao Shi5de006b2014-10-26 20:20:52 -070068 catch (tlv::Error& e) {
Junxiao Shi7b6b79d2014-03-26 20:59:35 -070069 if (static_cast<bool>(onFailure))
Junxiao Shi5de006b2014-10-26 20:20:52 -070070 onFailure(ERROR_SERVER, e.what());
Junxiao Shi7b6b79d2014-03-26 20:59:35 -070071 return;
72 }
73
74 uint32_t code = response.getCode();
Junxiao Shi5de006b2014-10-26 20:20:52 -070075 if (code >= ERROR_LBOUND) {
Junxiao Shi7b6b79d2014-03-26 20:59:35 -070076 if (static_cast<bool>(onFailure))
77 onFailure(code, response.getText());
78 return;
79 }
80
81 ControlParameters parameters;
82 try {
83 parameters.wireDecode(response.getBody());
84 }
Junxiao Shi5de006b2014-10-26 20:20:52 -070085 catch (tlv::Error& e) {
Junxiao Shi7b6b79d2014-03-26 20:59:35 -070086 if (static_cast<bool>(onFailure))
Junxiao Shi5de006b2014-10-26 20:20:52 -070087 onFailure(ERROR_SERVER, e.what());
Junxiao Shi7b6b79d2014-03-26 20:59:35 -070088 return;
89 }
90
91 try {
92 command->validateResponse(parameters);
93 }
94 catch (ControlCommand::ArgumentError& e) {
95 if (static_cast<bool>(onFailure))
Junxiao Shi5de006b2014-10-26 20:20:52 -070096 onFailure(ERROR_SERVER, e.what());
Junxiao Shi7b6b79d2014-03-26 20:59:35 -070097 return;
98 }
99
Alexander Afanasyevee8bb1e2014-05-02 17:39:54 -0700100 if (static_cast<bool>(onSuccess))
101 onSuccess(parameters);
Junxiao Shi7b6b79d2014-03-26 20:59:35 -0700102}
103
Alexander Afanasyeve289b532014-02-09 22:14:44 -0800104} // namespace nfd
105} // namespace ndn