// Copyright 2020 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// https://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
#include "third_party/private_membership/src/internal/rlwe_id_utils.h"
#include <string>
#include <vector>
#include "third_party/private_membership/src/internal/constants.h"
#include "third_party/private_membership/src/internal/testing/constants.h"
#include <gmock/gmock.h>
#include <gtest/gtest.h>
#include "absl/status/status.h"
#include "third_party/shell-encryption/src/testing/protobuf_matchers.h"
#include "third_party/shell-encryption/src/testing/status_matchers.h"
#include "third_party/shell-encryption/src/testing/status_testing.h"
namespace private_membership {
namespace rlwe {
namespace {
using ::rlwe::testing::StatusIs;
using ::testing::HasSubstr;
TEST(RlweIdUtils, ComputeBucketStoredEncryptedIdSuccess) {
EncryptedBucketsParameters params;
params.set_encrypted_bucket_id_length(14);
params.set_sensitive_id_hash_type(ENCRYPTED_BUCKET_TEST_HASH_TYPE);
RlwePlaintextId plaintext_id;
plaintext_id.set_non_sensitive_id("nsid");
plaintext_id.set_sensitive_id("sid");
::private_join_and_compute::Context ctx;
ASSERT_OK_AND_ASSIGN(
auto ec_cipher,
::private_join_and_compute::ECCommutativeCipher::CreateWithNewKey(
kTestCurveId, ::private_join_and_compute::ECCommutativeCipher::HashType::SHA256));
std::string full_id = HashRlwePlaintextId(plaintext_id);
ASSERT_OK_AND_ASSIGN(std::string encrypted_id, ec_cipher->Encrypt(full_id));
ASSERT_OK_AND_ASSIGN(std::string id1,
ComputeBucketStoredEncryptedId(plaintext_id, params,
ec_cipher.get(), &ctx));
ASSERT_OK_AND_ASSIGN(std::string id2, ComputeBucketStoredEncryptedId(
encrypted_id, params, &ctx));
EXPECT_EQ(id1, id2);
EXPECT_GE(id1.length() + params.encrypted_bucket_id_length(),
kStoredEncryptedIdByteLength);
}
TEST(RlweIdUtils, ComputeBucketStoredEncryptedIdEmpty) {
EncryptedBucketsParameters empty_id_params;
empty_id_params.set_encrypted_bucket_id_length(kStoredEncryptedIdByteLength *
8);
empty_id_params.set_sensitive_id_hash_type(ENCRYPTED_BUCKET_TEST_HASH_TYPE);
RlwePlaintextId plaintext_id;
plaintext_id.set_non_sensitive_id("empty-nsid");
plaintext_id.set_sensitive_id("empty-sid");
::private_join_and_compute::Context ctx;
ASSERT_OK_AND_ASSIGN(
auto ec_cipher,
::private_join_and_compute::ECCommutativeCipher::CreateWithNewKey(
kTestCurveId, ::private_join_and_compute::ECCommutativeCipher::HashType::SHA256));
ASSERT_OK_AND_ASSIGN(std::string id, ComputeBucketStoredEncryptedId(
plaintext_id, empty_id_params,
ec_cipher.get(), &ctx));
EXPECT_TRUE(id.empty());
}
TEST(RlweIdUtils, ComputeBucketStoredEncryptedIdError) {
EncryptedBucketsParameters params;
params.set_encrypted_bucket_id_length(14);
params.set_sensitive_id_hash_type(ENCRYPTED_BUCKET_TEST_HASH_TYPE);
RlwePlaintextId plaintext_id;
plaintext_id.set_non_sensitive_id("nsid-test");
plaintext_id.set_sensitive_id("sid-test");
::private_join_and_compute::Context ctx;
ASSERT_OK_AND_ASSIGN(
auto ec_cipher,
::private_join_and_compute::ECCommutativeCipher::CreateWithNewKey(
kTestCurveId, ::private_join_and_compute::ECCommutativeCipher::HashType::SHA256));
EXPECT_THAT(
ComputeBucketStoredEncryptedId(plaintext_id, params, nullptr, &ctx),
StatusIs(absl::StatusCode::kInvalidArgument, HasSubstr("non-null")));
EXPECT_THAT(
ComputeBucketStoredEncryptedId(plaintext_id, params, ec_cipher.get(),
nullptr),
StatusIs(absl::StatusCode::kInvalidArgument, HasSubstr("non-null")));
EXPECT_THAT(
ComputeBucketStoredEncryptedId("encrypted-id", params, nullptr),
StatusIs(absl::StatusCode::kInvalidArgument, HasSubstr("non-null")));
}
TEST(RlweIdUtils, EnsureInjectiveInternalProtoNoNonSensitiveId) {
RlwePlaintextId id1;
id1.set_sensitive_id("sid1");
RlwePlaintextId id2;
id2.set_sensitive_id("sid2");
EXPECT_EQ(HashRlwePlaintextId(id1), HashRlwePlaintextId(id1));
EXPECT_EQ(HashRlwePlaintextId(id2), HashRlwePlaintextId(id2));
EXPECT_NE(HashRlwePlaintextId(id1), HashRlwePlaintextId(id2));
}
TEST(RlweIdUtils, EnsureInjectiveInternalProto) {
RlwePlaintextId id1;
id1.set_non_sensitive_id("nsid1");
id1.set_sensitive_id("sid1");
RlwePlaintextId id2;
id2.set_non_sensitive_id("nsid2");
id2.set_sensitive_id("sid2");
EXPECT_EQ(HashRlwePlaintextId(id1), HashRlwePlaintextId(id1));
EXPECT_EQ(HashRlwePlaintextId(id2), HashRlwePlaintextId(id2));
EXPECT_NE(HashRlwePlaintextId(id1), HashRlwePlaintextId(id2));
RlwePlaintextId id3;
id3.set_non_sensitive_id("1");
id3.set_sensitive_id("23456789111");
RlwePlaintextId id4;
id4.set_non_sensitive_id("11234567891");
id4.set_sensitive_id("1");
EXPECT_NE(HashRlwePlaintextId(id3), HashRlwePlaintextId(id4));
}
TEST(RlweIdUtils, HashNonsensitiveIdWithSalt) {
::private_join_and_compute::Context ctx;
std::string nsid1("nsid1");
std::string nsid2("nsid2");
ASSERT_OK_AND_ASSIGN(
std::string hash1a,
HashNonsensitiveIdWithSalt(nsid1, HashType::TEST_HASH_TYPE, &ctx));
ASSERT_OK_AND_ASSIGN(
std::string hash1b,
HashNonsensitiveIdWithSalt(nsid1, HashType::TEST_HASH_TYPE, &ctx));
ASSERT_OK_AND_ASSIGN(
std::string hash2a,
HashNonsensitiveIdWithSalt(nsid2, HashType::TEST_HASH_TYPE, &ctx));
ASSERT_OK_AND_ASSIGN(
std::string hash2b,
HashNonsensitiveIdWithSalt(nsid2, HashType::TEST_HASH_TYPE, &ctx));
EXPECT_EQ(hash1a, hash1b);
EXPECT_EQ(hash2a, hash2b);
EXPECT_NE(hash1a, hash2a);
}
TEST(RlweIdUtils, HashNonsensitiveIdWithSaltRegression) {
::private_join_and_compute::Context ctx;
std::string nsid("nsid");
ASSERT_OK_AND_ASSIGN(std::string hash, HashNonsensitiveIdWithSalt(
nsid, HashType::SHA256, &ctx));
constexpr unsigned char expected_hash[] = {
0x7f, 0xfb, 0xbd, 0x26, 0x8d, 0x1b, 0xd4, 0xc1, 0x7c, 0xa0, 0x3d,
0xf2, 0x1c, 0x5c, 0x6b, 0x45, 0x72, 0xe5, 0x2a, 0x99, 0x9b, 0x4a,
0x4b, 0x51, 0xfe, 0x6d, 0x67, 0x68, 0xf0, 0xa6, 0xe7, 0x0};
EXPECT_EQ(hash, std::string(reinterpret_cast<const char*>(expected_hash),
hash.length()));
}
TEST(RlweIdUtils, AllSensitiveIdHashTypesCovered) {
RlwePlaintextId plaintext_id;
plaintext_id.set_non_sensitive_id("nsid");
plaintext_id.set_sensitive_id("sid");
::private_join_and_compute::Context ctx;
ASSERT_OK_AND_ASSIGN(
auto ec_cipher,
::private_join_and_compute::ECCommutativeCipher::CreateWithNewKey(
kTestCurveId, ::private_join_and_compute::ECCommutativeCipher::HashType::SHA256));
// The EnumerateEnumValues method is unavailable in Chromium.
// Test uses a hardcoded vector of the enums in order to allow clean
// compilation and have this test coverage in Chromium.
// LINT.IfChange(encrypted_bucket_hash_types)
std::vector<EncryptedBucketHashType> encrypted_bucket_hash_types = {
ENCRYPTED_BUCKET_HASH_TYPE_UNDEFINED, ENCRYPTED_BUCKET_TEST_HASH_TYPE,
SHA256_NON_SENSITIVE_AND_SENSITIVE_ID,
};
// LINT.ThenChange()
for (const auto& hash_type : encrypted_bucket_hash_types) {
EncryptedBucketsParameters params;
params.set_encrypted_bucket_id_length(14);
params.set_sensitive_id_hash_type(hash_type);
if (hash_type == ENCRYPTED_BUCKET_HASH_TYPE_UNDEFINED) {
EXPECT_THAT(ComputeBucketStoredEncryptedId(plaintext_id, params,
ec_cipher.get(), &ctx),
StatusIs(absl::StatusCode::kInvalidArgument,
HasSubstr("must be defined.")));
} else {
EXPECT_OK(ComputeBucketStoredEncryptedId(plaintext_id, params,
ec_cipher.get(), &ctx));
}
}
}
} // namespace
} // namespace rlwe
} // namespace private_membership