blob: 67f58cc254e76d0e90b5fab62526e660b62273b4 [file] [log] [blame]
Laqin Fan54a43f02017-03-08 12:31:30 -06001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
Davide Pesaventoc1d0e8e2022-06-15 14:26:02 -04002/*
Davide Pesaventod2610dc2025-01-03 13:20:06 -05003 * Copyright (c) 2014-2025, The University of Memphis,
Laqin Fan54a43f02017-03-08 12:31:30 -06004 * Regents of the University of California,
5 * Arizona Board of Regents.
6 *
7 * This file is part of NLSR (Named-data Link State Routing).
8 * See AUTHORS.md for complete list of NLSR authors and contributors.
9 *
10 * NLSR is free software: you can redistribute it and/or modify it under the terms
11 * of the GNU General Public License as published by the Free Software Foundation,
12 * either version 3 of the License, or (at your option) any later version.
13 *
14 * NLSR is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
15 * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
16 * PURPOSE. See the GNU General Public License for more details.
17 *
18 * You should have received a copy of the GNU General Public License along with
19 * NLSR, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
Davide Pesaventoc1d0e8e2022-06-15 14:26:02 -040020 */
Laqin Fan54a43f02017-03-08 12:31:30 -060021
Davide Pesavento20e60a22025-01-07 01:50:10 -050022#include "command-processor.hpp"
Davide Pesaventoc1d0e8e2022-06-15 14:26:02 -040023#include "logger.hpp"
Laqin Fan54a43f02017-03-08 12:31:30 -060024
Davide Pesavento20e60a22025-01-07 01:50:10 -050025#include <ndn-cxx/mgmt/nfd/control-response.hpp>
Laqin Fan54a43f02017-03-08 12:31:30 -060026
Davide Pesavento20e60a22025-01-07 01:50:10 -050027namespace nlsr::update {
Laqin Fan54a43f02017-03-08 12:31:30 -060028
Davide Pesavento20e60a22025-01-07 01:50:10 -050029INIT_LOGGER(update.CommandProcessor);
30
31CommandProcessor::CommandProcessor(ndn::mgmt::Dispatcher& dispatcher,
32 NamePrefixList& namePrefixList,
33 Lsdb& lsdb)
Laqin Fan54a43f02017-03-08 12:31:30 -060034 : m_dispatcher(dispatcher)
Laqin Fan54a43f02017-03-08 12:31:30 -060035 , m_namePrefixList(namePrefixList)
36 , m_lsdb(lsdb)
37{
38}
39
Davide Pesavento20e60a22025-01-07 01:50:10 -050040CommandProcessor::~CommandProcessor() = default;
41
Laqin Fan54a43f02017-03-08 12:31:30 -060042void
Davide Pesavento20e60a22025-01-07 01:50:10 -050043CommandProcessor::advertiseAndInsertPrefix(const ndn::mgmt::ControlParametersBase& parameters,
44 const ndn::mgmt::CommandContinuation& done)
Muktadir Chowdhuryf04f9892017-08-20 20:42:56 -050045{
Davide Pesaventod2610dc2025-01-03 13:20:06 -050046 const auto& castParams = static_cast<const ndn::nfd::ControlParameters&>(parameters);
awlane697a0ad2025-04-21 13:09:17 -050047 // This is a bit of a hack, waiting on the work in #5348 to complete for full refactoring
48 ndn::nfd::ControlParameters responseParams(castParams.wireEncode());
49 uint64_t responseFaceId = (castParams.hasFaceId() && castParams.getFaceId() > 0)
50 ? responseParams.getFaceId() : m_defaultResponseFaceId;
51 responseParams.setFaceId(responseFaceId);
Laqin Fan54a43f02017-03-08 12:31:30 -060052 // Only build a Name LSA if the added name is new
53 if (m_namePrefixList.insert(castParams.getName())) {
Davide Pesavento968eb1a2025-01-07 00:46:05 -050054 NLSR_LOG_INFO("Advertising name: " << castParams.getName());
Laqin Fan54a43f02017-03-08 12:31:30 -060055 m_lsdb.buildAndInstallOwnNameLsa();
Saurab Dulal7526cee2018-01-31 18:14:10 +000056 if (castParams.hasFlags() && castParams.getFlags() == PREFIX_FLAG) {
Ashlesh Gawande85998a12017-12-07 22:22:13 -060057 NLSR_LOG_INFO("Saving name to the configuration file ");
awlane697a0ad2025-04-21 13:09:17 -050058 auto [afterAdvertiseReturn, afterAdvertiseMessage] = afterAdvertise(castParams.getName());
59 if (afterAdvertiseReturn) {
60 return done(ndn::nfd::ControlResponse(205, afterAdvertiseMessage).setBody(responseParams.wireEncode()));
Saurab Dulal7526cee2018-01-31 18:14:10 +000061 }
62 else {
awlane697a0ad2025-04-21 13:09:17 -050063 return done(ndn::nfd::ControlResponse(500, afterAdvertiseMessage)
64 .setBody(responseParams.wireEncode()));
Saurab Dulal7526cee2018-01-31 18:14:10 +000065 }
66 }
awlane697a0ad2025-04-21 13:09:17 -050067 return done(ndn::nfd::ControlResponse(200, "OK").setBody(responseParams.wireEncode()));
Laqin Fan54a43f02017-03-08 12:31:30 -060068 }
Saurab Dulal7526cee2018-01-31 18:14:10 +000069 else {
70 if (castParams.hasFlags() && castParams.getFlags() == PREFIX_FLAG) {
71 // Save an already advertised prefix
Davide Pesavento968eb1a2025-01-07 00:46:05 -050072 NLSR_LOG_INFO("Saving an already advertised name: " << castParams.getName());
awlane697a0ad2025-04-21 13:09:17 -050073 auto [afterAdvertiseReturn, afterAdvertiseMessage] = afterAdvertise(castParams.getName());
74 if (afterAdvertiseReturn) {
75 return done(ndn::nfd::ControlResponse(205, afterAdvertiseMessage).setBody(responseParams.wireEncode()));
Saurab Dulal7526cee2018-01-31 18:14:10 +000076 }
77 else {
awlane697a0ad2025-04-21 13:09:17 -050078 return done(ndn::nfd::ControlResponse(500, afterAdvertiseMessage)
79 .setBody(responseParams.wireEncode()));
Saurab Dulal7526cee2018-01-31 18:14:10 +000080 }
81 }
82 return done(ndn::nfd::ControlResponse(204, "Prefix is already advertised/inserted.")
awlane697a0ad2025-04-21 13:09:17 -050083 .setBody(responseParams.wireEncode()));
Saurab Dulal7526cee2018-01-31 18:14:10 +000084 }
Laqin Fan54a43f02017-03-08 12:31:30 -060085}
86
87void
Davide Pesavento20e60a22025-01-07 01:50:10 -050088CommandProcessor::withdrawAndRemovePrefix(const ndn::mgmt::ControlParametersBase& parameters,
89 const ndn::mgmt::CommandContinuation& done)
Laqin Fan54a43f02017-03-08 12:31:30 -060090{
Davide Pesaventod2610dc2025-01-03 13:20:06 -050091 const auto& castParams = static_cast<const ndn::nfd::ControlParameters&>(parameters);
awlane697a0ad2025-04-21 13:09:17 -050092 // This is a bit of a hack, waiting on the work in #5348 to complete for full refactoring
93 ndn::nfd::ControlParameters responseParams(castParams.wireEncode());
94 uint64_t responseFaceId = (castParams.hasFaceId() && castParams.getFaceId() > 0)
95 ? responseParams.getFaceId() : m_defaultResponseFaceId;
96 responseParams.setFaceId(responseFaceId);
Laqin Fan54a43f02017-03-08 12:31:30 -060097 // Only build a Name LSA if the added name is new
Junxiao Shi52f16642023-08-15 00:18:35 +000098 if (m_namePrefixList.erase(castParams.getName())) {
Davide Pesavento968eb1a2025-01-07 00:46:05 -050099 NLSR_LOG_INFO("Withdrawing/Removing name: " << castParams.getName());
Laqin Fan54a43f02017-03-08 12:31:30 -0600100 m_lsdb.buildAndInstallOwnNameLsa();
Saurab Dulal7526cee2018-01-31 18:14:10 +0000101 if (castParams.hasFlags() && castParams.getFlags() == PREFIX_FLAG) {
awlane697a0ad2025-04-21 13:09:17 -0500102 auto [afterWithdrawReturn, afterWithdrawMessage] = afterWithdraw(castParams.getName());
103 if (afterWithdrawReturn) {
104 return done(ndn::nfd::ControlResponse(205, afterWithdrawMessage).setBody(responseParams.wireEncode()));
Saurab Dulal7526cee2018-01-31 18:14:10 +0000105 }
106 else {
awlane697a0ad2025-04-21 13:09:17 -0500107 return done(ndn::nfd::ControlResponse(500, afterWithdrawMessage)
108 .setBody(responseParams.wireEncode()));
Saurab Dulal7526cee2018-01-31 18:14:10 +0000109 }
110 }
awlane697a0ad2025-04-21 13:09:17 -0500111 return done(ndn::nfd::ControlResponse(200, "OK").setBody(responseParams.wireEncode()));
Laqin Fan54a43f02017-03-08 12:31:30 -0600112 }
Saurab Dulal7526cee2018-01-31 18:14:10 +0000113 else {
114 if (castParams.hasFlags() && castParams.getFlags() == PREFIX_FLAG) {
115 // Delete an already withdrawn prefix
Davide Pesavento968eb1a2025-01-07 00:46:05 -0500116 NLSR_LOG_INFO("Deleting an already withdrawn name: " << castParams.getName());
awlane697a0ad2025-04-21 13:09:17 -0500117 auto [afterWithdrawReturn, afterWithdrawMessage] = afterWithdraw(castParams.getName());
118 if (afterWithdrawReturn) {
119 return done(ndn::nfd::ControlResponse(205, afterWithdrawMessage).setBody(responseParams.wireEncode()));
Saurab Dulal7526cee2018-01-31 18:14:10 +0000120 }
121 else {
awlane697a0ad2025-04-21 13:09:17 -0500122 return done(ndn::nfd::ControlResponse(500, afterWithdrawMessage)
123 .setBody(responseParams.wireEncode()));
Saurab Dulal7526cee2018-01-31 18:14:10 +0000124 }
125 }
126 return done(ndn::nfd::ControlResponse(204, "Prefix is already withdrawn/removed.")
awlane697a0ad2025-04-21 13:09:17 -0500127 .setBody(responseParams.wireEncode()));
Saurab Dulal7526cee2018-01-31 18:14:10 +0000128 }
Laqin Fan54a43f02017-03-08 12:31:30 -0600129}
130
Davide Pesavento20e60a22025-01-07 01:50:10 -0500131} // namespace nlsr::update