Packages

exprotobuf

0.3.0
1.2.17 1.2.16 1.2.9 1.2.7 1.2.5 1.2.4 1.2.3 1.2.2 1.2.1 1.2.0 1.1.0 1.0.2 1.0.1 1.0.0 1.0.0-rc1 0.13.0 0.12.0 0.11.0 0.10.2 0.10.1 0.10.0 0.9.0 0.8.5 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.7.0 0.6.1 0.5.0 0.4.0 0.3.1 0.3.0 0.2.1 0.2.0

exprotobuf provides native encoding/decoding of protobuf messages via generated modules/structs.

HexDocs

Current section

Files

Jump to
Readme
36 Versions
0 Dependencies
Dependants
Files
Activity
exprotobuf lib exprotobuf encoder.ex
Raw

lib/exprotobuf/encoder.ex 

defmodule Protobuf.Encoder do

  alias Protobuf.Utils

  alias Protobuf.Field



  def encode(%{} = msg, defs) do

    fixed_defs = for {{:msg, mod}, fields} <- defs, into: [] do

      {{:msg, mod}, Enum.map(fields, fn field -> field |> Utils.convert_to_record(Field) end)}

    end



    msg

    |> fix_undefined

    |> Utils.convert_to_record(msg.__struct__)

    |> :gpb.encode_msg(fixed_defs)

  end



  defp fix_undefined(%{} = msg) do

    Enum.reduce(Map.keys(msg), msg, fn

      field, msg ->

        original = Map.get(msg, field)

        fixed    = fix_value(original)

        if original != fixed do

          Map.put(msg, field, fixed)

        else

          msg

        end

    end)

  end



  defp fix_value(nil),                         do: :undefined

  defp fix_value(values) when is_list(values), do: Enum.map(values, &fix_value/1)

  defp fix_value(value)  when is_map(value),   do: value |> fix_undefined |> Utils.convert_to_record(value.__struct__)

  defp fix_value(value),                       do: value

end