From ef05846cf1d5c7369f1c8b62e0e8b9c244a4009b Mon Sep 17 00:00:00 2001 From: anlicheng <244108715@qq.com> Date: Sat, 18 Apr 2026 23:40:01 +0800 Subject: [PATCH] fix pb --- include/message_pb.hrl | 23 ++ src/protobuf/message_pb.erl | 548 +++++++++++++++++++++++++++++++++++- 2 files changed, 565 insertions(+), 6 deletions(-) diff --git a/include/message_pb.hrl b/include/message_pb.hrl index 798f14c..6fd0eaa 100644 --- a/include/message_pb.hrl +++ b/include/message_pb.hrl @@ -60,6 +60,29 @@ }). -endif. +-ifndef('REQUESTFRAME_PB_H'). +-define('REQUESTFRAME_PB_H', true). +-record('RequestFrame', + {packet_id = 0 :: non_neg_integer() | undefined, % = 1, optional, 32 bits + body :: {auth_request, message_pb:'AuthRequest'()} | {jsonrpc_request, message_pb:'JsonRpcRequest'()} | undefined % oneof + }). +-endif. + +-ifndef('RESPONSEFRAME_PB_H'). +-define('RESPONSEFRAME_PB_H', true). +-record('ResponseFrame', + {packet_id = 0 :: non_neg_integer() | undefined, % = 1, optional, 32 bits + body :: {auth_reply, message_pb:'AuthReply'()} | {jsonrpc_reply, message_pb:'JsonRpcReply'()} | undefined % oneof + }). +-endif. + +-ifndef('CASTFRAME_PB_H'). +-define('CASTFRAME_PB_H', true). +-record('CastFrame', + {body :: {pub, message_pb:'Pub'()} | {command, message_pb:'Command'()} | {data, message_pb:'Data'()} | {event_stream, message_pb:'TaskEventStream'()} | undefined % oneof + }). +-endif. + -ifndef('DATA_PB_H'). -define('DATA_PB_H', true). -record('Data', diff --git a/src/protobuf/message_pb.erl b/src/protobuf/message_pb.erl index e1e8aec..3a4b2d9 100644 --- a/src/protobuf/message_pb.erl +++ b/src/protobuf/message_pb.erl @@ -66,13 +66,19 @@ -type 'JsonRpcReply'() :: #'JsonRpcReply'{}. +-type 'RequestFrame'() :: #'RequestFrame'{}. + +-type 'ResponseFrame'() :: #'ResponseFrame'{}. + +-type 'CastFrame'() :: #'CastFrame'{}. + -type 'Data'() :: #'Data'{}. -type 'TaskEventStream'() :: #'TaskEventStream'{}. --export_type(['AuthRequest'/0, 'AuthReply'/0, 'Pub'/0, 'Command'/0, 'JsonRpcRequest'/0, 'JsonRpcReply'/0, 'Data'/0, 'TaskEventStream'/0]). --type '$msg_name'() :: 'AuthRequest' | 'AuthReply' | 'Pub' | 'Command' | 'JsonRpcRequest' | 'JsonRpcReply' | 'Data' | 'TaskEventStream'. --type '$msg'() :: 'AuthRequest'() | 'AuthReply'() | 'Pub'() | 'Command'() | 'JsonRpcRequest'() | 'JsonRpcReply'() | 'Data'() | 'TaskEventStream'(). +-export_type(['AuthRequest'/0, 'AuthReply'/0, 'Pub'/0, 'Command'/0, 'JsonRpcRequest'/0, 'JsonRpcReply'/0, 'RequestFrame'/0, 'ResponseFrame'/0, 'CastFrame'/0, 'Data'/0, 'TaskEventStream'/0]). +-type '$msg_name'() :: 'AuthRequest' | 'AuthReply' | 'Pub' | 'Command' | 'JsonRpcRequest' | 'JsonRpcReply' | 'RequestFrame' | 'ResponseFrame' | 'CastFrame' | 'Data' | 'TaskEventStream'. +-type '$msg'() :: 'AuthRequest'() | 'AuthReply'() | 'Pub'() | 'Command'() | 'JsonRpcRequest'() | 'JsonRpcReply'() | 'RequestFrame'() | 'ResponseFrame'() | 'CastFrame'() | 'Data'() | 'TaskEventStream'(). -export_type(['$msg_name'/0, '$msg'/0]). -if(?OTP_RELEASE >= 24). @@ -105,6 +111,9 @@ encode_msg(Msg, MsgName, Opts) -> 'Command' -> encode_msg_Command(id(Msg, TrUserData), TrUserData); 'JsonRpcRequest' -> encode_msg_JsonRpcRequest(id(Msg, TrUserData), TrUserData); 'JsonRpcReply' -> encode_msg_JsonRpcReply(id(Msg, TrUserData), TrUserData); + 'RequestFrame' -> encode_msg_RequestFrame(id(Msg, TrUserData), TrUserData); + 'ResponseFrame' -> encode_msg_ResponseFrame(id(Msg, TrUserData), TrUserData); + 'CastFrame' -> encode_msg_CastFrame(id(Msg, TrUserData), TrUserData); 'Data' -> encode_msg_Data(id(Msg, TrUserData), TrUserData); 'TaskEventStream' -> encode_msg_TaskEventStream(id(Msg, TrUserData), TrUserData) end. @@ -296,6 +305,62 @@ encode_msg_JsonRpcReply(#'JsonRpcReply'{result = F1, error = F2}, Bin, TrUserDat end end. +encode_msg_RequestFrame(Msg, TrUserData) -> encode_msg_RequestFrame(Msg, <<>>, TrUserData). + + +encode_msg_RequestFrame(#'RequestFrame'{packet_id = F1, body = F2}, Bin, TrUserData) -> + B1 = if F1 == undefined -> Bin; + true -> + begin + TrF1 = id(F1, TrUserData), + if TrF1 =:= 0 -> Bin; + true -> e_varint(TrF1, <>, TrUserData) + end + end + end, + if F2 =:= undefined -> B1; + true -> + case id(F2, TrUserData) of + {auth_request, TF2} -> begin TrTF2 = id(TF2, TrUserData), e_mfield_RequestFrame_auth_request(TrTF2, <>, TrUserData) end; + {jsonrpc_request, TF2} -> begin TrTF2 = id(TF2, TrUserData), e_mfield_RequestFrame_jsonrpc_request(TrTF2, <>, TrUserData) end + end + end. + +encode_msg_ResponseFrame(Msg, TrUserData) -> encode_msg_ResponseFrame(Msg, <<>>, TrUserData). + + +encode_msg_ResponseFrame(#'ResponseFrame'{packet_id = F1, body = F2}, Bin, TrUserData) -> + B1 = if F1 == undefined -> Bin; + true -> + begin + TrF1 = id(F1, TrUserData), + if TrF1 =:= 0 -> Bin; + true -> e_varint(TrF1, <>, TrUserData) + end + end + end, + if F2 =:= undefined -> B1; + true -> + case id(F2, TrUserData) of + {auth_reply, TF2} -> begin TrTF2 = id(TF2, TrUserData), e_mfield_ResponseFrame_auth_reply(TrTF2, <>, TrUserData) end; + {jsonrpc_reply, TF2} -> begin TrTF2 = id(TF2, TrUserData), e_mfield_ResponseFrame_jsonrpc_reply(TrTF2, <>, TrUserData) end + end + end. + +encode_msg_CastFrame(Msg, TrUserData) -> encode_msg_CastFrame(Msg, <<>>, TrUserData). + + +encode_msg_CastFrame(#'CastFrame'{body = F1}, Bin, TrUserData) -> + if F1 =:= undefined -> Bin; + true -> + case id(F1, TrUserData) of + {pub, TF1} -> begin TrTF1 = id(TF1, TrUserData), e_mfield_CastFrame_pub(TrTF1, <>, TrUserData) end; + {command, TF1} -> begin TrTF1 = id(TF1, TrUserData), e_mfield_CastFrame_command(TrTF1, <>, TrUserData) end; + {data, TF1} -> begin TrTF1 = id(TF1, TrUserData), e_mfield_CastFrame_data(TrTF1, <>, TrUserData) end; + {event_stream, TF1} -> begin TrTF1 = id(TF1, TrUserData), e_mfield_CastFrame_event_stream(TrTF1, <>, TrUserData) end + end + end. + encode_msg_Data(Msg, TrUserData) -> encode_msg_Data(Msg, <<>>, TrUserData). @@ -355,6 +420,46 @@ encode_msg_TaskEventStream(#'TaskEventStream'{task_id = F1, type = F2, stream = end end. +e_mfield_RequestFrame_auth_request(Msg, Bin, TrUserData) -> + SubBin = encode_msg_AuthRequest(Msg, <<>>, TrUserData), + Bin2 = e_varint(byte_size(SubBin), Bin), + <>. + +e_mfield_RequestFrame_jsonrpc_request(Msg, Bin, TrUserData) -> + SubBin = encode_msg_JsonRpcRequest(Msg, <<>>, TrUserData), + Bin2 = e_varint(byte_size(SubBin), Bin), + <>. + +e_mfield_ResponseFrame_auth_reply(Msg, Bin, TrUserData) -> + SubBin = encode_msg_AuthReply(Msg, <<>>, TrUserData), + Bin2 = e_varint(byte_size(SubBin), Bin), + <>. + +e_mfield_ResponseFrame_jsonrpc_reply(Msg, Bin, TrUserData) -> + SubBin = encode_msg_JsonRpcReply(Msg, <<>>, TrUserData), + Bin2 = e_varint(byte_size(SubBin), Bin), + <>. + +e_mfield_CastFrame_pub(Msg, Bin, TrUserData) -> + SubBin = encode_msg_Pub(Msg, <<>>, TrUserData), + Bin2 = e_varint(byte_size(SubBin), Bin), + <>. + +e_mfield_CastFrame_command(Msg, Bin, TrUserData) -> + SubBin = encode_msg_Command(Msg, <<>>, TrUserData), + Bin2 = e_varint(byte_size(SubBin), Bin), + <>. + +e_mfield_CastFrame_data(Msg, Bin, TrUserData) -> + SubBin = encode_msg_Data(Msg, <<>>, TrUserData), + Bin2 = e_varint(byte_size(SubBin), Bin), + <>. + +e_mfield_CastFrame_event_stream(Msg, Bin, TrUserData) -> + SubBin = encode_msg_TaskEventStream(Msg, <<>>, TrUserData), + Bin2 = e_varint(byte_size(SubBin), 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). @@ -483,6 +588,9 @@ decode_msg_2_doit('Pub', Bin, TrUserData) -> id(decode_msg_Pub(Bin, TrUserData), decode_msg_2_doit('Command', Bin, TrUserData) -> id(decode_msg_Command(Bin, TrUserData), TrUserData); decode_msg_2_doit('JsonRpcRequest', Bin, TrUserData) -> id(decode_msg_JsonRpcRequest(Bin, TrUserData), TrUserData); decode_msg_2_doit('JsonRpcReply', Bin, TrUserData) -> id(decode_msg_JsonRpcReply(Bin, TrUserData), TrUserData); +decode_msg_2_doit('RequestFrame', Bin, TrUserData) -> id(decode_msg_RequestFrame(Bin, TrUserData), TrUserData); +decode_msg_2_doit('ResponseFrame', Bin, TrUserData) -> id(decode_msg_ResponseFrame(Bin, TrUserData), TrUserData); +decode_msg_2_doit('CastFrame', Bin, TrUserData) -> id(decode_msg_CastFrame(Bin, TrUserData), TrUserData); decode_msg_2_doit('Data', Bin, TrUserData) -> id(decode_msg_Data(Bin, TrUserData), TrUserData); decode_msg_2_doit('TaskEventStream', Bin, TrUserData) -> id(decode_msg_TaskEventStream(Bin, TrUserData), TrUserData). @@ -822,6 +930,263 @@ skip_32_JsonRpcReply(<<_:32, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) - skip_64_JsonRpcReply(<<_:64, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> dfp_read_field_def_JsonRpcReply(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData). +decode_msg_RequestFrame(Bin, TrUserData) -> dfp_read_field_def_RequestFrame(Bin, 0, 0, 0, id(0, TrUserData), id(undefined, TrUserData), TrUserData). + +dfp_read_field_def_RequestFrame(<<8, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> d_field_RequestFrame_packet_id(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData); +dfp_read_field_def_RequestFrame(<<18, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> d_field_RequestFrame_auth_request(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData); +dfp_read_field_def_RequestFrame(<<26, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> d_field_RequestFrame_jsonrpc_request(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData); +dfp_read_field_def_RequestFrame(<<>>, 0, 0, _, F@_1, F@_2, _) -> #'RequestFrame'{packet_id = F@_1, body = F@_2}; +dfp_read_field_def_RequestFrame(Other, Z1, Z2, F, F@_1, F@_2, TrUserData) -> dg_read_field_def_RequestFrame(Other, Z1, Z2, F, F@_1, F@_2, TrUserData). + +dg_read_field_def_RequestFrame(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, F@_2, TrUserData) when N < 32 - 7 -> dg_read_field_def_RequestFrame(Rest, N + 7, X bsl N + Acc, F, F@_1, F@_2, TrUserData); +dg_read_field_def_RequestFrame(<<0:1, X:7, Rest/binary>>, N, Acc, _, F@_1, F@_2, TrUserData) -> + Key = X bsl N + Acc, + case Key of + 8 -> d_field_RequestFrame_packet_id(Rest, 0, 0, 0, F@_1, F@_2, TrUserData); + 18 -> d_field_RequestFrame_auth_request(Rest, 0, 0, 0, F@_1, F@_2, TrUserData); + 26 -> d_field_RequestFrame_jsonrpc_request(Rest, 0, 0, 0, F@_1, F@_2, TrUserData); + _ -> + case Key band 7 of + 0 -> skip_varint_RequestFrame(Rest, 0, 0, Key bsr 3, F@_1, F@_2, TrUserData); + 1 -> skip_64_RequestFrame(Rest, 0, 0, Key bsr 3, F@_1, F@_2, TrUserData); + 2 -> skip_length_delimited_RequestFrame(Rest, 0, 0, Key bsr 3, F@_1, F@_2, TrUserData); + 3 -> skip_group_RequestFrame(Rest, 0, 0, Key bsr 3, F@_1, F@_2, TrUserData); + 5 -> skip_32_RequestFrame(Rest, 0, 0, Key bsr 3, F@_1, F@_2, TrUserData) + end + end; +dg_read_field_def_RequestFrame(<<>>, 0, 0, _, F@_1, F@_2, _) -> #'RequestFrame'{packet_id = F@_1, body = F@_2}. + +d_field_RequestFrame_packet_id(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, F@_2, TrUserData) when N < 57 -> d_field_RequestFrame_packet_id(Rest, N + 7, X bsl N + Acc, F, F@_1, F@_2, TrUserData); +d_field_RequestFrame_packet_id(<<0:1, X:7, Rest/binary>>, N, Acc, F, _, F@_2, TrUserData) -> + {NewFValue, RestF} = {id((X bsl N + Acc) band 4294967295, TrUserData), Rest}, + dfp_read_field_def_RequestFrame(RestF, 0, 0, F, NewFValue, F@_2, TrUserData). + +d_field_RequestFrame_auth_request(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, F@_2, TrUserData) when N < 57 -> d_field_RequestFrame_auth_request(Rest, N + 7, X bsl N + Acc, F, F@_1, F@_2, TrUserData); +d_field_RequestFrame_auth_request(<<0:1, X:7, Rest/binary>>, N, Acc, F, F@_1, Prev, TrUserData) -> + {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(decode_msg_AuthRequest(Bs, TrUserData), TrUserData), Rest2} end, + dfp_read_field_def_RequestFrame(RestF, + 0, + 0, + F, + F@_1, + case Prev of + undefined -> id({auth_request, NewFValue}, TrUserData); + {auth_request, MVPrev} -> id({auth_request, merge_msg_AuthRequest(MVPrev, NewFValue, TrUserData)}, TrUserData); + _ -> id({auth_request, NewFValue}, TrUserData) + end, + TrUserData). + +d_field_RequestFrame_jsonrpc_request(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, F@_2, TrUserData) when N < 57 -> d_field_RequestFrame_jsonrpc_request(Rest, N + 7, X bsl N + Acc, F, F@_1, F@_2, TrUserData); +d_field_RequestFrame_jsonrpc_request(<<0:1, X:7, Rest/binary>>, N, Acc, F, F@_1, Prev, TrUserData) -> + {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(decode_msg_JsonRpcRequest(Bs, TrUserData), TrUserData), Rest2} end, + dfp_read_field_def_RequestFrame(RestF, + 0, + 0, + F, + F@_1, + case Prev of + undefined -> id({jsonrpc_request, NewFValue}, TrUserData); + {jsonrpc_request, MVPrev} -> id({jsonrpc_request, merge_msg_JsonRpcRequest(MVPrev, NewFValue, TrUserData)}, TrUserData); + _ -> id({jsonrpc_request, NewFValue}, TrUserData) + end, + TrUserData). + +skip_varint_RequestFrame(<<1:1, _:7, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> skip_varint_RequestFrame(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData); +skip_varint_RequestFrame(<<0:1, _:7, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> dfp_read_field_def_RequestFrame(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData). + +skip_length_delimited_RequestFrame(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, F@_2, TrUserData) when N < 57 -> skip_length_delimited_RequestFrame(Rest, N + 7, X bsl N + Acc, F, F@_1, F@_2, TrUserData); +skip_length_delimited_RequestFrame(<<0:1, X:7, Rest/binary>>, N, Acc, F, F@_1, F@_2, TrUserData) -> + Length = X bsl N + Acc, + <<_:Length/binary, Rest2/binary>> = Rest, + dfp_read_field_def_RequestFrame(Rest2, 0, 0, F, F@_1, F@_2, TrUserData). + +skip_group_RequestFrame(Bin, _, Z2, FNum, F@_1, F@_2, TrUserData) -> + {_, Rest} = read_group(Bin, FNum), + dfp_read_field_def_RequestFrame(Rest, 0, Z2, FNum, F@_1, F@_2, TrUserData). + +skip_32_RequestFrame(<<_:32, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> dfp_read_field_def_RequestFrame(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData). + +skip_64_RequestFrame(<<_:64, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> dfp_read_field_def_RequestFrame(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData). + +decode_msg_ResponseFrame(Bin, TrUserData) -> dfp_read_field_def_ResponseFrame(Bin, 0, 0, 0, id(0, TrUserData), id(undefined, TrUserData), TrUserData). + +dfp_read_field_def_ResponseFrame(<<8, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> d_field_ResponseFrame_packet_id(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData); +dfp_read_field_def_ResponseFrame(<<18, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> d_field_ResponseFrame_auth_reply(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData); +dfp_read_field_def_ResponseFrame(<<26, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> d_field_ResponseFrame_jsonrpc_reply(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData); +dfp_read_field_def_ResponseFrame(<<>>, 0, 0, _, F@_1, F@_2, _) -> #'ResponseFrame'{packet_id = F@_1, body = F@_2}; +dfp_read_field_def_ResponseFrame(Other, Z1, Z2, F, F@_1, F@_2, TrUserData) -> dg_read_field_def_ResponseFrame(Other, Z1, Z2, F, F@_1, F@_2, TrUserData). + +dg_read_field_def_ResponseFrame(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, F@_2, TrUserData) when N < 32 - 7 -> dg_read_field_def_ResponseFrame(Rest, N + 7, X bsl N + Acc, F, F@_1, F@_2, TrUserData); +dg_read_field_def_ResponseFrame(<<0:1, X:7, Rest/binary>>, N, Acc, _, F@_1, F@_2, TrUserData) -> + Key = X bsl N + Acc, + case Key of + 8 -> d_field_ResponseFrame_packet_id(Rest, 0, 0, 0, F@_1, F@_2, TrUserData); + 18 -> d_field_ResponseFrame_auth_reply(Rest, 0, 0, 0, F@_1, F@_2, TrUserData); + 26 -> d_field_ResponseFrame_jsonrpc_reply(Rest, 0, 0, 0, F@_1, F@_2, TrUserData); + _ -> + case Key band 7 of + 0 -> skip_varint_ResponseFrame(Rest, 0, 0, Key bsr 3, F@_1, F@_2, TrUserData); + 1 -> skip_64_ResponseFrame(Rest, 0, 0, Key bsr 3, F@_1, F@_2, TrUserData); + 2 -> skip_length_delimited_ResponseFrame(Rest, 0, 0, Key bsr 3, F@_1, F@_2, TrUserData); + 3 -> skip_group_ResponseFrame(Rest, 0, 0, Key bsr 3, F@_1, F@_2, TrUserData); + 5 -> skip_32_ResponseFrame(Rest, 0, 0, Key bsr 3, F@_1, F@_2, TrUserData) + end + end; +dg_read_field_def_ResponseFrame(<<>>, 0, 0, _, F@_1, F@_2, _) -> #'ResponseFrame'{packet_id = F@_1, body = F@_2}. + +d_field_ResponseFrame_packet_id(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, F@_2, TrUserData) when N < 57 -> d_field_ResponseFrame_packet_id(Rest, N + 7, X bsl N + Acc, F, F@_1, F@_2, TrUserData); +d_field_ResponseFrame_packet_id(<<0:1, X:7, Rest/binary>>, N, Acc, F, _, F@_2, TrUserData) -> + {NewFValue, RestF} = {id((X bsl N + Acc) band 4294967295, TrUserData), Rest}, + dfp_read_field_def_ResponseFrame(RestF, 0, 0, F, NewFValue, F@_2, TrUserData). + +d_field_ResponseFrame_auth_reply(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, F@_2, TrUserData) when N < 57 -> d_field_ResponseFrame_auth_reply(Rest, N + 7, X bsl N + Acc, F, F@_1, F@_2, TrUserData); +d_field_ResponseFrame_auth_reply(<<0:1, X:7, Rest/binary>>, N, Acc, F, F@_1, Prev, TrUserData) -> + {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(decode_msg_AuthReply(Bs, TrUserData), TrUserData), Rest2} end, + dfp_read_field_def_ResponseFrame(RestF, + 0, + 0, + F, + F@_1, + case Prev of + undefined -> id({auth_reply, NewFValue}, TrUserData); + {auth_reply, MVPrev} -> id({auth_reply, merge_msg_AuthReply(MVPrev, NewFValue, TrUserData)}, TrUserData); + _ -> id({auth_reply, NewFValue}, TrUserData) + end, + TrUserData). + +d_field_ResponseFrame_jsonrpc_reply(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, F@_2, TrUserData) when N < 57 -> d_field_ResponseFrame_jsonrpc_reply(Rest, N + 7, X bsl N + Acc, F, F@_1, F@_2, TrUserData); +d_field_ResponseFrame_jsonrpc_reply(<<0:1, X:7, Rest/binary>>, N, Acc, F, F@_1, Prev, TrUserData) -> + {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(decode_msg_JsonRpcReply(Bs, TrUserData), TrUserData), Rest2} end, + dfp_read_field_def_ResponseFrame(RestF, + 0, + 0, + F, + F@_1, + case Prev of + undefined -> id({jsonrpc_reply, NewFValue}, TrUserData); + {jsonrpc_reply, MVPrev} -> id({jsonrpc_reply, merge_msg_JsonRpcReply(MVPrev, NewFValue, TrUserData)}, TrUserData); + _ -> id({jsonrpc_reply, NewFValue}, TrUserData) + end, + TrUserData). + +skip_varint_ResponseFrame(<<1:1, _:7, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> skip_varint_ResponseFrame(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData); +skip_varint_ResponseFrame(<<0:1, _:7, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> dfp_read_field_def_ResponseFrame(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData). + +skip_length_delimited_ResponseFrame(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, F@_2, TrUserData) when N < 57 -> skip_length_delimited_ResponseFrame(Rest, N + 7, X bsl N + Acc, F, F@_1, F@_2, TrUserData); +skip_length_delimited_ResponseFrame(<<0:1, X:7, Rest/binary>>, N, Acc, F, F@_1, F@_2, TrUserData) -> + Length = X bsl N + Acc, + <<_:Length/binary, Rest2/binary>> = Rest, + dfp_read_field_def_ResponseFrame(Rest2, 0, 0, F, F@_1, F@_2, TrUserData). + +skip_group_ResponseFrame(Bin, _, Z2, FNum, F@_1, F@_2, TrUserData) -> + {_, Rest} = read_group(Bin, FNum), + dfp_read_field_def_ResponseFrame(Rest, 0, Z2, FNum, F@_1, F@_2, TrUserData). + +skip_32_ResponseFrame(<<_:32, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> dfp_read_field_def_ResponseFrame(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData). + +skip_64_ResponseFrame(<<_:64, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> dfp_read_field_def_ResponseFrame(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData). + +decode_msg_CastFrame(Bin, TrUserData) -> dfp_read_field_def_CastFrame(Bin, 0, 0, 0, id(undefined, TrUserData), TrUserData). + +dfp_read_field_def_CastFrame(<<10, Rest/binary>>, Z1, Z2, F, F@_1, TrUserData) -> d_field_CastFrame_pub(Rest, Z1, Z2, F, F@_1, TrUserData); +dfp_read_field_def_CastFrame(<<18, Rest/binary>>, Z1, Z2, F, F@_1, TrUserData) -> d_field_CastFrame_command(Rest, Z1, Z2, F, F@_1, TrUserData); +dfp_read_field_def_CastFrame(<<26, Rest/binary>>, Z1, Z2, F, F@_1, TrUserData) -> d_field_CastFrame_data(Rest, Z1, Z2, F, F@_1, TrUserData); +dfp_read_field_def_CastFrame(<<34, Rest/binary>>, Z1, Z2, F, F@_1, TrUserData) -> d_field_CastFrame_event_stream(Rest, Z1, Z2, F, F@_1, TrUserData); +dfp_read_field_def_CastFrame(<<>>, 0, 0, _, F@_1, _) -> #'CastFrame'{body = F@_1}; +dfp_read_field_def_CastFrame(Other, Z1, Z2, F, F@_1, TrUserData) -> dg_read_field_def_CastFrame(Other, Z1, Z2, F, F@_1, TrUserData). + +dg_read_field_def_CastFrame(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, TrUserData) when N < 32 - 7 -> dg_read_field_def_CastFrame(Rest, N + 7, X bsl N + Acc, F, F@_1, TrUserData); +dg_read_field_def_CastFrame(<<0:1, X:7, Rest/binary>>, N, Acc, _, F@_1, TrUserData) -> + Key = X bsl N + Acc, + case Key of + 10 -> d_field_CastFrame_pub(Rest, 0, 0, 0, F@_1, TrUserData); + 18 -> d_field_CastFrame_command(Rest, 0, 0, 0, F@_1, TrUserData); + 26 -> d_field_CastFrame_data(Rest, 0, 0, 0, F@_1, TrUserData); + 34 -> d_field_CastFrame_event_stream(Rest, 0, 0, 0, F@_1, TrUserData); + _ -> + case Key band 7 of + 0 -> skip_varint_CastFrame(Rest, 0, 0, Key bsr 3, F@_1, TrUserData); + 1 -> skip_64_CastFrame(Rest, 0, 0, Key bsr 3, F@_1, TrUserData); + 2 -> skip_length_delimited_CastFrame(Rest, 0, 0, Key bsr 3, F@_1, TrUserData); + 3 -> skip_group_CastFrame(Rest, 0, 0, Key bsr 3, F@_1, TrUserData); + 5 -> skip_32_CastFrame(Rest, 0, 0, Key bsr 3, F@_1, TrUserData) + end + end; +dg_read_field_def_CastFrame(<<>>, 0, 0, _, F@_1, _) -> #'CastFrame'{body = F@_1}. + +d_field_CastFrame_pub(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, TrUserData) when N < 57 -> d_field_CastFrame_pub(Rest, N + 7, X bsl N + Acc, F, F@_1, TrUserData); +d_field_CastFrame_pub(<<0:1, X:7, Rest/binary>>, N, Acc, F, Prev, TrUserData) -> + {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(decode_msg_Pub(Bs, TrUserData), TrUserData), Rest2} end, + dfp_read_field_def_CastFrame(RestF, + 0, + 0, + F, + case Prev of + undefined -> id({pub, NewFValue}, TrUserData); + {pub, MVPrev} -> id({pub, merge_msg_Pub(MVPrev, NewFValue, TrUserData)}, TrUserData); + _ -> id({pub, NewFValue}, TrUserData) + end, + TrUserData). + +d_field_CastFrame_command(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, TrUserData) when N < 57 -> d_field_CastFrame_command(Rest, N + 7, X bsl N + Acc, F, F@_1, TrUserData); +d_field_CastFrame_command(<<0:1, X:7, Rest/binary>>, N, Acc, F, Prev, TrUserData) -> + {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(decode_msg_Command(Bs, TrUserData), TrUserData), Rest2} end, + dfp_read_field_def_CastFrame(RestF, + 0, + 0, + F, + case Prev of + undefined -> id({command, NewFValue}, TrUserData); + {command, MVPrev} -> id({command, merge_msg_Command(MVPrev, NewFValue, TrUserData)}, TrUserData); + _ -> id({command, NewFValue}, TrUserData) + end, + TrUserData). + +d_field_CastFrame_data(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, TrUserData) when N < 57 -> d_field_CastFrame_data(Rest, N + 7, X bsl N + Acc, F, F@_1, TrUserData); +d_field_CastFrame_data(<<0:1, X:7, Rest/binary>>, N, Acc, F, Prev, TrUserData) -> + {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(decode_msg_Data(Bs, TrUserData), TrUserData), Rest2} end, + dfp_read_field_def_CastFrame(RestF, + 0, + 0, + F, + case Prev of + undefined -> id({data, NewFValue}, TrUserData); + {data, MVPrev} -> id({data, merge_msg_Data(MVPrev, NewFValue, TrUserData)}, TrUserData); + _ -> id({data, NewFValue}, TrUserData) + end, + TrUserData). + +d_field_CastFrame_event_stream(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, TrUserData) when N < 57 -> d_field_CastFrame_event_stream(Rest, N + 7, X bsl N + Acc, F, F@_1, TrUserData); +d_field_CastFrame_event_stream(<<0:1, X:7, Rest/binary>>, N, Acc, F, Prev, TrUserData) -> + {NewFValue, RestF} = begin Len = X bsl N + Acc, <> = Rest, {id(decode_msg_TaskEventStream(Bs, TrUserData), TrUserData), Rest2} end, + dfp_read_field_def_CastFrame(RestF, + 0, + 0, + F, + case Prev of + undefined -> id({event_stream, NewFValue}, TrUserData); + {event_stream, MVPrev} -> id({event_stream, merge_msg_TaskEventStream(MVPrev, NewFValue, TrUserData)}, TrUserData); + _ -> id({event_stream, NewFValue}, TrUserData) + end, + TrUserData). + +skip_varint_CastFrame(<<1:1, _:7, Rest/binary>>, Z1, Z2, F, F@_1, TrUserData) -> skip_varint_CastFrame(Rest, Z1, Z2, F, F@_1, TrUserData); +skip_varint_CastFrame(<<0:1, _:7, Rest/binary>>, Z1, Z2, F, F@_1, TrUserData) -> dfp_read_field_def_CastFrame(Rest, Z1, Z2, F, F@_1, TrUserData). + +skip_length_delimited_CastFrame(<<1:1, X:7, Rest/binary>>, N, Acc, F, F@_1, TrUserData) when N < 57 -> skip_length_delimited_CastFrame(Rest, N + 7, X bsl N + Acc, F, F@_1, TrUserData); +skip_length_delimited_CastFrame(<<0:1, X:7, Rest/binary>>, N, Acc, F, F@_1, TrUserData) -> + Length = X bsl N + Acc, + <<_:Length/binary, Rest2/binary>> = Rest, + dfp_read_field_def_CastFrame(Rest2, 0, 0, F, F@_1, TrUserData). + +skip_group_CastFrame(Bin, _, Z2, FNum, F@_1, TrUserData) -> + {_, Rest} = read_group(Bin, FNum), + dfp_read_field_def_CastFrame(Rest, 0, Z2, FNum, F@_1, TrUserData). + +skip_32_CastFrame(<<_:32, Rest/binary>>, Z1, Z2, F, F@_1, TrUserData) -> dfp_read_field_def_CastFrame(Rest, Z1, Z2, F, F@_1, TrUserData). + +skip_64_CastFrame(<<_:64, Rest/binary>>, Z1, Z2, F, F@_1, TrUserData) -> dfp_read_field_def_CastFrame(Rest, Z1, Z2, F, F@_1, TrUserData). + decode_msg_Data(Bin, TrUserData) -> dfp_read_field_def_Data(Bin, 0, 0, 0, id(<<>>, TrUserData), id(<<>>, TrUserData), TrUserData). dfp_read_field_def_Data(<<10, Rest/binary>>, Z1, Z2, F, F@_1, F@_2, TrUserData) -> d_field_Data_route_key(Rest, Z1, Z2, F, F@_1, F@_2, TrUserData); @@ -1003,6 +1368,9 @@ merge_msgs(Prev, New, MsgName, Opts) -> 'Command' -> merge_msg_Command(Prev, New, TrUserData); 'JsonRpcRequest' -> merge_msg_JsonRpcRequest(Prev, New, TrUserData); 'JsonRpcReply' -> merge_msg_JsonRpcReply(Prev, New, TrUserData); + 'RequestFrame' -> merge_msg_RequestFrame(Prev, New, TrUserData); + 'ResponseFrame' -> merge_msg_ResponseFrame(Prev, New, TrUserData); + 'CastFrame' -> merge_msg_CastFrame(Prev, New, TrUserData); 'Data' -> merge_msg_Data(Prev, New, TrUserData); 'TaskEventStream' -> merge_msg_TaskEventStream(Prev, New, TrUserData) end. @@ -1089,6 +1457,46 @@ merge_msg_JsonRpcReply(#'JsonRpcReply'{result = PFresult, error = PFerror}, #'Js true -> NFerror end}. +-compile({nowarn_unused_function,merge_msg_RequestFrame/3}). +merge_msg_RequestFrame(#'RequestFrame'{packet_id = PFpacket_id, body = PFbody}, #'RequestFrame'{packet_id = NFpacket_id, body = NFbody}, TrUserData) -> + #'RequestFrame'{packet_id = + if NFpacket_id =:= undefined -> PFpacket_id; + true -> NFpacket_id + end, + body = + case {PFbody, NFbody} of + {{auth_request, OPFbody}, {auth_request, ONFbody}} -> {auth_request, merge_msg_AuthRequest(OPFbody, ONFbody, TrUserData)}; + {{jsonrpc_request, OPFbody}, {jsonrpc_request, ONFbody}} -> {jsonrpc_request, merge_msg_JsonRpcRequest(OPFbody, ONFbody, TrUserData)}; + {_, undefined} -> PFbody; + _ -> NFbody + end}. + +-compile({nowarn_unused_function,merge_msg_ResponseFrame/3}). +merge_msg_ResponseFrame(#'ResponseFrame'{packet_id = PFpacket_id, body = PFbody}, #'ResponseFrame'{packet_id = NFpacket_id, body = NFbody}, TrUserData) -> + #'ResponseFrame'{packet_id = + if NFpacket_id =:= undefined -> PFpacket_id; + true -> NFpacket_id + end, + body = + case {PFbody, NFbody} of + {{auth_reply, OPFbody}, {auth_reply, ONFbody}} -> {auth_reply, merge_msg_AuthReply(OPFbody, ONFbody, TrUserData)}; + {{jsonrpc_reply, OPFbody}, {jsonrpc_reply, ONFbody}} -> {jsonrpc_reply, merge_msg_JsonRpcReply(OPFbody, ONFbody, TrUserData)}; + {_, undefined} -> PFbody; + _ -> NFbody + end}. + +-compile({nowarn_unused_function,merge_msg_CastFrame/3}). +merge_msg_CastFrame(#'CastFrame'{body = PFbody}, #'CastFrame'{body = NFbody}, TrUserData) -> + #'CastFrame'{body = + case {PFbody, NFbody} of + {{pub, OPFbody}, {pub, ONFbody}} -> {pub, merge_msg_Pub(OPFbody, ONFbody, TrUserData)}; + {{command, OPFbody}, {command, ONFbody}} -> {command, merge_msg_Command(OPFbody, ONFbody, TrUserData)}; + {{data, OPFbody}, {data, ONFbody}} -> {data, merge_msg_Data(OPFbody, ONFbody, TrUserData)}; + {{event_stream, OPFbody}, {event_stream, ONFbody}} -> {event_stream, merge_msg_TaskEventStream(OPFbody, ONFbody, TrUserData)}; + {_, undefined} -> PFbody; + _ -> NFbody + end}. + -compile({nowarn_unused_function,merge_msg_Data/3}). merge_msg_Data(#'Data'{route_key = PFroute_key, metric = PFmetric}, #'Data'{route_key = NFroute_key, metric = NFmetric}, _) -> #'Data'{route_key = @@ -1132,12 +1540,19 @@ verify_msg(Msg, MsgName, Opts) -> 'Command' -> v_msg_Command(Msg, [MsgName], TrUserData); 'JsonRpcRequest' -> v_msg_JsonRpcRequest(Msg, [MsgName], TrUserData); 'JsonRpcReply' -> v_msg_JsonRpcReply(Msg, [MsgName], TrUserData); + 'RequestFrame' -> v_msg_RequestFrame(Msg, [MsgName], TrUserData); + 'ResponseFrame' -> v_msg_ResponseFrame(Msg, [MsgName], TrUserData); + 'CastFrame' -> v_msg_CastFrame(Msg, [MsgName], TrUserData); 'Data' -> v_msg_Data(Msg, [MsgName], TrUserData); 'TaskEventStream' -> v_msg_TaskEventStream(Msg, [MsgName], TrUserData); _ -> mk_type_error(not_a_known_message, Msg, []) end. +-compile({nowarn_unused_function,v_submsg_AuthRequest/3}). +-dialyzer({nowarn_function,v_submsg_AuthRequest/3}). +v_submsg_AuthRequest(Msg, Path, TrUserData) -> v_msg_AuthRequest(Msg, Path, TrUserData). + -compile({nowarn_unused_function,v_msg_AuthRequest/3}). -dialyzer({nowarn_function,v_msg_AuthRequest/3}). v_msg_AuthRequest(#'AuthRequest'{uuid = F1, username = F2, salt = F3, token = F4, timestamp = F5}, Path, TrUserData) -> @@ -1159,6 +1574,10 @@ v_msg_AuthRequest(#'AuthRequest'{uuid = F1, username = F2, salt = F3, token = F4 ok; v_msg_AuthRequest(X, Path, _TrUserData) -> mk_type_error({expected_msg, 'AuthRequest'}, X, Path). +-compile({nowarn_unused_function,v_submsg_AuthReply/3}). +-dialyzer({nowarn_function,v_submsg_AuthReply/3}). +v_submsg_AuthReply(Msg, Path, TrUserData) -> v_msg_AuthReply(Msg, Path, TrUserData). + -compile({nowarn_unused_function,v_msg_AuthReply/3}). -dialyzer({nowarn_function,v_msg_AuthReply/3}). v_msg_AuthReply(#'AuthReply'{code = F1, payload = F2}, Path, TrUserData) -> @@ -1171,6 +1590,10 @@ v_msg_AuthReply(#'AuthReply'{code = F1, payload = F2}, Path, TrUserData) -> ok; v_msg_AuthReply(X, Path, _TrUserData) -> mk_type_error({expected_msg, 'AuthReply'}, X, Path). +-compile({nowarn_unused_function,v_submsg_Pub/3}). +-dialyzer({nowarn_function,v_submsg_Pub/3}). +v_submsg_Pub(Msg, Path, TrUserData) -> v_msg_Pub(Msg, Path, TrUserData). + -compile({nowarn_unused_function,v_msg_Pub/3}). -dialyzer({nowarn_function,v_msg_Pub/3}). v_msg_Pub(#'Pub'{topic = F1, qos = F2, content = F3}, Path, TrUserData) -> @@ -1186,6 +1609,10 @@ v_msg_Pub(#'Pub'{topic = F1, qos = F2, content = F3}, Path, TrUserData) -> ok; v_msg_Pub(X, Path, _TrUserData) -> mk_type_error({expected_msg, 'Pub'}, X, Path). +-compile({nowarn_unused_function,v_submsg_Command/3}). +-dialyzer({nowarn_function,v_submsg_Command/3}). +v_submsg_Command(Msg, Path, TrUserData) -> v_msg_Command(Msg, Path, TrUserData). + -compile({nowarn_unused_function,v_msg_Command/3}). -dialyzer({nowarn_function,v_msg_Command/3}). v_msg_Command(#'Command'{command_type = F1, command = F2}, Path, TrUserData) -> @@ -1198,6 +1625,10 @@ v_msg_Command(#'Command'{command_type = F1, command = F2}, Path, TrUserData) -> ok; v_msg_Command(X, Path, _TrUserData) -> mk_type_error({expected_msg, 'Command'}, X, Path). +-compile({nowarn_unused_function,v_submsg_JsonRpcRequest/3}). +-dialyzer({nowarn_function,v_submsg_JsonRpcRequest/3}). +v_submsg_JsonRpcRequest(Msg, Path, TrUserData) -> v_msg_JsonRpcRequest(Msg, Path, TrUserData). + -compile({nowarn_unused_function,v_msg_JsonRpcRequest/3}). -dialyzer({nowarn_function,v_msg_JsonRpcRequest/3}). v_msg_JsonRpcRequest(#'JsonRpcRequest'{method = F1, params = F2}, Path, TrUserData) -> @@ -1210,6 +1641,10 @@ v_msg_JsonRpcRequest(#'JsonRpcRequest'{method = F1, params = F2}, Path, TrUserDa ok; v_msg_JsonRpcRequest(X, Path, _TrUserData) -> mk_type_error({expected_msg, 'JsonRpcRequest'}, X, Path). +-compile({nowarn_unused_function,v_submsg_JsonRpcReply/3}). +-dialyzer({nowarn_function,v_submsg_JsonRpcReply/3}). +v_submsg_JsonRpcReply(Msg, Path, TrUserData) -> v_msg_JsonRpcReply(Msg, Path, TrUserData). + -compile({nowarn_unused_function,v_msg_JsonRpcReply/3}). -dialyzer({nowarn_function,v_msg_JsonRpcReply/3}). v_msg_JsonRpcReply(#'JsonRpcReply'{result = F1, error = F2}, Path, TrUserData) -> @@ -1222,6 +1657,54 @@ v_msg_JsonRpcReply(#'JsonRpcReply'{result = F1, error = F2}, Path, TrUserData) - ok; v_msg_JsonRpcReply(X, Path, _TrUserData) -> mk_type_error({expected_msg, 'JsonRpcReply'}, X, Path). +-compile({nowarn_unused_function,v_msg_RequestFrame/3}). +-dialyzer({nowarn_function,v_msg_RequestFrame/3}). +v_msg_RequestFrame(#'RequestFrame'{packet_id = F1, body = F2}, Path, TrUserData) -> + if F1 == undefined -> ok; + true -> v_type_uint32(F1, [packet_id | Path], TrUserData) + end, + case F2 of + undefined -> ok; + {auth_request, OF2} -> v_submsg_AuthRequest(OF2, [auth_request, body | Path], TrUserData); + {jsonrpc_request, OF2} -> v_submsg_JsonRpcRequest(OF2, [jsonrpc_request, body | Path], TrUserData); + _ -> mk_type_error(invalid_oneof, F2, [body | Path]) + end, + ok; +v_msg_RequestFrame(X, Path, _TrUserData) -> mk_type_error({expected_msg, 'RequestFrame'}, X, Path). + +-compile({nowarn_unused_function,v_msg_ResponseFrame/3}). +-dialyzer({nowarn_function,v_msg_ResponseFrame/3}). +v_msg_ResponseFrame(#'ResponseFrame'{packet_id = F1, body = F2}, Path, TrUserData) -> + if F1 == undefined -> ok; + true -> v_type_uint32(F1, [packet_id | Path], TrUserData) + end, + case F2 of + undefined -> ok; + {auth_reply, OF2} -> v_submsg_AuthReply(OF2, [auth_reply, body | Path], TrUserData); + {jsonrpc_reply, OF2} -> v_submsg_JsonRpcReply(OF2, [jsonrpc_reply, body | Path], TrUserData); + _ -> mk_type_error(invalid_oneof, F2, [body | Path]) + end, + ok; +v_msg_ResponseFrame(X, Path, _TrUserData) -> mk_type_error({expected_msg, 'ResponseFrame'}, X, Path). + +-compile({nowarn_unused_function,v_msg_CastFrame/3}). +-dialyzer({nowarn_function,v_msg_CastFrame/3}). +v_msg_CastFrame(#'CastFrame'{body = F1}, Path, TrUserData) -> + case F1 of + undefined -> ok; + {pub, OF1} -> v_submsg_Pub(OF1, [pub, body | Path], TrUserData); + {command, OF1} -> v_submsg_Command(OF1, [command, body | Path], TrUserData); + {data, OF1} -> v_submsg_Data(OF1, [data, body | Path], TrUserData); + {event_stream, OF1} -> v_submsg_TaskEventStream(OF1, [event_stream, body | Path], TrUserData); + _ -> mk_type_error(invalid_oneof, F1, [body | Path]) + end, + ok; +v_msg_CastFrame(X, Path, _TrUserData) -> mk_type_error({expected_msg, 'CastFrame'}, X, Path). + +-compile({nowarn_unused_function,v_submsg_Data/3}). +-dialyzer({nowarn_function,v_submsg_Data/3}). +v_submsg_Data(Msg, Path, TrUserData) -> v_msg_Data(Msg, Path, TrUserData). + -compile({nowarn_unused_function,v_msg_Data/3}). -dialyzer({nowarn_function,v_msg_Data/3}). v_msg_Data(#'Data'{route_key = F1, metric = F2}, Path, TrUserData) -> @@ -1234,6 +1717,10 @@ v_msg_Data(#'Data'{route_key = F1, metric = F2}, Path, TrUserData) -> ok; v_msg_Data(X, Path, _TrUserData) -> mk_type_error({expected_msg, 'Data'}, X, Path). +-compile({nowarn_unused_function,v_submsg_TaskEventStream/3}). +-dialyzer({nowarn_function,v_submsg_TaskEventStream/3}). +v_submsg_TaskEventStream(Msg, Path, TrUserData) -> v_msg_TaskEventStream(Msg, Path, TrUserData). + -compile({nowarn_unused_function,v_msg_TaskEventStream/3}). -dialyzer({nowarn_function,v_msg_TaskEventStream/3}). v_msg_TaskEventStream(#'TaskEventStream'{task_id = F1, type = F2, stream = F3}, Path, TrUserData) -> @@ -1255,6 +1742,12 @@ v_type_int32(N, _Path, _TrUserData) when is_integer(N), -2147483648 =< N, N =< 2 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_uint32/3}). +-dialyzer({nowarn_function,v_type_uint32/3}). +v_type_uint32(N, _Path, _TrUserData) when is_integer(N), 0 =< N, N =< 4294967295 -> ok; +v_type_uint32(N, Path, _TrUserData) when is_integer(N) -> mk_type_error({value_out_of_range, uint32, unsigned, 32}, N, Path); +v_type_uint32(X, Path, _TrUserData) -> mk_type_error({bad_integer, uint32, unsigned, 32}, X, Path). + -compile({nowarn_unused_function,v_type_bytes/3}). -dialyzer({nowarn_function,v_type_bytes/3}). v_type_bytes(B, _Path, _TrUserData) when is_binary(B) -> ok; @@ -1313,6 +1806,23 @@ get_msg_defs() -> {{msg, 'Command'}, [#field{name = command_type, fnum = 1, rnum = 2, type = int32, occurrence = optional, opts = []}, #field{name = command, fnum = 2, rnum = 3, type = bytes, occurrence = optional, opts = []}]}, {{msg, 'JsonRpcRequest'}, [#field{name = method, fnum = 1, rnum = 2, type = bytes, occurrence = optional, opts = []}, #field{name = params, fnum = 2, rnum = 3, type = bytes, occurrence = optional, opts = []}]}, {{msg, 'JsonRpcReply'}, [#field{name = result, fnum = 1, rnum = 2, type = bytes, occurrence = optional, opts = []}, #field{name = error, fnum = 2, rnum = 3, type = bytes, occurrence = optional, opts = []}]}, + {{msg, 'RequestFrame'}, + [#field{name = packet_id, fnum = 1, rnum = 2, type = uint32, occurrence = optional, opts = []}, + #gpb_oneof{name = body, rnum = 3, + fields = [#field{name = auth_request, fnum = 2, rnum = 3, type = {msg, 'AuthRequest'}, occurrence = optional, opts = []}, #field{name = jsonrpc_request, fnum = 3, rnum = 3, type = {msg, 'JsonRpcRequest'}, occurrence = optional, opts = []}], + opts = []}]}, + {{msg, 'ResponseFrame'}, + [#field{name = packet_id, fnum = 1, rnum = 2, type = uint32, occurrence = optional, opts = []}, + #gpb_oneof{name = body, rnum = 3, + fields = [#field{name = auth_reply, fnum = 2, rnum = 3, type = {msg, 'AuthReply'}, occurrence = optional, opts = []}, #field{name = jsonrpc_reply, fnum = 3, rnum = 3, type = {msg, 'JsonRpcReply'}, occurrence = optional, opts = []}], opts = []}]}, + {{msg, 'CastFrame'}, + [#gpb_oneof{name = body, rnum = 2, + fields = + [#field{name = pub, fnum = 1, rnum = 2, type = {msg, 'Pub'}, occurrence = optional, opts = []}, + #field{name = command, fnum = 2, rnum = 2, type = {msg, 'Command'}, occurrence = optional, opts = []}, + #field{name = data, fnum = 3, rnum = 2, type = {msg, 'Data'}, occurrence = optional, opts = []}, + #field{name = event_stream, fnum = 4, rnum = 2, type = {msg, 'TaskEventStream'}, occurrence = optional, opts = []}], + opts = []}]}, {{msg, 'Data'}, [#field{name = route_key, fnum = 1, rnum = 2, type = bytes, occurrence = optional, opts = []}, #field{name = metric, fnum = 2, rnum = 3, type = bytes, occurrence = optional, opts = []}]}, {{msg, 'TaskEventStream'}, [#field{name = task_id, fnum = 1, rnum = 2, type = int32, occurrence = optional, opts = []}, @@ -1320,13 +1830,13 @@ get_msg_defs() -> #field{name = stream, fnum = 3, rnum = 4, type = bytes, occurrence = optional, opts = []}]}]. -get_msg_names() -> ['AuthRequest', 'AuthReply', 'Pub', 'Command', 'JsonRpcRequest', 'JsonRpcReply', 'Data', 'TaskEventStream']. +get_msg_names() -> ['AuthRequest', 'AuthReply', 'Pub', 'Command', 'JsonRpcRequest', 'JsonRpcReply', 'RequestFrame', 'ResponseFrame', 'CastFrame', 'Data', 'TaskEventStream']. get_group_names() -> []. -get_msg_or_group_names() -> ['AuthRequest', 'AuthReply', 'Pub', 'Command', 'JsonRpcRequest', 'JsonRpcReply', 'Data', 'TaskEventStream']. +get_msg_or_group_names() -> ['AuthRequest', 'AuthReply', 'Pub', 'Command', 'JsonRpcRequest', 'JsonRpcReply', 'RequestFrame', 'ResponseFrame', 'CastFrame', 'Data', 'TaskEventStream']. get_enum_names() -> []. @@ -1357,6 +1867,23 @@ find_msg_def('Pub') -> find_msg_def('Command') -> [#field{name = command_type, fnum = 1, rnum = 2, type = int32, occurrence = optional, opts = []}, #field{name = command, fnum = 2, rnum = 3, type = bytes, occurrence = optional, opts = []}]; find_msg_def('JsonRpcRequest') -> [#field{name = method, fnum = 1, rnum = 2, type = bytes, occurrence = optional, opts = []}, #field{name = params, fnum = 2, rnum = 3, type = bytes, occurrence = optional, opts = []}]; find_msg_def('JsonRpcReply') -> [#field{name = result, fnum = 1, rnum = 2, type = bytes, occurrence = optional, opts = []}, #field{name = error, fnum = 2, rnum = 3, type = bytes, occurrence = optional, opts = []}]; +find_msg_def('RequestFrame') -> + [#field{name = packet_id, fnum = 1, rnum = 2, type = uint32, occurrence = optional, opts = []}, + #gpb_oneof{name = body, rnum = 3, + fields = [#field{name = auth_request, fnum = 2, rnum = 3, type = {msg, 'AuthRequest'}, occurrence = optional, opts = []}, #field{name = jsonrpc_request, fnum = 3, rnum = 3, type = {msg, 'JsonRpcRequest'}, occurrence = optional, opts = []}], + opts = []}]; +find_msg_def('ResponseFrame') -> + [#field{name = packet_id, fnum = 1, rnum = 2, type = uint32, occurrence = optional, opts = []}, + #gpb_oneof{name = body, rnum = 3, + fields = [#field{name = auth_reply, fnum = 2, rnum = 3, type = {msg, 'AuthReply'}, occurrence = optional, opts = []}, #field{name = jsonrpc_reply, fnum = 3, rnum = 3, type = {msg, 'JsonRpcReply'}, occurrence = optional, opts = []}], opts = []}]; +find_msg_def('CastFrame') -> + [#gpb_oneof{name = body, rnum = 2, + fields = + [#field{name = pub, fnum = 1, rnum = 2, type = {msg, 'Pub'}, occurrence = optional, opts = []}, + #field{name = command, fnum = 2, rnum = 2, type = {msg, 'Command'}, occurrence = optional, opts = []}, + #field{name = data, fnum = 3, rnum = 2, type = {msg, 'Data'}, occurrence = optional, opts = []}, + #field{name = event_stream, fnum = 4, rnum = 2, type = {msg, 'TaskEventStream'}, occurrence = optional, opts = []}], + opts = []}]; find_msg_def('Data') -> [#field{name = route_key, fnum = 1, rnum = 2, type = bytes, occurrence = optional, opts = []}, #field{name = metric, fnum = 2, rnum = 3, type = bytes, occurrence = optional, opts = []}]; find_msg_def('TaskEventStream') -> [#field{name = task_id, fnum = 1, rnum = 2, type = int32, occurrence = optional, opts = []}, @@ -1426,6 +1953,9 @@ fqbin_to_msg_name(<<"Pub">>) -> 'Pub'; fqbin_to_msg_name(<<"Command">>) -> 'Command'; fqbin_to_msg_name(<<"JsonRpcRequest">>) -> 'JsonRpcRequest'; fqbin_to_msg_name(<<"JsonRpcReply">>) -> 'JsonRpcReply'; +fqbin_to_msg_name(<<"RequestFrame">>) -> 'RequestFrame'; +fqbin_to_msg_name(<<"ResponseFrame">>) -> 'ResponseFrame'; +fqbin_to_msg_name(<<"CastFrame">>) -> 'CastFrame'; fqbin_to_msg_name(<<"Data">>) -> 'Data'; fqbin_to_msg_name(<<"TaskEventStream">>) -> 'TaskEventStream'; fqbin_to_msg_name(E) -> error({gpb_error, {badmsg, E}}). @@ -1437,6 +1967,9 @@ msg_name_to_fqbin('Pub') -> <<"Pub">>; msg_name_to_fqbin('Command') -> <<"Command">>; msg_name_to_fqbin('JsonRpcRequest') -> <<"JsonRpcRequest">>; msg_name_to_fqbin('JsonRpcReply') -> <<"JsonRpcReply">>; +msg_name_to_fqbin('RequestFrame') -> <<"RequestFrame">>; +msg_name_to_fqbin('ResponseFrame') -> <<"ResponseFrame">>; +msg_name_to_fqbin('CastFrame') -> <<"CastFrame">>; msg_name_to_fqbin('Data') -> <<"Data">>; msg_name_to_fqbin('TaskEventStream') -> <<"TaskEventStream">>; msg_name_to_fqbin(E) -> error({gpb_error, {badmsg, E}}). @@ -1477,7 +2010,7 @@ get_all_source_basenames() -> ["message.proto"]. get_all_proto_names() -> ["message"]. -get_msg_containment("message") -> ['AuthReply', 'AuthRequest', 'Command', 'Data', 'JsonRpcReply', 'JsonRpcRequest', 'Pub', 'TaskEventStream']; +get_msg_containment("message") -> ['AuthReply', 'AuthRequest', 'CastFrame', 'Command', 'Data', 'JsonRpcReply', 'JsonRpcRequest', 'Pub', 'RequestFrame', 'ResponseFrame', 'TaskEventStream']; get_msg_containment(P) -> error({gpb_error, {badproto, P}}). @@ -1502,6 +2035,9 @@ get_proto_by_msg_name_as_fqbin(<<"Pub">>) -> "message"; get_proto_by_msg_name_as_fqbin(<<"JsonRpcRequest">>) -> "message"; get_proto_by_msg_name_as_fqbin(<<"Command">>) -> "message"; get_proto_by_msg_name_as_fqbin(<<"AuthRequest">>) -> "message"; +get_proto_by_msg_name_as_fqbin(<<"ResponseFrame">>) -> "message"; +get_proto_by_msg_name_as_fqbin(<<"RequestFrame">>) -> "message"; +get_proto_by_msg_name_as_fqbin(<<"CastFrame">>) -> "message"; get_proto_by_msg_name_as_fqbin(<<"JsonRpcReply">>) -> "message"; get_proto_by_msg_name_as_fqbin(<<"AuthReply">>) -> "message"; get_proto_by_msg_name_as_fqbin(<<"TaskEventStream">>) -> "message";