From 059846a08d1fb67b468004a908f650a10f47457e Mon Sep 17 00:00:00 2001 From: "U-JOHNLIU\\jonhl" Date: Tue, 8 Feb 2022 01:26:15 +0800 Subject: [PATCH] fix: ci failed --- apps/dgiot_dlink/src/dgiot_dlink_bhvr.erl | 20 - apps/dgiot_dlink/src/dgiot_dlink_client.erl | 79 - apps/dgiot_dlink/src/dgiot_dlink_pb.erl | 1631 ------------------- 3 files changed, 1730 deletions(-) delete mode 100644 apps/dgiot_dlink/src/dgiot_dlink_bhvr.erl delete mode 100644 apps/dgiot_dlink/src/dgiot_dlink_client.erl delete mode 100644 apps/dgiot_dlink/src/dgiot_dlink_pb.erl diff --git a/apps/dgiot_dlink/src/dgiot_dlink_bhvr.erl b/apps/dgiot_dlink/src/dgiot_dlink_bhvr.erl deleted file mode 100644 index 423839c6..00000000 --- a/apps/dgiot_dlink/src/dgiot_dlink_bhvr.erl +++ /dev/null @@ -1,20 +0,0 @@ -%%%------------------------------------------------------------------- -%% @doc Behaviour to implement for grpc service dgiot.Dlink. -%% @end -%%%------------------------------------------------------------------- - -%% this module was generated and should not be modified manually - --module(dgiot_dlink_bhvr). - --callback say_hello(dgiot_dlink_pb:hello_request(), grpc:metadata()) - -> {ok, dgiot_dlink_pb:hello_reply(), grpc:metadata()} - | {error, grpc_stream:error_response()}. - --callback check(dgiot_dlink_pb:health_check_request(), grpc:metadata()) - -> {ok, dgiot_dlink_pb:health_check_response(), grpc:metadata()} - | {error, grpc_stream:error_response()}. - --callback watch(grpc_stream:stream(), grpc:metadata()) - -> {ok, grpc_stream:stream()}. - diff --git a/apps/dgiot_dlink/src/dgiot_dlink_client.erl b/apps/dgiot_dlink/src/dgiot_dlink_client.erl deleted file mode 100644 index 5d2da067..00000000 --- a/apps/dgiot_dlink/src/dgiot_dlink_client.erl +++ /dev/null @@ -1,79 +0,0 @@ -%%%------------------------------------------------------------------- -%% @doc Client module for grpc service dgiot.Dlink. -%% @end -%%%------------------------------------------------------------------- - -%% this module was generated and should not be modified manually - --module(dgiot_dlink_client). - --compile(export_all). --compile(nowarn_export_all). - --include_lib("grpc/include/grpc.hrl"). - --define(SERVICE, 'dgiot.Dlink'). --define(PROTO_MODULE, 'dgiot_dlink_pb'). --define(MARSHAL(T), fun(I) -> ?PROTO_MODULE:encode_msg(I, T) end). --define(UNMARSHAL(T), fun(I) -> ?PROTO_MODULE:decode_msg(I, T) end). --define(DEF(Path, Req, Resp, MessageType), - #{path => Path, - service =>?SERVICE, - message_type => MessageType, - marshal => ?MARSHAL(Req), - unmarshal => ?UNMARSHAL(Resp)}). - --spec say_hello(dgiot_dlink_pb:hello_request()) - -> {ok, dgiot_dlink_pb:hello_reply(), grpc:metadata()} - | {error, term()}. -say_hello(Req) -> - say_hello(Req, #{}, #{}). - --spec say_hello(dgiot_dlink_pb:hello_request(), grpc:options()) - -> {ok, dgiot_dlink_pb:hello_reply(), grpc:metadata()} - | {error, term()}. -say_hello(Req, Options) -> - say_hello(Req, #{}, Options). - --spec say_hello(dgiot_dlink_pb:hello_request(), grpc:metadata(), grpc_client:options()) - -> {ok, dgiot_dlink_pb:hello_reply(), grpc:metadata()} - | {error, term()}. -say_hello(Req, Metadata, Options) -> - grpc_client:unary(?DEF(<<"/dgiot.Dlink/SayHello">>, - hello_request, hello_reply, <<"dgiot.HelloRequest">>), - Req, Metadata, Options). - --spec check(dgiot_dlink_pb:health_check_request()) - -> {ok, dgiot_dlink_pb:health_check_response(), grpc:metadata()} - | {error, term()}. -check(Req) -> - check(Req, #{}, #{}). - --spec check(dgiot_dlink_pb:health_check_request(), grpc:options()) - -> {ok, dgiot_dlink_pb:health_check_response(), grpc:metadata()} - | {error, term()}. -check(Req, Options) -> - check(Req, #{}, Options). - --spec check(dgiot_dlink_pb:health_check_request(), grpc:metadata(), grpc_client:options()) - -> {ok, dgiot_dlink_pb:health_check_response(), grpc:metadata()} - | {error, term()}. -check(Req, Metadata, Options) -> - grpc_client:unary(?DEF(<<"/dgiot.Dlink/Check">>, - health_check_request, health_check_response, <<"dgiot.HealthCheckRequest">>), - Req, Metadata, Options). - --spec watch(grpc_client:options()) - -> {ok, grpc_client:grpcstream()} - | {error, term()}. -watch(Options) -> - watch(#{}, Options). - --spec watch(grpc:metadata(), grpc_client:options()) - -> {ok, grpc_client:grpcstream()} - | {error, term()}. -watch(Metadata, Options) -> - grpc_client:open(?DEF(<<"/dgiot.Dlink/Watch">>, - health_check_request, health_check_response, <<"dgiot.HealthCheckRequest">>), - Metadata, Options). - diff --git a/apps/dgiot_dlink/src/dgiot_dlink_pb.erl b/apps/dgiot_dlink/src/dgiot_dlink_pb.erl deleted file mode 100644 index c331a8ab..00000000 --- a/apps/dgiot_dlink/src/dgiot_dlink_pb.erl +++ /dev/null @@ -1,1631 +0,0 @@ -%% -*- coding: utf-8 -*- -%% @private -%% Automatically generated, do not edit -%% Generated by gpb_compile version 4.11.2 --module(dgiot_dlink_pb). - --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(['enum_symbol_by_value_health_check_response.ServingStatus'/1, 'enum_value_by_symbol_health_check_response.ServingStatus'/1]). --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([fqbin_to_service_name/1]). --export([service_name_to_fqbin/1]). --export([fqbins_to_service_and_rpc_name/2]). --export([service_and_rpc_name_to_fqbins/2]). --export([fqbin_to_msg_name/1]). --export([msg_name_to_fqbin/1]). --export([fqbin_to_enum_name/1]). --export([enum_name_to_fqbin/1]). --export([get_package_name/0]). --export([uses_packages/0]). --export([source_basename/0]). --export([get_all_source_basenames/0]). --export([get_all_proto_names/0]). --export([get_msg_containment/1]). --export([get_pkg_containment/1]). --export([get_service_containment/1]). --export([get_rpc_containment/1]). --export([get_enum_containment/1]). --export([get_proto_by_msg_name_as_fqbin/1]). --export([get_proto_by_service_name_as_fqbin/1]). --export([get_proto_by_enum_name_as_fqbin/1]). --export([get_protos_by_pkg_name_as_fqbin/1]). --export([gpb_version_as_string/0, gpb_version_as_list/0]). - - -%% enumerated types --type 'health_check_response.ServingStatus'() :: 'UNKNOWN' | 'SERVING' | 'NOT_SERVING' | 'SERVICE_UNKNOWN'. --export_type(['health_check_response.ServingStatus'/0]). - -%% message types --type hello_request() :: - #{name => iodata() % = 1 - }. - --type hello_reply() :: - #{message => iodata() % = 1 - }. - --type health_check_request() :: - #{service => iodata() % = 1 - }. - --type health_check_response() :: - #{status => 'UNKNOWN' | 'SERVING' | 'NOT_SERVING' | 'SERVICE_UNKNOWN' | integer() % = 1, enum health_check_response.ServingStatus - }. - --export_type(['hello_request'/0, 'hello_reply'/0, 'health_check_request'/0, 'health_check_response'/0]). - --spec encode_msg(hello_request() | hello_reply() | health_check_request() | health_check_response(), atom()) -> binary(). -encode_msg(Msg, MsgName) when is_atom(MsgName) -> - encode_msg(Msg, MsgName, []). - --spec encode_msg(hello_request() | hello_reply() | health_check_request() | health_check_response(), atom(), list()) -> binary(). -encode_msg(Msg, MsgName, Opts) -> - case proplists:get_bool(verify, Opts) of - true -> verify_msg(Msg, MsgName, Opts); - false -> ok - end, - TrUserData = proplists:get_value(user_data, Opts), - case MsgName of - hello_request -> - encode_msg_hello_request(id(Msg, TrUserData), - TrUserData); - hello_reply -> - encode_msg_hello_reply(id(Msg, TrUserData), TrUserData); - health_check_request -> - encode_msg_health_check_request(id(Msg, TrUserData), - TrUserData); - health_check_response -> - encode_msg_health_check_response(id(Msg, TrUserData), - TrUserData) - end. - - -encode_msg_hello_request(Msg, TrUserData) -> - encode_msg_hello_request(Msg, <<>>, TrUserData). - - -encode_msg_hello_request(#{} = M, Bin, TrUserData) -> - case M of - #{name := F1} -> - begin - TrF1 = id(F1, TrUserData), - case is_empty_string(TrF1) of - true -> Bin; - false -> - e_type_string(TrF1, <>, TrUserData) - end - end; - _ -> Bin - end. - -encode_msg_hello_reply(Msg, TrUserData) -> - encode_msg_hello_reply(Msg, <<>>, TrUserData). - - -encode_msg_hello_reply(#{} = M, Bin, TrUserData) -> - case M of - #{message := F1} -> - begin - TrF1 = id(F1, TrUserData), - case is_empty_string(TrF1) of - true -> Bin; - false -> - e_type_string(TrF1, <>, TrUserData) - end - end; - _ -> Bin - end. - -encode_msg_health_check_request(Msg, TrUserData) -> - encode_msg_health_check_request(Msg, <<>>, TrUserData). - - -encode_msg_health_check_request(#{} = M, Bin, - TrUserData) -> - case M of - #{service := F1} -> - begin - TrF1 = id(F1, TrUserData), - case is_empty_string(TrF1) of - true -> Bin; - false -> - e_type_string(TrF1, <>, TrUserData) - end - end; - _ -> Bin - end. - -encode_msg_health_check_response(Msg, TrUserData) -> - encode_msg_health_check_response(Msg, <<>>, TrUserData). - - -encode_msg_health_check_response(#{} = M, Bin, - TrUserData) -> - case M of - #{status := F1} -> - begin - TrF1 = id(F1, TrUserData), - if TrF1 =:= 'UNKNOWN'; TrF1 =:= 0 -> Bin; - true -> - 'e_enum_health_check_response.ServingStatus'(TrF1, - <>, - TrUserData) - end - end; - _ -> Bin - end. - -'e_enum_health_check_response.ServingStatus'('UNKNOWN', - Bin, _TrUserData) -> - <>; -'e_enum_health_check_response.ServingStatus'('SERVING', - Bin, _TrUserData) -> - <>; -'e_enum_health_check_response.ServingStatus'('NOT_SERVING', - Bin, _TrUserData) -> - <>; -'e_enum_health_check_response.ServingStatus'('SERVICE_UNKNOWN', - Bin, _TrUserData) -> - <>; -'e_enum_health_check_response.ServingStatus'(V, Bin, - _TrUserData) -> - e_varint(V, 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 -> - <>; -e_type_int32(Value, Bin, _TrUserData) -> - <> = <>, - e_varint(N, Bin). - --compile({nowarn_unused_function,e_type_int64/3}). -e_type_int64(Value, Bin, _TrUserData) - when 0 =< Value, Value =< 127 -> - <>; -e_type_int64(Value, Bin, _TrUserData) -> - <> = <>, - e_varint(N, Bin). - --compile({nowarn_unused_function,e_type_bool/3}). -e_type_bool(true, Bin, _TrUserData) -> - <>; -e_type_bool(false, Bin, _TrUserData) -> - <>; -e_type_bool(1, Bin, _TrUserData) -> <>; -e_type_bool(0, Bin, _TrUserData) -> <>. - --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), - <>. - --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), - <>; -e_type_bytes(Bytes, Bin, _TrUserData) - when is_list(Bytes) -> - BytesBin = iolist_to_binary(Bytes), - Bin2 = e_varint(byte_size(BytesBin), Bin), - <>. - --compile({nowarn_unused_function,e_type_fixed32/3}). -e_type_fixed32(Value, Bin, _TrUserData) -> - <>. - --compile({nowarn_unused_function,e_type_sfixed32/3}). -e_type_sfixed32(Value, Bin, _TrUserData) -> - <>. - --compile({nowarn_unused_function,e_type_fixed64/3}). -e_type_fixed64(Value, Bin, _TrUserData) -> - <>. - --compile({nowarn_unused_function,e_type_sfixed64/3}). -e_type_sfixed64(Value, Bin, _TrUserData) -> - <>. - --compile({nowarn_unused_function,e_type_float/3}). -e_type_float(V, Bin, _) when is_number(V) -> - <>; -e_type_float(infinity, Bin, _) -> - <>; -e_type_float('-infinity', Bin, _) -> - <>; -e_type_float(nan, Bin, _) -> - <>. - --compile({nowarn_unused_function,e_type_double/3}). -e_type_double(V, Bin, _) when is_number(V) -> - <>; -e_type_double(infinity, Bin, _) -> - <>; -e_type_double('-infinity', Bin, _) -> - <>; -e_type_double(nan, Bin, _) -> - <>. - --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 -> <>; -e_varint(N, Bin) -> - Bin2 = <>, - e_varint(N bsr 7, Bin2). - -is_empty_string("") -> true; -is_empty_string(<<>>) -> true; -is_empty_string(L) when is_list(L) -> - not string_has_chars(L); -is_empty_string(B) when is_binary(B) -> false. - -string_has_chars([C | _]) when is_integer(C) -> true; -string_has_chars([H | T]) -> - case string_has_chars(H) of - true -> true; - false -> string_has_chars(T) - end; -string_has_chars(B) - when is_binary(B), byte_size(B) =/= 0 -> - true; -string_has_chars(C) when is_integer(C) -> true; -string_has_chars(<<>>) -> false; -string_has_chars([]) -> false. - - -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. -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. - -decode_msg_2_doit(hello_request, Bin, TrUserData) -> - id(decode_msg_hello_request(Bin, TrUserData), - TrUserData); -decode_msg_2_doit(hello_reply, Bin, TrUserData) -> - id(decode_msg_hello_reply(Bin, TrUserData), TrUserData); -decode_msg_2_doit(health_check_request, Bin, - TrUserData) -> - id(decode_msg_health_check_request(Bin, TrUserData), - TrUserData); -decode_msg_2_doit(health_check_response, Bin, - TrUserData) -> - id(decode_msg_health_check_response(Bin, TrUserData), - TrUserData). - - - -decode_msg_hello_request(Bin, TrUserData) -> - dfp_read_field_def_hello_request(Bin, - 0, - 0, - id(<<>>, TrUserData), - TrUserData). - -dfp_read_field_def_hello_request(<<10, Rest/binary>>, - Z1, Z2, F@_1, TrUserData) -> - d_field_hello_request_name(Rest, - Z1, - Z2, - F@_1, - TrUserData); -dfp_read_field_def_hello_request(<<>>, 0, 0, F@_1, _) -> - #{name => F@_1}; -dfp_read_field_def_hello_request(Other, Z1, Z2, F@_1, - TrUserData) -> - dg_read_field_def_hello_request(Other, - Z1, - Z2, - F@_1, - TrUserData). - -dg_read_field_def_hello_request(<<1:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) - when N < 32 - 7 -> - dg_read_field_def_hello_request(Rest, - N + 7, - X bsl N + Acc, - F@_1, - TrUserData); -dg_read_field_def_hello_request(<<0:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) -> - Key = X bsl N + Acc, - case Key of - 10 -> - d_field_hello_request_name(Rest, - 0, - 0, - F@_1, - TrUserData); - _ -> - case Key band 7 of - 0 -> - skip_varint_hello_request(Rest, 0, 0, F@_1, TrUserData); - 1 -> - skip_64_hello_request(Rest, 0, 0, F@_1, TrUserData); - 2 -> - skip_length_delimited_hello_request(Rest, - 0, - 0, - F@_1, - TrUserData); - 3 -> - skip_group_hello_request(Rest, - Key bsr 3, - 0, - F@_1, - TrUserData); - 5 -> skip_32_hello_request(Rest, 0, 0, F@_1, TrUserData) - end - end; -dg_read_field_def_hello_request(<<>>, 0, 0, F@_1, _) -> - #{name => F@_1}. - -d_field_hello_request_name(<<1:1, X:7, Rest/binary>>, N, - Acc, F@_1, TrUserData) - when N < 57 -> - d_field_hello_request_name(Rest, - N + 7, - X bsl N + Acc, - F@_1, - TrUserData); -d_field_hello_request_name(<<0:1, X:7, Rest/binary>>, N, - Acc, _, TrUserData) -> - {NewFValue, RestF} = begin - Len = X bsl N + Acc, - <> = Rest, - {id(binary:copy(Bytes), TrUserData), Rest2} - end, - dfp_read_field_def_hello_request(RestF, - 0, - 0, - NewFValue, - TrUserData). - -skip_varint_hello_request(<<1:1, _:7, Rest/binary>>, Z1, - Z2, F@_1, TrUserData) -> - skip_varint_hello_request(Rest, - Z1, - Z2, - F@_1, - TrUserData); -skip_varint_hello_request(<<0:1, _:7, Rest/binary>>, Z1, - Z2, F@_1, TrUserData) -> - dfp_read_field_def_hello_request(Rest, - Z1, - Z2, - F@_1, - TrUserData). - -skip_length_delimited_hello_request(<<1:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) - when N < 57 -> - skip_length_delimited_hello_request(Rest, - N + 7, - X bsl N + Acc, - F@_1, - TrUserData); -skip_length_delimited_hello_request(<<0:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) -> - Length = X bsl N + Acc, - <<_:Length/binary, Rest2/binary>> = Rest, - dfp_read_field_def_hello_request(Rest2, - 0, - 0, - F@_1, - TrUserData). - -skip_group_hello_request(Bin, FNum, Z2, F@_1, - TrUserData) -> - {_, Rest} = read_group(Bin, FNum), - dfp_read_field_def_hello_request(Rest, - 0, - Z2, - F@_1, - TrUserData). - -skip_32_hello_request(<<_:32, Rest/binary>>, Z1, Z2, - F@_1, TrUserData) -> - dfp_read_field_def_hello_request(Rest, - Z1, - Z2, - F@_1, - TrUserData). - -skip_64_hello_request(<<_:64, Rest/binary>>, Z1, Z2, - F@_1, TrUserData) -> - dfp_read_field_def_hello_request(Rest, - Z1, - Z2, - F@_1, - TrUserData). - -decode_msg_hello_reply(Bin, TrUserData) -> - dfp_read_field_def_hello_reply(Bin, - 0, - 0, - id(<<>>, TrUserData), - TrUserData). - -dfp_read_field_def_hello_reply(<<10, Rest/binary>>, Z1, - Z2, F@_1, TrUserData) -> - d_field_hello_reply_message(Rest, - Z1, - Z2, - F@_1, - TrUserData); -dfp_read_field_def_hello_reply(<<>>, 0, 0, F@_1, _) -> - #{message => F@_1}; -dfp_read_field_def_hello_reply(Other, Z1, Z2, F@_1, - TrUserData) -> - dg_read_field_def_hello_reply(Other, - Z1, - Z2, - F@_1, - TrUserData). - -dg_read_field_def_hello_reply(<<1:1, X:7, Rest/binary>>, - N, Acc, F@_1, TrUserData) - when N < 32 - 7 -> - dg_read_field_def_hello_reply(Rest, - N + 7, - X bsl N + Acc, - F@_1, - TrUserData); -dg_read_field_def_hello_reply(<<0:1, X:7, Rest/binary>>, - N, Acc, F@_1, TrUserData) -> - Key = X bsl N + Acc, - case Key of - 10 -> - d_field_hello_reply_message(Rest, - 0, - 0, - F@_1, - TrUserData); - _ -> - case Key band 7 of - 0 -> - skip_varint_hello_reply(Rest, 0, 0, F@_1, TrUserData); - 1 -> skip_64_hello_reply(Rest, 0, 0, F@_1, TrUserData); - 2 -> - skip_length_delimited_hello_reply(Rest, - 0, - 0, - F@_1, - TrUserData); - 3 -> - skip_group_hello_reply(Rest, - Key bsr 3, - 0, - F@_1, - TrUserData); - 5 -> skip_32_hello_reply(Rest, 0, 0, F@_1, TrUserData) - end - end; -dg_read_field_def_hello_reply(<<>>, 0, 0, F@_1, _) -> - #{message => F@_1}. - -d_field_hello_reply_message(<<1:1, X:7, Rest/binary>>, - N, Acc, F@_1, TrUserData) - when N < 57 -> - d_field_hello_reply_message(Rest, - N + 7, - X bsl N + Acc, - F@_1, - TrUserData); -d_field_hello_reply_message(<<0:1, X:7, Rest/binary>>, - N, Acc, _, TrUserData) -> - {NewFValue, RestF} = begin - Len = X bsl N + Acc, - <> = Rest, - {id(binary:copy(Bytes), TrUserData), Rest2} - end, - dfp_read_field_def_hello_reply(RestF, - 0, - 0, - NewFValue, - TrUserData). - -skip_varint_hello_reply(<<1:1, _:7, Rest/binary>>, Z1, - Z2, F@_1, TrUserData) -> - skip_varint_hello_reply(Rest, Z1, Z2, F@_1, TrUserData); -skip_varint_hello_reply(<<0:1, _:7, Rest/binary>>, Z1, - Z2, F@_1, TrUserData) -> - dfp_read_field_def_hello_reply(Rest, - Z1, - Z2, - F@_1, - TrUserData). - -skip_length_delimited_hello_reply(<<1:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) - when N < 57 -> - skip_length_delimited_hello_reply(Rest, - N + 7, - X bsl N + Acc, - F@_1, - TrUserData); -skip_length_delimited_hello_reply(<<0:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) -> - Length = X bsl N + Acc, - <<_:Length/binary, Rest2/binary>> = Rest, - dfp_read_field_def_hello_reply(Rest2, - 0, - 0, - F@_1, - TrUserData). - -skip_group_hello_reply(Bin, FNum, Z2, F@_1, - TrUserData) -> - {_, Rest} = read_group(Bin, FNum), - dfp_read_field_def_hello_reply(Rest, - 0, - Z2, - F@_1, - TrUserData). - -skip_32_hello_reply(<<_:32, Rest/binary>>, Z1, Z2, F@_1, - TrUserData) -> - dfp_read_field_def_hello_reply(Rest, - Z1, - Z2, - F@_1, - TrUserData). - -skip_64_hello_reply(<<_:64, Rest/binary>>, Z1, Z2, F@_1, - TrUserData) -> - dfp_read_field_def_hello_reply(Rest, - Z1, - Z2, - F@_1, - TrUserData). - -decode_msg_health_check_request(Bin, TrUserData) -> - dfp_read_field_def_health_check_request(Bin, - 0, - 0, - id(<<>>, TrUserData), - TrUserData). - -dfp_read_field_def_health_check_request(<<10, - Rest/binary>>, - Z1, Z2, F@_1, TrUserData) -> - d_field_health_check_request_service(Rest, - Z1, - Z2, - F@_1, - TrUserData); -dfp_read_field_def_health_check_request(<<>>, 0, 0, - F@_1, _) -> - #{service => F@_1}; -dfp_read_field_def_health_check_request(Other, Z1, Z2, - F@_1, TrUserData) -> - dg_read_field_def_health_check_request(Other, - Z1, - Z2, - F@_1, - TrUserData). - -dg_read_field_def_health_check_request(<<1:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) - when N < 32 - 7 -> - dg_read_field_def_health_check_request(Rest, - N + 7, - X bsl N + Acc, - F@_1, - TrUserData); -dg_read_field_def_health_check_request(<<0:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) -> - Key = X bsl N + Acc, - case Key of - 10 -> - d_field_health_check_request_service(Rest, - 0, - 0, - F@_1, - TrUserData); - _ -> - case Key band 7 of - 0 -> - skip_varint_health_check_request(Rest, - 0, - 0, - F@_1, - TrUserData); - 1 -> - skip_64_health_check_request(Rest, - 0, - 0, - F@_1, - TrUserData); - 2 -> - skip_length_delimited_health_check_request(Rest, - 0, - 0, - F@_1, - TrUserData); - 3 -> - skip_group_health_check_request(Rest, - Key bsr 3, - 0, - F@_1, - TrUserData); - 5 -> - skip_32_health_check_request(Rest, - 0, - 0, - F@_1, - TrUserData) - end - end; -dg_read_field_def_health_check_request(<<>>, 0, 0, F@_1, - _) -> - #{service => F@_1}. - -d_field_health_check_request_service(<<1:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) - when N < 57 -> - d_field_health_check_request_service(Rest, - N + 7, - X bsl N + Acc, - F@_1, - TrUserData); -d_field_health_check_request_service(<<0:1, X:7, - Rest/binary>>, - N, Acc, _, TrUserData) -> - {NewFValue, RestF} = begin - Len = X bsl N + Acc, - <> = Rest, - {id(binary:copy(Bytes), TrUserData), Rest2} - end, - dfp_read_field_def_health_check_request(RestF, - 0, - 0, - NewFValue, - TrUserData). - -skip_varint_health_check_request(<<1:1, _:7, - Rest/binary>>, - Z1, Z2, F@_1, TrUserData) -> - skip_varint_health_check_request(Rest, - Z1, - Z2, - F@_1, - TrUserData); -skip_varint_health_check_request(<<0:1, _:7, - Rest/binary>>, - Z1, Z2, F@_1, TrUserData) -> - dfp_read_field_def_health_check_request(Rest, - Z1, - Z2, - F@_1, - TrUserData). - -skip_length_delimited_health_check_request(<<1:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) - when N < 57 -> - skip_length_delimited_health_check_request(Rest, - N + 7, - X bsl N + Acc, - F@_1, - TrUserData); -skip_length_delimited_health_check_request(<<0:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) -> - Length = X bsl N + Acc, - <<_:Length/binary, Rest2/binary>> = Rest, - dfp_read_field_def_health_check_request(Rest2, - 0, - 0, - F@_1, - TrUserData). - -skip_group_health_check_request(Bin, FNum, Z2, F@_1, - TrUserData) -> - {_, Rest} = read_group(Bin, FNum), - dfp_read_field_def_health_check_request(Rest, - 0, - Z2, - F@_1, - TrUserData). - -skip_32_health_check_request(<<_:32, Rest/binary>>, Z1, - Z2, F@_1, TrUserData) -> - dfp_read_field_def_health_check_request(Rest, - Z1, - Z2, - F@_1, - TrUserData). - -skip_64_health_check_request(<<_:64, Rest/binary>>, Z1, - Z2, F@_1, TrUserData) -> - dfp_read_field_def_health_check_request(Rest, - Z1, - Z2, - F@_1, - TrUserData). - -decode_msg_health_check_response(Bin, TrUserData) -> - dfp_read_field_def_health_check_response(Bin, - 0, - 0, - id('UNKNOWN', TrUserData), - TrUserData). - -dfp_read_field_def_health_check_response(<<8, - Rest/binary>>, - Z1, Z2, F@_1, TrUserData) -> - d_field_health_check_response_status(Rest, - Z1, - Z2, - F@_1, - TrUserData); -dfp_read_field_def_health_check_response(<<>>, 0, 0, - F@_1, _) -> - #{status => F@_1}; -dfp_read_field_def_health_check_response(Other, Z1, Z2, - F@_1, TrUserData) -> - dg_read_field_def_health_check_response(Other, - Z1, - Z2, - F@_1, - TrUserData). - -dg_read_field_def_health_check_response(<<1:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) - when N < 32 - 7 -> - dg_read_field_def_health_check_response(Rest, - N + 7, - X bsl N + Acc, - F@_1, - TrUserData); -dg_read_field_def_health_check_response(<<0:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) -> - Key = X bsl N + Acc, - case Key of - 8 -> - d_field_health_check_response_status(Rest, - 0, - 0, - F@_1, - TrUserData); - _ -> - case Key band 7 of - 0 -> - skip_varint_health_check_response(Rest, - 0, - 0, - F@_1, - TrUserData); - 1 -> - skip_64_health_check_response(Rest, - 0, - 0, - F@_1, - TrUserData); - 2 -> - skip_length_delimited_health_check_response(Rest, - 0, - 0, - F@_1, - TrUserData); - 3 -> - skip_group_health_check_response(Rest, - Key bsr 3, - 0, - F@_1, - TrUserData); - 5 -> - skip_32_health_check_response(Rest, - 0, - 0, - F@_1, - TrUserData) - end - end; -dg_read_field_def_health_check_response(<<>>, 0, 0, - F@_1, _) -> - #{status => F@_1}. - -d_field_health_check_response_status(<<1:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) - when N < 57 -> - d_field_health_check_response_status(Rest, - N + 7, - X bsl N + Acc, - F@_1, - TrUserData); -d_field_health_check_response_status(<<0:1, X:7, - Rest/binary>>, - N, Acc, _, TrUserData) -> - {NewFValue, RestF} = - {id('d_enum_health_check_response.ServingStatus'(begin - <> = - <<(X bsl N + - Acc):32/unsigned-native>>, - id(Res, TrUserData) - end), - TrUserData), - Rest}, - dfp_read_field_def_health_check_response(RestF, - 0, - 0, - NewFValue, - TrUserData). - -skip_varint_health_check_response(<<1:1, _:7, - Rest/binary>>, - Z1, Z2, F@_1, TrUserData) -> - skip_varint_health_check_response(Rest, - Z1, - Z2, - F@_1, - TrUserData); -skip_varint_health_check_response(<<0:1, _:7, - Rest/binary>>, - Z1, Z2, F@_1, TrUserData) -> - dfp_read_field_def_health_check_response(Rest, - Z1, - Z2, - F@_1, - TrUserData). - -skip_length_delimited_health_check_response(<<1:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) - when N < 57 -> - skip_length_delimited_health_check_response(Rest, - N + 7, - X bsl N + Acc, - F@_1, - TrUserData); -skip_length_delimited_health_check_response(<<0:1, X:7, - Rest/binary>>, - N, Acc, F@_1, TrUserData) -> - Length = X bsl N + Acc, - <<_:Length/binary, Rest2/binary>> = Rest, - dfp_read_field_def_health_check_response(Rest2, - 0, - 0, - F@_1, - TrUserData). - -skip_group_health_check_response(Bin, FNum, Z2, F@_1, - TrUserData) -> - {_, Rest} = read_group(Bin, FNum), - dfp_read_field_def_health_check_response(Rest, - 0, - Z2, - F@_1, - TrUserData). - -skip_32_health_check_response(<<_:32, Rest/binary>>, Z1, - Z2, F@_1, TrUserData) -> - dfp_read_field_def_health_check_response(Rest, - Z1, - Z2, - F@_1, - TrUserData). - -skip_64_health_check_response(<<_:64, Rest/binary>>, Z1, - Z2, F@_1, TrUserData) -> - dfp_read_field_def_health_check_response(Rest, - Z1, - Z2, - F@_1, - TrUserData). - -'d_enum_health_check_response.ServingStatus'(0) -> - 'UNKNOWN'; -'d_enum_health_check_response.ServingStatus'(1) -> - 'SERVING'; -'d_enum_health_check_response.ServingStatus'(2) -> - 'NOT_SERVING'; -'d_enum_health_check_response.ServingStatus'(3) -> - 'SERVICE_UNKNOWN'; -'d_enum_health_check_response.ServingStatus'(V) -> V. - -read_group(Bin, FieldNum) -> - {NumBytes, EndTagLen} = read_gr_b(Bin, 0, 0, 0, 0, FieldNum), - <> = Bin, - {Group, Rest}. - -%% Like skipping over fields, but record the total length, -%% Each field is <(FieldNum bsl 3) bor FieldType> ++ -%% 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 - hello_request -> - merge_msg_hello_request(Prev, New, TrUserData); - hello_reply -> - merge_msg_hello_reply(Prev, New, TrUserData); - health_check_request -> - merge_msg_health_check_request(Prev, New, TrUserData); - health_check_response -> - merge_msg_health_check_response(Prev, New, TrUserData) - end. - --compile({nowarn_unused_function,merge_msg_hello_request/3}). -merge_msg_hello_request(PMsg, NMsg, _) -> - S1 = #{}, - case {PMsg, NMsg} of - {_, #{name := NFname}} -> S1#{name => NFname}; - {#{name := PFname}, _} -> S1#{name => PFname}; - _ -> S1 - end. - --compile({nowarn_unused_function,merge_msg_hello_reply/3}). -merge_msg_hello_reply(PMsg, NMsg, _) -> - S1 = #{}, - case {PMsg, NMsg} of - {_, #{message := NFmessage}} -> - S1#{message => NFmessage}; - {#{message := PFmessage}, _} -> - S1#{message => PFmessage}; - _ -> S1 - end. - --compile({nowarn_unused_function,merge_msg_health_check_request/3}). -merge_msg_health_check_request(PMsg, NMsg, _) -> - S1 = #{}, - case {PMsg, NMsg} of - {_, #{service := NFservice}} -> - S1#{service => NFservice}; - {#{service := PFservice}, _} -> - S1#{service => PFservice}; - _ -> S1 - end. - --compile({nowarn_unused_function,merge_msg_health_check_response/3}). -merge_msg_health_check_response(PMsg, NMsg, _) -> - S1 = #{}, - case {PMsg, NMsg} of - {_, #{status := NFstatus}} -> S1#{status => NFstatus}; - {#{status := PFstatus}, _} -> S1#{status => PFstatus}; - _ -> S1 - 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 - hello_request -> - v_msg_hello_request(Msg, [MsgName], TrUserData); - hello_reply -> - v_msg_hello_reply(Msg, [MsgName], TrUserData); - health_check_request -> - v_msg_health_check_request(Msg, [MsgName], TrUserData); - health_check_response -> - v_msg_health_check_response(Msg, [MsgName], TrUserData); - _ -> mk_type_error(not_a_known_message, Msg, []) - end. - - --compile({nowarn_unused_function,v_msg_hello_request/3}). --dialyzer({nowarn_function,v_msg_hello_request/3}). -v_msg_hello_request(#{} = M, Path, TrUserData) -> - case M of - #{name := F1} -> - v_type_string(F1, [name | Path], TrUserData); - _ -> ok - end, - lists:foreach(fun (name) -> ok; - (OtherKey) -> - mk_type_error({extraneous_key, OtherKey}, M, Path) - end, - maps:keys(M)), - ok; -v_msg_hello_request(M, Path, _TrUserData) - when is_map(M) -> - mk_type_error({missing_fields, - [] -- maps:keys(M), - hello_request}, - M, - Path); -v_msg_hello_request(X, Path, _TrUserData) -> - mk_type_error({expected_msg, hello_request}, X, Path). - --compile({nowarn_unused_function,v_msg_hello_reply/3}). --dialyzer({nowarn_function,v_msg_hello_reply/3}). -v_msg_hello_reply(#{} = M, Path, TrUserData) -> - case M of - #{message := F1} -> - v_type_string(F1, [message | Path], TrUserData); - _ -> ok - end, - lists:foreach(fun (message) -> ok; - (OtherKey) -> - mk_type_error({extraneous_key, OtherKey}, M, Path) - end, - maps:keys(M)), - ok; -v_msg_hello_reply(M, Path, _TrUserData) - when is_map(M) -> - mk_type_error({missing_fields, - [] -- maps:keys(M), - hello_reply}, - M, - Path); -v_msg_hello_reply(X, Path, _TrUserData) -> - mk_type_error({expected_msg, hello_reply}, X, Path). - --compile({nowarn_unused_function,v_msg_health_check_request/3}). --dialyzer({nowarn_function,v_msg_health_check_request/3}). -v_msg_health_check_request(#{} = M, Path, TrUserData) -> - case M of - #{service := F1} -> - v_type_string(F1, [service | Path], TrUserData); - _ -> ok - end, - lists:foreach(fun (service) -> ok; - (OtherKey) -> - mk_type_error({extraneous_key, OtherKey}, M, Path) - end, - maps:keys(M)), - ok; -v_msg_health_check_request(M, Path, _TrUserData) - when is_map(M) -> - mk_type_error({missing_fields, - [] -- maps:keys(M), - health_check_request}, - M, - Path); -v_msg_health_check_request(X, Path, _TrUserData) -> - mk_type_error({expected_msg, health_check_request}, - X, - Path). - --compile({nowarn_unused_function,v_msg_health_check_response/3}). --dialyzer({nowarn_function,v_msg_health_check_response/3}). -v_msg_health_check_response(#{} = M, Path, - TrUserData) -> - case M of - #{status := F1} -> - 'v_enum_health_check_response.ServingStatus'(F1, - [status | Path], - TrUserData); - _ -> ok - end, - lists:foreach(fun (status) -> ok; - (OtherKey) -> - mk_type_error({extraneous_key, OtherKey}, M, Path) - end, - maps:keys(M)), - ok; -v_msg_health_check_response(M, Path, _TrUserData) - when is_map(M) -> - mk_type_error({missing_fields, - [] -- maps:keys(M), - health_check_response}, - M, - Path); -v_msg_health_check_response(X, Path, _TrUserData) -> - mk_type_error({expected_msg, health_check_response}, - X, - Path). - --compile({nowarn_unused_function,'v_enum_health_check_response.ServingStatus'/3}). --dialyzer({nowarn_function,'v_enum_health_check_response.ServingStatus'/3}). -'v_enum_health_check_response.ServingStatus'('UNKNOWN', - _Path, _TrUserData) -> - ok; -'v_enum_health_check_response.ServingStatus'('SERVING', - _Path, _TrUserData) -> - ok; -'v_enum_health_check_response.ServingStatus'('NOT_SERVING', - _Path, _TrUserData) -> - ok; -'v_enum_health_check_response.ServingStatus'('SERVICE_UNKNOWN', - _Path, _TrUserData) -> - ok; -'v_enum_health_check_response.ServingStatus'(V, Path, - TrUserData) - when is_integer(V) -> - v_type_sint32(V, Path, TrUserData); -'v_enum_health_check_response.ServingStatus'(X, Path, - _TrUserData) -> - mk_type_error({invalid_enum, - 'health_check_response.ServingStatus'}, - X, - Path). - --compile({nowarn_unused_function,v_type_sint32/3}). --dialyzer({nowarn_function,v_type_sint32/3}). -v_type_sint32(N, _Path, _TrUserData) - when -2147483648 =< N, N =< 2147483647 -> - ok; -v_type_sint32(N, Path, _TrUserData) - when is_integer(N) -> - mk_type_error({value_out_of_range, sint32, signed, 32}, - N, - Path); -v_type_sint32(X, Path, _TrUserData) -> - mk_type_error({bad_integer, sint32, signed, 32}, - X, - Path). - --compile({nowarn_unused_function,v_type_string/3}). --dialyzer({nowarn_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}). --dialyzer({nowarn_function,prettify_path/1}). -prettify_path([]) -> top_level; -prettify_path(PathR) -> - list_to_atom(lists:append(lists: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() -> - [{{enum, 'health_check_response.ServingStatus'}, - [{'UNKNOWN', 0}, - {'SERVING', 1}, - {'NOT_SERVING', 2}, - {'SERVICE_UNKNOWN', 3}]}, - {{msg, hello_request}, - [#{name => name, fnum => 1, rnum => 2, type => string, - occurrence => optional, opts => []}]}, - {{msg, hello_reply}, - [#{name => message, fnum => 1, rnum => 2, - type => string, occurrence => optional, opts => []}]}, - {{msg, health_check_request}, - [#{name => service, fnum => 1, rnum => 2, - type => string, occurrence => optional, opts => []}]}, - {{msg, health_check_response}, - [#{name => status, fnum => 1, rnum => 2, - type => {enum, 'health_check_response.ServingStatus'}, - occurrence => optional, opts => []}]}]. - - -get_msg_names() -> - [hello_request, - hello_reply, - health_check_request, - health_check_response]. - - -get_group_names() -> []. - - -get_msg_or_group_names() -> - [hello_request, - hello_reply, - health_check_request, - health_check_response]. - - -get_enum_names() -> - ['health_check_response.ServingStatus']. - - -fetch_msg_def(MsgName) -> - case find_msg_def(MsgName) of - Fs when is_list(Fs) -> Fs; - error -> erlang:error({no_such_msg, MsgName}) - end. - - -fetch_enum_def(EnumName) -> - case find_enum_def(EnumName) of - Es when is_list(Es) -> Es; - error -> erlang:error({no_such_enum, EnumName}) - end. - - -find_msg_def(hello_request) -> - [#{name => name, fnum => 1, rnum => 2, type => string, - occurrence => optional, opts => []}]; -find_msg_def(hello_reply) -> - [#{name => message, fnum => 1, rnum => 2, - type => string, occurrence => optional, opts => []}]; -find_msg_def(health_check_request) -> - [#{name => service, fnum => 1, rnum => 2, - type => string, occurrence => optional, opts => []}]; -find_msg_def(health_check_response) -> - [#{name => status, fnum => 1, rnum => 2, - type => {enum, 'health_check_response.ServingStatus'}, - occurrence => optional, opts => []}]; -find_msg_def(_) -> error. - - -find_enum_def('health_check_response.ServingStatus') -> - [{'UNKNOWN', 0}, - {'SERVING', 1}, - {'NOT_SERVING', 2}, - {'SERVICE_UNKNOWN', 3}]; -find_enum_def(_) -> error. - - -enum_symbol_by_value('health_check_response.ServingStatus', - Value) -> - 'enum_symbol_by_value_health_check_response.ServingStatus'(Value). - - -enum_value_by_symbol('health_check_response.ServingStatus', - Sym) -> - 'enum_value_by_symbol_health_check_response.ServingStatus'(Sym). - - -'enum_symbol_by_value_health_check_response.ServingStatus'(0) -> - 'UNKNOWN'; -'enum_symbol_by_value_health_check_response.ServingStatus'(1) -> - 'SERVING'; -'enum_symbol_by_value_health_check_response.ServingStatus'(2) -> - 'NOT_SERVING'; -'enum_symbol_by_value_health_check_response.ServingStatus'(3) -> - 'SERVICE_UNKNOWN'. - - -'enum_value_by_symbol_health_check_response.ServingStatus'('UNKNOWN') -> - 0; -'enum_value_by_symbol_health_check_response.ServingStatus'('SERVING') -> - 1; -'enum_value_by_symbol_health_check_response.ServingStatus'('NOT_SERVING') -> - 2; -'enum_value_by_symbol_health_check_response.ServingStatus'('SERVICE_UNKNOWN') -> - 3. - - -get_service_names() -> ['dgiot.Dlink']. - - -get_service_def('dgiot.Dlink') -> - {{service, 'dgiot.Dlink'}, - [#{name => 'SayHello', input => hello_request, - output => hello_reply, input_stream => false, - output_stream => false, opts => []}, - #{name => 'Check', input => health_check_request, - output => health_check_response, input_stream => false, - output_stream => false, opts => []}, - #{name => 'Watch', input => health_check_request, - output => health_check_response, input_stream => false, - output_stream => true, opts => []}]}; -get_service_def(_) -> error. - - -get_rpc_names('dgiot.Dlink') -> - ['SayHello', 'Check', 'Watch']; -get_rpc_names(_) -> error. - - -find_rpc_def('dgiot.Dlink', RpcName) -> - 'find_rpc_def_dgiot.Dlink'(RpcName); -find_rpc_def(_, _) -> error. - - -'find_rpc_def_dgiot.Dlink'('SayHello') -> - #{name => 'SayHello', input => hello_request, - output => hello_reply, input_stream => false, - output_stream => false, opts => []}; -'find_rpc_def_dgiot.Dlink'('Check') -> - #{name => 'Check', input => health_check_request, - output => health_check_response, input_stream => false, - output_stream => false, opts => []}; -'find_rpc_def_dgiot.Dlink'('Watch') -> - #{name => 'Watch', input => health_check_request, - output => health_check_response, input_stream => false, - output_stream => true, opts => []}; -'find_rpc_def_dgiot.Dlink'(_) -> error. - - -fetch_rpc_def(ServiceName, RpcName) -> - case find_rpc_def(ServiceName, RpcName) of - Def when is_map(Def) -> Def; - error -> - erlang:error({no_such_rpc, ServiceName, RpcName}) - end. - - -%% Convert a a fully qualified (ie with package name) service name -%% as a binary to a service name as an atom. -fqbin_to_service_name(<<"dgiot.Dlink">>) -> 'dgiot.Dlink'; -fqbin_to_service_name(X) -> - error({gpb_error, {badservice, X}}). - - -%% Convert a service name as an atom to a fully qualified -%% (ie with package name) name as a binary. -service_name_to_fqbin('dgiot.Dlink') -> <<"dgiot.Dlink">>; -service_name_to_fqbin(X) -> - error({gpb_error, {badservice, X}}). - - -%% Convert a a fully qualified (ie with package name) service name -%% and an rpc name, both as binaries to a service name and an rpc -%% name, as atoms. -fqbins_to_service_and_rpc_name(<<"dgiot.Dlink">>, <<"SayHello">>) -> - {'dgiot.Dlink', 'SayHello'}; -fqbins_to_service_and_rpc_name(<<"dgiot.Dlink">>, <<"Check">>) -> - {'dgiot.Dlink', 'Check'}; -fqbins_to_service_and_rpc_name(<<"dgiot.Dlink">>, <<"Watch">>) -> - {'dgiot.Dlink', 'Watch'}; -fqbins_to_service_and_rpc_name(S, R) -> - error({gpb_error, {badservice_or_rpc, {S, R}}}). - - -%% Convert a service name and an rpc name, both as atoms, -%% to a fully qualified (ie with package name) service name and -%% an rpc name as binaries. -service_and_rpc_name_to_fqbins('dgiot.Dlink', - 'SayHello') -> - {<<"dgiot.Dlink">>, <<"SayHello">>}; -service_and_rpc_name_to_fqbins('dgiot.Dlink', - 'Check') -> - {<<"dgiot.Dlink">>, <<"Check">>}; -service_and_rpc_name_to_fqbins('dgiot.Dlink', - 'Watch') -> - {<<"dgiot.Dlink">>, <<"Watch">>}; -service_and_rpc_name_to_fqbins(S, R) -> - error({gpb_error, {badservice_or_rpc, {S, R}}}). - - -fqbin_to_msg_name(<<"dgiot.HelloRequest">>) -> hello_request; -fqbin_to_msg_name(<<"dgiot.HelloReply">>) -> hello_reply; -fqbin_to_msg_name(<<"dgiot.HealthCheckRequest">>) -> health_check_request; -fqbin_to_msg_name(<<"dgiot.HealthCheckResponse">>) -> health_check_response; -fqbin_to_msg_name(E) -> error({gpb_error, {badmsg, E}}). - - -msg_name_to_fqbin(hello_request) -> <<"dgiot.HelloRequest">>; -msg_name_to_fqbin(hello_reply) -> <<"dgiot.HelloReply">>; -msg_name_to_fqbin(health_check_request) -> <<"dgiot.HealthCheckRequest">>; -msg_name_to_fqbin(health_check_response) -> <<"dgiot.HealthCheckResponse">>; -msg_name_to_fqbin(E) -> error({gpb_error, {badmsg, E}}). - - -fqbin_to_enum_name(<<"dgiot.HealthCheckResponse.ServingStatus">>) -> - 'health_check_response.ServingStatus'; -fqbin_to_enum_name(E) -> - error({gpb_error, {badenum, E}}). - - -enum_name_to_fqbin('health_check_response.ServingStatus') -> - <<"dgiot.HealthCheckResponse.ServingStatus">>; -enum_name_to_fqbin(E) -> - error({gpb_error, {badenum, E}}). - - -get_package_name() -> dgiot. - - -%% Whether or not the message names -%% are prepended with package name or not. -uses_packages() -> true. - - -source_basename() -> "dlink.proto". - - -%% Retrieve all proto file names, also imported ones. -%% The order is top-down. The first element is always the main -%% source file. The files are returned with extension, -%% see get_all_proto_names/0 for a version that returns -%% the basenames sans extension -get_all_source_basenames() -> ["dlink.proto"]. - - -%% Retrieve all proto file names, also imported ones. -%% The order is top-down. The first element is always the main -%% source file. The files are returned sans .proto extension, -%% to make it easier to use them with the various get_xyz_containment -%% functions. -get_all_proto_names() -> ["dlink"]. - - -get_msg_containment("dlink") -> - [health_check_request, - health_check_response, - hello_reply, - hello_request]; -get_msg_containment(P) -> - error({gpb_error, {badproto, P}}). - - -get_pkg_containment("dlink") -> dgiot; -get_pkg_containment(P) -> - error({gpb_error, {badproto, P}}). - - -get_service_containment("dlink") -> ['dgiot.Dlink']; -get_service_containment(P) -> - error({gpb_error, {badproto, P}}). - - -get_rpc_containment("dlink") -> - [{'dgiot.Dlink', 'SayHello'}, - {'dgiot.Dlink', 'Check'}, - {'dgiot.Dlink', 'Watch'}]; -get_rpc_containment(P) -> - error({gpb_error, {badproto, P}}). - - -get_enum_containment("dlink") -> - ['health_check_response.ServingStatus']; -get_enum_containment(P) -> - error({gpb_error, {badproto, P}}). - - -get_proto_by_msg_name_as_fqbin(<<"dgiot.HelloRequest">>) -> "dlink"; -get_proto_by_msg_name_as_fqbin(<<"dgiot.HealthCheckRequest">>) -> "dlink"; -get_proto_by_msg_name_as_fqbin(<<"dgiot.HealthCheckResponse">>) -> "dlink"; -get_proto_by_msg_name_as_fqbin(<<"dgiot.HelloReply">>) -> "dlink"; -get_proto_by_msg_name_as_fqbin(E) -> - error({gpb_error, {badmsg, E}}). - - -get_proto_by_service_name_as_fqbin(<<"dgiot.Dlink">>) -> "dlink"; -get_proto_by_service_name_as_fqbin(E) -> - error({gpb_error, {badservice, E}}). - - -get_proto_by_enum_name_as_fqbin(<<"dgiot.HealthCheckResponse.ServingStatus">>) -> "dlink"; -get_proto_by_enum_name_as_fqbin(E) -> - error({gpb_error, {badenum, E}}). - - -get_protos_by_pkg_name_as_fqbin(<<"dgiot">>) -> ["dlink"]; -get_protos_by_pkg_name_as_fqbin(E) -> - error({gpb_error, {badpkg, E}}). - - - -gpb_version_as_string() -> - "4.11.2". - -gpb_version_as_list() -> - [4,11,2].