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

Compare commits

base: QPQ-AG:uw-msg-format-tweaks
Branches Tags
QPQ-AG:master
QPQ-AG:uw-250514
QPQ-AG:uw-zompify
QPQ-AG:uw-update-deps
QPQ-AG:uw-fix-validation
QPQ-AG:uw-msg-format-tweaks
QPQ-AG:uw-multiple-solutions
QPQ-AG:uw-client-debugging
..
compare: QPQ-AG:master
Branches Tags
QPQ-AG:uw-250514
QPQ-AG:uw-zompify
QPQ-AG:master
QPQ-AG:uw-update-deps
QPQ-AG:uw-fix-validation
QPQ-AG:uw-msg-format-tweaks
QPQ-AG:uw-multiple-solutions
QPQ-AG:uw-client-debugging

9 Commits
uw-msg-for ... master

Author SHA1 Message Date
Ulf Wiger
f408af0eb3 Merge pull request 'update deps (gmserialization)' (#7) from uw-update-deps0423 into master 
Reviewed-on: #7
 2025-04-24 07:02:03 +09:00
Ulf Wiger
e9b027a353 update deps (gmserialization) 2025-04-23 23:51:40 +02:00
Ulf Wiger
ac3c1e52f1 Merge pull request 'update deps' (#6) from uw-update-deps0414 into master 
Reviewed-on: #6
 2025-04-14 21:46:00 +09:00
Ulf Wiger
4ef670162b update deps 2025-04-14 14:42:05 +02:00
Ulf Wiger
a006410ce6 Merge pull request 'update gmserialization dep' (#5) from uw-update-deps into master 
Reviewed-on: #5
 2025-04-11 19:43:29 +09:00
Ulf Wiger
e21f8f6fbf update gmserialization dep 2025-04-11 12:39:25 +02:00
Ulf Wiger
fe47d3715c Merge pull request 'Validation results were ignored, and also partly broken' (#4) from uw-fix-validation into master 
Reviewed-on: #4
 2025-04-11 17:26:36 +09:00
Ulf Wiger
b9681dec88 Validation results were ignored, and also partly broken 2025-04-11 10:23:00 +02:00
Ulf Wiger
b7cf6375fe Merge pull request 'Reduce notification nesting, add 'continue' result' (#3) from uw-msg-format-tweaks into master 
Reviewed-on: #3
 2025-04-10 17:15:58 +09:00
3 changed files with 14 additions and 7 deletions
Show Stats Expand all files Collapse all files

2
rebar.config
View File

@ -3,7 +3,7 @@
{plugins, [rebar3_hex]}. {plugins, [rebar3_hex]}.
{deps, [ {deps, [
{gmserialization, {git, "https://git.qpq.swiss/QPQ-AG/gmserialization.git", {gmserialization, {git, "https://git.qpq.swiss/QPQ-AG/gmserialization.git",
{ref, "ac64e01b0f"}}} {ref, "0288719ae1"}}}
]}. ]}.
{xref_checks, [undefined_function_calls, undefined_functions, {xref_checks, [undefined_function_calls, undefined_functions,

2
rebar.lock
View File

@ -8,5 +8,5 @@
1}, 1},
{<<"gmserialization">>, {<<"gmserialization">>,
{git,"https://git.qpq.swiss/QPQ-AG/gmserialization.git", {git,"https://git.qpq.swiss/QPQ-AG/gmserialization.git",
{ref,"ac64e01b0f675c1a34c70a827062f381920742db"}}, {ref,"0288719ae15814f3a53114c657502a24376bebfa"}},
0}]. 0}].

17
src/gmmpp_msgs.erl
View File

@ -60,9 +60,10 @@ validate(#{ connect := #{ pubkey := PK
, versions := Versions , versions := Versions
, pool_id := PoolId , pool_id := PoolId
, extra_pubkeys := Extra , extra_pubkeys := Extra
, type := Type , type := Type0
, nonces := Nonces , nonces := Nonces
}} = Msg, _Vsn) -> }} = Msg, _Vsn) ->
Type = to_atom(Type0),
valid({list, protocol}, Protocols), valid({list, protocol}, Protocols),
valid({list, version} , Versions), valid({list, version} , Versions),
valid(pubkey, PK), valid(pubkey, PK),
@ -91,7 +92,7 @@ validate(#{ candidate := #{ seq := Seq
validate(#{ get_nonces := #{ seq := Seq validate(#{ get_nonces := #{ seq := Seq
, n := N }} = Msg, _Vsn) -> , n := N }} = Msg, _Vsn) ->
valid(seq, Seq), valid(seq, Seq),
valid(pos_integer, N), valid(pos_int, N),
Msg; Msg;
validate(#{ new_server := #{ host := Host, port := Port, keep := Keep }} = Msg, _Vsn) -> validate(#{ new_server := #{ host := Host, port := Port, keep := Keep }} = Msg, _Vsn) ->
valid(string, Host), valid(string, Host),
@ -297,10 +298,10 @@ decode_msg_(<<"no_solution">>, #{ <<"seq">> := Seq
, nonce => Nonce }}. , nonce => Nonce }}.
valid(Type, Val) -> valid(Type, Val) ->
try valid_(Type, Val) try true = valid_(Type, Val)
catch catch
error:_ -> error:_ ->
false error({invalid, {Type, Val}})
end. end.
valid_({list,T}, Ps) -> lists:all(fun(X) -> valid_(T, X) end, Ps); valid_({list,T}, Ps) -> lists:all(fun(X) -> valid_(T, X) end, Ps);
@ -308,12 +309,13 @@ 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_(nonce, Nonce) -> pos_integer(Nonce);
valid_(target, T) -> pos_integer(T); 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_(string, S) -> is_binary(S); valid_(string, S) -> is_binary(S);
valid_(boolean, B) -> is_boolean(B); valid_(boolean, B) -> is_boolean(B);
valid_(contract, Id) -> ok_tuple(gmser_api_encoder:safe_defode(contract_pubkey, Id)); valid_(contract, Id) -> ok_tuple(gmser_api_encoder:safe_decode(contract_pubkey, Id));
valid_(type, T) -> lists:member(T, [miner, monitor]); valid_(type, T) -> lists:member(T, [miner, monitor]);
valid_(solutions, S) -> lists:all(fun(#{nonce := N, evidence := Evd}) -> valid_(solutions, S) -> lists:all(fun(#{nonce := N, evidence := Evd}) ->
valid_(pos_int, N), valid_(pos_int, N),
@ -336,3 +338,8 @@ ok_tuple(V) ->
pos_integer(I) -> pos_integer(I) ->
is_integer(I) andalso I >= 0. is_integer(I) andalso I >= 0.
to_atom(A) when is_atom(A) ->
A;
to_atom(B) when is_binary(B) ->
binary_to_existing_atom(B, utf8).