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 31# require mixins before we hook them into the java & c code 32require 'google/protobuf/message_exts' 33 34# We define these before requiring the platform-specific modules. 35# That way the module init can grab references to these. 36module Google 37 module Protobuf 38 class Error < StandardError; end 39 class ParseError < Error; end 40 class TypeError < ::TypeError; end 41 end 42end 43 44if RUBY_PLATFORM == "java" 45 require 'json' 46 require 'google/protobuf_java' 47else 48 begin 49 require "google/#{RUBY_VERSION.sub(/\.\d+$/, '')}/protobuf_c" 50 rescue LoadError 51 require 'google/protobuf_c' 52 end 53 54 module Google 55 module Protobuf 56 module Internal 57 def self.infer_package(names) 58 # Package is longest common prefix ending in '.', if any. 59 if not names.empty? 60 min, max = names.minmax 61 last_common_dot = nil 62 min.size.times { |i| 63 if min[i] != max[i] then break end 64 if min[i] == ?. then last_common_dot = i end 65 } 66 if last_common_dot 67 return min.slice(0, last_common_dot) 68 end 69 end 70 71 nil 72 end 73 74 class NestingBuilder 75 def initialize(msg_names, enum_names) 76 @to_pos = {nil=>nil} 77 @msg_children = Hash.new { |hash, key| hash[key] = [] } 78 @enum_children = Hash.new { |hash, key| hash[key] = [] } 79 80 msg_names.each_with_index { |name, idx| @to_pos[name] = idx } 81 enum_names.each_with_index { |name, idx| @to_pos[name] = idx } 82 83 msg_names.each { |name| @msg_children[parent(name)] << name } 84 enum_names.each { |name| @enum_children[parent(name)] << name } 85 end 86 87 def build(package) 88 return build_msg(package) 89 end 90 91 private 92 def build_msg(msg) 93 return { 94 :pos => @to_pos[msg], 95 :msgs => @msg_children[msg].map { |child| build_msg(child) }, 96 :enums => @enum_children[msg].map { |child| @to_pos[child] }, 97 } 98 end 99 100 private 101 def parent(name) 102 idx = name.rindex(?.) 103 if idx 104 return name.slice(0, idx) 105 else 106 return nil 107 end 108 end 109 end 110 111 def self.fixup_descriptor(package, msg_names, enum_names) 112 if package.nil? 113 package = self.infer_package(msg_names + enum_names) 114 end 115 116 nesting = NestingBuilder.new(msg_names, enum_names).build(package) 117 118 return package, nesting 119 end 120 end 121 end 122 end 123end 124 125require 'google/protobuf/repeated_field' 126 127module Google 128 module Protobuf 129 130 def self.encode(msg) 131 msg.to_proto 132 end 133 134 def self.encode_json(msg, options = {}) 135 msg.to_json(options) 136 end 137 138 def self.decode(klass, proto) 139 klass.decode(proto) 140 end 141 142 def self.decode_json(klass, json, options = {}) 143 klass.decode_json(json, options) 144 end 145 146 end 147end 148