any.cc 4.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123
  1. // Protocol Buffers - Google's data interchange format
  2. // Copyright 2008 Google Inc. All rights reserved.
  3. // https://developers.google.com/protocol-buffers/
  4. //
  5. // Redistribution and use in source and binary forms, with or without
  6. // modification, are permitted provided that the following conditions are
  7. // met:
  8. //
  9. // * Redistributions of source code must retain the above copyright
  10. // notice, this list of conditions and the following disclaimer.
  11. // * Redistributions in binary form must reproduce the above
  12. // copyright notice, this list of conditions and the following disclaimer
  13. // in the documentation and/or other materials provided with the
  14. // distribution.
  15. // * Neither the name of Google Inc. nor the names of its
  16. // contributors may be used to endorse or promote products derived from
  17. // this software without specific prior written permission.
  18. //
  19. // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  20. // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  21. // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  22. // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  23. // OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  24. // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  25. // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  26. // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  27. // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  28. // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  29. // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  30. #include <google/protobuf/any.h>
  31. #include <google/protobuf/generated_message_util.h>
  32. namespace google {
  33. namespace protobuf {
  34. namespace internal {
  35. namespace {
  36. string GetTypeUrl(const Descriptor* message,
  37. const string& type_url_prefix) {
  38. if (!type_url_prefix.empty() &&
  39. type_url_prefix[type_url_prefix.size() - 1] == '/') {
  40. return type_url_prefix + message->full_name();
  41. } else {
  42. return type_url_prefix + "/" + message->full_name();
  43. }
  44. }
  45. } // namespace
  46. const char kAnyFullTypeName[] = "google.protobuf.Any";
  47. const char kTypeGoogleApisComPrefix[] = "type.googleapis.com/";
  48. const char kTypeGoogleProdComPrefix[] = "type.googleprod.com/";
  49. AnyMetadata::AnyMetadata(UrlType* type_url, ValueType* value)
  50. : type_url_(type_url), value_(value) {
  51. }
  52. void AnyMetadata::PackFrom(const Message& message) {
  53. PackFrom(message, kTypeGoogleApisComPrefix);
  54. }
  55. void AnyMetadata::PackFrom(const Message& message,
  56. const string& type_url_prefix) {
  57. type_url_->SetNoArena(&::google::protobuf::internal::GetEmptyString(),
  58. GetTypeUrl(message.GetDescriptor(), type_url_prefix));
  59. message.SerializeToString(value_->MutableNoArena(
  60. &::google::protobuf::internal::GetEmptyStringAlreadyInited()));
  61. }
  62. bool AnyMetadata::UnpackTo(Message* message) const {
  63. if (!InternalIs(message->GetDescriptor())) {
  64. return false;
  65. }
  66. return message->ParseFromString(value_->GetNoArena());
  67. }
  68. bool AnyMetadata::InternalIs(const Descriptor* descriptor) const {
  69. const string type_url = type_url_->GetNoArena();
  70. string full_name;
  71. if (!ParseAnyTypeUrl(type_url, &full_name)) {
  72. return false;
  73. }
  74. return full_name == descriptor->full_name();
  75. }
  76. bool ParseAnyTypeUrl(const string& type_url, string* url_prefix,
  77. string* full_type_name) {
  78. size_t pos = type_url.find_last_of("/");
  79. if (pos == string::npos || pos + 1 == type_url.size()) {
  80. return false;
  81. }
  82. if (url_prefix) {
  83. *url_prefix = type_url.substr(0, pos + 1);
  84. }
  85. *full_type_name = type_url.substr(pos + 1);
  86. return true;
  87. }
  88. bool ParseAnyTypeUrl(const string& type_url, string* full_type_name) {
  89. return ParseAnyTypeUrl(type_url, NULL, full_type_name);
  90. }
  91. bool GetAnyFieldDescriptors(const Message& message,
  92. const FieldDescriptor** type_url_field,
  93. const FieldDescriptor** value_field) {
  94. const Descriptor* descriptor = message.GetDescriptor();
  95. if (descriptor->full_name() != kAnyFullTypeName) {
  96. return false;
  97. }
  98. *type_url_field = descriptor->FindFieldByNumber(1);
  99. *value_field = descriptor->FindFieldByNumber(2);
  100. return (*type_url_field != NULL &&
  101. (*type_url_field)->type() == FieldDescriptor::TYPE_STRING &&
  102. *value_field != NULL &&
  103. (*value_field)->type() == FieldDescriptor::TYPE_BYTES);
  104. }
  105. } // namespace internal
  106. } // namespace protobuf
  107. } // namespace google