Protocol Buffers - Google's data interchange format (grpc依赖)
https://developers.google.com/protocol-buffers/
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
552 lines
23 KiB
552 lines
23 KiB
3 years ago
|
/*
|
||
|
* Copyright (c) 2009-2021, Google LLC
|
||
|
* All rights reserved.
|
||
|
*
|
||
|
* Redistribution and use in source and binary forms, with or without
|
||
|
* modification, are permitted provided that the following conditions are met:
|
||
|
* * Redistributions of source code must retain the above copyright
|
||
|
* notice, this list of conditions and the following disclaimer.
|
||
|
* * Redistributions in binary form must reproduce the above copyright
|
||
|
* notice, this list of conditions and the following disclaimer in the
|
||
|
* documentation and/or other materials provided with the distribution.
|
||
|
* * Neither the name of Google LLC nor the
|
||
|
* names of its contributors may be used to endorse or promote products
|
||
|
* derived from this software without specific prior written permission.
|
||
|
*
|
||
|
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
|
||
|
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
||
|
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
||
|
* ARE DISCLAIMED. IN NO EVENT SHALL Google LLC BE LIABLE FOR ANY DIRECT,
|
||
|
* INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
|
||
|
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
|
||
|
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
|
||
|
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
||
|
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
|
||
|
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||
|
*/
|
||
|
|
||
|
/* Test of mini table accessors.
|
||
|
*
|
||
|
* Messages are created and mutated using generated code, and then
|
||
|
* accessed through reflective APIs exposed through mini table accessors.
|
||
|
*/
|
||
|
|
||
2 years ago
|
#include "upb/message/accessors.h"
|
||
3 years ago
|
|
||
|
#include "gtest/gtest.h"
|
||
3 years ago
|
#include "google/protobuf/test_messages_proto2.upb.h"
|
||
|
#include "google/protobuf/test_messages_proto3.upb.h"
|
||
2 years ago
|
#include "upb/collections/array.h"
|
||
2 years ago
|
#include "upb/mini_table/decode.h"
|
||
2 years ago
|
#include "upb/mini_table/encode_internal.hpp"
|
||
3 years ago
|
#include "upb/test.upb.h"
|
||
2 years ago
|
#include "upb/upb.h"
|
||
2 years ago
|
#include "upb/wire/decode.h"
|
||
3 years ago
|
|
||
|
namespace {
|
||
|
|
||
3 years ago
|
// Proto2 test messages field numbers used for reflective access.
|
||
3 years ago
|
const uint32_t kFieldOptionalInt32 = 1;
|
||
3 years ago
|
const uint32_t kFieldOptionalUInt32 = 3;
|
||
3 years ago
|
const uint32_t kFieldOptionalBool = 13;
|
||
|
const uint32_t kFieldOptionalString = 14;
|
||
|
const uint32_t kFieldOptionalNestedMessage = 18;
|
||
3 years ago
|
const uint32_t kFieldOptionalRepeatedInt32 = 31;
|
||
|
const uint32_t kFieldOptionalNestedMessageA = 1;
|
||
3 years ago
|
const uint32_t kFieldOptionalOneOfUInt32 = 111;
|
||
|
const uint32_t kFieldOptionalOneOfString = 113;
|
||
|
|
||
3 years ago
|
const uint32_t kFieldProto3OptionalInt64 = 2;
|
||
|
const uint32_t kFieldProto3OptionalUInt64 = 4;
|
||
|
|
||
|
const char kTestStr1[] = "Hello1";
|
||
|
const char kTestStr2[] = "Hello2";
|
||
3 years ago
|
const int32_t kTestInt32 = 567;
|
||
3 years ago
|
const int32_t kTestUInt32 = 0xF1234567;
|
||
|
const uint64_t kTestUInt64 = 0xFEDCBAFF87654321;
|
||
|
|
||
2 years ago
|
const upb_MiniTableField* find_proto3_field(int field_number) {
|
||
3 years ago
|
return upb_MiniTable_FindFieldByNumber(
|
||
2 years ago
|
&protobuf_test_messages_proto3_TestAllTypesProto3_msg_init, field_number);
|
||
3 years ago
|
}
|
||
3 years ago
|
|
||
2 years ago
|
const upb_MiniTableField* find_proto2_field(int field_number) {
|
||
3 years ago
|
return upb_MiniTable_FindFieldByNumber(
|
||
2 years ago
|
&protobuf_test_messages_proto2_TestAllTypesProto2_msg_init, field_number);
|
||
3 years ago
|
}
|
||
|
|
||
|
TEST(GeneratedCode, HazzersProto2) {
|
||
|
upb_Arena* arena = upb_Arena_New();
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2* msg =
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_new(arena);
|
||
|
|
||
|
// Scalar/Boolean.
|
||
2 years ago
|
const upb_MiniTableField* optional_bool_field =
|
||
3 years ago
|
find_proto2_field(kFieldOptionalBool);
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_bool_field));
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_set_optional_bool(msg, true);
|
||
|
EXPECT_EQ(true, upb_MiniTable_HasField(msg, optional_bool_field));
|
||
|
upb_MiniTable_ClearField(msg, optional_bool_field);
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_bool_field));
|
||
|
EXPECT_EQ(
|
||
|
false,
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_optional_bool(msg));
|
||
|
|
||
|
// String.
|
||
2 years ago
|
const upb_MiniTableField* optional_string_field =
|
||
3 years ago
|
find_proto2_field(kFieldOptionalString);
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_string_field));
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_set_optional_string(
|
||
|
msg, upb_StringView_FromString(kTestStr1));
|
||
|
EXPECT_EQ(true, upb_MiniTable_HasField(msg, optional_string_field));
|
||
|
EXPECT_EQ(
|
||
|
strlen(kTestStr1),
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_optional_string(msg)
|
||
|
.size);
|
||
|
upb_MiniTable_ClearField(msg, optional_string_field);
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_string_field));
|
||
|
EXPECT_EQ(
|
||
|
0, protobuf_test_messages_proto2_TestAllTypesProto2_optional_string(msg)
|
||
|
.size);
|
||
|
|
||
|
// Message.
|
||
2 years ago
|
const upb_MiniTableField* optional_message_field =
|
||
3 years ago
|
find_proto2_field(kFieldOptionalNestedMessage);
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_message_field));
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_mutable_optional_nested_message(
|
||
|
msg, arena);
|
||
|
EXPECT_EQ(true, upb_MiniTable_HasField(msg, optional_message_field));
|
||
|
upb_MiniTable_ClearField(msg, optional_message_field);
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_message_field));
|
||
|
EXPECT_EQ(
|
||
|
true,
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_optional_nested_message(
|
||
|
msg) == nullptr);
|
||
|
|
||
|
// One of.
|
||
2 years ago
|
const upb_MiniTableField* optional_oneof_uint32_field =
|
||
3 years ago
|
find_proto2_field(kFieldOptionalOneOfUInt32);
|
||
2 years ago
|
const upb_MiniTableField* optional_oneof_string_field =
|
||
3 years ago
|
find_proto2_field(kFieldOptionalOneOfString);
|
||
|
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_oneof_uint32_field));
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_oneof_string_field));
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_set_oneof_uint32(msg, 123);
|
||
|
EXPECT_EQ(true, upb_MiniTable_HasField(msg, optional_oneof_uint32_field));
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_oneof_string_field));
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_set_oneof_string(
|
||
|
msg, upb_StringView_FromString(kTestStr1));
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_oneof_uint32_field));
|
||
|
EXPECT_EQ(true, upb_MiniTable_HasField(msg, optional_oneof_string_field));
|
||
|
upb_MiniTable_ClearField(msg, optional_oneof_uint32_field);
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_oneof_uint32_field));
|
||
|
EXPECT_EQ(true, upb_MiniTable_HasField(msg, optional_oneof_string_field));
|
||
|
upb_MiniTable_ClearField(msg, optional_oneof_string_field);
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_oneof_uint32_field));
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_oneof_string_field));
|
||
|
|
||
|
upb_Arena_Free(arena);
|
||
|
}
|
||
|
|
||
|
TEST(GeneratedCode, ScalarsProto2) {
|
||
|
upb_Arena* arena = upb_Arena_New();
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2* msg =
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_new(arena);
|
||
|
|
||
2 years ago
|
const upb_MiniTableField* optional_int32_field =
|
||
3 years ago
|
find_proto2_field(kFieldOptionalInt32);
|
||
|
|
||
|
EXPECT_EQ(
|
||
|
0, protobuf_test_messages_proto2_TestAllTypesProto2_optional_int32(msg));
|
||
|
|
||
2 years ago
|
EXPECT_EQ(0, upb_MiniTable_GetInt32(msg, optional_int32_field, 0));
|
||
3 years ago
|
upb_MiniTable_SetInt32(msg, optional_int32_field, kTestInt32);
|
||
|
EXPECT_EQ(true, upb_MiniTable_HasField(msg, optional_int32_field));
|
||
2 years ago
|
EXPECT_EQ(kTestInt32, upb_MiniTable_GetInt32(msg, optional_int32_field, 0));
|
||
3 years ago
|
EXPECT_EQ(
|
||
|
kTestInt32,
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_optional_int32(msg));
|
||
|
|
||
2 years ago
|
const upb_MiniTableField* optional_uint32_field =
|
||
3 years ago
|
find_proto2_field(kFieldOptionalUInt32);
|
||
|
|
||
|
EXPECT_EQ(
|
||
|
0, protobuf_test_messages_proto2_TestAllTypesProto2_optional_uint32(msg));
|
||
2 years ago
|
EXPECT_EQ(0, upb_MiniTable_GetUInt32(msg, optional_uint32_field, 0));
|
||
3 years ago
|
upb_MiniTable_SetUInt32(msg, optional_uint32_field, kTestUInt32);
|
||
2 years ago
|
EXPECT_EQ(kTestUInt32,
|
||
|
upb_MiniTable_GetUInt32(msg, optional_uint32_field, 0));
|
||
3 years ago
|
EXPECT_EQ(
|
||
|
kTestUInt32,
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_optional_uint32(msg));
|
||
|
|
||
|
upb_Arena_Free(arena);
|
||
|
}
|
||
|
|
||
|
TEST(GeneratedCode, ScalarProto3) {
|
||
|
upb_Arena* arena = upb_Arena_New();
|
||
|
protobuf_test_messages_proto3_TestAllTypesProto3* msg =
|
||
|
protobuf_test_messages_proto3_TestAllTypesProto3_new(arena);
|
||
|
|
||
2 years ago
|
const upb_MiniTableField* optional_int64_field =
|
||
3 years ago
|
find_proto3_field(kFieldProto3OptionalInt64);
|
||
2 years ago
|
const upb_MiniTableField* optional_uint64_field =
|
||
3 years ago
|
find_proto3_field(kFieldProto3OptionalUInt64);
|
||
|
|
||
|
EXPECT_EQ(
|
||
|
0, protobuf_test_messages_proto3_TestAllTypesProto3_optional_int64(msg));
|
||
|
upb_MiniTable_SetInt64(msg, optional_int64_field, -1);
|
||
|
EXPECT_EQ(
|
||
|
-1, protobuf_test_messages_proto3_TestAllTypesProto3_optional_int64(msg));
|
||
2 years ago
|
EXPECT_EQ(-1, upb_MiniTable_GetInt64(msg, optional_int64_field, 0));
|
||
3 years ago
|
|
||
|
EXPECT_EQ(
|
||
|
0, protobuf_test_messages_proto3_TestAllTypesProto3_optional_uint64(msg));
|
||
|
upb_MiniTable_SetUInt64(msg, optional_uint64_field, kTestUInt64);
|
||
|
EXPECT_EQ(
|
||
|
kTestUInt64,
|
||
|
protobuf_test_messages_proto3_TestAllTypesProto3_optional_uint64(msg));
|
||
2 years ago
|
EXPECT_EQ(kTestUInt64,
|
||
|
upb_MiniTable_GetUInt64(msg, optional_uint64_field, 0));
|
||
3 years ago
|
|
||
|
upb_Arena_Free(arena);
|
||
|
}
|
||
|
|
||
|
TEST(GeneratedCode, Strings) {
|
||
|
upb_Arena* arena = upb_Arena_New();
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2* msg =
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_new(arena);
|
||
|
|
||
2 years ago
|
const upb_MiniTableField* optional_string_field =
|
||
3 years ago
|
find_proto2_field(kFieldOptionalString);
|
||
|
|
||
|
// Test default.
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_string_field));
|
||
|
// Test read after write using C.
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_set_optional_string(
|
||
|
msg, upb_StringView_FromString(kTestStr1));
|
||
|
EXPECT_EQ(true, upb_MiniTable_HasField(msg, optional_string_field));
|
||
2 years ago
|
upb_StringView value = upb_MiniTable_GetString(msg, optional_string_field,
|
||
|
upb_StringView{NULL, 0});
|
||
3 years ago
|
std::string read_value = std::string(value.data, value.size);
|
||
|
EXPECT_EQ(kTestStr1, read_value);
|
||
|
// Clear.
|
||
|
upb_MiniTable_ClearField(msg, optional_string_field);
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_string_field));
|
||
|
EXPECT_EQ(
|
||
|
false,
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_has_optional_string(
|
||
|
msg));
|
||
|
upb_MiniTable_SetString(msg, optional_string_field,
|
||
|
upb_StringView_FromString(kTestStr2));
|
||
|
EXPECT_EQ(true, upb_MiniTable_HasField(msg, optional_string_field));
|
||
|
EXPECT_EQ(
|
||
|
true,
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_has_optional_string(
|
||
|
msg));
|
||
|
value = protobuf_test_messages_proto2_TestAllTypesProto2_optional_string(msg);
|
||
|
read_value = std::string(value.data, value.size);
|
||
|
EXPECT_EQ(kTestStr2, read_value);
|
||
|
|
||
|
upb_Arena_Free(arena);
|
||
|
}
|
||
|
|
||
|
TEST(GeneratedCode, SubMessage) {
|
||
|
upb_Arena* arena = upb_Arena_New();
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2* msg =
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_new(arena);
|
||
|
|
||
2 years ago
|
const upb_MiniTableField* optional_message_field =
|
||
3 years ago
|
find_proto2_field(kFieldOptionalNestedMessage);
|
||
|
|
||
|
const upb_Message* test_message =
|
||
2 years ago
|
upb_MiniTable_GetMessage(msg, optional_message_field, NULL);
|
||
3 years ago
|
EXPECT_EQ(NULL, test_message);
|
||
|
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_message_field));
|
||
|
|
||
|
// Get mutable using C API.
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_NestedMessage* nested_message =
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_mutable_optional_nested_message(
|
||
|
msg, arena);
|
||
|
EXPECT_EQ(true, nested_message != nullptr);
|
||
|
EXPECT_EQ(true, upb_MiniTable_HasField(msg, optional_message_field));
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_NestedMessage_set_a(
|
||
|
nested_message, 5);
|
||
|
|
||
|
// Read back using mini table API.
|
||
|
const upb_Message* sub_message =
|
||
2 years ago
|
upb_MiniTable_GetMessage(msg, optional_message_field, NULL);
|
||
3 years ago
|
EXPECT_EQ(true, sub_message != NULL);
|
||
|
|
||
2 years ago
|
const upb_MiniTableField* nested_message_a_field =
|
||
3 years ago
|
upb_MiniTable_FindFieldByNumber(
|
||
2 years ago
|
&protobuf_test_messages_proto2_TestAllTypesProto2_NestedMessage_msg_init,
|
||
3 years ago
|
kFieldOptionalNestedMessageA);
|
||
2 years ago
|
EXPECT_EQ(5, upb_MiniTable_GetInt32(sub_message, nested_message_a_field, 0));
|
||
3 years ago
|
|
||
|
upb_MiniTable_ClearField(msg, optional_message_field);
|
||
|
EXPECT_EQ(
|
||
|
NULL,
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_optional_nested_message(
|
||
|
msg));
|
||
|
EXPECT_EQ(false, upb_MiniTable_HasField(msg, optional_message_field));
|
||
|
|
||
|
upb_Message* new_nested_message =
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_NestedMessage_new(arena);
|
||
|
upb_MiniTable_SetInt32(new_nested_message, nested_message_a_field, 123);
|
||
2 years ago
|
upb_MiniTable_SetMessage(
|
||
|
msg, &protobuf_test_messages_proto2_TestAllTypesProto2_msg_init,
|
||
|
optional_message_field, new_nested_message);
|
||
3 years ago
|
|
||
|
upb_Message* mutable_message = upb_MiniTable_GetMutableMessage(
|
||
2 years ago
|
msg, &protobuf_test_messages_proto2_TestAllTypesProto2_msg_init,
|
||
3 years ago
|
optional_message_field, arena);
|
||
|
EXPECT_EQ(
|
||
|
true,
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_optional_nested_message(
|
||
|
msg) != NULL);
|
||
|
EXPECT_EQ(true, upb_MiniTable_HasField(msg, optional_message_field));
|
||
|
EXPECT_EQ(123,
|
||
2 years ago
|
upb_MiniTable_GetInt32(mutable_message, nested_message_a_field, 0));
|
||
3 years ago
|
|
||
|
upb_Arena_Free(arena);
|
||
|
}
|
||
|
|
||
|
TEST(GeneratedCode, RepeatedScalar) {
|
||
|
upb_Arena* arena = upb_Arena_New();
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2* msg =
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_new(arena);
|
||
|
|
||
2 years ago
|
const upb_MiniTableField* repeated_int32_field =
|
||
3 years ago
|
find_proto2_field(kFieldOptionalRepeatedInt32);
|
||
|
|
||
|
size_t len;
|
||
|
const int32_t* arr =
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_repeated_int32(msg,
|
||
|
&len);
|
||
|
// Test Get/Set Array values, validate with C API.
|
||
|
EXPECT_EQ(0, len);
|
||
|
EXPECT_EQ(NULL, arr);
|
||
|
EXPECT_EQ(NULL, upb_MiniTable_GetArray(msg, repeated_int32_field));
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_resize_repeated_int32(
|
||
|
msg, 10, arena);
|
||
|
int32_t* mutable_values =
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_mutable_repeated_int32(
|
||
|
msg, &len);
|
||
|
mutable_values[5] = 123;
|
||
|
const upb_Array* readonly_arr =
|
||
|
upb_MiniTable_GetArray(msg, repeated_int32_field);
|
||
|
EXPECT_EQ(123, upb_Array_Get(readonly_arr, 5).int32_val);
|
||
|
|
||
|
upb_MessageValue new_value;
|
||
|
new_value.int32_val = 567;
|
||
|
upb_Array* mutable_array =
|
||
|
upb_MiniTable_GetMutableArray(msg, repeated_int32_field);
|
||
|
upb_Array_Set(mutable_array, 5, new_value);
|
||
|
EXPECT_EQ(new_value.int32_val,
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_repeated_int32(
|
||
|
msg, &len)[5]);
|
||
|
|
||
|
// Test resize.
|
||
|
bool result = upb_Array_Resize(mutable_array, 20, arena);
|
||
|
EXPECT_EQ(true, result);
|
||
|
upb_Array_Set(mutable_array, 19, new_value);
|
||
|
EXPECT_EQ(new_value.int32_val,
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_repeated_int32(
|
||
|
msg, &len)[19]);
|
||
|
upb_Array_Resize(mutable_array, 0, arena);
|
||
|
const int32_t* zero_length_array =
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_repeated_int32(msg,
|
||
|
&len);
|
||
|
EXPECT_EQ(0, len);
|
||
|
EXPECT_EQ(true, zero_length_array != NULL);
|
||
|
|
||
3 years ago
|
upb_Arena_Free(arena);
|
||
|
}
|
||
|
|
||
3 years ago
|
TEST(GeneratedCode, GetMutableMessage) {
|
||
|
upb_Arena* arena = upb_Arena_New();
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2* msg =
|
||
|
protobuf_test_messages_proto2_TestAllTypesProto2_new(arena);
|
||
|
// Message.
|
||
2 years ago
|
const upb_MiniTableField* optional_message_field =
|
||
3 years ago
|
find_proto2_field(kFieldOptionalNestedMessage);
|
||
|
upb_Message* msg1 = upb_MiniTable_GetMutableMessage(
|
||
2 years ago
|
msg, &protobuf_test_messages_proto2_TestAllTypesProto2_msg_init,
|
||
3 years ago
|
optional_message_field, arena);
|
||
|
upb_Message* msg2 = upb_MiniTable_GetMutableMessage(
|
||
2 years ago
|
msg, &protobuf_test_messages_proto2_TestAllTypesProto2_msg_init,
|
||
3 years ago
|
optional_message_field, arena);
|
||
|
// Verify that newly constructed sub message is stored in msg.
|
||
|
EXPECT_EQ(msg1, msg2);
|
||
|
|
||
|
upb_Arena_Free(arena);
|
||
|
}
|
||
|
|
||
2 years ago
|
TEST(GeneratedCode, FindUnknown) {
|
||
|
upb_Arena* arena = upb_Arena_New();
|
||
|
upb_test_ModelWithExtensions* msg = upb_test_ModelWithExtensions_new(arena);
|
||
|
upb_test_ModelWithExtensions_set_random_int32(msg, 10);
|
||
|
upb_test_ModelWithExtensions_set_random_name(
|
||
|
msg, upb_StringView_FromString("Hello"));
|
||
|
|
||
|
upb_test_ModelExtension1* extension1 = upb_test_ModelExtension1_new(arena);
|
||
|
upb_test_ModelExtension1_set_str(extension1,
|
||
|
upb_StringView_FromString("World"));
|
||
|
|
||
|
upb_test_ModelExtension1_set_model_ext(msg, extension1, arena);
|
||
|
|
||
|
size_t serialized_size;
|
||
|
char* serialized =
|
||
|
upb_test_ModelWithExtensions_serialize(msg, arena, &serialized_size);
|
||
|
|
||
|
upb_test_EmptyMessageWithExtensions* base_msg =
|
||
|
upb_test_EmptyMessageWithExtensions_parse(serialized, serialized_size,
|
||
|
arena);
|
||
|
|
||
|
upb_FindUnknownRet result = upb_MiniTable_FindUnknown(
|
||
|
base_msg, upb_test_ModelExtension1_model_ext_ext.field.number);
|
||
|
EXPECT_EQ(kUpb_FindUnknown_Ok, result.status);
|
||
|
|
||
|
result = upb_MiniTable_FindUnknown(
|
||
|
base_msg, upb_test_ModelExtension2_model_ext_ext.field.number);
|
||
|
EXPECT_EQ(kUpb_FindUnknown_NotPresent, result.status);
|
||
|
|
||
|
upb_Arena_Free(arena);
|
||
|
}
|
||
|
|
||
3 years ago
|
TEST(GeneratedCode, Extensions) {
|
||
|
upb_Arena* arena = upb_Arena_New();
|
||
|
upb_test_ModelWithExtensions* msg = upb_test_ModelWithExtensions_new(arena);
|
||
|
upb_test_ModelWithExtensions_set_random_int32(msg, 10);
|
||
|
upb_test_ModelWithExtensions_set_random_name(
|
||
|
msg, upb_StringView_FromString("Hello"));
|
||
|
|
||
|
upb_test_ModelExtension1* extension1 = upb_test_ModelExtension1_new(arena);
|
||
|
upb_test_ModelExtension1_set_str(extension1,
|
||
|
upb_StringView_FromString("World"));
|
||
|
|
||
|
upb_test_ModelExtension2* extension2 = upb_test_ModelExtension2_new(arena);
|
||
|
upb_test_ModelExtension2_set_i(extension2, 5);
|
||
|
|
||
|
upb_test_ModelExtension1_set_model_ext(msg, extension1, arena);
|
||
|
upb_test_ModelExtension2_set_model_ext(msg, extension2, arena);
|
||
|
|
||
|
size_t serialized_size;
|
||
|
char* serialized =
|
||
|
upb_test_ModelWithExtensions_serialize(msg, arena, &serialized_size);
|
||
|
|
||
|
// Test known GetExtension
|
||
|
const upb_Message_Extension* upb_ext2;
|
||
|
upb_GetExtension_Status promote_status = upb_MiniTable_GetOrPromoteExtension(
|
||
|
msg, &upb_test_ModelExtension2_model_ext_ext, 0, arena, &upb_ext2);
|
||
|
|
||
|
upb_test_ModelExtension2* ext2 =
|
||
|
(upb_test_ModelExtension2*)upb_ext2->data.ptr;
|
||
|
EXPECT_EQ(kUpb_GetExtension_Ok, promote_status);
|
||
|
EXPECT_EQ(5, upb_test_ModelExtension2_i(ext2));
|
||
|
|
||
|
upb_test_EmptyMessageWithExtensions* base_msg =
|
||
|
upb_test_EmptyMessageWithExtensions_parse(serialized, serialized_size,
|
||
|
arena);
|
||
|
|
||
|
// Get unknown extension bytes before promotion.
|
||
|
const char* extension_data;
|
||
|
size_t len;
|
||
2 years ago
|
upb_GetExtensionAsBytes_Status status = upb_MiniTable_GetExtensionAsBytes(
|
||
|
base_msg, &upb_test_ModelExtension2_model_ext_ext, 0, arena,
|
||
|
&extension_data, &len);
|
||
3 years ago
|
EXPECT_EQ(kUpb_GetExtensionAsBytes_Ok, status);
|
||
|
EXPECT_EQ(0x48, extension_data[0]);
|
||
|
EXPECT_EQ(5, extension_data[1]);
|
||
|
|
||
|
// Test unknown GetExtension.
|
||
|
promote_status = upb_MiniTable_GetOrPromoteExtension(
|
||
|
base_msg, &upb_test_ModelExtension2_model_ext_ext, 0, arena, &upb_ext2);
|
||
|
|
||
|
ext2 = (upb_test_ModelExtension2*)upb_ext2->data.ptr;
|
||
|
EXPECT_EQ(kUpb_GetExtension_Ok, promote_status);
|
||
|
EXPECT_EQ(5, upb_test_ModelExtension2_i(ext2));
|
||
|
|
||
|
// Get unknown extension bytes after promotion.
|
||
|
status = upb_MiniTable_GetExtensionAsBytes(
|
||
|
base_msg, &upb_test_ModelExtension2_model_ext_ext, 0, arena,
|
||
|
&extension_data, &len);
|
||
|
EXPECT_EQ(kUpb_GetExtensionAsBytes_Ok, status);
|
||
|
EXPECT_EQ(0x48, extension_data[0]);
|
||
|
EXPECT_EQ(5, extension_data[1]);
|
||
|
|
||
|
upb_Arena_Free(arena);
|
||
|
}
|
||
|
|
||
2 years ago
|
// Create a minitable to mimic ModelWithSubMessages with unlinked subs
|
||
|
// to lazily promote unknowns after parsing.
|
||
|
upb_MiniTable* CreateMiniTableWithEmptySubTables(upb_Arena* arena) {
|
||
2 years ago
|
upb::MtDataEncoder e;
|
||
|
e.StartMessage(0);
|
||
|
e.PutField(kUpb_FieldType_Int32, 4, 0);
|
||
|
e.PutField(kUpb_FieldType_Message, 5, 0);
|
||
|
e.PutField(kUpb_FieldType_Message, 6, kUpb_FieldModifier_IsRepeated);
|
||
2 years ago
|
|
||
|
upb_Status status;
|
||
|
upb_Status_Clear(&status);
|
||
2 years ago
|
upb_MiniTable* table =
|
||
|
upb_MiniTable_Build(e.data().data(), e.data().size(),
|
||
|
kUpb_MiniTablePlatform_Native, arena, &status);
|
||
2 years ago
|
EXPECT_EQ(status.ok, true);
|
||
|
// Initialize sub table to null. Not using upb_MiniTable_SetSubMessage
|
||
|
// since it checks ->ext on parameter.
|
||
2 years ago
|
upb_MiniTableSub* sub = const_cast<upb_MiniTableSub*>(
|
||
2 years ago
|
&table->subs[table->fields[1].submsg_index]);
|
||
|
sub->submsg = nullptr;
|
||
2 years ago
|
sub = const_cast<upb_MiniTableSub*>(
|
||
2 years ago
|
&table->subs[table->fields[2].submsg_index]);
|
||
|
sub->submsg = nullptr;
|
||
|
return table;
|
||
|
}
|
||
|
|
||
|
TEST(GeneratedCode, PromoteUnknownMessage) {
|
||
|
upb_Arena* arena = upb_Arena_New();
|
||
|
upb_test_ModelWithSubMessages* input_msg =
|
||
|
upb_test_ModelWithSubMessages_new(arena);
|
||
|
upb_test_ModelWithExtensions* sub_message =
|
||
|
upb_test_ModelWithExtensions_new(arena);
|
||
|
upb_test_ModelWithSubMessages_set_id(input_msg, 11);
|
||
|
upb_test_ModelWithExtensions_set_random_int32(sub_message, 12);
|
||
|
upb_test_ModelWithSubMessages_set_optional_child(input_msg, sub_message);
|
||
|
size_t serialized_size;
|
||
|
char* serialized = upb_test_ModelWithSubMessages_serialize(input_msg, arena,
|
||
|
&serialized_size);
|
||
|
|
||
|
upb_MiniTable* mini_table = CreateMiniTableWithEmptySubTables(arena);
|
||
2 years ago
|
upb_Message* msg = _upb_Message_New(mini_table, arena);
|
||
2 years ago
|
upb_DecodeStatus decode_status = upb_Decode(serialized, serialized_size, msg,
|
||
|
mini_table, nullptr, 0, arena);
|
||
|
EXPECT_EQ(decode_status, kUpb_DecodeStatus_Ok);
|
||
|
int32_t val = upb_MiniTable_GetInt32(
|
||
2 years ago
|
msg, upb_MiniTable_FindFieldByNumber(mini_table, 4), 0);
|
||
2 years ago
|
EXPECT_EQ(val, 11);
|
||
|
upb_FindUnknownRet unknown = upb_MiniTable_FindUnknown(msg, 5);
|
||
|
EXPECT_EQ(unknown.status, kUpb_FindUnknown_Ok);
|
||
|
// Update mini table and promote unknown to a message.
|
||
|
upb_MiniTable_SetSubMessage(mini_table,
|
||
2 years ago
|
(upb_MiniTableField*)&mini_table->fields[1],
|
||
2 years ago
|
&upb_test_ModelWithExtensions_msg_init);
|
||
|
const int decode_options =
|
||
|
UPB_DECODE_MAXDEPTH(100); // UPB_DECODE_ALIAS disabled.
|
||
|
upb_UnknownToMessageRet promote_result =
|
||
|
upb_MiniTable_PromoteUnknownToMessage(
|
||
|
msg, mini_table, &mini_table->fields[1],
|
||
|
&upb_test_ModelWithExtensions_msg_init, decode_options, arena);
|
||
|
EXPECT_EQ(promote_result.status, kUpb_UnknownToMessage_Ok);
|
||
|
const upb_Message* promoted_message =
|
||
2 years ago
|
upb_MiniTable_GetMessage(msg, &mini_table->fields[1], NULL);
|
||
2 years ago
|
EXPECT_EQ(upb_test_ModelWithExtensions_random_int32(
|
||
|
(upb_test_ModelWithExtensions*)promoted_message),
|
||
|
12);
|
||
|
upb_Arena_Free(arena);
|
||
|
}
|
||
|
|
||
3 years ago
|
} // namespace
|