12046188202

Committed 27 Nov 2024 08:09AM UTC coverage: 64.693% (-8.4%) from 73.085%

Build # 12046188202

Build Type

Pull #14896

github

Committed by

web-flow

Commit Message

Merge 009d3ea50 into 9cc72106e

Pull Request Pull Request #14896: rec: coverity fixes, all minor optimizations

Run Details

37474 of 88810 branches covered (42.2%)

Branch coverage included in aggregate %.

3 of 3 new or added lines in 3 files covered. (100.0%)

84 existing lines in 11 files now uncovered.

125855 of 163658 relevant lines covered (76.9%)

5260502.93 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

76.01

/pdns/dnsdistdist/dnsdist-crypto.cc

/*
 * This file is part of PowerDNS or dnsdist.
 * Copyright -- PowerDNS.COM B.V. and its contributors
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of version 2 of the GNU General Public License as
 * published by the Free Software Foundation.
 *
 * In addition, for the avoidance of any doubt, permission is granted to
 * link this program with OpenSSL and to (re)distribute the binaries
 * produced as the result of such linking.
 *
 * This program 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 this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 */
#include <iostream>
#include <arpa/inet.h>

#include "dnsdist-crypto.hh"

#include "namespaces.hh"
#include "noinitvector.hh"
#include "misc.hh"
#include "base64.hh"

