QPQ-AG/gm_mining_pool_protocol
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add target info to candidate msg

Browse Source
This commit is contained in:
Ulf Wiger 2025-03-14 23:15:12 +01:00
parent be8dfe32f2
commit a7b17a37f2
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/gmmpp_msgs.erl
View File

@ -74,9 +74,11 @@ validate(#{ connect_ack := #{ protocol := Protocol
Msg; Msg;
validate(#{ candidate := #{ seq := Seq validate(#{ candidate := #{ seq := Seq
, candidate := C , candidate := C
, target := Target
, nonces := Nonces , nonces := Nonces
, edge_bits := EdgeBits } } = Msg, _Vsn) -> , edge_bits := EdgeBits } } = Msg, _Vsn) ->
valid(candidate, C), valid(candidate, C),
valid(target, Target),
valid(nonces, Nonces), valid(nonces, Nonces),
valid(seq, Seq), valid(seq, Seq),
valid(edge_bits, EdgeBits), valid(edge_bits, EdgeBits),
@ -226,10 +228,12 @@ decode_msg_(<<"get_nonces">>, #{ <<"seq">> := Seq
, <<"n">> := N }) -> , <<"n">> := N }) ->
#{get_nonces => #{seq => Seq, n => N}}; #{get_nonces => #{seq => Seq, n => N}};
decode_msg_(<<"candidate">>, #{ <<"candidate">> := C decode_msg_(<<"candidate">>, #{ <<"candidate">> := C
, <<"target">> := Target
, <<"nonces">> := Nonces , <<"nonces">> := Nonces
, <<"seq">> := Seq , <<"seq">> := Seq
, <<"edge_bits">> := EdgeBits }) -> , <<"edge_bits">> := EdgeBits }) ->
#{candidate => #{ candidate => C #{candidate => #{ candidate => C
, target => Target
, nonces => Nonces , nonces => Nonces
, seq => Seq , seq => Seq
, edge_bits => EdgeBits }}; , edge_bits => EdgeBits }};
@ -256,6 +260,7 @@ valid_(protocol, P) -> is_binary(P);
valid_(version, V) -> is_binary(V); valid_(version, V) -> is_binary(V);
valid_(pubkey, PK) -> ok_tuple(gmser_api_encoder:safe_decode(account_pubkey, PK)); valid_(pubkey, PK) -> ok_tuple(gmser_api_encoder:safe_decode(account_pubkey, PK));
valid_(seq, Seq) -> pos_integer(Seq); valid_(seq, Seq) -> pos_integer(Seq);
valid_(target, T) -> pos_integer(T);
valid_(edge_bits, E) -> pos_integer(E); valid_(edge_bits, E) -> pos_integer(E);
valid_(pos_int, I) -> pos_integer(I); valid_(pos_int, I) -> pos_integer(I);
valid_(contract, Id) -> ok_tuple(gmser_api_encoder:safe_defode(contract_pubkey, Id)); valid_(contract, Id) -> ok_tuple(gmser_api_encoder:safe_defode(contract_pubkey, Id));