summaryrefslogtreecommitdiff
path: root/src/r3_hex_pb_versions.erl
diff options
context:
space:
mode:
authorBryan Paxton <39971740+starbelly@users.noreply.github.com>2019-03-07 10:54:01 -0600
committerTristan Sloughter <t@crashfast.com>2019-03-07 09:54:01 -0700
commit209c02ec57c2cc3207ee0174c3af3675b8dc8f79 (patch)
treee07b25a27a2c4cc438db75d8d066179b4e57f3f7 /src/r3_hex_pb_versions.erl
parent9e2e54afd74104ecb05c55e033803f41932eb940 (diff)
Fix fetching of private packages from orgs on hex repos (#2020)
- vendor in hex_core at v0.5.0 - Change where repo_name should be the org and not the parent - Changed rebar_utils:url_append_path/2 to not explicitly add a '?', this is returned in the Query chunk by http_uri:parse/1 (e.g., "?foo=bar") - update organization_merging test to expect the sub-repo as the repo_name - Add tests for rebar_utils:url_append_path/2 - Stop referencing/setting "organization" in config and use new organization settings (api_repository and repo_organization) - Do not set (assume) the read key is valid for any/every repo - Set repo_organization and api_repository to org - Update tests to check for new config opts
Diffstat (limited to 'src/r3_hex_pb_versions.erl')
-rw-r--r--src/r3_hex_pb_versions.erl958
1 files changed, 958 insertions, 0 deletions
diff --git a/src/r3_hex_pb_versions.erl b/src/r3_hex_pb_versions.erl
new file mode 100644
index 0000000..66407dd
--- /dev/null
+++ b/src/r3_hex_pb_versions.erl
@@ -0,0 +1,958 @@
+%% Vendored from hex_core v0.5.0, do not edit manually
+
+%% -*- coding: utf-8 -*-
+%% Automatically generated, do not edit
+%% Generated by gpb_compile version 4.3.1
+-module(r3_hex_pb_versions).
+
+-export([encode_msg/2, encode_msg/3]).
+-export([decode_msg/2, decode_msg/3]).
+-export([merge_msgs/3, merge_msgs/4]).
+-export([verify_msg/2, verify_msg/3]).
+-export([get_msg_defs/0]).
+-export([get_msg_names/0]).
+-export([get_group_names/0]).
+-export([get_msg_or_group_names/0]).
+-export([get_enum_names/0]).
+-export([find_msg_def/1, fetch_msg_def/1]).
+-export([find_enum_def/1, fetch_enum_def/1]).
+-export([enum_symbol_by_value/2, enum_value_by_symbol/2]).
+-export([get_service_names/0]).
+-export([get_service_def/1]).
+-export([get_rpc_names/1]).
+-export([find_rpc_def/2, fetch_rpc_def/2]).
+-export([get_package_name/0]).
+-export([gpb_version_as_string/0, gpb_version_as_list/0]).
+
+
+%% enumerated types
+
+-export_type([]).
+
+%% message types
+-type 'Versions'() ::
+ #{packages => ['Package'()], % = 1
+ repository => iodata() % = 2
+ }.
+
+-type 'Package'() ::
+ #{name => iodata(), % = 1
+ versions => [iodata()], % = 2
+ retired => [integer()] % = 3, 32 bits
+ }.
+
+-export_type(['Versions'/0, 'Package'/0]).
+
+-spec encode_msg('Versions'() | 'Package'(), atom()) -> binary().
+encode_msg(Msg, MsgName) when is_atom(MsgName) ->
+ encode_msg(Msg, MsgName, []).
+
+-spec encode_msg('Versions'() | 'Package'(), atom(), list()) -> binary().
+encode_msg(Msg, MsgName, Opts) ->
+ verify_msg(Msg, MsgName, Opts),
+ TrUserData = proplists:get_value(user_data, Opts),
+ case MsgName of
+ 'Versions' ->
+ e_msg_Versions(id(Msg, TrUserData), TrUserData);
+ 'Package' ->
+ e_msg_Package(id(Msg, TrUserData), TrUserData)
+ end.
+
+
+e_msg_Versions(Msg, TrUserData) ->
+ e_msg_Versions(Msg, <<>>, TrUserData).
+
+
+e_msg_Versions(#{repository := F2} = M, Bin,
+ TrUserData) ->
+ B1 = case M of
+ #{packages := F1} ->
+ TrF1 = id(F1, TrUserData),
+ if TrF1 == [] -> Bin;
+ true -> e_field_Versions_packages(TrF1, Bin, TrUserData)
+ end;
+ _ -> Bin
+ end,
+ begin
+ TrF2 = id(F2, TrUserData),
+ e_type_string(TrF2, <<B1/binary, 18>>, TrUserData)
+ end.
+
+e_msg_Package(Msg, TrUserData) ->
+ e_msg_Package(Msg, <<>>, TrUserData).
+
+
+e_msg_Package(#{name := F1} = M, Bin, TrUserData) ->
+ B1 = begin
+ TrF1 = id(F1, TrUserData),
+ e_type_string(TrF1, <<Bin/binary, 10>>, TrUserData)
+ end,
+ B2 = case M of
+ #{versions := F2} ->
+ TrF2 = id(F2, TrUserData),
+ if TrF2 == [] -> B1;
+ true -> e_field_Package_versions(TrF2, B1, TrUserData)
+ end;
+ _ -> B1
+ end,
+ case M of
+ #{retired := F3} ->
+ TrF3 = id(F3, TrUserData),
+ if TrF3 == [] -> B2;
+ true -> e_field_Package_retired(TrF3, B2, TrUserData)
+ end;
+ _ -> B2
+ end.
+
+e_mfield_Versions_packages(Msg, Bin, TrUserData) ->
+ SubBin = e_msg_Package(Msg, <<>>, TrUserData),
+ Bin2 = e_varint(byte_size(SubBin), Bin),
+ <<Bin2/binary, SubBin/binary>>.
+
+e_field_Versions_packages([Elem | Rest], Bin,
+ TrUserData) ->
+ Bin2 = <<Bin/binary, 10>>,
+ Bin3 = e_mfield_Versions_packages(id(Elem, TrUserData),
+ Bin2, TrUserData),
+ e_field_Versions_packages(Rest, Bin3, TrUserData);
+e_field_Versions_packages([], Bin, _TrUserData) -> Bin.
+
+e_field_Package_versions([Elem | Rest], Bin,
+ TrUserData) ->
+ Bin2 = <<Bin/binary, 18>>,
+ Bin3 = e_type_string(id(Elem, TrUserData), Bin2,
+ TrUserData),
+ e_field_Package_versions(Rest, Bin3, TrUserData);
+e_field_Package_versions([], Bin, _TrUserData) -> Bin.
+
+e_field_Package_retired(Elems, Bin, TrUserData)
+ when Elems =/= [] ->
+ SubBin = e_pfield_Package_retired(Elems, <<>>,
+ TrUserData),
+ Bin2 = <<Bin/binary, 26>>,
+ Bin3 = e_varint(byte_size(SubBin), Bin2),
+ <<Bin3/binary, SubBin/binary>>;
+e_field_Package_retired([], Bin, _TrUserData) -> Bin.
+
+e_pfield_Package_retired([Value | Rest], Bin,
+ TrUserData) ->
+ Bin2 = e_type_int32(id(Value, TrUserData), Bin,
+ TrUserData),
+ e_pfield_Package_retired(Rest, Bin2, TrUserData);
+e_pfield_Package_retired([], Bin, _TrUserData) -> Bin.
+
+-compile({nowarn_unused_function,e_type_sint/3}).
+e_type_sint(Value, Bin, _TrUserData) when Value >= 0 ->
+ e_varint(Value * 2, Bin);
+e_type_sint(Value, Bin, _TrUserData) ->
+ e_varint(Value * -2 - 1, Bin).
+
+-compile({nowarn_unused_function,e_type_int32/3}).
+e_type_int32(Value, Bin, _TrUserData)
+ when 0 =< Value, Value =< 127 ->
+ <<Bin/binary, Value>>;
+e_type_int32(Value, Bin, _TrUserData) ->
+ <<N:64/unsigned-native>> = <<Value:64/signed-native>>,
+ e_varint(N, Bin).
+
+-compile({nowarn_unused_function,e_type_int64/3}).
+e_type_int64(Value, Bin, _TrUserData)
+ when 0 =< Value, Value =< 127 ->
+ <<Bin/binary, Value>>;
+e_type_int64(Value, Bin, _TrUserData) ->
+ <<N:64/unsigned-native>> = <<Value:64/signed-native>>,
+ e_varint(N, Bin).
+
+-compile({nowarn_unused_function,e_type_bool/3}).
+e_type_bool(true, Bin, _TrUserData) ->
+ <<Bin/binary, 1>>;
+e_type_bool(false, Bin, _TrUserData) ->
+ <<Bin/binary, 0>>;
+e_type_bool(1, Bin, _TrUserData) -> <<Bin/binary, 1>>;
+e_type_bool(0, Bin, _TrUserData) -> <<Bin/binary, 0>>.
+
+-compile({nowarn_unused_function,e_type_string/3}).
+e_type_string(S, Bin, _TrUserData) ->
+ Utf8 = unicode:characters_to_binary(S),
+ Bin2 = e_varint(byte_size(Utf8), Bin),
+ <<Bin2/binary, Utf8/binary>>.
+
+-compile({nowarn_unused_function,e_type_bytes/3}).
+e_type_bytes(Bytes, Bin, _TrUserData)
+ when is_binary(Bytes) ->
+ Bin2 = e_varint(byte_size(Bytes), Bin),
+ <<Bin2/binary, Bytes/binary>>;
+e_type_bytes(Bytes, Bin, _TrUserData)
+ when is_list(Bytes) ->
+ BytesBin = iolist_to_binary(Bytes),
+ Bin2 = e_varint(byte_size(BytesBin), Bin),
+ <<Bin2/binary, BytesBin/binary>>.
+
+-compile({nowarn_unused_function,e_type_fixed32/3}).
+e_type_fixed32(Value, Bin, _TrUserData) ->
+ <<Bin/binary, Value:32/little>>.
+
+-compile({nowarn_unused_function,e_type_sfixed32/3}).
+e_type_sfixed32(Value, Bin, _TrUserData) ->
+ <<Bin/binary, Value:32/little-signed>>.
+
+-compile({nowarn_unused_function,e_type_fixed64/3}).
+e_type_fixed64(Value, Bin, _TrUserData) ->
+ <<Bin/binary, Value:64/little>>.
+
+-compile({nowarn_unused_function,e_type_sfixed64/3}).
+e_type_sfixed64(Value, Bin, _TrUserData) ->
+ <<Bin/binary, Value:64/little-signed>>.
+
+-compile({nowarn_unused_function,e_type_float/3}).
+e_type_float(V, Bin, _) when is_number(V) ->
+ <<Bin/binary, V:32/little-float>>;
+e_type_float(infinity, Bin, _) ->
+ <<Bin/binary, 0:16, 128, 127>>;
+e_type_float('-infinity', Bin, _) ->
+ <<Bin/binary, 0:16, 128, 255>>;
+e_type_float(nan, Bin, _) ->
+ <<Bin/binary, 0:16, 192, 127>>.
+
+-compile({nowarn_unused_function,e_type_double/3}).
+e_type_double(V, Bin, _) when is_number(V) ->
+ <<Bin/binary, V:64/little-float>>;
+e_type_double(infinity, Bin, _) ->
+ <<Bin/binary, 0:48, 240, 127>>;
+e_type_double('-infinity', Bin, _) ->
+ <<Bin/binary, 0:48, 240, 255>>;
+e_type_double(nan, Bin, _) ->
+ <<Bin/binary, 0:48, 248, 127>>.
+
+-compile({nowarn_unused_function,e_varint/3}).
+e_varint(N, Bin, _TrUserData) -> e_varint(N, Bin).
+
+-compile({nowarn_unused_function,e_varint/2}).
+e_varint(N, Bin) when N =< 127 -> <<Bin/binary, N>>;
+e_varint(N, Bin) ->
+ Bin2 = <<Bin/binary, (N band 127 bor 128)>>,
+ e_varint(N bsr 7, Bin2).
+
+
+decode_msg(Bin, MsgName) when is_binary(Bin) ->
+ decode_msg(Bin, MsgName, []).
+
+decode_msg(Bin, MsgName, Opts) when is_binary(Bin) ->
+ TrUserData = proplists:get_value(user_data, Opts),
+ decode_msg_1_catch(Bin, MsgName, TrUserData).
+
+-ifdef('OTP_RELEASE').
+decode_msg_1_catch(Bin, MsgName, TrUserData) ->
+ try decode_msg_2_doit(MsgName, Bin, TrUserData)
+ catch Class:Reason:StackTrace -> error({gpb_error,{decoding_failure, {Bin, MsgName, {Class, Reason, StackTrace}}}})
+ end.
+-else.
+-ifdef('GPB_PATTERN_STACK').
+decode_msg_1_catch(Bin, MsgName, TrUserData) ->
+ try decode_msg_2_doit(MsgName, Bin, TrUserData)
+ catch Class:Reason:StackTrace -> error({gpb_error,{decoding_failure, {Bin, MsgName, {Class, Reason, StackTrace}}}})
+ end.
+-else.
+decode_msg_1_catch(Bin, MsgName, TrUserData) ->
+ try decode_msg_2_doit(MsgName, Bin, TrUserData)
+ catch Class:Reason ->
+ StackTrace = erlang:get_stacktrace(),
+ error({gpb_error,{decoding_failure, {Bin, MsgName, {Class, Reason, StackTrace}}}})
+ end.
+-endif.
+
+-endif.
+
+decode_msg_2_doit('Versions', Bin, TrUserData) ->
+ id(d_msg_Versions(Bin, TrUserData), TrUserData);
+decode_msg_2_doit('Package', Bin, TrUserData) ->
+ id(d_msg_Package(Bin, TrUserData), TrUserData).
+
+
+
+d_msg_Versions(Bin, TrUserData) ->
+ dfp_read_field_def_Versions(Bin, 0, 0,
+ id([], TrUserData), id('$undef', TrUserData),
+ TrUserData).
+
+dfp_read_field_def_Versions(<<10, Rest/binary>>, Z1, Z2,
+ F@_1, F@_2, TrUserData) ->
+ d_field_Versions_packages(Rest, Z1, Z2, F@_1, F@_2,
+ TrUserData);
+dfp_read_field_def_Versions(<<18, Rest/binary>>, Z1, Z2,
+ F@_1, F@_2, TrUserData) ->
+ d_field_Versions_repository(Rest, Z1, Z2, F@_1, F@_2,
+ TrUserData);
+dfp_read_field_def_Versions(<<>>, 0, 0, R1, F@_2,
+ TrUserData) ->
+ S1 = #{repository => F@_2},
+ if R1 == '$undef' -> S1;
+ true -> S1#{packages => lists_reverse(R1, TrUserData)}
+ end;
+dfp_read_field_def_Versions(Other, Z1, Z2, F@_1, F@_2,
+ TrUserData) ->
+ dg_read_field_def_Versions(Other, Z1, Z2, F@_1, F@_2,
+ TrUserData).
+
+dg_read_field_def_Versions(<<1:1, X:7, Rest/binary>>, N,
+ Acc, F@_1, F@_2, TrUserData)
+ when N < 32 - 7 ->
+ dg_read_field_def_Versions(Rest, N + 7, X bsl N + Acc,
+ F@_1, F@_2, TrUserData);
+dg_read_field_def_Versions(<<0:1, X:7, Rest/binary>>, N,
+ Acc, F@_1, F@_2, TrUserData) ->
+ Key = X bsl N + Acc,
+ case Key of
+ 10 ->
+ d_field_Versions_packages(Rest, 0, 0, F@_1, F@_2,
+ TrUserData);
+ 18 ->
+ d_field_Versions_repository(Rest, 0, 0, F@_1, F@_2,
+ TrUserData);
+ _ ->
+ case Key band 7 of
+ 0 ->
+ skip_varint_Versions(Rest, 0, 0, F@_1, F@_2,
+ TrUserData);
+ 1 ->
+ skip_64_Versions(Rest, 0, 0, F@_1, F@_2, TrUserData);
+ 2 ->
+ skip_length_delimited_Versions(Rest, 0, 0, F@_1, F@_2,
+ TrUserData);
+ 3 ->
+ skip_group_Versions(Rest, Key bsr 3, 0, F@_1, F@_2,
+ TrUserData);
+ 5 ->
+ skip_32_Versions(Rest, 0, 0, F@_1, F@_2, TrUserData)
+ end
+ end;
+dg_read_field_def_Versions(<<>>, 0, 0, R1, F@_2,
+ TrUserData) ->
+ S1 = #{repository => F@_2},
+ if R1 == '$undef' -> S1;
+ true -> S1#{packages => lists_reverse(R1, TrUserData)}
+ end.
+
+d_field_Versions_packages(<<1:1, X:7, Rest/binary>>, N,
+ Acc, F@_1, F@_2, TrUserData)
+ when N < 57 ->
+ d_field_Versions_packages(Rest, N + 7, X bsl N + Acc,
+ F@_1, F@_2, TrUserData);
+d_field_Versions_packages(<<0:1, X:7, Rest/binary>>, N,
+ Acc, Prev, F@_2, TrUserData) ->
+ {NewFValue, RestF} = begin
+ Len = X bsl N + Acc,
+ <<Bs:Len/binary, Rest2/binary>> = Rest,
+ {id(d_msg_Package(Bs, TrUserData), TrUserData),
+ Rest2}
+ end,
+ dfp_read_field_def_Versions(RestF, 0, 0,
+ cons(NewFValue, Prev, TrUserData), F@_2,
+ TrUserData).
+
+d_field_Versions_repository(<<1:1, X:7, Rest/binary>>,
+ N, Acc, F@_1, F@_2, TrUserData)
+ when N < 57 ->
+ d_field_Versions_repository(Rest, N + 7, X bsl N + Acc,
+ F@_1, F@_2, TrUserData);
+d_field_Versions_repository(<<0:1, X:7, Rest/binary>>,
+ N, Acc, F@_1, _, TrUserData) ->
+ {NewFValue, RestF} = begin
+ Len = X bsl N + Acc,
+ <<Bytes:Len/binary, Rest2/binary>> = Rest,
+ {id(binary:copy(Bytes), TrUserData), Rest2}
+ end,
+ dfp_read_field_def_Versions(RestF, 0, 0, F@_1,
+ NewFValue, TrUserData).
+
+skip_varint_Versions(<<1:1, _:7, Rest/binary>>, Z1, Z2,
+ F@_1, F@_2, TrUserData) ->
+ skip_varint_Versions(Rest, Z1, Z2, F@_1, F@_2,
+ TrUserData);
+skip_varint_Versions(<<0:1, _:7, Rest/binary>>, Z1, Z2,
+ F@_1, F@_2, TrUserData) ->
+ dfp_read_field_def_Versions(Rest, Z1, Z2, F@_1, F@_2,
+ TrUserData).
+
+skip_length_delimited_Versions(<<1:1, X:7,
+ Rest/binary>>,
+ N, Acc, F@_1, F@_2, TrUserData)
+ when N < 57 ->
+ skip_length_delimited_Versions(Rest, N + 7,
+ X bsl N + Acc, F@_1, F@_2, TrUserData);
+skip_length_delimited_Versions(<<0:1, X:7,
+ Rest/binary>>,
+ N, Acc, F@_1, F@_2, TrUserData) ->
+ Length = X bsl N + Acc,
+ <<_:Length/binary, Rest2/binary>> = Rest,
+ dfp_read_field_def_Versions(Rest2, 0, 0, F@_1, F@_2,
+ TrUserData).
+
+skip_group_Versions(Bin, FNum, Z2, F@_1, F@_2,
+ TrUserData) ->
+ {_, Rest} = read_group(Bin, FNum),
+ dfp_read_field_def_Versions(Rest, 0, Z2, F@_1, F@_2,
+ TrUserData).
+
+skip_32_Versions(<<_:32, Rest/binary>>, Z1, Z2, F@_1,
+ F@_2, TrUserData) ->
+ dfp_read_field_def_Versions(Rest, Z1, Z2, F@_1, F@_2,
+ TrUserData).
+
+skip_64_Versions(<<_:64, Rest/binary>>, Z1, Z2, F@_1,
+ F@_2, TrUserData) ->
+ dfp_read_field_def_Versions(Rest, Z1, Z2, F@_1, F@_2,
+ TrUserData).
+
+d_msg_Package(Bin, TrUserData) ->
+ dfp_read_field_def_Package(Bin, 0, 0,
+ id('$undef', TrUserData), id([], TrUserData),
+ id([], TrUserData), TrUserData).
+
+dfp_read_field_def_Package(<<10, Rest/binary>>, Z1, Z2,
+ F@_1, F@_2, F@_3, TrUserData) ->
+ d_field_Package_name(Rest, Z1, Z2, F@_1, F@_2, F@_3,
+ TrUserData);
+dfp_read_field_def_Package(<<18, Rest/binary>>, Z1, Z2,
+ F@_1, F@_2, F@_3, TrUserData) ->
+ d_field_Package_versions(Rest, Z1, Z2, F@_1, F@_2, F@_3,
+ TrUserData);
+dfp_read_field_def_Package(<<26, Rest/binary>>, Z1, Z2,
+ F@_1, F@_2, F@_3, TrUserData) ->
+ d_pfield_Package_retired(Rest, Z1, Z2, F@_1, F@_2, F@_3,
+ TrUserData);
+dfp_read_field_def_Package(<<24, Rest/binary>>, Z1, Z2,
+ F@_1, F@_2, F@_3, TrUserData) ->
+ d_field_Package_retired(Rest, Z1, Z2, F@_1, F@_2, F@_3,
+ TrUserData);
+dfp_read_field_def_Package(<<>>, 0, 0, F@_1, R1, R2,
+ TrUserData) ->
+ #{name => F@_1,
+ versions => lists_reverse(R1, TrUserData),
+ retired => lists_reverse(R2, TrUserData)};
+dfp_read_field_def_Package(Other, Z1, Z2, F@_1, F@_2,
+ F@_3, TrUserData) ->
+ dg_read_field_def_Package(Other, Z1, Z2, F@_1, F@_2,
+ F@_3, TrUserData).
+
+dg_read_field_def_Package(<<1:1, X:7, Rest/binary>>, N,
+ Acc, F@_1, F@_2, F@_3, TrUserData)
+ when N < 32 - 7 ->
+ dg_read_field_def_Package(Rest, N + 7, X bsl N + Acc,
+ F@_1, F@_2, F@_3, TrUserData);
+dg_read_field_def_Package(<<0:1, X:7, Rest/binary>>, N,
+ Acc, F@_1, F@_2, F@_3, TrUserData) ->
+ Key = X bsl N + Acc,
+ case Key of
+ 10 ->
+ d_field_Package_name(Rest, 0, 0, F@_1, F@_2, F@_3,
+ TrUserData);
+ 18 ->
+ d_field_Package_versions(Rest, 0, 0, F@_1, F@_2, F@_3,
+ TrUserData);
+ 26 ->
+ d_pfield_Package_retired(Rest, 0, 0, F@_1, F@_2, F@_3,
+ TrUserData);
+ 24 ->
+ d_field_Package_retired(Rest, 0, 0, F@_1, F@_2, F@_3,
+ TrUserData);
+ _ ->
+ case Key band 7 of
+ 0 ->
+ skip_varint_Package(Rest, 0, 0, F@_1, F@_2, F@_3,
+ TrUserData);
+ 1 ->
+ skip_64_Package(Rest, 0, 0, F@_1, F@_2, F@_3,
+ TrUserData);
+ 2 ->
+ skip_length_delimited_Package(Rest, 0, 0, F@_1, F@_2,
+ F@_3, TrUserData);
+ 3 ->
+ skip_group_Package(Rest, Key bsr 3, 0, F@_1, F@_2, F@_3,
+ TrUserData);
+ 5 ->
+ skip_32_Package(Rest, 0, 0, F@_1, F@_2, F@_3,
+ TrUserData)
+ end
+ end;
+dg_read_field_def_Package(<<>>, 0, 0, F@_1, R1, R2,
+ TrUserData) ->
+ #{name => F@_1,
+ versions => lists_reverse(R1, TrUserData),
+ retired => lists_reverse(R2, TrUserData)}.
+
+d_field_Package_name(<<1:1, X:7, Rest/binary>>, N, Acc,
+ F@_1, F@_2, F@_3, TrUserData)
+ when N < 57 ->
+ d_field_Package_name(Rest, N + 7, X bsl N + Acc, F@_1,
+ F@_2, F@_3, TrUserData);
+d_field_Package_name(<<0:1, X:7, Rest/binary>>, N, Acc,
+ _, F@_2, F@_3, TrUserData) ->
+ {NewFValue, RestF} = begin
+ Len = X bsl N + Acc,
+ <<Bytes:Len/binary, Rest2/binary>> = Rest,
+ {id(binary:copy(Bytes), TrUserData), Rest2}
+ end,
+ dfp_read_field_def_Package(RestF, 0, 0, NewFValue, F@_2,
+ F@_3, TrUserData).
+
+d_field_Package_versions(<<1:1, X:7, Rest/binary>>, N,
+ Acc, F@_1, F@_2, F@_3, TrUserData)
+ when N < 57 ->
+ d_field_Package_versions(Rest, N + 7, X bsl N + Acc,
+ F@_1, F@_2, F@_3, TrUserData);
+d_field_Package_versions(<<0:1, X:7, Rest/binary>>, N,
+ Acc, F@_1, Prev, F@_3, TrUserData) ->
+ {NewFValue, RestF} = begin
+ Len = X bsl N + Acc,
+ <<Bytes:Len/binary, Rest2/binary>> = Rest,
+ {id(binary:copy(Bytes), TrUserData), Rest2}
+ end,
+ dfp_read_field_def_Package(RestF, 0, 0, F@_1,
+ cons(NewFValue, Prev, TrUserData), F@_3,
+ TrUserData).
+
+d_field_Package_retired(<<1:1, X:7, Rest/binary>>, N,
+ Acc, F@_1, F@_2, F@_3, TrUserData)
+ when N < 57 ->
+ d_field_Package_retired(Rest, N + 7, X bsl N + Acc,
+ F@_1, F@_2, F@_3, TrUserData);
+d_field_Package_retired(<<0:1, X:7, Rest/binary>>, N,
+ Acc, F@_1, F@_2, Prev, TrUserData) ->
+ {NewFValue, RestF} = {begin
+ <<Res:32/signed-native>> = <<(X bsl N +
+ Acc):32/unsigned-native>>,
+ id(Res, TrUserData)
+ end,
+ Rest},
+ dfp_read_field_def_Package(RestF, 0, 0, F@_1, F@_2,
+ cons(NewFValue, Prev, TrUserData), TrUserData).
+
+d_pfield_Package_retired(<<1:1, X:7, Rest/binary>>, N,
+ Acc, F@_1, F@_2, F@_3, TrUserData)
+ when N < 57 ->
+ d_pfield_Package_retired(Rest, N + 7, X bsl N + Acc,
+ F@_1, F@_2, F@_3, TrUserData);
+d_pfield_Package_retired(<<0:1, X:7, Rest/binary>>, N,
+ Acc, F@_1, F@_2, E, TrUserData) ->
+ Len = X bsl N + Acc,
+ <<PackedBytes:Len/binary, Rest2/binary>> = Rest,
+ NewSeq = d_packed_field_Package_retired(PackedBytes, 0,
+ 0, E, TrUserData),
+ dfp_read_field_def_Package(Rest2, 0, 0, F@_1, F@_2,
+ NewSeq, TrUserData).
+
+d_packed_field_Package_retired(<<1:1, X:7,
+ Rest/binary>>,
+ N, Acc, AccSeq, TrUserData)
+ when N < 57 ->
+ d_packed_field_Package_retired(Rest, N + 7,
+ X bsl N + Acc, AccSeq, TrUserData);
+d_packed_field_Package_retired(<<0:1, X:7,
+ Rest/binary>>,
+ N, Acc, AccSeq, TrUserData) ->
+ {NewFValue, RestF} = {begin
+ <<Res:32/signed-native>> = <<(X bsl N +
+ Acc):32/unsigned-native>>,
+ id(Res, TrUserData)
+ end,
+ Rest},
+ d_packed_field_Package_retired(RestF, 0, 0,
+ [NewFValue | AccSeq], TrUserData);
+d_packed_field_Package_retired(<<>>, 0, 0, AccSeq, _) ->
+ AccSeq.
+
+skip_varint_Package(<<1:1, _:7, Rest/binary>>, Z1, Z2,
+ F@_1, F@_2, F@_3, TrUserData) ->
+ skip_varint_Package(Rest, Z1, Z2, F@_1, F@_2, F@_3,
+ TrUserData);
+skip_varint_Package(<<0:1, _:7, Rest/binary>>, Z1, Z2,
+ F@_1, F@_2, F@_3, TrUserData) ->
+ dfp_read_field_def_Package(Rest, Z1, Z2, F@_1, F@_2,
+ F@_3, TrUserData).
+
+skip_length_delimited_Package(<<1:1, X:7, Rest/binary>>,
+ N, Acc, F@_1, F@_2, F@_3, TrUserData)
+ when N < 57 ->
+ skip_length_delimited_Package(Rest, N + 7,
+ X bsl N + Acc, F@_1, F@_2, F@_3, TrUserData);
+skip_length_delimited_Package(<<0:1, X:7, Rest/binary>>,
+ N, Acc, F@_1, F@_2, F@_3, TrUserData) ->
+ Length = X bsl N + Acc,
+ <<_:Length/binary, Rest2/binary>> = Rest,
+ dfp_read_field_def_Package(Rest2, 0, 0, F@_1, F@_2,
+ F@_3, TrUserData).
+
+skip_group_Package(Bin, FNum, Z2, F@_1, F@_2, F@_3,
+ TrUserData) ->
+ {_, Rest} = read_group(Bin, FNum),
+ dfp_read_field_def_Package(Rest, 0, Z2, F@_1, F@_2,
+ F@_3, TrUserData).
+
+skip_32_Package(<<_:32, Rest/binary>>, Z1, Z2, F@_1,
+ F@_2, F@_3, TrUserData) ->
+ dfp_read_field_def_Package(Rest, Z1, Z2, F@_1, F@_2,
+ F@_3, TrUserData).
+
+skip_64_Package(<<_:64, Rest/binary>>, Z1, Z2, F@_1,
+ F@_2, F@_3, TrUserData) ->
+ dfp_read_field_def_Package(Rest, Z1, Z2, F@_1, F@_2,
+ F@_3, TrUserData).
+
+read_group(Bin, FieldNum) ->
+ {NumBytes, EndTagLen} = read_gr_b(Bin, 0, 0, 0, 0, FieldNum),
+ <<Group:NumBytes/binary, _:EndTagLen/binary, Rest/binary>> = Bin,
+ {Group, Rest}.
+
+%% Like skipping over fields, but record the total length,
+%% Each field is <(FieldNum bsl 3) bor FieldType> ++ <FieldValue>
+%% Record the length because varints may be non-optimally encoded.
+%%
+%% Groups can be nested, but assume the same FieldNum cannot be nested
+%% because group field numbers are shared with the rest of the fields
+%% numbers. Thus we can search just for an group-end with the same
+%% field number.
+%%
+%% (The only time the same group field number could occur would
+%% be in a nested sub message, but then it would be inside a
+%% length-delimited entry, which we skip-read by length.)
+read_gr_b(<<1:1, X:7, Tl/binary>>, N, Acc, NumBytes, TagLen, FieldNum)
+ when N < (32-7) ->
+ read_gr_b(Tl, N+7, X bsl N + Acc, NumBytes, TagLen+1, FieldNum);
+read_gr_b(<<0:1, X:7, Tl/binary>>, N, Acc, NumBytes, TagLen,
+ FieldNum) ->
+ Key = X bsl N + Acc,
+ TagLen1 = TagLen + 1,
+ case {Key bsr 3, Key band 7} of
+ {FieldNum, 4} -> % 4 = group_end
+ {NumBytes, TagLen1};
+ {_, 0} -> % 0 = varint
+ read_gr_vi(Tl, 0, NumBytes + TagLen1, FieldNum);
+ {_, 1} -> % 1 = bits64
+ <<_:64, Tl2/binary>> = Tl,
+ read_gr_b(Tl2, 0, 0, NumBytes + TagLen1 + 8, 0, FieldNum);
+ {_, 2} -> % 2 = length_delimited
+ read_gr_ld(Tl, 0, 0, NumBytes + TagLen1, FieldNum);
+ {_, 3} -> % 3 = group_start
+ read_gr_b(Tl, 0, 0, NumBytes + TagLen1, 0, FieldNum);
+ {_, 4} -> % 4 = group_end
+ read_gr_b(Tl, 0, 0, NumBytes + TagLen1, 0, FieldNum);
+ {_, 5} -> % 5 = bits32
+ <<_:32, Tl2/binary>> = Tl,
+ read_gr_b(Tl2, 0, 0, NumBytes + TagLen1 + 4, 0, FieldNum)
+ end.
+
+read_gr_vi(<<1:1, _:7, Tl/binary>>, N, NumBytes, FieldNum)
+ when N < (64-7) ->
+ read_gr_vi(Tl, N+7, NumBytes+1, FieldNum);
+read_gr_vi(<<0:1, _:7, Tl/binary>>, _, NumBytes, FieldNum) ->
+ read_gr_b(Tl, 0, 0, NumBytes+1, 0, FieldNum).
+
+read_gr_ld(<<1:1, X:7, Tl/binary>>, N, Acc, NumBytes, FieldNum)
+ when N < (64-7) ->
+ read_gr_ld(Tl, N+7, X bsl N + Acc, NumBytes+1, FieldNum);
+read_gr_ld(<<0:1, X:7, Tl/binary>>, N, Acc, NumBytes, FieldNum) ->
+ Len = X bsl N + Acc,
+ NumBytes1 = NumBytes + 1,
+ <<_:Len/binary, Tl2/binary>> = Tl,
+ read_gr_b(Tl2, 0, 0, NumBytes1 + Len, 0, FieldNum).
+
+merge_msgs(Prev, New, MsgName) when is_atom(MsgName) ->
+ merge_msgs(Prev, New, MsgName, []).
+
+merge_msgs(Prev, New, MsgName, Opts) ->
+ TrUserData = proplists:get_value(user_data, Opts),
+ case MsgName of
+ 'Versions' -> merge_msg_Versions(Prev, New, TrUserData);
+ 'Package' -> merge_msg_Package(Prev, New, TrUserData)
+ end.
+
+-compile({nowarn_unused_function,merge_msg_Versions/3}).
+merge_msg_Versions(#{} = PMsg,
+ #{repository := NFrepository} = NMsg, TrUserData) ->
+ S1 = #{repository => NFrepository},
+ case {PMsg, NMsg} of
+ {#{packages := PFpackages},
+ #{packages := NFpackages}} ->
+ S1#{packages =>
+ 'erlang_++'(PFpackages, NFpackages, TrUserData)};
+ {_, #{packages := NFpackages}} ->
+ S1#{packages => NFpackages};
+ {#{packages := PFpackages}, _} ->
+ S1#{packages => PFpackages};
+ {_, _} -> S1
+ end.
+
+-compile({nowarn_unused_function,merge_msg_Package/3}).
+merge_msg_Package(#{} = PMsg, #{name := NFname} = NMsg,
+ TrUserData) ->
+ S1 = #{name => NFname},
+ S2 = case {PMsg, NMsg} of
+ {#{versions := PFversions},
+ #{versions := NFversions}} ->
+ S1#{versions =>
+ 'erlang_++'(PFversions, NFversions, TrUserData)};
+ {_, #{versions := NFversions}} ->
+ S1#{versions => NFversions};
+ {#{versions := PFversions}, _} ->
+ S1#{versions => PFversions};
+ {_, _} -> S1
+ end,
+ case {PMsg, NMsg} of
+ {#{retired := PFretired}, #{retired := NFretired}} ->
+ S2#{retired =>
+ 'erlang_++'(PFretired, NFretired, TrUserData)};
+ {_, #{retired := NFretired}} ->
+ S2#{retired => NFretired};
+ {#{retired := PFretired}, _} ->
+ S2#{retired => PFretired};
+ {_, _} -> S2
+ end.
+
+
+verify_msg(Msg, MsgName) when is_atom(MsgName) ->
+ verify_msg(Msg, MsgName, []).
+
+verify_msg(Msg, MsgName, Opts) ->
+ TrUserData = proplists:get_value(user_data, Opts),
+ case MsgName of
+ 'Versions' ->
+ v_msg_Versions(Msg, [MsgName], TrUserData);
+ 'Package' -> v_msg_Package(Msg, [MsgName], TrUserData);
+ _ -> mk_type_error(not_a_known_message, Msg, [])
+ end.
+
+
+-compile({nowarn_unused_function,v_msg_Versions/3}).
+v_msg_Versions(#{repository := F2} = M, Path,
+ TrUserData) ->
+ case M of
+ #{packages := F1} ->
+ if is_list(F1) ->
+ _ = [v_msg_Package(Elem, [packages | Path], TrUserData)
+ || Elem <- F1],
+ ok;
+ true ->
+ mk_type_error({invalid_list_of, {msg, 'Package'}}, F1,
+ [packages | Path])
+ end;
+ _ -> ok
+ end,
+ v_type_string(F2, [repository | Path], TrUserData),
+ lists:foreach(fun (packages) -> ok;
+ (repository) -> ok;
+ (OtherKey) ->
+ mk_type_error({extraneous_key, OtherKey}, M, Path)
+ end,
+ maps:keys(M)),
+ ok;
+v_msg_Versions(M, Path, _TrUserData) when is_map(M) ->
+ mk_type_error({missing_fields,
+ [repository] -- maps:keys(M), 'Versions'},
+ M, Path);
+v_msg_Versions(X, Path, _TrUserData) ->
+ mk_type_error({expected_msg, 'Versions'}, X, Path).
+
+-compile({nowarn_unused_function,v_msg_Package/3}).
+v_msg_Package(#{name := F1} = M, Path, TrUserData) ->
+ v_type_string(F1, [name | Path], TrUserData),
+ case M of
+ #{versions := F2} ->
+ if is_list(F2) ->
+ _ = [v_type_string(Elem, [versions | Path], TrUserData)
+ || Elem <- F2],
+ ok;
+ true ->
+ mk_type_error({invalid_list_of, string}, F2,
+ [versions | Path])
+ end;
+ _ -> ok
+ end,
+ case M of
+ #{retired := F3} ->
+ if is_list(F3) ->
+ _ = [v_type_int32(Elem, [retired | Path], TrUserData)
+ || Elem <- F3],
+ ok;
+ true ->
+ mk_type_error({invalid_list_of, int32}, F3,
+ [retired | Path])
+ end;
+ _ -> ok
+ end,
+ lists:foreach(fun (name) -> ok;
+ (versions) -> ok;
+ (retired) -> ok;
+ (OtherKey) ->
+ mk_type_error({extraneous_key, OtherKey}, M, Path)
+ end,
+ maps:keys(M)),
+ ok;
+v_msg_Package(M, Path, _TrUserData) when is_map(M) ->
+ mk_type_error({missing_fields, [name] -- maps:keys(M),
+ 'Package'},
+ M, Path);
+v_msg_Package(X, Path, _TrUserData) ->
+ mk_type_error({expected_msg, 'Package'}, X, Path).
+
+-compile({nowarn_unused_function,v_type_int32/3}).
+v_type_int32(N, _Path, _TrUserData)
+ when -2147483648 =< N, N =< 2147483647 ->
+ ok;
+v_type_int32(N, Path, _TrUserData) when is_integer(N) ->
+ mk_type_error({value_out_of_range, int32, signed, 32},
+ N, Path);
+v_type_int32(X, Path, _TrUserData) ->
+ mk_type_error({bad_integer, int32, signed, 32}, X,
+ Path).
+
+-compile({nowarn_unused_function,v_type_string/3}).
+v_type_string(S, Path, _TrUserData)
+ when is_list(S); is_binary(S) ->
+ try unicode:characters_to_binary(S) of
+ B when is_binary(B) -> ok;
+ {error, _, _} ->
+ mk_type_error(bad_unicode_string, S, Path)
+ catch
+ error:badarg ->
+ mk_type_error(bad_unicode_string, S, Path)
+ end;
+v_type_string(X, Path, _TrUserData) ->
+ mk_type_error(bad_unicode_string, X, Path).
+
+-compile({nowarn_unused_function,mk_type_error/3}).
+-spec mk_type_error(_, _, list()) -> no_return().
+mk_type_error(Error, ValueSeen, Path) ->
+ Path2 = prettify_path(Path),
+ erlang:error({gpb_type_error,
+ {Error, [{value, ValueSeen}, {path, Path2}]}}).
+
+
+-compile({nowarn_unused_function,prettify_path/1}).
+prettify_path([]) -> top_level;
+prettify_path(PathR) ->
+ list_to_atom(string:join(lists:map(fun atom_to_list/1,
+ lists:reverse(PathR)),
+ ".")).
+
+
+-compile({nowarn_unused_function,id/2}).
+-compile({inline,id/2}).
+id(X, _TrUserData) -> X.
+
+-compile({nowarn_unused_function,v_ok/3}).
+-compile({inline,v_ok/3}).
+v_ok(_Value, _Path, _TrUserData) -> ok.
+
+-compile({nowarn_unused_function,m_overwrite/3}).
+-compile({inline,m_overwrite/3}).
+m_overwrite(_Prev, New, _TrUserData) -> New.
+
+-compile({nowarn_unused_function,cons/3}).
+-compile({inline,cons/3}).
+cons(Elem, Acc, _TrUserData) -> [Elem | Acc].
+
+-compile({nowarn_unused_function,lists_reverse/2}).
+-compile({inline,lists_reverse/2}).
+'lists_reverse'(L, _TrUserData) -> lists:reverse(L).
+-compile({nowarn_unused_function,'erlang_++'/3}).
+-compile({inline,'erlang_++'/3}).
+'erlang_++'(A, B, _TrUserData) -> A ++ B.
+
+get_msg_defs() ->
+ [{{msg, 'Versions'},
+ [#{name => packages, fnum => 1, rnum => 2,
+ type => {msg, 'Package'}, occurrence => repeated,
+ opts => []},
+ #{name => repository, fnum => 2, rnum => 3,
+ type => string, occurrence => required, opts => []}]},
+ {{msg, 'Package'},
+ [#{name => name, fnum => 1, rnum => 2, type => string,
+ occurrence => required, opts => []},
+ #{name => versions, fnum => 2, rnum => 3,
+ type => string, occurrence => repeated, opts => []},
+ #{name => retired, fnum => 3, rnum => 4, type => int32,
+ occurrence => repeated, opts => [packed]}]}].
+
+
+get_msg_names() -> ['Versions', 'Package'].
+
+
+get_group_names() -> [].
+
+
+get_msg_or_group_names() -> ['Versions', 'Package'].
+
+
+get_enum_names() -> [].
+
+
+fetch_msg_def(MsgName) ->
+ case find_msg_def(MsgName) of
+ Fs when is_list(Fs) -> Fs;
+ error -> erlang:error({no_such_msg, MsgName})
+ end.
+
+
+-spec fetch_enum_def(_) -> no_return().
+fetch_enum_def(EnumName) ->
+ erlang:error({no_such_enum, EnumName}).
+
+
+find_msg_def('Versions') ->
+ [#{name => packages, fnum => 1, rnum => 2,
+ type => {msg, 'Package'}, occurrence => repeated,
+ opts => []},
+ #{name => repository, fnum => 2, rnum => 3,
+ type => string, occurrence => required, opts => []}];
+find_msg_def('Package') ->
+ [#{name => name, fnum => 1, rnum => 2, type => string,
+ occurrence => required, opts => []},
+ #{name => versions, fnum => 2, rnum => 3,
+ type => string, occurrence => repeated, opts => []},
+ #{name => retired, fnum => 3, rnum => 4, type => int32,
+ occurrence => repeated, opts => [packed]}];
+find_msg_def(_) -> error.
+
+
+find_enum_def(_) -> error.
+
+
+-spec enum_symbol_by_value(_, _) -> no_return().
+enum_symbol_by_value(E, V) ->
+ erlang:error({no_enum_defs, E, V}).
+
+
+-spec enum_value_by_symbol(_, _) -> no_return().
+enum_value_by_symbol(E, V) ->
+ erlang:error({no_enum_defs, E, V}).
+
+
+
+get_service_names() -> [].
+
+
+get_service_def(_) -> error.
+
+
+get_rpc_names(_) -> error.
+
+
+find_rpc_def(_, _) -> error.
+
+
+
+-spec fetch_rpc_def(_, _) -> no_return().
+fetch_rpc_def(ServiceName, RpcName) ->
+ erlang:error({no_such_rpc, ServiceName, RpcName}).
+
+
+get_package_name() -> undefined.
+
+
+
+gpb_version_as_string() ->
+ "4.3.1".
+
+gpb_version_as_list() ->
+ [4,3,1].