namespace dnsdist::crypto::authenticated
{
#ifdef HAVE_LIBSODIUM
string newKey(bool base64Encoded)
{
  std::string key;
  key.resize(crypto_secretbox_KEYBYTES);

  // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
  randombytes_buf(reinterpret_cast<unsigned char*>(key.data()), key.size());

  if (!base64Encoded) {
    return key;
  }
  return "\"" + Base64Encode(key) + "\"";
}

bool isValidKey(const std::string& key)
{
  return key.size() == crypto_secretbox_KEYBYTES;
}

std::string encryptSym(const std::string_view& msg, const std::string& key, Nonce& nonce, bool incrementNonce)
{
  if (!isValidKey(key)) {
    throw std::runtime_error("Invalid encryption key of size " + std::to_string(key.size()) + " (" + std::to_string(crypto_secretbox_KEYBYTES) + " expected), use setKey() to set a valid key");
  }

  std::string ciphertext;
  ciphertext.resize(msg.length() + crypto_secretbox_MACBYTES);
  // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
  crypto_secretbox_easy(reinterpret_cast<unsigned char*>(ciphertext.data()),
                        // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
                        reinterpret_cast<const unsigned char*>(msg.data()),
                        msg.length(),
                        nonce.value.data(),
                        // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
                        reinterpret_cast<const unsigned char*>(key.data()));

  if (incrementNonce) {
    nonce.increment();
  }

  return ciphertext;
}

std::string decryptSym(const std::string_view& msg, const std::string& key, Nonce& nonce, bool incrementNonce)
{
  std::string decrypted;

  if (msg.length() < crypto_secretbox_MACBYTES) {
    throw std::runtime_error("Could not decrypt message of size " + std::to_string(msg.length()));
  }

  if (!isValidKey(key)) {
    throw std::runtime_error("Invalid decryption key of size " + std::to_string(key.size()) + ", use setKey() to set a valid key");
  }

  decrypted.resize(msg.length() - crypto_secretbox_MACBYTES);

  // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
  if (crypto_secretbox_open_easy(reinterpret_cast<unsigned char*>(decrypted.data()),
                                 // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
                                 reinterpret_cast<const unsigned char*>(msg.data()),
                                 msg.length(),
                                 nonce.value.data(),
                                 // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
                                 reinterpret_cast<const unsigned char*>(key.data()))
      != 0) {
    throw std::runtime_error("Could not decrypt message, please check that the key configured with setKey() is correct");
  }

  if (incrementNonce) {
    nonce.increment();
  }

  return decrypted;
}

void Nonce::init()
{
  randombytes_buf(value.data(), value.size());
}

#elif defined(HAVE_LIBCRYPTO)
#include <openssl/evp.h>
#include <openssl/rand.h>

static constexpr size_t s_CHACHA20_POLY1305_KEY_SIZE = 32U;
static constexpr size_t s_POLY1305_BLOCK_SIZE = 16U;

string newKey(bool base64Encoded)
{
  std::string key;
  key.resize(s_CHACHA20_POLY1305_KEY_SIZE);
  // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
  if (RAND_priv_bytes(reinterpret_cast<unsigned char*>(key.data()), key.size()) != 1) {
    throw std::runtime_error("Could not initialize random number generator for cryptographic functions");
  }
  if (!base64Encoded) {
    return key;
  }
  return "\"" + Base64Encode(key) + "\"";
}

bool isValidKey(const std::string& key)
{
  return key.size() == s_CHACHA20_POLY1305_KEY_SIZE;
}

std::string encryptSym(const std::string_view& msg, const std::string& key, Nonce& nonce, bool incrementNonce)
{
  if (!isValidKey(key)) {
    throw std::runtime_error("Invalid encryption key of size " + std::to_string(key.size()) + " (" + std::to_string(s_CHACHA20_POLY1305_KEY_SIZE) + " expected), use setKey() to set a valid key");
  }

  // Each thread gets its own cipher context
  static thread_local auto ctx = std::unique_ptr<EVP_CIPHER_CTX, decltype(&EVP_CIPHER_CTX_free)>(nullptr, EVP_CIPHER_CTX_free);

  if (!ctx) {
    ctx = std::unique_ptr<EVP_CIPHER_CTX, decltype(&EVP_CIPHER_CTX_free)>(EVP_CIPHER_CTX_new(), EVP_CIPHER_CTX_free);
    if (!ctx) {
      throw std::runtime_error("encryptSym: EVP_CIPHER_CTX_new() could not initialize cipher context");
    }

    if (EVP_EncryptInit_ex(ctx.get(), EVP_chacha20_poly1305(), nullptr, nullptr, nullptr) != 1) {
      throw std::runtime_error("encryptSym: EVP_EncryptInit_ex() could not initialize encryption operation");
    }
  }

  std::string ciphertext;
  /* plus one so we can access the last byte in EncryptFinal which does nothing for this algo */
  ciphertext.resize(s_POLY1305_BLOCK_SIZE + msg.length() + 1);
  int outLength{0};
  // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
  if (EVP_EncryptInit_ex(ctx.get(), nullptr, nullptr, reinterpret_cast<const unsigned char*>(key.c_str()), nonce.value.data()) != 1) {
    throw std::runtime_error("encryptSym: EVP_EncryptInit_ex() could not initialize encryption key and IV");
  }

  if (!msg.empty()) {
    // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
    if (EVP_EncryptUpdate(ctx.get(),
                          reinterpret_cast<unsigned char*>(&ciphertext.at(s_POLY1305_BLOCK_SIZE)), &outLength,
                          reinterpret_cast<const unsigned char*>(msg.data()), msg.length())
        != 1) {
      throw std::runtime_error("encryptSym: EVP_EncryptUpdate() could not encrypt message");
    }
  }

  // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
  if (EVP_EncryptFinal_ex(ctx.get(), reinterpret_cast<unsigned char*>(&ciphertext.at(s_POLY1305_BLOCK_SIZE + outLength)), &outLength) != 1) {
    throw std::runtime_error("encryptSym: EVP_EncryptFinal_ex() could finalize message encryption");
    ;
  }

  /* Get the tag */
  // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
  if (EVP_CIPHER_CTX_ctrl(ctx.get(), EVP_CTRL_AEAD_GET_TAG, s_POLY1305_BLOCK_SIZE, ciphertext.data()) != 1) {
    throw std::runtime_error("encryptSym: EVP_CIPHER_CTX_ctrl() could not get tag");
  }

  if (incrementNonce) {
    nonce.increment();
  }

  ciphertext.resize(ciphertext.size() - 1);
  return ciphertext;
}

std::string decryptSym(const std::string_view& msg, const std::string& key, Nonce& nonce, bool incrementNonce)
{
  if (msg.length() < s_POLY1305_BLOCK_SIZE) {
    throw std::runtime_error("Could not decrypt message of size " + std::to_string(msg.length()));
  }

  if (!isValidKey(key)) {
    throw std::runtime_error("Invalid decryption key of size " + std::to_string(key.size()) + ", use setKey() to set a valid key");
  }

  if (msg.length() == s_POLY1305_BLOCK_SIZE) {
    if (incrementNonce) {
      nonce.increment();
    }
    return std::string();
  }

  // Each thread gets its own cipher context
  static thread_local auto ctx = std::unique_ptr<EVP_CIPHER_CTX, decltype(&EVP_CIPHER_CTX_free)>(nullptr, EVP_CIPHER_CTX_free);
  if (!ctx) {
    ctx = std::unique_ptr<EVP_CIPHER_CTX, decltype(&EVP_CIPHER_CTX_free)>(EVP_CIPHER_CTX_new(), EVP_CIPHER_CTX_free);
    if (!ctx) {
      throw std::runtime_error("decryptSym: EVP_CIPHER_CTX_new() could not initialize cipher context");
    }

    if (EVP_DecryptInit_ex(ctx.get(), EVP_chacha20_poly1305(), nullptr, nullptr, nullptr) != 1) {
      throw std::runtime_error("decryptSym: EVP_DecryptInit_ex() could not initialize decryption operation");
    }
  }

  // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
  if (EVP_DecryptInit_ex(ctx.get(), nullptr, nullptr, reinterpret_cast<const unsigned char*>(key.c_str()), nonce.value.data()) != 1) {
    throw std::runtime_error("decryptSym: EVP_DecryptInit_ex() could not initialize decryption key and IV");
  }

  const auto tag = msg.substr(0, s_POLY1305_BLOCK_SIZE);
  std::string decrypted;
  /* plus one so we can access the last byte in DecryptFinal, which does nothing */
  decrypted.resize(msg.length() - s_POLY1305_BLOCK_SIZE + 1);
  int outLength{0};
  if (msg.size() > s_POLY1305_BLOCK_SIZE) {
    if (!EVP_DecryptUpdate(ctx.get(),
                           // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
                           reinterpret_cast<unsigned char*>(decrypted.data()), &outLength,
                           // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
                           reinterpret_cast<const unsigned char*>(&msg.at(s_POLY1305_BLOCK_SIZE)), msg.size() - s_POLY1305_BLOCK_SIZE)) {
      throw std::runtime_error("Could not decrypt message (update failed), please check that the key configured with setKey() is correct");
    }
  }

  /* Set expected tag value. Works in OpenSSL 1.0.1d and later */
  // NOLINTNEXTLINE(cppcoreguidelines-pro-type-const-cast): sorry, OpenSSL's API is terrible
  if (!EVP_CIPHER_CTX_ctrl(ctx.get(), EVP_CTRL_AEAD_SET_TAG, s_POLY1305_BLOCK_SIZE, const_cast<char*>(tag.data()))) {
    throw std::runtime_error("Could not decrypt message (invalid tag), please check that the key configured with setKey() is correct");
  }

  // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
  if (!EVP_DecryptFinal_ex(ctx.get(), reinterpret_cast<unsigned char*>(&decrypted.at(outLength)), &outLength)) {
    throw std::runtime_error("Could not decrypt message (final failed), please check that the key configured with setKey() is correct");
  }

  if (incrementNonce) {
    nonce.increment();
  }

  decrypted.resize(decrypted.size() - 1);
  return decrypted;
}

void Nonce::init()
{
  if (RAND_priv_bytes(value.data(), value.size()) != 1) {
    throw std::runtime_error("Could not initialize random number generator for cryptographic functions");
  }
}
#endif

#if defined(HAVE_LIBSODIUM) || defined(HAVE_LIBCRYPTO)
void Nonce::merge(const Nonce& lower, const Nonce& higher)
{
  constexpr size_t halfSize = std::tuple_size<decltype(value)>{} / 2;
  memcpy(value.data(), lower.value.data(), halfSize);
  memcpy(value.data() + halfSize, higher.value.data() + halfSize, halfSize);
}

void Nonce::increment()
{
  // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
  auto* ptr = reinterpret_cast<uint32_t*>(value.data());
  uint32_t count = htonl(*ptr);
  *ptr = ntohl(++count);
}

#else
void Nonce::init()
{
}

void Nonce::merge(const Nonce& lower, const Nonce& higher)
{
}

void Nonce::increment()
{
}

std::string encryptSym(const std::string_view& msg, const std::string& key, Nonce& nonce, bool incrementNonce)
{
  return std::string(msg);
}
std::string decryptSym(const std::string_view& msg, const std::string& key, Nonce& nonce, bool incrementNonce)
{
  return std::string(msg);
}

string newKey(bool base64Encoded)
{
  return "\"plaintext\"";
}

bool isValidKey(const std::string& key)
{
  return true;
}

#endif
}

