blob: 5a5468fe003603d3b1339c7a46b9e39e4d45038e [file]
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you 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
*
* http://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 <array>
#include <cstdint>
#include <limits>
#include <string>
#include <gtest/gtest.h>
#include "lib.rs.h"
TEST(LowLevelE2E_Identifier, FromStringCreatesStringIdentifier) {
RecordProperty("description", "Creates a string identifier and preserves its UTF-8 byte payload.");
const std::string value = "stream-identifier";
iggy::ffi::Identifier identifier;
ASSERT_NO_THROW(identifier.set_string(value));
ASSERT_EQ(identifier.kind, "string");
ASSERT_EQ(identifier.length, value.size());
ASSERT_EQ(identifier.value.size(), value.size());
for (size_t i = 0; i < value.size(); ++i) {
EXPECT_EQ(identifier.value[i], static_cast<std::uint8_t>(value[i]));
}
}
TEST(LowLevelE2E_Identifier, FromStringAcceptsExact255ByteUtf8Value) {
RecordProperty("description", "Accepts a UTF-8 string identifier whose encoded byte length is exactly 255.");
std::string value;
for (size_t i = 0; i < 127; ++i) {
value += "\xC2\xA2";
}
value += "a";
ASSERT_EQ(value.size(), 255u);
iggy::ffi::Identifier identifier;
ASSERT_NO_THROW(identifier.set_string(value));
ASSERT_EQ(identifier.kind, "string");
ASSERT_EQ(identifier.length, value.size());
ASSERT_EQ(identifier.value.size(), value.size());
for (size_t i = 0; i < value.size(); ++i) {
EXPECT_EQ(identifier.value[i], static_cast<std::uint8_t>(value[i]));
}
}
TEST(LowLevelE2E_Identifier, FromStringRejectsEmptyValue) {
RecordProperty("description", "Rejects creating a string identifier from an empty string.");
iggy::ffi::Identifier identifier;
ASSERT_THROW(identifier.set_string(""), std::exception);
}
TEST(LowLevelE2E_Identifier, FromStringRejectsUtf8ValueLongerThan255Bytes) {
RecordProperty("description", "Rejects creating a UTF-8 string identifier longer than 255 encoded bytes.");
iggy::ffi::Identifier identifier;
std::string too_long_value;
for (size_t i = 0; i < 128; ++i) {
too_long_value += "\xC2\xA2";
}
ASSERT_EQ(too_long_value.size(), 256u);
ASSERT_THROW(identifier.set_string(too_long_value), std::exception);
}
TEST(LowLevelE2E_Identifier, FromStringRejectsAsciiValueLongerThan255Bytes) {
RecordProperty("description", "Rejects creating an ASCII string identifier longer than 255 bytes.");
iggy::ffi::Identifier identifier;
const std::string too_long_value(256, 'a');
ASSERT_THROW(identifier.set_string(too_long_value), std::exception);
}
TEST(LowLevelE2E_Identifier, FromNumericCreatesNumericIdentifier) {
RecordProperty("description", "Creates a numeric identifier encoded as four little-endian bytes.");
iggy::ffi::Identifier identifier;
constexpr std::uint32_t value = 0x12345678;
constexpr std::array<std::uint8_t, 4> expected_bytes = {0x78, 0x56, 0x34, 0x12};
ASSERT_NO_THROW(identifier.set_numeric(value));
ASSERT_EQ(identifier.kind, "numeric");
ASSERT_EQ(identifier.length, 4u);
ASSERT_EQ(identifier.value.size(), expected_bytes.size());
for (size_t i = 0; i < expected_bytes.size(); ++i) {
EXPECT_EQ(identifier.value[i], expected_bytes[i]);
}
}
TEST(LowLevelE2E_Identifier, FromNumericCreatesUint32MaxIdentifier) {
RecordProperty("description", "Creates a numeric identifier for UINT32_MAX using four 0xFF bytes.");
iggy::ffi::Identifier identifier;
constexpr std::array<std::uint8_t, 4> expected_bytes = {0xFF, 0xFF, 0xFF, 0xFF};
ASSERT_NO_THROW(identifier.set_numeric(std::numeric_limits<std::uint32_t>::max()));
ASSERT_EQ(identifier.kind, "numeric");
ASSERT_EQ(identifier.length, 4u);
ASSERT_EQ(identifier.value.size(), expected_bytes.size());
for (size_t i = 0; i < expected_bytes.size(); ++i) {
EXPECT_EQ(identifier.value[i], expected_bytes[i]);
}
}
TEST(LowLevelE2E_Identifier, FromNumericOverwritesExistingStringIdentifier) {
RecordProperty("description", "Replaces a previously created string identifier with numeric identifier data.");
iggy::ffi::Identifier identifier;
ASSERT_NO_THROW(identifier.set_string("temporary-name"));
ASSERT_NO_THROW(identifier.set_numeric(7));
ASSERT_EQ(identifier.kind, "numeric");
ASSERT_EQ(identifier.length, 4u);
ASSERT_EQ(identifier.value.size(), 4u);
EXPECT_EQ(identifier.value[0], 7u);
EXPECT_EQ(identifier.value[1], 0u);
EXPECT_EQ(identifier.value[2], 0u);
EXPECT_EQ(identifier.value[3], 0u);
}
TEST(LowLevelE2E_Identifier, FromStringOverwritesExistingNumericIdentifier) {
RecordProperty("description", "Replaces a previously created numeric identifier with string identifier data.");
const std::string value = "replacement-name";
iggy::ffi::Identifier identifier;
ASSERT_NO_THROW(identifier.set_numeric(42));
ASSERT_NO_THROW(identifier.set_string(value));
ASSERT_EQ(identifier.kind, "string");
ASSERT_EQ(identifier.length, value.size());
ASSERT_EQ(identifier.value.size(), value.size());
for (size_t i = 0; i < value.size(); ++i) {
EXPECT_EQ(identifier.value[i], static_cast<std::uint8_t>(value[i]));
}
}