blob: 183a9471ba95834cb7405cfbb7c676d5126a996a [file] [log] [blame]
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
* Copyright (c) 2013-2022 Regents of the University of California.
*
* This file is part of ndn-cxx library (NDN C++ library with eXperimental eXtensions).
*
* ndn-cxx library is free software: you can redistribute it and/or modify it under the
* terms of the GNU Lesser General Public License as published by the Free Software
* Foundation, either version 3 of the License, or (at your option) any later version.
*
* ndn-cxx library 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 Lesser General Public License for more details.
*
* You should have received copies of the GNU General Public License and GNU Lesser
* General Public License along with ndn-cxx, e.g., in COPYING.md file. If not, see
* <http://www.gnu.org/licenses/>.
*
* See AUTHORS.md for complete list of ndn-cxx authors and contributors.
*/
#include "ndn-cxx/security/certificate-fetcher-direct-fetch.hpp"
#include "ndn-cxx/lp/nack.hpp"
#include "ndn-cxx/lp/tags.hpp"
#include "ndn-cxx/security/validation-policy-simple-hierarchy.hpp"
#include "tests/boost-test.hpp"
#include "tests/unit/security/validator-fixture.hpp"
#include <boost/range/adaptor/sliced.hpp>
#include <boost/range/adaptor/strided.hpp>
namespace ndn {
namespace security {
inline namespace v2 {
namespace tests {
using namespace ndn::tests;
BOOST_AUTO_TEST_SUITE(Security)
BOOST_AUTO_TEST_SUITE(TestCertificateFetcherDirectFetch)
class Cert
{
};
class Timeout
{
};
class Nack
{
};
template<class Response>
class CertificateFetcherDirectFetchFixture : public HierarchicalValidatorFixture<ValidationPolicySimpleHierarchy,
CertificateFetcherDirectFetch>
{
public:
enum class ResponseType {
INFRASTRUCTURE,
DIRECT,
BOTH
};
public:
CertificateFetcherDirectFetchFixture()
: data("/Security/ValidatorFixture/Sub1/Sub3/Data")
, interest("/Security/ValidatorFixture/Sub1/Sub3/Interest")
, interestNoTag("/Security/ValidatorFixture/Sub1/Sub3/Interest2")
{
Identity subSubIdentity = addSubCertificate("/Security/ValidatorFixture/Sub1/Sub3", subIdentity);
cache.insert(subSubIdentity.getDefaultKey().getDefaultCertificate());
m_keyChain.sign(data, signingByIdentity(subSubIdentity));
m_keyChain.sign(interest, signingByIdentity(subSubIdentity));
m_keyChain.sign(interestNoTag, signingByIdentity(subSubIdentity));
data.setTag(make_shared<lp::IncomingFaceIdTag>(123));
interest.setTag(make_shared<lp::IncomingFaceIdTag>(123));
processInterest = [this] (const Interest& interest) {
auto nextHopFaceIdTag = interest.template getTag<lp::NextHopFaceIdTag>();
if (nextHopFaceIdTag == nullptr) {
if (responseType == ResponseType::INFRASTRUCTURE || responseType == ResponseType::BOTH) {
makeResponse(interest);
}
}
else {
if (responseType == ResponseType::DIRECT || responseType == ResponseType::BOTH) {
makeResponse(interest);
}
}
};
}
void
makeResponse(const Interest& interest);
void
setResponseType(ResponseType type)
{
responseType = type;
}
public:
Data data;
Interest interest;
Interest interestNoTag;
ResponseType responseType = ResponseType::INFRASTRUCTURE;
};
template<>
void
CertificateFetcherDirectFetchFixture<Cert>::makeResponse(const Interest& interest)
{
auto cert = cache.find(interest);
if (cert == nullptr) {
return;
}
face.receive(*cert);
}
template<>
void
CertificateFetcherDirectFetchFixture<Timeout>::makeResponse(const Interest& interest)
{
// do nothing
}
template<>
void
CertificateFetcherDirectFetchFixture<Nack>::makeResponse(const Interest& interest)
{
lp::Nack nack(interest);
nack.setHeader(lp::NackHeader().setReason(lp::NackReason::NO_ROUTE));
face.receive(nack);
}
using Failures = boost::mpl::vector<Timeout, Nack>;
BOOST_FIXTURE_TEST_CASE(ValidateSuccessData, CertificateFetcherDirectFetchFixture<Cert>)
{
VALIDATE_SUCCESS(this->data, "Should get accepted, normal and/or direct interests bring certs");
BOOST_CHECK_EQUAL(this->face.sentInterests.size(), 4);
// odd interests
for (const auto& sentInterest : this->face.sentInterests | boost::adaptors::strided(2)) {
BOOST_CHECK(sentInterest.template getTag<lp::NextHopFaceIdTag>() != nullptr);
}
// even interests
for (const auto& sentInterest : this->face.sentInterests |
boost::adaptors::sliced(1, this->face.sentInterests.size()) |
boost::adaptors::strided(2)) {
BOOST_CHECK(sentInterest.template getTag<lp::NextHopFaceIdTag>() == nullptr);
}
}
BOOST_FIXTURE_TEST_CASE(ValidateSuccessDataDirectOnly, CertificateFetcherDirectFetchFixture<Cert>)
{
setResponseType(ResponseType::DIRECT);
static_cast<CertificateFetcherDirectFetch&>(validator.getFetcher()).setSendDirectInterestOnly(true);
VALIDATE_SUCCESS(this->data, "Should get accepted, direct interests bring certs");
BOOST_CHECK_EQUAL(this->face.sentInterests.size(), 2);
for (const auto& sentInterest : this->face.sentInterests) {
BOOST_CHECK(sentInterest.template getTag<lp::NextHopFaceIdTag>() != nullptr);
}
}
BOOST_FIXTURE_TEST_CASE_TEMPLATE(ValidateFailureData, T, Failures, CertificateFetcherDirectFetchFixture<T>)
{
VALIDATE_FAILURE(this->data, "Should fail, as all interests either NACKed or timeout");
// Direct fetcher sends two interests each time - to network and face
// 3 retries on nack or timeout (2 * (1 + 3) = 8)
BOOST_CHECK_EQUAL(this->face.sentInterests.size(), 8);
// odd interests
for (const auto& sentInterest : this->face.sentInterests | boost::adaptors::strided(2)) {
BOOST_CHECK(sentInterest.template getTag<lp::NextHopFaceIdTag>() != nullptr);
}
// even interests
for (const auto& sentInterest : this->face.sentInterests |
boost::adaptors::sliced(1, this->face.sentInterests.size()) |
boost::adaptors::strided(2)) {
BOOST_CHECK(sentInterest.template getTag<lp::NextHopFaceIdTag>() == nullptr);
}
}
BOOST_FIXTURE_TEST_CASE_TEMPLATE(ValidateFailureDataDirectOnly, T, Failures, CertificateFetcherDirectFetchFixture<T>)
{
this->setResponseType(CertificateFetcherDirectFetchFixture<T>::ResponseType::DIRECT);
static_cast<CertificateFetcherDirectFetch&>(this->validator.getFetcher()).setSendDirectInterestOnly(true);
VALIDATE_FAILURE(this->data, "Should fail, as all interests either NACKed or timeout");
// Direct fetcher sends two interests each time - to network and face
// 3 retries on nack or timeout (1 + 3 = 4)
BOOST_CHECK_EQUAL(this->face.sentInterests.size(), 4);
for (const auto& sentInterest : this->face.sentInterests) {
BOOST_CHECK(sentInterest.template getTag<lp::NextHopFaceIdTag>() != nullptr);
}
}
BOOST_FIXTURE_TEST_CASE_TEMPLATE(ValidateFailureDataNoTagDirectOnly, T, Failures, CertificateFetcherDirectFetchFixture<T>)
{
this->setResponseType(CertificateFetcherDirectFetchFixture<T>::ResponseType::DIRECT);
static_cast<CertificateFetcherDirectFetch&>(this->validator.getFetcher()).setSendDirectInterestOnly(true);
this->data.template removeTag<lp::IncomingFaceIdTag>();
this->interest.template removeTag<lp::IncomingFaceIdTag>();
VALIDATE_FAILURE(this->data, "Should fail, as no interests are expected");
BOOST_CHECK_EQUAL(this->face.sentInterests.size(), 0);
BOOST_CHECK_NE(this->lastError.getCode(), ValidationError::IMPLEMENTATION_ERROR);
}
BOOST_FIXTURE_TEST_CASE(ValidateSuccessInterest, CertificateFetcherDirectFetchFixture<Cert>)
{
VALIDATE_SUCCESS(this->interest, "Should get accepted, normal and/or direct interests bring certs");
BOOST_CHECK_EQUAL(this->face.sentInterests.size(), 4);
// odd interests
for (const auto& sentInterest : this->face.sentInterests | boost::adaptors::strided(2)) {
BOOST_CHECK(sentInterest.template getTag<lp::NextHopFaceIdTag>() != nullptr);
}
// even interests
for (const auto& sentInterest : this->face.sentInterests |
boost::adaptors::sliced(1, this->face.sentInterests.size()) |
boost::adaptors::strided(2)) {
BOOST_CHECK(sentInterest.template getTag<lp::NextHopFaceIdTag>() == nullptr);
}
}
BOOST_FIXTURE_TEST_CASE_TEMPLATE(ValidateFailureInterest, T, Failures, CertificateFetcherDirectFetchFixture<T>)
{
VALIDATE_FAILURE(this->interest, "Should fail, as all interests either NACKed or timeout");
// Direct fetcher sends two interests each time - to network and face
// 3 retries on nack or timeout (2 * (1 + 3) = 4)
BOOST_CHECK_EQUAL(this->face.sentInterests.size(), 8);
// odd interests
for (const auto& sentInterest : this->face.sentInterests | boost::adaptors::strided(2)) {
BOOST_CHECK(sentInterest.template getTag<lp::NextHopFaceIdTag>() != nullptr);
}
// even interests
for (const auto& sentInterest : this->face.sentInterests |
boost::adaptors::sliced(1, this->face.sentInterests.size()) |
boost::adaptors::strided(2)) {
BOOST_CHECK(sentInterest.template getTag<lp::NextHopFaceIdTag>() == nullptr);
}
}
BOOST_AUTO_TEST_SUITE_END() // TestCertificateFetcherDirectFetch
BOOST_AUTO_TEST_SUITE_END() // Security
} // namespace tests
} // inline namespace v2
} // namespace security
} // namespace ndn