| /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil -*- */ |
| /** |
| * Copyright (C) 2013 Regents of the University of California. |
| * @author: Yingdi Yu <yingdi@cs.ucla.edu> |
| * @author: Jeff Thompson <jefft0@remap.ucla.edu> |
| * See COPYING for copyright and distribution information. |
| */ |
| |
| #ifndef NDN_KEY_CHAIN_HPP |
| #define NDN_KEY_CHAIN_HPP |
| |
| #include "identity-certificate.hpp" |
| #include "public-key.hpp" |
| #include "signature-sha256-with-rsa.hpp" |
| #include "../interest.hpp" |
| #include "../encoding/tlv-security.hpp" |
| |
| //PublicInfo |
| #include "sec-public-info-sqlite3.hpp" |
| #include "sec-public-info-memory.hpp" |
| //TPM |
| #include "sec-tpm-file.hpp" |
| #include "sec-tpm-memory.hpp" |
| |
| #ifdef NDN_CPP_HAVE_OSX_SECURITY |
| #include "sec-tpm-osx.hpp" |
| #endif |
| |
| |
| namespace ndn { |
| |
| /** |
| * KeyChain is one of the main classes of the security library. |
| * |
| * The KeyChain class provides a set of interfaces of identity management and private key related operations. |
| */ |
| template<class Info, class Tpm> |
| class KeyChainImpl : public Info, public Tpm |
| { |
| typedef typename Info::Error InfoError; |
| public: |
| |
| /** |
| * Create an identity by creating a pair of Key-Signing-Key (KSK) for this identity and a self-signed certificate of the KSK. |
| * @param identityName The name of the identity. |
| * @return The name of the default certificate of the identity. |
| */ |
| Name |
| createIdentity(const Name& identityName) |
| { |
| if (!Info::doesIdentityExist(identityName)) |
| Info::addIdentity(identityName); |
| |
| Name keyName = Info::getDefaultKeyNameForIdentity(identityName); |
| |
| if(keyName.empty()) |
| keyName = generateRSAKeyPairAsDefault(identityName, true); |
| |
| Name certName = Info::getDefaultCertificateNameForKey(keyName); |
| |
| if(certName.empty()) |
| { |
| shared_ptr<IdentityCertificate> selfCert = selfSign(keyName); |
| Info::addCertificateAsIdentityDefault(*selfCert); |
| certName = selfCert->getName(); |
| } |
| |
| return certName; |
| } |
| |
| /** |
| * Generate a pair of RSA keys for the specified identity. |
| * @param identityName The name of the identity. |
| * @param isKsk true for generating a Key-Signing-Key (KSK), false for a Data-Signing-Key (KSK). |
| * @param keySize The size of the key. |
| * @return The generated key name. |
| */ |
| Name |
| generateRSAKeyPair(const Name& identityName, bool isKsk = false, int keySize = 2048) |
| { |
| return generateKeyPair(identityName, isKsk, KEY_TYPE_RSA, keySize); |
| } |
| |
| /** |
| * Generate a pair of RSA keys for the specified identity and set it as default key for the identity. |
| * @param identityName The name of the identity. |
| * @param isKsk true for generating a Key-Signing-Key (KSK), false for a Data-Signing-Key (KSK). |
| * @param keySize The size of the key. |
| * @return The generated key name. |
| */ |
| Name |
| generateRSAKeyPairAsDefault(const Name& identityName, bool isKsk = false, int keySize = 2048) |
| { |
| Name keyName = generateKeyPair(identityName, isKsk, KEY_TYPE_RSA, keySize); |
| |
| Info::setDefaultKeyNameForIdentity(keyName); |
| |
| return keyName; |
| } |
| |
| /** |
| * Create an identity certificate for a public key managed by this IdentityManager. |
| * @param certificatePrefix The name of public key to be signed. |
| * @param signerCertificateName The name of signing certificate. |
| * @param notBefore The notBefore value in the validity field of the generated certificate. |
| * @param notAfter The notAfter vallue in validity field of the generated certificate. |
| * @return The name of generated identity certificate. |
| */ |
| shared_ptr<IdentityCertificate> |
| createIdentityCertificate |
| (const Name& certificatePrefix, |
| const Name& signerCertificateName, |
| const MillisecondsSince1970& notBefore, |
| const MillisecondsSince1970& notAfter) |
| { |
| Name keyName = getKeyNameFromCertificatePrefix(certificatePrefix); |
| |
| shared_ptr<PublicKey> pubKey = Info::getPublicKey(keyName); |
| if (!pubKey) |
| throw InfoError("Requested public key [" + keyName.toUri() + "] doesn't exist"); |
| |
| shared_ptr<IdentityCertificate> certificate = |
| createIdentityCertificate(certificatePrefix, |
| *pubKey, |
| signerCertificateName, |
| notBefore, notAfter); |
| |
| Info::addCertificate(*certificate); |
| |
| return certificate; |
| } |
| |
| |
| /** |
| * Create an identity certificate for a public key supplied by the caller. |
| * @param certificatePrefix The name of public key to be signed. |
| * @param publickey The public key to be signed. |
| * @param signerCertificateName The name of signing certificate. |
| * @param notBefore The notBefore value in the validity field of the generated certificate. |
| * @param notAfter The notAfter vallue in validity field of the generated certificate. |
| * @return The generated identity certificate. |
| */ |
| shared_ptr<IdentityCertificate> |
| createIdentityCertificate |
| (const Name& certificatePrefix, |
| const PublicKey& publicKey, |
| const Name& signerCertificateName, |
| const MillisecondsSince1970& notBefore, |
| const MillisecondsSince1970& notAfter) |
| { |
| shared_ptr<IdentityCertificate> certificate (new IdentityCertificate()); |
| Name keyName = getKeyNameFromCertificatePrefix(certificatePrefix); |
| |
| Name certificateName = certificatePrefix; |
| certificateName.append("ID-CERT").appendVersion(); |
| |
| certificate->setName(certificateName); |
| certificate->setNotBefore(notBefore); |
| certificate->setNotAfter(notAfter); |
| certificate->setPublicKeyInfo(publicKey); |
| certificate->addSubjectDescription(CertificateSubjectDescription("2.5.4.41", keyName.toUri())); |
| certificate->encode(); |
| |
| sign(*certificate, signerCertificateName); |
| |
| return certificate; |
| } |
| |
| void |
| sign(Data &data) |
| { |
| if (!Info::defaultCertificate()) |
| { |
| Info::refreshDefaultCertificate(); |
| |
| if(!Info::defaultCertificate()) |
| throw InfoError("Default IdentityCertificate cannot be determined"); |
| } |
| |
| sign(data, *Info::defaultCertificate()); |
| } |
| |
| void |
| sign(Interest &interest) |
| { |
| if (!Info::defaultCertificate()) |
| { |
| Info::refreshDefaultCertificate(); |
| |
| if(!Info::defaultCertificate()) |
| throw InfoError("Default IdentityCertificate cannot be determined"); |
| } |
| |
| sign(interest, *Info::defaultCertificate()); |
| } |
| |
| /** |
| * Wire encode the Data object, sign it and set its signature. |
| * @param data The Data object to be signed. This updates its signature and key locator field and wireEncoding. |
| * @param certificateName The certificate name of the key to use for signing. If omitted, infer the signing identity from the data packet name. |
| */ |
| void |
| sign(Data& data, const Name& certificateName) |
| { |
| shared_ptr<IdentityCertificate> cert = Info::getCertificate(certificateName); |
| if (!cert) |
| throw InfoError("Requested certificate [" + certificateName.toUri() + "] doesn't exist"); |
| |
| SignatureSha256WithRsa signature; |
| signature.setKeyLocator(certificateName.getPrefix(-1)); // implicit conversion should take care |
| data.setSignature(signature); |
| |
| // For temporary usage, we support RSA + SHA256 only, but will support more. |
| signDataInTpm(data, cert->getPublicKeyName(), DIGEST_ALGORITHM_SHA256); |
| } |
| |
| void |
| sign(Interest &interest, const Name &certificateName) |
| { |
| shared_ptr<IdentityCertificate> cert = Info::getCertificate(certificateName); |
| if(!static_cast<bool>(cert)) |
| throw InfoError("Requested certificate [" + certificateName.toUri() + "] doesn't exist"); |
| |
| SignatureSha256WithRsa signature; |
| signature.setKeyLocator(certificateName.getPrefix(-1)); // implicit conversion should take care |
| |
| Name signedName = Name(interest.getName()).append(signature.getInfo()); |
| |
| signature.setValue(Tpm::signInTpm(signedName.wireEncode().value(), |
| signedName.wireEncode().value_size(), |
| cert->getPublicKeyName(), |
| DIGEST_ALGORITHM_SHA256)); |
| signedName.append(signature.getValue()); |
| interest.setName(signedName); |
| } |
| |
| /** |
| * Sign the byte array using a certificate name and return a Signature object. |
| * @param buffer The byte array to be signed. |
| * @param bufferLength the length of buffer. |
| * @param certificateName The certificate name used to get the signing key and which will be put into KeyLocator. |
| * @return The Signature. |
| */ |
| Signature |
| sign(const uint8_t* buffer, size_t bufferLength, const Name& certificateName) |
| { |
| shared_ptr<IdentityCertificate> cert = Info::getCertificate(certificateName); |
| if (!static_cast<bool>(cert)) |
| throw InfoError("Requested certificate [" + certificateName.toUri() + "] doesn't exist"); |
| |
| SignatureSha256WithRsa signature; |
| signature.setKeyLocator(certificateName.getPrefix(-1)); // implicit conversion should take care |
| |
| // For temporary usage, we support RSA + SHA256 only, but will support more. |
| signature.setValue(Tpm::signInTpm(buffer, bufferLength, cert->getPublicKeyName(), DIGEST_ALGORITHM_SHA256)); |
| return signature; |
| } |
| |
| /** |
| * Wire encode the Data object, sign it and set its signature. |
| * @param data The Data object to be signed. This updates its signature and key locator field and wireEncoding. |
| * @param identityName The identity name for the key to use for signing. If omitted, infer the signing identity from the data packet name. |
| */ |
| void |
| signByIdentity(Data& data, const Name& identityName) |
| { |
| Name signingCertificateName = Info::getDefaultCertificateNameForIdentity(identityName); |
| |
| if (signingCertificateName.empty()) |
| signingCertificateName = createIdentity(identityName); |
| |
| sign(data, signingCertificateName); |
| } |
| |
| void |
| signByIdentity(Interest& interest, const Name& identityName) |
| { |
| Name signingCertificateName = Info::getDefaultCertificateNameForIdentity(identityName); |
| |
| if (signingCertificateName.empty()) |
| signingCertificateName = createIdentity(identityName); |
| |
| sign(interest, signingCertificateName); |
| } |
| |
| |
| /** |
| * Sign the byte array using an identity name and return a Signature object. |
| * @param buffer The byte array to be signed. |
| * @param bufferLength the length of buffer. |
| * @param identityName The identity name. |
| * @return The Signature. |
| */ |
| Signature |
| signByIdentity(const uint8_t* buffer, size_t bufferLength, const Name& identityName) |
| { |
| Name signingCertificateName = Info::getDefaultCertificateNameForIdentity(identityName); |
| |
| if (signingCertificateName.empty()) |
| signingCertificateName = createIdentity(identityName); |
| |
| return sign(buffer, bufferLength, signingCertificateName); |
| } |
| |
| /** |
| * Generate a self-signed certificate for a public key. |
| * @param keyName The name of the public key. |
| * @return The generated certificate. |
| */ |
| shared_ptr<IdentityCertificate> |
| selfSign(const Name& keyName) |
| { |
| if(keyName.empty()) |
| throw InfoError("Incorrect key name: " + keyName.toUri()); |
| |
| shared_ptr<IdentityCertificate> certificate = make_shared<IdentityCertificate>(); |
| |
| Name certificateName = keyName.getPrefix(-1); |
| certificateName.append("KEY").append(keyName.get(-1)).append("ID-CERT").appendVersion(); |
| |
| shared_ptr<PublicKey> pubKey = Info::getPublicKey(keyName); |
| if (!pubKey) |
| throw InfoError("Requested public key [" + keyName.toUri() + "] doesn't exist"); |
| |
| certificate->setName(certificateName); |
| certificate->setNotBefore(getNow()); |
| certificate->setNotAfter(getNow() + 630720000 /* 20 years*/); |
| certificate->setPublicKeyInfo(*pubKey); |
| certificate->addSubjectDescription(CertificateSubjectDescription("2.5.4.41", keyName.toUri())); |
| certificate->encode(); |
| |
| selfSign(*certificate); |
| return certificate; |
| } |
| |
| /** |
| * @brief Self-sign the supplied identity certificate |
| */ |
| void |
| selfSign (IdentityCertificate& cert) |
| { |
| SignatureSha256WithRsa signature; |
| signature.setKeyLocator(cert.getName().getPrefix(-1)); // implicit conversion should take care |
| cert.setSignature(signature); |
| |
| // For temporary usage, we support RSA + SHA256 only, but will support more. |
| signDataInTpm(cert, cert.getPublicKeyName(), DIGEST_ALGORITHM_SHA256); |
| } |
| |
| void |
| deleteCertificate (const Name &certificateName) |
| { |
| if(Info::getDefaultIdentity() == IdentityCertificate::certificateNameToPublicKeyName(certificateName).getPrefix(-1)) |
| return; |
| |
| Info::deleteCertificateInfo(certificateName); |
| } |
| |
| void |
| deleteKey (const Name &keyName) |
| { |
| if(Info::getDefaultIdentity() == keyName.getPrefix(-1)) |
| return; |
| |
| Info::deletePublicKeyInfo(keyName); |
| Tpm::deleteKeyPairInTpm(keyName); |
| } |
| |
| void |
| deleteIdentity (const Name& identity) |
| { |
| if(Info::getDefaultIdentity() == identity) |
| return; |
| |
| std::vector<Name> nameList; |
| Info::getAllKeyNamesOfIdentity(identity, nameList, true); |
| Info::getAllKeyNamesOfIdentity(identity, nameList, false); |
| |
| Info::deleteIdentityInfo(identity); |
| |
| std::vector<Name>::const_iterator it = nameList.begin(); |
| for(; it != nameList.end(); it++) |
| Tpm::deleteKeyPairInTpm(*it); |
| } |
| |
| Block |
| exportIdentity(const Name& identity, bool inTerminal = true, std::string passwordStr = "") |
| { |
| if (!Info::doesIdentityExist(identity)) |
| throw InfoError("Identity does not exist!"); |
| |
| Name keyName = Info::getDefaultKeyNameForIdentity(identity); |
| |
| if(keyName.empty()) |
| throw InfoError("Default key does not exist!"); |
| |
| ConstBufferPtr pkcs8 = Tpm::exportPrivateKeyPkcs8FromTpm(keyName, inTerminal, passwordStr); |
| Block wireKey(tlv::security::KeyPackage, pkcs8); |
| |
| Name certName = Info::getDefaultCertificateNameForKey(keyName); |
| |
| if(certName.empty()) |
| { |
| shared_ptr<IdentityCertificate> selfCert = selfSign(keyName); |
| Info::addCertificateAsIdentityDefault(*selfCert); |
| certName = selfCert->getName(); |
| } |
| |
| shared_ptr<IdentityCertificate> cert = Info::getCertificate(certName); |
| Block wireCert(tlv::security::CertificatePackage, cert->wireEncode()); |
| |
| Block wire(tlv::security::IdentityPackage); |
| wire.push_back(wireCert); |
| wire.push_back(wireKey); |
| |
| return wire; |
| } |
| |
| void |
| importIdentity(const Block& block, bool inTerminal = true, std::string passwordStr = "") |
| { |
| block.parse(); |
| |
| Data data; |
| data.wireDecode(block.get(tlv::security::CertificatePackage).blockFromValue()); |
| shared_ptr<IdentityCertificate> cert = make_shared<IdentityCertificate>(data); |
| |
| Name keyName = IdentityCertificate::certificateNameToPublicKeyName(cert->getName()); |
| Name identity = keyName.getPrefix(-1); |
| |
| // Add identity |
| if (Info::doesIdentityExist(identity)) |
| deleteIdentity(identity); |
| Info::addIdentity(identity); |
| |
| // Add key |
| Block wireKey = block.get(tlv::security::KeyPackage); |
| if (Tpm::doesKeyExistInTpm(keyName, KEY_CLASS_PRIVATE)) |
| deleteKey(keyName); |
| Tpm::importPrivateKeyPkcs8IntoTpm(keyName, wireKey.value(), wireKey.value_size(), inTerminal, passwordStr); |
| shared_ptr<PublicKey> pubKey = Tpm::getPublicKeyFromTpm(keyName.toUri()); |
| Info::addPublicKey(keyName, KEY_TYPE_RSA, *pubKey); // HACK! We should set key type according to the pkcs8 info. |
| Info::setDefaultKeyNameForIdentity(keyName); |
| |
| // Add cert |
| if (Info::doesCertificateExist(cert->getName())) |
| deleteCertificate(cert->getName()); |
| Info::addCertificateAsIdentityDefault(*cert); |
| } |
| |
| |
| private: |
| |
| void |
| sign(Data &data, const IdentityCertificate& certificate) |
| { |
| SignatureSha256WithRsa signature; |
| signature.setKeyLocator(certificate.getName().getPrefix(-1)); |
| data.setSignature(signature); |
| |
| // For temporary usage, we support RSA + SHA256 only, but will support more. |
| signDataInTpm(data, certificate.getPublicKeyName(), DIGEST_ALGORITHM_SHA256); |
| } |
| |
| void |
| sign(Interest &interest, const IdentityCertificate& certificate) |
| { |
| SignatureSha256WithRsa signature; |
| signature.setKeyLocator(certificate.getName().getPrefix(-1)); // implicit conversion should take care |
| |
| Name signedName = Name(interest.getName()).append(signature.getInfo()); |
| |
| signature.setValue(Tpm::signInTpm(signedName.wireEncode().value(), |
| signedName.wireEncode().value_size(), |
| certificate.getPublicKeyName(), |
| DIGEST_ALGORITHM_SHA256)); |
| |
| signedName.append(signature.getValue()); |
| interest.setName(signedName); |
| } |
| |
| /** |
| * Generate a key pair for the specified identity. |
| * @param identityName The name of the specified identity. |
| * @param isKsk true for generating a Key-Signing-Key (KSK), false for a Data-Signing-Key (KSK). |
| * @param keyType The type of the key pair, e.g. KEY_TYPE_RSA. |
| * @param keySize The size of the key pair. |
| * @return The name of the generated key. |
| */ |
| Name |
| generateKeyPair(const Name& identityName, bool isKsk = false, KeyType keyType = KEY_TYPE_RSA, int keySize = 2048) |
| { |
| Name keyName = Info::getNewKeyName(identityName, isKsk); |
| |
| Tpm::generateKeyPairInTpm(keyName.toUri(), keyType, keySize); |
| |
| shared_ptr<PublicKey> pubKey = Tpm::getPublicKeyFromTpm(keyName.toUri()); |
| Info::addPublicKey(keyName, keyType, *pubKey); |
| |
| return keyName; |
| } |
| |
| static Name |
| getKeyNameFromCertificatePrefix(const Name& certificatePrefix) |
| { |
| Name result; |
| |
| std::string keyString("KEY"); |
| int i = 0; |
| for(; i < certificatePrefix.size(); i++) { |
| if (certificatePrefix.get(i).toEscapedString() == keyString) |
| break; |
| } |
| |
| if (i >= certificatePrefix.size()) |
| throw InfoError("Identity Certificate Prefix does not have a KEY component"); |
| |
| result.append(certificatePrefix.getSubName(0, i)); |
| result.append(certificatePrefix.getSubName(i + 1, certificatePrefix.size()-i-1)); |
| |
| return result; |
| } |
| |
| /** |
| * Fetch the private key for keyName and sign the data, and set the signature block of the data packet. |
| * @param data Reference to the input data packet. |
| * @param keyName The name of the signing key. |
| * @param digestAlgorithm the digest algorithm. |
| * @throws Tpm::Error |
| */ |
| void |
| signDataInTpm(Data &data, const Name& keyName, DigestAlgorithm digestAlgorithm) |
| { |
| data.setSignatureValue |
| (Tpm::signInTpm(data.wireEncode().value(), |
| data.wireEncode().value_size() - data.getSignature().getValue().size(), |
| keyName, digestAlgorithm)); |
| } |
| |
| }; |
| |
| } |
| |
| |
| |
| #if defined(NDN_CPP_HAVE_OSX_SECURITY) and defined(NDN_CPP_WITH_OSX_KEYCHAIN) |
| |
| namespace ndn |
| { |
| typedef KeyChainImpl<SecPublicInfoSqlite3, SecTpmOsx> KeyChain; |
| }; |
| |
| #else |
| |
| namespace ndn |
| { |
| typedef KeyChainImpl<SecPublicInfoSqlite3, SecTpmFile> KeyChain; |
| }; |
| |
| #endif //NDN_CPP_HAVE_OSX_SECURITY |
| |
| #endif |