#include <cinttypes>

namespace anonpdns
{
static char B64Decode1(char cInChar)
{
  // The incoming character will be A-Z, a-z, 0-9, +, /, or =.
  // The idea is to quickly determine which grouping the
  // letter belongs to and return the associated value
  // without having to search the global encoding string
  // (the value we're looking for would be the resulting
  // index into that string).
  //
  // To do that, we'll play some tricks...
  unsigned char iIndex = '\0';
  switch (cInChar) {
  case '+':
    iIndex = 62;
    break;

  case '/':
    iIndex = 63;
    break;

  case '=':
    iIndex = 0;
    break;

  default:
    // Must be 'A'-'Z', 'a'-'z', '0'-'9', or an error...
    //
    // Numerically, small letters are "greater" in value than
    // capital letters and numerals (ASCII value), and capital
    // letters are "greater" than numerals (again, ASCII value),
    // so we check for numerals first, then capital letters,
    // and finally small letters.
    iIndex = '9' - cInChar;
    if (iIndex > 0x3F) {
      // Not from '0' to '9'...
      iIndex = 'Z' - cInChar;
      if (iIndex > 0x3F) {
        // Not from 'A' to 'Z'...
        iIndex = 'z' - cInChar;
        if (iIndex > 0x3F) {
          // Invalid character...cannot
          // decode!
          iIndex = 0x80; // set the high bit
        } // if
        else {
          // From 'a' to 'z'
          iIndex = (('z' - iIndex) - 'a') + 26;
        } // else
      } // if
      else {
        // From 'A' to 'Z'
        iIndex = ('Z' - iIndex) - 'A';
      } // else
    } // if
    else {
      // Adjust the index...
      iIndex = (('9' - iIndex) - '0') + 52;
    } // else
    break;

  } // switch

  return static_cast<char>(iIndex);
}

static inline char B64Encode1(unsigned char input)
{
  if (input < 26) {
    return static_cast<char>('A' + input);
  }
  if (input < 52) {
    return static_cast<char>('a' + (input - 26));
  }
  if (input < 62) {
    return static_cast<char>('0' + (input - 52));
  }
  if (input == 62) {
    return '+';
  }
  return '/';
};

}
using namespace anonpdns;

