fix pb

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',

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]).
+-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' | 'Data' | 'TaskEventStream'.
+-type '$msg_name'() :: 'AuthRequest' | 'AuthReply' | 'Pub' | 'Command' | 'JsonRpcRequest' | 'JsonRpcReply' | 'RequestFrame' | 'ResponseFrame' | 'CastFrame' | 'Data' | 'TaskEventStream'.
--type '$msg'() :: 'AuthRequest'() | 'AuthReply'() | 'Pub'() | 'Command'() | 'JsonRpcRequest'() | 'JsonRpcReply'() | '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, <<Bin/binary, 8>>, 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, <<B1/binary, 18>>, TrUserData) end;
+               {jsonrpc_request, TF2} -> begin TrTF2 = id(TF2, TrUserData), e_mfield_RequestFrame_jsonrpc_request(TrTF2, <<B1/binary, 26>>, 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, <<Bin/binary, 8>>, 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, <<B1/binary, 18>>, TrUserData) end;
+               {jsonrpc_reply, TF2} -> begin TrTF2 = id(TF2, TrUserData), e_mfield_ResponseFrame_jsonrpc_reply(TrTF2, <<B1/binary, 26>>, 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, <<Bin/binary, 10>>, TrUserData) end;
+               {command, TF1} -> begin TrTF1 = id(TF1, TrUserData), e_mfield_CastFrame_command(TrTF1, <<Bin/binary, 18>>, TrUserData) end;
+               {data, TF1} -> begin TrTF1 = id(TF1, TrUserData), e_mfield_CastFrame_data(TrTF1, <<Bin/binary, 26>>, TrUserData) end;
+               {event_stream, TF1} -> begin TrTF1 = id(TF1, TrUserData), e_mfield_CastFrame_event_stream(TrTF1, <<Bin/binary, 34>>, 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),
+    <<Bin2/binary, SubBin/binary>>.
+
+e_mfield_RequestFrame_jsonrpc_request(Msg, Bin, TrUserData) ->
+    SubBin = encode_msg_JsonRpcRequest(Msg, <<>>, TrUserData),
+    Bin2 = e_varint(byte_size(SubBin), Bin),
+    <<Bin2/binary, SubBin/binary>>.
+
+e_mfield_ResponseFrame_auth_reply(Msg, Bin, TrUserData) ->
+    SubBin = encode_msg_AuthReply(Msg, <<>>, TrUserData),
+    Bin2 = e_varint(byte_size(SubBin), Bin),
+    <<Bin2/binary, SubBin/binary>>.
+
+e_mfield_ResponseFrame_jsonrpc_reply(Msg, Bin, TrUserData) ->
+    SubBin = encode_msg_JsonRpcReply(Msg, <<>>, TrUserData),
+    Bin2 = e_varint(byte_size(SubBin), Bin),
+    <<Bin2/binary, SubBin/binary>>.
+
+e_mfield_CastFrame_pub(Msg, Bin, TrUserData) ->
+    SubBin = encode_msg_Pub(Msg, <<>>, TrUserData),
+    Bin2 = e_varint(byte_size(SubBin), Bin),
+    <<Bin2/binary, SubBin/binary>>.
+
+e_mfield_CastFrame_command(Msg, Bin, TrUserData) ->
+    SubBin = encode_msg_Command(Msg, <<>>, TrUserData),
+    Bin2 = e_varint(byte_size(SubBin), Bin),
+    <<Bin2/binary, SubBin/binary>>.
+
+e_mfield_CastFrame_data(Msg, Bin, TrUserData) ->
+    SubBin = encode_msg_Data(Msg, <<>>, TrUserData),
+    Bin2 = e_varint(byte_size(SubBin), Bin),
+    <<Bin2/binary, SubBin/binary>>.
+
+e_mfield_CastFrame_event_stream(Msg, Bin, TrUserData) ->
+    SubBin = encode_msg_TaskEventStream(Msg, <<>>, TrUserData),
+    Bin2 = e_varint(byte_size(SubBin), Bin),
+    <<Bin2/binary, SubBin/binary>>.
+
 -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, <<Bs:Len/binary, Rest2/binary>> = 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, <<Bs:Len/binary, Rest2/binary>> = 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, <<Bs:Len/binary, Rest2/binary>> = 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, <<Bs:Len/binary, Rest2/binary>> = 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, <<Bs:Len/binary, Rest2/binary>> = 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, <<Bs:Len/binary, Rest2/binary>> = 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, <<Bs:Len/binary, Rest2/binary>> = 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, <<Bs:Len/binary, Rest2/binary>> = 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";