BSON: unsigned integers
This commit is contained in:
parent
c0d8921a67
commit
83b427ad67
3 changed files with 136 additions and 4 deletions
|
@ -723,14 +723,42 @@ class binary_writer
|
||||||
|
|
||||||
std::size_t write_bson_integer(const typename BasicJsonType::string_t& name, const BasicJsonType& j)
|
std::size_t write_bson_integer(const typename BasicJsonType::string_t& name, const BasicJsonType& j)
|
||||||
{
|
{
|
||||||
if (j.m_value.number_integer <= static_cast<uint64_t>((std::numeric_limits<int32_t>::max)()))
|
auto n = j.m_value.number_integer;
|
||||||
|
if ((std::numeric_limits<int32_t>::min)() <= n and n <= (std::numeric_limits<int32_t>::max)())
|
||||||
{
|
{
|
||||||
oa->write_character(static_cast<CharType>(0x10)); // int32
|
oa->write_character(static_cast<CharType>(0x10)); // int32
|
||||||
oa->write_characters(
|
oa->write_characters(
|
||||||
reinterpret_cast<const CharType*>(name.c_str()),
|
reinterpret_cast<const CharType*>(name.c_str()),
|
||||||
name.size() + 1u);
|
name.size() + 1u);
|
||||||
|
|
||||||
write_number_little_endian(static_cast<std::int32_t>(j.m_value.number_integer));
|
write_number_little_endian(static_cast<std::int32_t>(n));
|
||||||
|
|
||||||
|
return /*id*/ 1ul + name.size() + 1ul + sizeof(std::int32_t);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
oa->write_character(static_cast<CharType>(0x12)); // int64
|
||||||
|
oa->write_characters(
|
||||||
|
reinterpret_cast<const CharType*>(name.c_str()),
|
||||||
|
name.size() + 1u);
|
||||||
|
|
||||||
|
write_number_little_endian(static_cast<std::int64_t>(j.m_value.number_integer));
|
||||||
|
|
||||||
|
return /*id*/ 1ul + name.size() + 1ul + sizeof(std::int64_t);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
std::size_t write_bson_unsigned(const typename BasicJsonType::string_t& name, const BasicJsonType& j)
|
||||||
|
{
|
||||||
|
auto n = j.m_value.number_integer;
|
||||||
|
if (n <= static_cast<uint64_t>((std::numeric_limits<uint32_t>::max)()))
|
||||||
|
{
|
||||||
|
oa->write_character(static_cast<CharType>(0x10)); // int32
|
||||||
|
oa->write_characters(
|
||||||
|
reinterpret_cast<const CharType*>(name.c_str()),
|
||||||
|
name.size() + 1u);
|
||||||
|
|
||||||
|
write_number_little_endian(static_cast<std::int32_t>(n));
|
||||||
|
|
||||||
return /*id*/ 1ul + name.size() + 1ul + sizeof(std::int32_t);
|
return /*id*/ 1ul + name.size() + 1ul + sizeof(std::int32_t);
|
||||||
}
|
}
|
||||||
|
@ -760,6 +788,8 @@ class binary_writer
|
||||||
return write_bson_double(name, j);
|
return write_bson_double(name, j);
|
||||||
case value_t::number_integer:
|
case value_t::number_integer:
|
||||||
return write_bson_integer(name, j);
|
return write_bson_integer(name, j);
|
||||||
|
case value_t::number_unsigned:
|
||||||
|
return write_bson_unsigned(name, j);
|
||||||
case value_t::string:
|
case value_t::string:
|
||||||
return write_bson_string(name, j);
|
return write_bson_string(name, j);
|
||||||
case value_t::null:
|
case value_t::null:
|
||||||
|
|
|
@ -8557,14 +8557,42 @@ class binary_writer
|
||||||
|
|
||||||
std::size_t write_bson_integer(const typename BasicJsonType::string_t& name, const BasicJsonType& j)
|
std::size_t write_bson_integer(const typename BasicJsonType::string_t& name, const BasicJsonType& j)
|
||||||
{
|
{
|
||||||
if (j.m_value.number_integer <= static_cast<uint64_t>((std::numeric_limits<int32_t>::max)()))
|
auto n = j.m_value.number_integer;
|
||||||
|
if ((std::numeric_limits<int32_t>::min)() <= n and n <= (std::numeric_limits<int32_t>::max)())
|
||||||
{
|
{
|
||||||
oa->write_character(static_cast<CharType>(0x10)); // int32
|
oa->write_character(static_cast<CharType>(0x10)); // int32
|
||||||
oa->write_characters(
|
oa->write_characters(
|
||||||
reinterpret_cast<const CharType*>(name.c_str()),
|
reinterpret_cast<const CharType*>(name.c_str()),
|
||||||
name.size() + 1u);
|
name.size() + 1u);
|
||||||
|
|
||||||
write_number_little_endian(static_cast<std::int32_t>(j.m_value.number_integer));
|
write_number_little_endian(static_cast<std::int32_t>(n));
|
||||||
|
|
||||||
|
return /*id*/ 1ul + name.size() + 1ul + sizeof(std::int32_t);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
oa->write_character(static_cast<CharType>(0x12)); // int64
|
||||||
|
oa->write_characters(
|
||||||
|
reinterpret_cast<const CharType*>(name.c_str()),
|
||||||
|
name.size() + 1u);
|
||||||
|
|
||||||
|
write_number_little_endian(static_cast<std::int64_t>(j.m_value.number_integer));
|
||||||
|
|
||||||
|
return /*id*/ 1ul + name.size() + 1ul + sizeof(std::int64_t);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
std::size_t write_bson_unsigned(const typename BasicJsonType::string_t& name, const BasicJsonType& j)
|
||||||
|
{
|
||||||
|
auto n = j.m_value.number_integer;
|
||||||
|
if (n <= static_cast<uint64_t>((std::numeric_limits<uint32_t>::max)()))
|
||||||
|
{
|
||||||
|
oa->write_character(static_cast<CharType>(0x10)); // int32
|
||||||
|
oa->write_characters(
|
||||||
|
reinterpret_cast<const CharType*>(name.c_str()),
|
||||||
|
name.size() + 1u);
|
||||||
|
|
||||||
|
write_number_little_endian(static_cast<std::int32_t>(n));
|
||||||
|
|
||||||
return /*id*/ 1ul + name.size() + 1ul + sizeof(std::int32_t);
|
return /*id*/ 1ul + name.size() + 1ul + sizeof(std::int32_t);
|
||||||
}
|
}
|
||||||
|
@ -8594,6 +8622,8 @@ class binary_writer
|
||||||
return write_bson_double(name, j);
|
return write_bson_double(name, j);
|
||||||
case value_t::number_integer:
|
case value_t::number_integer:
|
||||||
return write_bson_integer(name, j);
|
return write_bson_integer(name, j);
|
||||||
|
case value_t::number_unsigned:
|
||||||
|
return write_bson_unsigned(name, j);
|
||||||
case value_t::string:
|
case value_t::string:
|
||||||
return write_bson_string(name, j);
|
return write_bson_string(name, j);
|
||||||
case value_t::null:
|
case value_t::null:
|
||||||
|
|
|
@ -279,5 +279,77 @@ TEST_CASE("BSON")
|
||||||
CHECK(json::from_bson(result, true, false) == j);
|
CHECK(json::from_bson(result, true, false) == j);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
SECTION("non-empty object with negative integer (32-bit) member")
|
||||||
|
{
|
||||||
|
json j =
|
||||||
|
{
|
||||||
|
{ "entry", std::int32_t{-1} }
|
||||||
|
};
|
||||||
|
|
||||||
|
std::vector<uint8_t> expected =
|
||||||
|
{
|
||||||
|
0x10, 0x00, 0x00, 0x00, // size (little endian)
|
||||||
|
0x10, /// entry: int32
|
||||||
|
'e', 'n', 't', 'r', 'y', '\x00',
|
||||||
|
0xFF, 0xFF, 0xFF, 0xFF,
|
||||||
|
0x00 // end marker
|
||||||
|
};
|
||||||
|
|
||||||
|
const auto result = json::to_bson(j);
|
||||||
|
CHECK(result == expected);
|
||||||
|
|
||||||
|
// roundtrip
|
||||||
|
CHECK(json::from_bson(result) == j);
|
||||||
|
CHECK(json::from_bson(result, true, false) == j);
|
||||||
|
}
|
||||||
|
|
||||||
|
SECTION("non-empty object with negative integer (64-bit) member")
|
||||||
|
{
|
||||||
|
json j =
|
||||||
|
{
|
||||||
|
{ "entry", std::int64_t{-1} }
|
||||||
|
};
|
||||||
|
|
||||||
|
std::vector<uint8_t> expected =
|
||||||
|
{
|
||||||
|
0x10, 0x00, 0x00, 0x00, // size (little endian)
|
||||||
|
0x10, /// entry: int32
|
||||||
|
'e', 'n', 't', 'r', 'y', '\x00',
|
||||||
|
0xFF, 0xFF, 0xFF, 0xFF,
|
||||||
|
0x00 // end marker
|
||||||
|
};
|
||||||
|
|
||||||
|
const auto result = json::to_bson(j);
|
||||||
|
CHECK(result == expected);
|
||||||
|
|
||||||
|
// roundtrip
|
||||||
|
CHECK(json::from_bson(result) == j);
|
||||||
|
CHECK(json::from_bson(result, true, false) == j);
|
||||||
|
}
|
||||||
|
|
||||||
|
SECTION("non-empty object with unsigned integer (64-bit) member")
|
||||||
|
{
|
||||||
|
// directly encoding uint64 is not supported in bson (only for timestamp values)
|
||||||
|
json j =
|
||||||
|
{
|
||||||
|
{ "entry", std::uint64_t{0x1234567804030201} }
|
||||||
|
};
|
||||||
|
|
||||||
|
std::vector<uint8_t> expected =
|
||||||
|
{
|
||||||
|
0x14, 0x00, 0x00, 0x00, // size (little endian)
|
||||||
|
0x12, /// entry: int64
|
||||||
|
'e', 'n', 't', 'r', 'y', '\x00',
|
||||||
|
0x01, 0x02, 0x03, 0x04, 0x78, 0x56, 0x34, 0x12,
|
||||||
|
0x00 // end marker
|
||||||
|
};
|
||||||
|
|
||||||
|
const auto result = json::to_bson(j);
|
||||||
|
CHECK(result == expected);
|
||||||
|
|
||||||
|
// roundtrip
|
||||||
|
CHECK(json::from_bson(result) == j);
|
||||||
|
CHECK(json::from_bson(result, true, false) == j);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue