Contents

require 'protobuf/common/wire_type'
require 'protobuf/common/exceptions'

module Protobuf

  module Encoder

    module_function

    # Encode +message+ and write to +stream+.
    def encode(stream, message)
      raise NotInitializedError unless message.initialized?
      message.each_field do |field, value|
        next unless message.has_field?(field.name)

        if field.repeated?
          next if value.empty?
          if field.packed?
            key = (field.tag << 3) | WireType::LENGTH_DELIMITED
            packed_value = value.map {|val| field.encode(val) }.join
            stream.write(Field::VarintField.encode(key))
            stream.write(Field::VarintField.encode(packed_value.size))
            stream.write(packed_value)
          else
            value.each do |val|
              write_pair(stream, field, val)
            end
          end
        else
          write_pair(stream, field, value)
        end
      end
    end

    # Encode key and value, and write to +stream+.
    def write_pair(stream, field, value)
      key = (field.tag << 3) | field.wire_type
      key_bytes = Field::VarintField.encode(key)
      stream.write(key_bytes)
      bytes = field.encode(value)
      stream.write(bytes)
    end

  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
ruby_protobuf-0.4.11	lib/protobuf/message/encoder.rb
ruby_protobuf-0.4.10	lib/protobuf/message/encoder.rb
ruby_protobuf-0.4.9	lib/protobuf/message/encoder.rb
ruby_protobuf-0.4.8	lib/protobuf/message/encoder.rb
ruby_protobuf-0.4.7	lib/protobuf/message/encoder.rb
ruby_protobuf-0.4.6	lib/protobuf/message/encoder.rb