block-cipher.cpp

Go to the documentation of this file.

/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
 * Copyright (c) 2013-2023 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/transform/block-cipher.hpp"
 
#include <openssl/bio.h>
#include <openssl/evp.h>
 
#include <boost/lexical_cast.hpp>
 
namespace ndn::security::transform {
 
class BlockCipher::Impl : boost::noncopyable
{
public:
  Impl() noexcept
    : m_cipher(BIO_new(BIO_f_cipher()))
    , m_sink(BIO_new(BIO_s_mem()))
  {
    BIO_push(m_cipher, m_sink);
  }
 
  ~Impl()
  {
    BIO_free_all(m_cipher);
  }
 
public:
  BIO* m_cipher;
  BIO* m_sink; // BIO_f_cipher alone does not work without a sink
};
 
 
BlockCipher::BlockCipher(BlockCipherAlgorithm algo, CipherOperator op,
                         span<const uint8_t> key, span<const uint8_t> iv)
  : m_impl(make_unique<Impl>())
{
  switch (algo) {
  case BlockCipherAlgorithm::AES_CBC:
    initializeAesCbc(key, iv, op);
    break;
  default:
    NDN_THROW(Error(getIndex(), "Unsupported block cipher algorithm " +
                    boost::lexical_cast<std::string>(algo)));
  }
}
 
BlockCipher::~BlockCipher() = default;
 
void
BlockCipher::preTransform()
{
  fillOutputBuffer();
}
 
size_t
BlockCipher::convert(span<const uint8_t> data)
{
  if (data.empty())
    return 0;
 
  int wLen = BIO_write(m_impl->m_cipher, data.data(), data.size());
 
  if (wLen <= 0) { // failed to write data
    if (!BIO_should_retry(m_impl->m_cipher)) {
      // we haven't written everything but some error happens, and we cannot retry
      NDN_THROW(Error(getIndex(), "Failed to accept more input"));
    }
    return 0;
  }
  else { // update number of bytes written
    fillOutputBuffer();
    return static_cast<size_t>(wLen);
  }
}
 
void
BlockCipher::finalize()
{
  if (BIO_flush(m_impl->m_cipher) != 1)
    NDN_THROW(Error(getIndex(), "Failed to flush"));
 
  while (!isConverterEmpty()) {
    fillOutputBuffer();
    while (!isOutputBufferEmpty()) {
      flushOutputBuffer();
    }
  }
}
 
void
BlockCipher::fillOutputBuffer()
{
  int nPending = BIO_pending(m_impl->m_sink);
  if (nPending <= 0)
    return;
 
  // there is something to read from BIO
  auto buffer = make_unique<OBuffer>(nPending);
  int nRead = BIO_read(m_impl->m_sink, buffer->data(), nPending);
  if (nRead < 0)
    return;
 
  buffer->erase(buffer->begin() + nRead, buffer->end());
  setOutputBuffer(std::move(buffer));
}
 
bool
BlockCipher::isConverterEmpty() const
{
  return BIO_pending(m_impl->m_sink) <= 0;
}
 
void
BlockCipher::initializeAesCbc(span<const uint8_t> key, span<const uint8_t> iv, CipherOperator op)
{
  const EVP_CIPHER* cipherType = nullptr;
  switch (key.size()) {
  case 16:
    cipherType = EVP_aes_128_cbc();
    break;
  case 24:
    cipherType = EVP_aes_192_cbc();
    break;
  case 32:
    cipherType = EVP_aes_256_cbc();
    break;
  default:
    NDN_THROW(Error(getIndex(), "Unsupported key length " + to_string(key.size())));
  }
 
  auto requiredIvLen = static_cast<size_t>(EVP_CIPHER_iv_length(cipherType));
  if (iv.size() != requiredIvLen)
    NDN_THROW(Error(getIndex(), "IV length must be " + to_string(requiredIvLen)));
 
  BIO_set_cipher(m_impl->m_cipher, cipherType, key.data(), iv.data(),
                 op == CipherOperator::ENCRYPT ? 1 : 0);
}
 
unique_ptr<Transform>
blockCipher(BlockCipherAlgorithm algo, CipherOperator op,
            span<const uint8_t> key, span<const uint8_t> iv)
{
  return make_unique<BlockCipher>(algo, op, key, iv);
}
 
} // namespace ndn::security::transform