tests/tools/nfdc/face-module.t.cpp - NFD - Gitiles

 /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
 /**
  * Copyright (c) 2014-2017,  Regents of the University of California,
  *                           Arizona Board of Regents,
  *                           Colorado State University,
  *                           University Pierre & Marie Curie, Sorbonne University,
  *                           Washington University in St. Louis,
  *                           Beijing Institute of Technology,
  *                           The University of Memphis.
  *
  * This file is part of NFD (Named Data Networking Forwarding Daemon).
  * See AUTHORS.md for complete list of NFD authors and contributors.
  *
  * NFD is free software: you can redistribute it and/or modify it under the terms
  * of the GNU General Public License as published by the Free Software Foundation,
  * either version 3 of the License, or (at your option) any later version.
  *
  * NFD is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
  * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
  * PURPOSE.  See the GNU General Public License for more details.
  *
  * You should have received a copy of the GNU General Public License along with
  * NFD, e.g., in COPYING.md file.  If not, see <http://www.gnu.org/licenses/>.
  */

 #include "nfdc/face-module.hpp"
 #include <ndn-cxx/mgmt/nfd/face-query-filter.hpp>

 #include "execute-command-fixture.hpp"
 #include "status-fixture.hpp"

 namespace nfd {
 namespace tools {
 namespace nfdc {
 namespace tests {

 using ndn::nfd::FaceQueryFilter;

 BOOST_AUTO_TEST_SUITE(Nfdc)
 BOOST_AUTO_TEST_SUITE(TestFaceModule)

 BOOST_FIXTURE_TEST_SUITE(ShowCommand, ExecuteCommandFixture)

 const std::string NORMAL_OUTPUT = std::string(R"TEXT(
   faceid=256
   remote=udp4://84.67.35.111:6363
    local=udp4://79.91.49.215:6363
 counters={in={28975i 28232d 212n 13307258B} out={19525i 30993d 1038n 6231946B}}
    flags={non-local on-demand point-to-point}
 )TEXT").substr(1);

 BOOST_AUTO_TEST_CASE(Normal)
 {
   this->processInterest = [this] (const Interest& interest) {
     Name datasetName("/localhost/nfd/faces/query");
     FaceQueryFilter filter;
     filter.setFaceId(256);
     datasetName.append(filter.wireEncode());

     FaceStatus payload;
     payload.setFaceId(256)
            .setRemoteUri("udp4://84.67.35.111:6363")
            .setLocalUri("udp4://79.91.49.215:6363")
            .setFaceScope(ndn::nfd::FACE_SCOPE_NON_LOCAL)
            .setFacePersistency(ndn::nfd::FACE_PERSISTENCY_ON_DEMAND)
            .setLinkType(ndn::nfd::LINK_TYPE_POINT_TO_POINT)
            .setNInInterests(28975)
            .setNInDatas(28232)
            .setNInNacks(212)
            .setNOutInterests(19525)
            .setNOutDatas(30993)
            .setNOutNacks(1038)
            .setNInBytes(13307258)
            .setNOutBytes(6231946);

     this->sendDataset(datasetName, payload);
   };

   this->execute("face show 256");
   BOOST_CHECK_EQUAL(exitCode, 0);
   BOOST_CHECK(out.is_equal(NORMAL_OUTPUT));
   BOOST_CHECK(err.is_empty());
 }

 BOOST_AUTO_TEST_CASE(NotFound)
 {
   this->processInterest = [this] (const Interest& interest) {
     this->sendEmptyDataset(interest.getName());
   };

   this->execute("face show 256");
   BOOST_CHECK_EQUAL(exitCode, 3);
   BOOST_CHECK(out.is_empty());
   BOOST_CHECK(err.is_equal("Face 256 not found.\n"));
 }

 BOOST_AUTO_TEST_CASE(Error)
 {
   this->processInterest = nullptr; // no response

   this->execute("face show 256");
   BOOST_CHECK_EQUAL(exitCode, 1);
   BOOST_CHECK(out.is_empty());
   BOOST_CHECK(err.is_equal("Error 10060 when fetching face information: Timeout\n"));
 }

 BOOST_AUTO_TEST_SUITE_END() // ShowCommand

 BOOST_FIXTURE_TEST_SUITE(CreateCommand, ExecuteCommandFixture)

 BOOST_AUTO_TEST_CASE(Normal)
 {
   this->processInterest = [this] (const Interest& interest) {
     ControlParameters req = MOCK_NFD_MGMT_REQUIRE_LAST_COMMAND_IS("/localhost/nfd/faces/create");
     BOOST_REQUIRE(req.hasUri());
     BOOST_CHECK_EQUAL(req.getUri(), "udp4://159.242.33.78:6363");
     BOOST_REQUIRE(req.hasFacePersistency());
     BOOST_CHECK_EQUAL(req.getFacePersistency(), FacePersistency::FACE_PERSISTENCY_PERSISTENT);

     ControlParameters resp;
     resp.setFaceId(2130)
         .setUri("udp4://159.242.33.78:6363")
         .setFacePersistency(FacePersistency::FACE_PERSISTENCY_PERSISTENT);
     this->succeedCommand(resp);
   };

   this->execute("face create udp://159.242.33.78");
   BOOST_CHECK_EQUAL(exitCode, 0);
   BOOST_CHECK(out.is_equal("face-created id=2130 remote=udp4://159.242.33.78:6363 persistency=persistent\n"));
   BOOST_CHECK(err.is_empty());
 }

 BOOST_AUTO_TEST_CASE(Error)
 {
   this->processInterest = nullptr; // no response

   this->execute("face create udp://159.242.33.78");
   BOOST_CHECK_EQUAL(exitCode, 1);
   BOOST_CHECK(out.is_empty());
   BOOST_CHECK(err.is_equal("Error 10060 when creating face: request timed out\n"));
 }

 BOOST_AUTO_TEST_SUITE_END() // CreateCommand

 const std::string STATUS_XML = stripXmlSpaces(R"XML(
   <faces>
     <face>
       <faceId>134</faceId>
       <remoteUri>udp4://233.252.0.4:6363</remoteUri>
       <localUri>udp4://192.0.2.1:6363</localUri>
       <faceScope>non-local</faceScope>
       <facePersistency>permanent</facePersistency>
       <linkType>multi-access</linkType>
       <flags/>
       <packetCounters>
         <incomingPackets>
           <nInterests>22562</nInterests>
           <nDatas>22031</nDatas>
           <nNacks>63</nNacks>
         </incomingPackets>
         <outgoingPackets>
           <nInterests>30121</nInterests>
           <nDatas>20940</nDatas>
           <nNacks>1218</nNacks>
         </outgoingPackets>
       </packetCounters>
       <byteCounters>
         <incomingBytes>2522915</incomingBytes>
         <outgoingBytes>1353592</outgoingBytes>
       </byteCounters>
     </face>
     <face>
       <faceId>745</faceId>
       <remoteUri>fd://75</remoteUri>
       <localUri>unix:///var/run/nfd.sock</localUri>
       <faceScope>local</faceScope>
       <facePersistency>on-demand</facePersistency>
       <linkType>point-to-point</linkType>
       <flags>
         <localFieldsEnabled/>
       </flags>
       <packetCounters>
         <incomingPackets>
           <nInterests>18998</nInterests>
           <nDatas>26701</nDatas>
           <nNacks>147</nNacks>
         </incomingPackets>
         <outgoingPackets>
           <nInterests>34779</nInterests>
           <nDatas>17028</nDatas>
           <nNacks>1176</nNacks>
         </outgoingPackets>
       </packetCounters>
       <byteCounters>
         <incomingBytes>4672308</incomingBytes>
         <outgoingBytes>8957187</outgoingBytes>
       </byteCounters>
     </face>
   </faces>
 )XML");

 const std::string STATUS_TEXT =
   "Faces:\n"
   "  faceid=134 remote=udp4://233.252.0.4:6363 local=udp4://192.0.2.1:6363"
     " counters={in={22562i 22031d 63n 2522915B} out={30121i 20940d 1218n 1353592B}}"
     " flags={non-local permanent multi-access}\n"
   "  faceid=745 remote=fd://75 local=unix:///var/run/nfd.sock"
     " counters={in={18998i 26701d 147n 4672308B} out={34779i 17028d 1176n 8957187B}}"
     " flags={local on-demand point-to-point local-fields}\n";

 BOOST_FIXTURE_TEST_CASE(Status, StatusFixture<FaceModule>)
 {
   this->fetchStatus();
   FaceStatus payload1;
   payload1.setFaceId(134)
           .setRemoteUri("udp4://233.252.0.4:6363")
           .setLocalUri("udp4://192.0.2.1:6363")
           .setFaceScope(ndn::nfd::FACE_SCOPE_NON_LOCAL)
           .setFacePersistency(ndn::nfd::FACE_PERSISTENCY_PERMANENT)
           .setLinkType(ndn::nfd::LINK_TYPE_MULTI_ACCESS)
           .setNInInterests(22562)
           .setNInDatas(22031)
           .setNInNacks(63)
           .setNOutInterests(30121)
           .setNOutDatas(20940)
           .setNOutNacks(1218)
           .setNInBytes(2522915)
           .setNOutBytes(1353592);
   FaceStatus payload2;
   payload2.setFaceId(745)
           .setRemoteUri("fd://75")
           .setLocalUri("unix:///var/run/nfd.sock")
           .setFaceScope(ndn::nfd::FACE_SCOPE_LOCAL)
           .setFacePersistency(ndn::nfd::FACE_PERSISTENCY_ON_DEMAND)
           .setLinkType(ndn::nfd::LINK_TYPE_POINT_TO_POINT)
           .setFlagBit(ndn::nfd::BIT_LOCAL_FIELDS_ENABLED, true)
           .setNInInterests(18998)
           .setNInDatas(26701)
           .setNInNacks(147)
           .setNOutInterests(34779)
           .setNOutDatas(17028)
           .setNOutNacks(1176)
           .setNInBytes(4672308)
           .setNOutBytes(8957187);
   this->sendDataset("/localhost/nfd/faces/list", payload1, payload2);
   this->prepareStatusOutput();

   BOOST_CHECK(statusXml.is_equal(STATUS_XML));
   BOOST_CHECK(statusText.is_equal(STATUS_TEXT));
 }

 BOOST_AUTO_TEST_SUITE_END() // TestFaceModule
 BOOST_AUTO_TEST_SUITE_END() // Nfdc

 } // namespace tests
 } // namespace nfdc
 } // namespace tools
 } // namespace nfd
	/* -- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -- */
	/**
	* Copyright (c) 2014-2017, Regents of the University of California,
	* Arizona Board of Regents,
	* Colorado State University,
	* University Pierre & Marie Curie, Sorbonne University,
	* Washington University in St. Louis,
	* Beijing Institute of Technology,
	* The University of Memphis.
	*
	* This file is part of NFD (Named Data Networking Forwarding Daemon).
	* See AUTHORS.md for complete list of NFD authors and contributors.
	*
	* NFD is free software: you can redistribute it and/or modify it under the terms
	* of the GNU General Public License as published by the Free Software Foundation,
	* either version 3 of the License, or (at your option) any later version.
	*
	* NFD is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
	* without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
	* PURPOSE. See the GNU General Public License for more details.
	*
	* You should have received a copy of the GNU General Public License along with
	* NFD, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
	*/

	#include "nfdc/face-module.hpp"
	#include <ndn-cxx/mgmt/nfd/face-query-filter.hpp>

	#include "execute-command-fixture.hpp"
	#include "status-fixture.hpp"

	namespace nfd {
	namespace tools {
	namespace nfdc {
	namespace tests {

	using ndn::nfd::FaceQueryFilter;

	BOOST_AUTO_TEST_SUITE(Nfdc)
	BOOST_AUTO_TEST_SUITE(TestFaceModule)

	BOOST_FIXTURE_TEST_SUITE(ShowCommand, ExecuteCommandFixture)

	const std::string NORMAL_OUTPUT = std::string(R"TEXT(
	faceid=256
	remote=udp4://84.67.35.111:6363
	local=udp4://79.91.49.215:6363
	counters={in={28975i 28232d 212n 13307258B} out={19525i 30993d 1038n 6231946B}}
	flags={non-local on-demand point-to-point}
	)TEXT").substr(1);

	BOOST_AUTO_TEST_CASE(Normal)
	{
	this->processInterest = [this] (const Interest& interest) {
	Name datasetName("/localhost/nfd/faces/query");
	FaceQueryFilter filter;
	filter.setFaceId(256);
	datasetName.append(filter.wireEncode());

	FaceStatus payload;
	payload.setFaceId(256)
	.setRemoteUri("udp4://84.67.35.111:6363")
	.setLocalUri("udp4://79.91.49.215:6363")
	.setFaceScope(ndn::nfd::FACE_SCOPE_NON_LOCAL)
	.setFacePersistency(ndn::nfd::FACE_PERSISTENCY_ON_DEMAND)
	.setLinkType(ndn::nfd::LINK_TYPE_POINT_TO_POINT)
	.setNInInterests(28975)
	.setNInDatas(28232)
	.setNInNacks(212)
	.setNOutInterests(19525)
	.setNOutDatas(30993)
	.setNOutNacks(1038)
	.setNInBytes(13307258)
	.setNOutBytes(6231946);

	this->sendDataset(datasetName, payload);
	};

	this->execute("face show 256");
	BOOST_CHECK_EQUAL(exitCode, 0);
	BOOST_CHECK(out.is_equal(NORMAL_OUTPUT));
	BOOST_CHECK(err.is_empty());
	}

	BOOST_AUTO_TEST_CASE(NotFound)
	{
	this->processInterest = [this] (const Interest& interest) {
	this->sendEmptyDataset(interest.getName());
	};

	this->execute("face show 256");
	BOOST_CHECK_EQUAL(exitCode, 3);
	BOOST_CHECK(out.is_empty());
	BOOST_CHECK(err.is_equal("Face 256 not found.\n"));
	}

	BOOST_AUTO_TEST_CASE(Error)
	{
	this->processInterest = nullptr; // no response

	this->execute("face show 256");
	BOOST_CHECK_EQUAL(exitCode, 1);
	BOOST_CHECK(out.is_empty());
	BOOST_CHECK(err.is_equal("Error 10060 when fetching face information: Timeout\n"));
	}

	BOOST_AUTO_TEST_SUITE_END() // ShowCommand

	BOOST_FIXTURE_TEST_SUITE(CreateCommand, ExecuteCommandFixture)

	BOOST_AUTO_TEST_CASE(Normal)
	{
	this->processInterest = [this] (const Interest& interest) {
	ControlParameters req = MOCK_NFD_MGMT_REQUIRE_LAST_COMMAND_IS("/localhost/nfd/faces/create");
	BOOST_REQUIRE(req.hasUri());
	BOOST_CHECK_EQUAL(req.getUri(), "udp4://159.242.33.78:6363");
	BOOST_REQUIRE(req.hasFacePersistency());
	BOOST_CHECK_EQUAL(req.getFacePersistency(), FacePersistency::FACE_PERSISTENCY_PERSISTENT);

	ControlParameters resp;
	resp.setFaceId(2130)
	.setUri("udp4://159.242.33.78:6363")
	.setFacePersistency(FacePersistency::FACE_PERSISTENCY_PERSISTENT);
	this->succeedCommand(resp);
	};

	this->execute("face create udp://159.242.33.78");
	BOOST_CHECK_EQUAL(exitCode, 0);
	BOOST_CHECK(out.is_equal("face-created id=2130 remote=udp4://159.242.33.78:6363 persistency=persistent\n"));
	BOOST_CHECK(err.is_empty());
	}

	BOOST_AUTO_TEST_CASE(Error)
	{
	this->processInterest = nullptr; // no response

	this->execute("face create udp://159.242.33.78");
	BOOST_CHECK_EQUAL(exitCode, 1);
	BOOST_CHECK(out.is_empty());
	BOOST_CHECK(err.is_equal("Error 10060 when creating face: request timed out\n"));
	}

	BOOST_AUTO_TEST_SUITE_END() // CreateCommand

	const std::string STATUS_XML = stripXmlSpaces(R"XML(
	<faces>
	<face>
	<faceId>134</faceId>
	<remoteUri>udp4://233.252.0.4:6363</remoteUri>
	<localUri>udp4://192.0.2.1:6363</localUri>
	<faceScope>non-local</faceScope>
	<facePersistency>permanent</facePersistency>
	<linkType>multi-access</linkType>
	<flags/>
	<packetCounters>
	<incomingPackets>
	<nInterests>22562</nInterests>
	<nDatas>22031</nDatas>
	<nNacks>63</nNacks>
	</incomingPackets>
	<outgoingPackets>
	<nInterests>30121</nInterests>
	<nDatas>20940</nDatas>
	<nNacks>1218</nNacks>
	</outgoingPackets>
	</packetCounters>
	<byteCounters>
	<incomingBytes>2522915</incomingBytes>
	<outgoingBytes>1353592</outgoingBytes>
	</byteCounters>
	</face>
	<face>
	<faceId>745</faceId>
	<remoteUri>fd://75</remoteUri>
	<localUri>unix:///var/run/nfd.sock</localUri>
	<faceScope>local</faceScope>
	<facePersistency>on-demand</facePersistency>
	<linkType>point-to-point</linkType>
	<flags>
	<localFieldsEnabled/>
	</flags>
	<packetCounters>
	<incomingPackets>
	<nInterests>18998</nInterests>
	<nDatas>26701</nDatas>
	<nNacks>147</nNacks>
	</incomingPackets>
	<outgoingPackets>
	<nInterests>34779</nInterests>
	<nDatas>17028</nDatas>
	<nNacks>1176</nNacks>
	</outgoingPackets>
	</packetCounters>
	<byteCounters>
	<incomingBytes>4672308</incomingBytes>
	<outgoingBytes>8957187</outgoingBytes>
	</byteCounters>
	</face>
	</faces>
	)XML");

	const std::string STATUS_TEXT =
	"Faces:\n"
	" faceid=134 remote=udp4://233.252.0.4:6363 local=udp4://192.0.2.1:6363"
	" counters={in={22562i 22031d 63n 2522915B} out={30121i 20940d 1218n 1353592B}}"
	" flags={non-local permanent multi-access}\n"
	" faceid=745 remote=fd://75 local=unix:///var/run/nfd.sock"
	" counters={in={18998i 26701d 147n 4672308B} out={34779i 17028d 1176n 8957187B}}"
	" flags={local on-demand point-to-point local-fields}\n";

	BOOST_FIXTURE_TEST_CASE(Status, StatusFixture<FaceModule>)
	{
	this->fetchStatus();
	FaceStatus payload1;
	payload1.setFaceId(134)
	.setRemoteUri("udp4://233.252.0.4:6363")
	.setLocalUri("udp4://192.0.2.1:6363")
	.setFaceScope(ndn::nfd::FACE_SCOPE_NON_LOCAL)
	.setFacePersistency(ndn::nfd::FACE_PERSISTENCY_PERMANENT)
	.setLinkType(ndn::nfd::LINK_TYPE_MULTI_ACCESS)
	.setNInInterests(22562)
	.setNInDatas(22031)
	.setNInNacks(63)
	.setNOutInterests(30121)
	.setNOutDatas(20940)
	.setNOutNacks(1218)
	.setNInBytes(2522915)
	.setNOutBytes(1353592);
	FaceStatus payload2;
	payload2.setFaceId(745)
	.setRemoteUri("fd://75")
	.setLocalUri("unix:///var/run/nfd.sock")
	.setFaceScope(ndn::nfd::FACE_SCOPE_LOCAL)
	.setFacePersistency(ndn::nfd::FACE_PERSISTENCY_ON_DEMAND)
	.setLinkType(ndn::nfd::LINK_TYPE_POINT_TO_POINT)
	.setFlagBit(ndn::nfd::BIT_LOCAL_FIELDS_ENABLED, true)
	.setNInInterests(18998)
	.setNInDatas(26701)
	.setNInNacks(147)
	.setNOutInterests(34779)
	.setNOutDatas(17028)
	.setNOutNacks(1176)
	.setNInBytes(4672308)
	.setNOutBytes(8957187);
	this->sendDataset("/localhost/nfd/faces/list", payload1, payload2);
	this->prepareStatusOutput();

	BOOST_CHECK(statusXml.is_equal(STATUS_XML));
	BOOST_CHECK(statusText.is_equal(STATUS_TEXT));
	}

	BOOST_AUTO_TEST_SUITE_END() // TestFaceModule
	BOOST_AUTO_TEST_SUITE_END() // Nfdc

	} // namespace tests
	} // namespace nfdc
	} // namespace tools
	} // namespace nfd