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

ensure encoded json is binary

Browse Source
This commit is contained in:
Ulf Wiger 2025-03-10 23:14:02 +01:00
parent a0c6cf10de
commit 7060c29099
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/gmmpp_msgs.erl
View File

@ -149,14 +149,14 @@ decode(MsgBin, ?PROTOCOL_JSON, Vsn) ->
encode_msg(Msg0, ?PROTOCOL_JSON, Vsn) -> encode_msg(Msg0, ?PROTOCOL_JSON, Vsn) ->
Msg = validate(Msg0, Vsn), Msg = validate(Msg0, Vsn),
[{Method, Args}] = maps:to_list(Msg), [{Method, Args}] = maps:to_list(Msg),
json:encode(#{ <<"jsonrpc">> => <<"2.0">> json_encode(#{ <<"jsonrpc">> => <<"2.0">>
, <<"method">> => Method , <<"method">> => Method
, <<"args">> => Args }). , <<"args">> => Args }).
encode_request(Req0, Id, ?PROTOCOL_JSON, Vsn) -> encode_request(Req0, Id, ?PROTOCOL_JSON, Vsn) ->
Req = validate(Req0, Vsn), Req = validate(Req0, Vsn),
[{Method, Args}] = maps:to_list(Req), [{Method, Args}] = maps:to_list(Req),
json:encode(#{ <<"jsonrpc">> => <<"2.0">> json_encode(#{ <<"jsonrpc">> => <<"2.0">>
, <<"id">> => Id , <<"id">> => Id
, <<"method">> => Method , <<"method">> => Method
, <<"args">> => Args }). , <<"args">> => Args }).
@ -166,7 +166,7 @@ encode_reply(Reply0, Id, ?PROTOCOL_JSON, Vsn) when is_map(Reply0) ->
Msg = #{ <<"jsonrpc">> => <<"2.0">> Msg = #{ <<"jsonrpc">> => <<"2.0">>
, <<"id">> => Id , <<"id">> => Id
, <<"result">> => Reply }, , <<"result">> => Reply },
json:encode(Msg); json_encode(Msg);
encode_reply(Reply, Id, ?PROTOCOL_JSON, _Vsn) -> encode_reply(Reply, Id, ?PROTOCOL_JSON, _Vsn) ->
Msg = case Reply of Msg = case Reply of
{error, Reason} -> {error, Reason} ->
@ -179,7 +179,10 @@ encode_reply(Reply, Id, ?PROTOCOL_JSON, _Vsn) ->
, <<"id">> => Id , <<"id">> => Id
, <<"result">> => <<"ok">> } , <<"result">> => <<"ok">> }
end, end,
json:encode(Msg). json_encode(Msg).
json_encode(Msg) ->
iolist_to_binary(json:encode(Msg)).
error_code(mining_disabled ) -> -32000; error_code(mining_disabled ) -> -32000;
error_code(pool_exists ) -> -32001; error_code(pool_exists ) -> -32001;