template <typename Container>
int B64Decode(const std::string& strInput, Container& strOutput)
{
  // Set up a decoding buffer
  long cBuf = 0;
  // NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
  char* pBuf = reinterpret_cast<char*>(&cBuf);

  // Decoding management...
  int iBitGroup = 0;
  int iInNum = 0;

  // While there are characters to process...
  //
  // We'll decode characters in blocks of 4, as
  // there are 4 groups of 6 bits in 3 bytes. The
  // incoming Base64 character is first decoded, and
  // then it is inserted into the decode buffer
  // (with any relevant shifting, as required).
  // Later, after all 3 bytes have been reconstituted,
  // we assign them to the output string, ultimately
  // to be returned as the original message.
  int iInSize = static_cast<int>(strInput.size());
  unsigned char cChar = '\0';
  uint8_t pad = 0;
  while (iInNum < iInSize) {
    // Fill the decode buffer with 4 groups of 6 bits
    cBuf = 0; // clear
    pad = 0;
    for (iBitGroup = 0; iBitGroup < 4; ++iBitGroup) {
      if (iInNum < iInSize) {
        // Decode a character
        if (strInput.at(iInNum) == '=') {
          pad++;
        }
        while (isspace(strInput.at(iInNum))) {
          iInNum++;
        }
        cChar = B64Decode1(strInput.at(iInNum++));

      } // if
      else {
        // Decode a padded zero
        cChar = '\0';
      } // else

      // Check for valid decode
      if (cChar > 0x7F) {
        return -1;
      }

      // Adjust the bits
      switch (iBitGroup) {
      case 0:
        // The first group is copied into
        // the least significant 6 bits of
        // the decode buffer...these 6 bits
        // will eventually shift over to be
        // the most significant bits of the
        // third byte.
        cBuf = cBuf | cChar;
        break;

      default:
        // For groupings 1-3, simply shift
        // the bits in the decode buffer over
        // by 6 and insert the 6 from the
        // current decode character.
        cBuf = (cBuf << 6) | cChar;
        break;

      } // switch
    } // for

    // Interpret the resulting 3 bytes...note there
    // may have been padding, so those padded bytes
    // are actually ignored.
#if BYTE_ORDER == BIG_ENDIAN
    // NOLINTNEXTLINE(cppcoreguidelines-pro-bounds-pointer-arithmetic)
    strOutput.push_back(pBuf[sizeof(long) - 3]);
    // NOLINTNEXTLINE(cppcoreguidelines-pro-bounds-pointer-arithmetic)
    strOutput.push_back(pBuf[sizeof(long) - 2]);
    // NOLINTNEXTLINE(cppcoreguidelines-pro-bounds-pointer-arithmetic)
    strOutput.push_back(pBuf[sizeof(long) - 1]);
#else
    // NOLINTNEXTLINE(cppcoreguidelines-pro-bounds-pointer-arithmetic)
    strOutput.push_back(pBuf[2]);
    // NOLINTNEXTLINE(cppcoreguidelines-pro-bounds-pointer-arithmetic)
    strOutput.push_back(pBuf[1]);
    // NOLINTNEXTLINE(cppcoreguidelines-pro-bounds-pointer-arithmetic)
    strOutput.push_back(pBuf[0]);
#endif
  } // while
  if (pad) {
    strOutput.resize(strOutput.size() - pad);
  }

  return 1;
}

template int B64Decode<std::vector<uint8_t>>(const std::string& strInput, std::vector<uint8_t>& strOutput);
template int B64Decode<PacketBuffer>(const std::string& strInput, PacketBuffer& strOutput);
template int B64Decode<std::string>(const std::string& strInput, std::string& strOutput);

/*
www.kbcafe.com
Copyright 2001-2002 Randy Charles Morin
The Encode static method takes an array of 8-bit values and returns a base-64 stream.
*/

std::string Base64Encode(const std::string& src)
{
  std::string retval;
  if (src.empty()) {
    return retval;
  }
  for (unsigned int i = 0; i < src.size(); i += 3) {
    unsigned char by1 = 0;
    unsigned char by2 = 0;
    unsigned char by3 = 0;
    by1 = src[i];
    if (i + 1 < src.size()) {
      by2 = src[i + 1];
    };
    if (i + 2 < src.size()) {
      by3 = src[i + 2];
    }
    unsigned char by4 = 0;
    unsigned char by5 = 0;
    unsigned char by6 = 0;
    unsigned char by7 = 0;
    by4 = by1 >> 2;
    by5 = ((by1 & 0x3) << 4) | (by2 >> 4);
    by6 = ((by2 & 0xf) << 2) | (by3 >> 6);
    by7 = by3 & 0x3f;
    retval += B64Encode1(by4);
    retval += B64Encode1(by5);
    if (i + 1 < src.size()) {
      retval += B64Encode1(by6);
    }
    else {
      retval += "=";
    };
    if (i + 2 < src.size()) {
      retval += B64Encode1(by7);
    }
    else {
      retval += "=";
    };
    /*      if ((i % (76 / 4 * 3)) == 0)
      {
        retval += "\r\n";
        }*/
  };
  return retval;
};

1	/*
2	* This file is part of PowerDNS or dnsdist.
3	* Copyright -- PowerDNS.COM B.V. and its contributors
4	*
5	* This program is free software; you can redistribute it and/or modify
6	* it under the terms of version 2 of the GNU General Public License as
7	* published by the Free Software Foundation.
8	*
9	* In addition, for the avoidance of any doubt, permission is granted to
10	* link this program with OpenSSL and to (re)distribute the binaries
11	* produced as the result of such linking.
12	*
13	* This program is distributed in the hope that it will be useful,
14	* but WITHOUT ANY WARRANTY; without even the implied warranty of
15	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16	* GNU General Public License for more details.
17	*
18	* You should have received a copy of the GNU General Public License
19	* along with this program; if not, write to the Free Software
20	* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
21	*/
22	#include <iostream>
23	#include <arpa/inet.h>
24
25	#include "dnsdist-crypto.hh"
26
27	#include "namespaces.hh"
28	#include "noinitvector.hh"
29	#include "misc.hh"
30	#include "base64.hh"
31
32	namespace dnsdist::crypto::authenticated
33	{
34	#ifdef HAVE_LIBSODIUM
35	string newKey(bool base64Encoded)
36	{	645✔
37	std::string key;	645✔
38	key.resize(crypto_secretbox_KEYBYTES);	645✔
39
40	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
41	randombytes_buf(reinterpret_cast<unsigned char*>(key.data()), key.size());	645✔
42
43	if (!base64Encoded) {	645!
44	return key;	645✔
45	}	645✔
46	return "\"" + Base64Encode(key) + "\"";
47	}	645✔
48
49	bool isValidKey(const std::string& key)
50	{	910✔
51	return key.size() == crypto_secretbox_KEYBYTES;	910✔
52	}	910✔
53
54	std::string encryptSym(const std::string_view& msg, const std::string& key, Nonce& nonce, bool incrementNonce)
55	{	328✔
56	if (!isValidKey(key)) {	328!
57	throw std::runtime_error("Invalid encryption key of size " + std::to_string(key.size()) + " (" + std::to_string(crypto_secretbox_KEYBYTES) + " expected), use setKey() to set a valid key");
58	}
59
60	std::string ciphertext;	328✔
61	ciphertext.resize(msg.length() + crypto_secretbox_MACBYTES);	328✔
62	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
63	crypto_secretbox_easy(reinterpret_cast<unsigned char*>(ciphertext.data()),	328✔
64	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
65	reinterpret_cast<const unsigned char*>(msg.data()),	328✔
66	msg.length(),	328✔
67	nonce.value.data(),	328✔
68	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
69	reinterpret_cast<const unsigned char*>(key.data()));	328✔
70
71	if (incrementNonce) {	328✔
72	nonce.increment();	249✔
73	}	249✔
74
75	return ciphertext;	328✔
76	}	328✔
77
78	std::string decryptSym(const std::string_view& msg, const std::string& key, Nonce& nonce, bool incrementNonce)
79	{	328✔
80	std::string decrypted;	328✔
81
82	if (msg.length() < crypto_secretbox_MACBYTES) {	328!
83	throw std::runtime_error("Could not decrypt message of size " + std::to_string(msg.length()));
84	}
85
86	if (!isValidKey(key)) {	328!
87	throw std::runtime_error("Invalid decryption key of size " + std::to_string(key.size()) + ", use setKey() to set a valid key");
88	}
89
90	decrypted.resize(msg.length() - crypto_secretbox_MACBYTES);	328✔
91
92	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
93	if (crypto_secretbox_open_easy(reinterpret_cast<unsigned char*>(decrypted.data()),	328!
94	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
95	reinterpret_cast<const unsigned char*>(msg.data()),	328✔
96	msg.length(),	328✔
97	nonce.value.data(),	328✔
98	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
99	reinterpret_cast<const unsigned char*>(key.data()))	328✔
100	!= 0) {	328✔
101	throw std::runtime_error("Could not decrypt message, please check that the key configured with setKey() is correct");
102	}
103
104	if (incrementNonce) {	328✔
105	nonce.increment();	249✔
106	}	249✔
107
108	return decrypted;	328✔
109	}	328✔
110
111	void Nonce::init()
112	{	330✔
113	randombytes_buf(value.data(), value.size());	330✔
114	}	330✔
115
116	#elif defined(HAVE_LIBCRYPTO)
117	#include <openssl/evp.h>
118	#include <openssl/rand.h>
119
120	static constexpr size_t s_CHACHA20_POLY1305_KEY_SIZE = 32U;
121	static constexpr size_t s_POLY1305_BLOCK_SIZE = 16U;
122
123	string newKey(bool base64Encoded)
124	{
125	std::string key;
126	key.resize(s_CHACHA20_POLY1305_KEY_SIZE);
127	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
128	if (RAND_priv_bytes(reinterpret_cast<unsigned char*>(key.data()), key.size()) != 1) {	×
129	throw std::runtime_error("Could not initialize random number generator for cryptographic functions");
130	}
131	if (!base64Encoded) {	×
132	return key;
133	}
134	return "\"" + Base64Encode(key) + "\"";
135	}
136
137	bool isValidKey(const std::string& key)
138	{
139	return key.size() == s_CHACHA20_POLY1305_KEY_SIZE;
140	}
141
142	std::string encryptSym(const std::string_view& msg, const std::string& key, Nonce& nonce, bool incrementNonce)
143	{
144	if (!isValidKey(key)) {	×
145	throw std::runtime_error("Invalid encryption key of size " + std::to_string(key.size()) + " (" + std::to_string(s_CHACHA20_POLY1305_KEY_SIZE) + " expected), use setKey() to set a valid key");
146	}
147
148	// Each thread gets its own cipher context
149	static thread_local auto ctx = std::unique_ptr<EVP_CIPHER_CTX, decltype(&EVP_CIPHER_CTX_free)>(nullptr, EVP_CIPHER_CTX_free);
150
151	if (!ctx) {	×
152	ctx = std::unique_ptr<EVP_CIPHER_CTX, decltype(&EVP_CIPHER_CTX_free)>(EVP_CIPHER_CTX_new(), EVP_CIPHER_CTX_free);
153	if (!ctx) {	×
154	throw std::runtime_error("encryptSym: EVP_CIPHER_CTX_new() could not initialize cipher context");
155	}
156
157	if (EVP_EncryptInit_ex(ctx.get(), EVP_chacha20_poly1305(), nullptr, nullptr, nullptr) != 1) {	×
158	throw std::runtime_error("encryptSym: EVP_EncryptInit_ex() could not initialize encryption operation");
159	}
160	}
161
162	std::string ciphertext;
163	/* plus one so we can access the last byte in EncryptFinal which does nothing for this algo */
164	ciphertext.resize(s_POLY1305_BLOCK_SIZE + msg.length() + 1);
165	int outLength{0};
166	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
167	if (EVP_EncryptInit_ex(ctx.get(), nullptr, nullptr, reinterpret_cast<const unsigned char*>(key.c_str()), nonce.value.data()) != 1) {	×
168	throw std::runtime_error("encryptSym: EVP_EncryptInit_ex() could not initialize encryption key and IV");
169	}
170
171	if (!msg.empty()) {	×
172	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
173	if (EVP_EncryptUpdate(ctx.get(),	×
174	reinterpret_cast<unsigned char*>(&ciphertext.at(s_POLY1305_BLOCK_SIZE)), &outLength,
175	reinterpret_cast<const unsigned char*>(msg.data()), msg.length())
176	!= 1) {
177	throw std::runtime_error("encryptSym: EVP_EncryptUpdate() could not encrypt message");
178	}
179	}
180
181	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
182	if (EVP_EncryptFinal_ex(ctx.get(), reinterpret_cast<unsigned char*>(&ciphertext.at(s_POLY1305_BLOCK_SIZE + outLength)), &outLength) != 1) {	×
183	throw std::runtime_error("encryptSym: EVP_EncryptFinal_ex() could finalize message encryption");
184	;
185	}
186
187	/* Get the tag */
188	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
189	if (EVP_CIPHER_CTX_ctrl(ctx.get(), EVP_CTRL_AEAD_GET_TAG, s_POLY1305_BLOCK_SIZE, ciphertext.data()) != 1) {	×
190	throw std::runtime_error("encryptSym: EVP_CIPHER_CTX_ctrl() could not get tag");
191	}
192
193	if (incrementNonce) {	×
194	nonce.increment();
195	}
196
197	ciphertext.resize(ciphertext.size() - 1);
198	return ciphertext;
199	}
200
201	std::string decryptSym(const std::string_view& msg, const std::string& key, Nonce& nonce, bool incrementNonce)
202	{
203	if (msg.length() < s_POLY1305_BLOCK_SIZE) {	×
204	throw std::runtime_error("Could not decrypt message of size " + std::to_string(msg.length()));
205	}
206
207	if (!isValidKey(key)) {	×
208	throw std::runtime_error("Invalid decryption key of size " + std::to_string(key.size()) + ", use setKey() to set a valid key");
209	}
210
211	if (msg.length() == s_POLY1305_BLOCK_SIZE) {	×
212	if (incrementNonce) {	×
213	nonce.increment();
214	}
215	return std::string();
216	}
217
218	// Each thread gets its own cipher context
219	static thread_local auto ctx = std::unique_ptr<EVP_CIPHER_CTX, decltype(&EVP_CIPHER_CTX_free)>(nullptr, EVP_CIPHER_CTX_free);
220	if (!ctx) {	×
221	ctx = std::unique_ptr<EVP_CIPHER_CTX, decltype(&EVP_CIPHER_CTX_free)>(EVP_CIPHER_CTX_new(), EVP_CIPHER_CTX_free);
222	if (!ctx) {	×
223	throw std::runtime_error("decryptSym: EVP_CIPHER_CTX_new() could not initialize cipher context");
224	}
225
226	if (EVP_DecryptInit_ex(ctx.get(), EVP_chacha20_poly1305(), nullptr, nullptr, nullptr) != 1) {	×
227	throw std::runtime_error("decryptSym: EVP_DecryptInit_ex() could not initialize decryption operation");
228	}
229	}
230
231	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
232	if (EVP_DecryptInit_ex(ctx.get(), nullptr, nullptr, reinterpret_cast<const unsigned char*>(key.c_str()), nonce.value.data()) != 1) {	×
233	throw std::runtime_error("decryptSym: EVP_DecryptInit_ex() could not initialize decryption key and IV");
234	}
235
236	const auto tag = msg.substr(0, s_POLY1305_BLOCK_SIZE);
237	std::string decrypted;
238	/* plus one so we can access the last byte in DecryptFinal, which does nothing */
239	decrypted.resize(msg.length() - s_POLY1305_BLOCK_SIZE + 1);
240	int outLength{0};
241	if (msg.size() > s_POLY1305_BLOCK_SIZE) {	×
242	if (!EVP_DecryptUpdate(ctx.get(),	×
243	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
244	reinterpret_cast<unsigned char*>(decrypted.data()), &outLength,
245	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
246	reinterpret_cast<const unsigned char*>(&msg.at(s_POLY1305_BLOCK_SIZE)), msg.size() - s_POLY1305_BLOCK_SIZE)) {
247	throw std::runtime_error("Could not decrypt message (update failed), please check that the key configured with setKey() is correct");
248	}
249	}
250
251	/* Set expected tag value. Works in OpenSSL 1.0.1d and later */
252	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-const-cast): sorry, OpenSSL's API is terrible
253	if (!EVP_CIPHER_CTX_ctrl(ctx.get(), EVP_CTRL_AEAD_SET_TAG, s_POLY1305_BLOCK_SIZE, const_cast<char*>(tag.data()))) {	×
254	throw std::runtime_error("Could not decrypt message (invalid tag), please check that the key configured with setKey() is correct");
255	}
256
257	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
258	if (!EVP_DecryptFinal_ex(ctx.get(), reinterpret_cast<unsigned char*>(&decrypted.at(outLength)), &outLength)) {	×
259	throw std::runtime_error("Could not decrypt message (final failed), please check that the key configured with setKey() is correct");
260	}
261
262	if (incrementNonce) {	×
263	nonce.increment();
264	}
265
266	decrypted.resize(decrypted.size() - 1);
267	return decrypted;
268	}
269
270	void Nonce::init()
271	{
272	if (RAND_priv_bytes(value.data(), value.size()) != 1) {	×
273	throw std::runtime_error("Could not initialize random number generator for cryptographic functions");
274	}
275	}
276	#endif
277
278	#if defined(HAVE_LIBSODIUM) \|\| defined(HAVE_LIBCRYPTO)
279	void Nonce::merge(const Nonce& lower, const Nonce& higher)
280	{	498✔
281	constexpr size_t halfSize = std::tuple_size<decltype(value)>{} / 2;	498✔
282	memcpy(value.data(), lower.value.data(), halfSize);	498✔
283	memcpy(value.data() + halfSize, higher.value.data() + halfSize, halfSize);	498✔
284	}	498✔
285
286	void Nonce::increment()
287	{	498✔
288	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
289	auto* ptr = reinterpret_cast<uint32_t*>(value.data());	498✔
290	uint32_t count = htonl(*ptr);	498✔
291	*ptr = ntohl(++count);	498✔
292	}	498✔
293
294	#else
295	void Nonce::init()
296	{
297	}
298
299	void Nonce::merge(const Nonce& lower, const Nonce& higher)
300	{
301	}
302
303	void Nonce::increment()
304	{
305	}
306
307	std::string encryptSym(const std::string_view& msg, const std::string& key, Nonce& nonce, bool incrementNonce)
308	{
309	return std::string(msg);
310	}
311	std::string decryptSym(const std::string_view& msg, const std::string& key, Nonce& nonce, bool incrementNonce)
312	{
313	return std::string(msg);
314	}
315
316	string newKey(bool base64Encoded)
317	{
318	return "\"plaintext\"";
319	}
320
321	bool isValidKey(const std::string& key)
322	{
323	return true;
324	}
325
326	#endif
327	}
328
329	#include <cinttypes>
330
331	namespace anonpdns
332	{
333	static char B64Decode1(char cInChar)
334	{	35,782✔
335	// The incoming character will be A-Z, a-z, 0-9, +, /, or =.
336	// The idea is to quickly determine which grouping the
337	// letter belongs to and return the associated value
338	// without having to search the global encoding string
339	// (the value we're looking for would be the resulting
340	// index into that string).
341	//
342	// To do that, we'll play some tricks...
343	unsigned char iIndex = '\0';	35,782✔
344	switch (cInChar) {	35,782✔
345	case '+':	177✔
346	iIndex = 62;	177✔
347	break;	177✔
348
349	case '/':	93✔
350	iIndex = 63;	93✔
351	break;	93✔
352
353	case '=':	894✔
354	iIndex = 0;	894✔
355	break;	894✔
356
357	default:	34,618✔
358	// Must be 'A'-'Z', 'a'-'z', '0'-'9', or an error...
359	//
360	// Numerically, small letters are "greater" in value than
361	// capital letters and numerals (ASCII value), and capital
362	// letters are "greater" than numerals (again, ASCII value),
363	// so we check for numerals first, then capital letters,
364	// and finally small letters.
365	iIndex = '9' - cInChar;	34,618✔
366	if (iIndex > 0x3F) {	34,618✔
367	// Not from '0' to '9'...
368	iIndex = 'Z' - cInChar;	29,883✔
369	if (iIndex > 0x3F) {	29,883✔
370	// Not from 'A' to 'Z'...
371	iIndex = 'z' - cInChar;	12,275✔
372	if (iIndex > 0x3F) {	12,275✔
373	// Invalid character...cannot
374	// decode!
375	iIndex = 0x80; // set the high bit	2✔
376	} // if	2✔
377	else {	12,273✔
378	// From 'a' to 'z'
379	iIndex = (('z' - iIndex) - 'a') + 26;	12,273✔
380	} // else	12,273✔
381	} // if	12,275✔
382	else {	17,608✔
383	// From 'A' to 'Z'
384	iIndex = ('Z' - iIndex) - 'A';	17,608✔
385	} // else	17,608✔
386	} // if	29,883✔
387	else {	4,735✔
388	// Adjust the index...
389	iIndex = (('9' - iIndex) - '0') + 52;	4,735✔
390	} // else	4,735✔
391	break;	34,618✔
392
393	} // switch	35,782✔
394
395	return static_cast<char>(iIndex);	35,782✔
396	}	35,782✔
397
398	static inline char B64Encode1(unsigned char input)
399	{	1,719✔
400	if (input < 26) {	1,719✔
401	return static_cast<char>('A' + input);	910✔
402	}	910✔
403	if (input < 52) {	809✔
404	return static_cast<char>('a' + (input - 26));	577✔
405	}	577✔
406	if (input < 62) {	232✔
407	return static_cast<char>('0' + (input - 52));	227✔
408	}	227✔
409	if (input == 62) {	5!
410	return '+';	5✔
411	}	5✔
UNCOV 412	return '/';	×
413	};	5✔
414
415	}
416	using namespace anonpdns;
417
418	template <typename Container>
419	int B64Decode(const std::string& strInput, Container& strOutput)
420	{	737✔
421	// Set up a decoding buffer
422	long cBuf = 0;	737✔
423	// NOLINTNEXTLINE(cppcoreguidelines-pro-type-reinterpret-cast)
424	char* pBuf = reinterpret_cast<char*>(&cBuf);	737✔
425
426	// Decoding management...
427	int iBitGroup = 0;	737✔
428	int iInNum = 0;	737✔
429
430	// While there are characters to process...
431	//
432	// We'll decode characters in blocks of 4, as
433	// there are 4 groups of 6 bits in 3 bytes. The
434	// incoming Base64 character is first decoded, and
435	// then it is inserted into the decode buffer
436	// (with any relevant shifting, as required).
437	// Later, after all 3 bytes have been reconstituted,
438	// we assign them to the output string, ultimately
439	// to be returned as the original message.
440	int iInSize = static_cast<int>(strInput.size());	737✔
441	unsigned char cChar = '\0';	737✔
442	uint8_t pad = 0;	737✔
443	while (iInNum < iInSize) {	9,682!
444	// Fill the decode buffer with 4 groups of 6 bits
445	cBuf = 0; // clear	8,947✔
446	pad = 0;	8,947✔
447	for (iBitGroup = 0; iBitGroup < 4; ++iBitGroup) {	44,731!
448	if (iInNum < iInSize) {	35,786!
449	// Decode a character
450	if (strInput.at(iInNum) == '=') {	35,782!
451	pad++;	894✔
452	}	894✔
453	while (isspace(strInput.at(iInNum))) {	35,782!
454	iInNum++;	×
455	}	×
456	cChar = B64Decode1(strInput.at(iInNum++));	35,782✔
457
458	} // if	35,782✔
459	else {	4✔
460	// Decode a padded zero
461	cChar = '\0';	4✔
462	} // else	4✔
463
464	// Check for valid decode
465	if (cChar > 0x7F) {	35,786!
466	return -1;	2✔
467	}	2✔
468
469	// Adjust the bits
470	switch (iBitGroup) {	35,784✔
471	case 0:	8,947!
472	// The first group is copied into
473	// the least significant 6 bits of
474	// the decode buffer...these 6 bits
475	// will eventually shift over to be
476	// the most significant bits of the
477	// third byte.
478	cBuf = cBuf \| cChar;	8,947✔
479	break;	8,947✔
480
481	default:	26,837!
482	// For groupings 1-3, simply shift
483	// the bits in the decode buffer over
484	// by 6 and insert the 6 from the
485	// current decode character.
486	cBuf = (cBuf << 6) \| cChar;	26,837✔
487	break;	26,837✔
488
489	} // switch	35,784✔
490	} // for	35,784✔
491
492	// Interpret the resulting 3 bytes...note there
493	// may have been padding, so those padded bytes
494	// are actually ignored.
495	#if BYTE_ORDER == BIG_ENDIAN
496	// NOLINTNEXTLINE(cppcoreguidelines-pro-bounds-pointer-arithmetic)
497	strOutput.push_back(pBuf[sizeof(long) - 3]);
498	// NOLINTNEXTLINE(cppcoreguidelines-pro-bounds-pointer-arithmetic)
499	strOutput.push_back(pBuf[sizeof(long) - 2]);
500	// NOLINTNEXTLINE(cppcoreguidelines-pro-bounds-pointer-arithmetic)
501	strOutput.push_back(pBuf[sizeof(long) - 1]);
502	#else
503	// NOLINTNEXTLINE(cppcoreguidelines-pro-bounds-pointer-arithmetic)
504	strOutput.push_back(pBuf[2]);	8,945✔
505	// NOLINTNEXTLINE(cppcoreguidelines-pro-bounds-pointer-arithmetic)
506	strOutput.push_back(pBuf[1]);	8,945✔
507	// NOLINTNEXTLINE(cppcoreguidelines-pro-bounds-pointer-arithmetic)
508	strOutput.push_back(pBuf[0]);	8,945✔
509	#endif	8,945✔
510	} // while	8,945✔
511	if (pad) {	735!
512	strOutput.resize(strOutput.size() - pad);	635✔
513	}	635✔
514
515	return 1;	735✔
516	}	737✔
517
518	template int B64Decode<std::vector<uint8_t>>(const std::string& strInput, std::vector<uint8_t>& strOutput);
519	template int B64Decode<PacketBuffer>(const std::string& strInput, PacketBuffer& strOutput);
520	template int B64Decode<std::string>(const std::string& strInput, std::string& strOutput);
521
522	/*
523	www.kbcafe.com
524	Copyright 2001-2002 Randy Charles Morin
525	The Encode static method takes an array of 8-bit values and returns a base-64 stream.
526	*/
527
528	std::string Base64Encode(const std::string& src)
529	{	75✔
530	std::string retval;	75✔
531	if (src.empty()) {	75✔
532	return retval;	2✔
533	}	2✔
534	for (unsigned int i = 0; i < src.size(); i += 3) {	522✔
535	unsigned char by1 = 0;	449✔
536	unsigned char by2 = 0;	449✔
537	unsigned char by3 = 0;	449✔
538	by1 = src[i];	449✔
539	if (i + 1 < src.size()) {	449✔
540	by2 = src[i + 1];	423✔
541	};	423✔
542	if (i + 2 < src.size()) {	449✔
543	by3 = src[i + 2];	398✔
544	}	398✔
545	unsigned char by4 = 0;	449✔
546	unsigned char by5 = 0;	449✔
547	unsigned char by6 = 0;	449✔
548	unsigned char by7 = 0;	449✔
549	by4 = by1 >> 2;	449✔
550	by5 = ((by1 & 0x3) << 4) \| (by2 >> 4);	449✔
551	by6 = ((by2 & 0xf) << 2) \| (by3 >> 6);	449✔
552	by7 = by3 & 0x3f;	449✔
553	retval += B64Encode1(by4);	449✔
554	retval += B64Encode1(by5);	449✔
555	if (i + 1 < src.size()) {	449✔
556	retval += B64Encode1(by6);	423✔
557	}	423✔
558	else {	26✔
559	retval += "=";	26✔
560	};	26✔
561	if (i + 2 < src.size()) {	449✔
562	retval += B64Encode1(by7);	398✔
563	}	398✔
564	else {	51✔
565	retval += "=";	51✔
566	};	51✔
567	/* if ((i % (76 / 4 * 3)) == 0)
568	{
569	retval += "\r\n";
570	}*/
571	};	449✔
572	return retval;	73✔
573	};	75✔

PowerDNS / pdns / 12046188202

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous