Compare commits

..

2 Commits

Author SHA1 Message Date
Jarvis Carroll
8d3d30425b Fix semicolon 2025-06-24 07:04:32 +10:00
92d061f572 Disable AVX2 for now
AVX2 is much less available than one would expect, is hard for e.g. me to test, and because of the way gmhive_worker currently works, the illegal-instruction exit codes go undetected, leaving users confused as their balance stays at zero, despite the app saying they are getting solutions.
2025-06-23 22:19:04 +09:00
7 changed files with 134 additions and 289 deletions

View File

@ -3,6 +3,6 @@
{registered,[]},
{included_applications,[]},
{applications,[stdlib,kernel]},
{vsn,"0.4.1"},
{vsn,"0.2.5"},
{modules,[gajumine,gmc_con,gmc_conf,gmc_gui,gmc_sup]},
{mod,{gajumine,[]}}]}.

View File

@ -3,7 +3,7 @@
%%% @end
-module(gajumine).
-vsn("0.4.1").
-vsn("0.2.5").
-behavior(application).
-author("Craig Everett <craigeverett@qpq.swiss>").
-copyright("QPQ AG <craigeverett@qpq.swiss>").
@ -29,7 +29,6 @@ start(normal, _Args) ->
{ok, _} = application:ensure_all_started(ssl),
ok = application:ensure_started(hakuzaru),
ok = application:ensure_started(zxwidgets),
ok = application:ensure_started(gproc),
gmc_sup:start_link().

View File

@ -3,7 +3,7 @@
%%% @end
-module(gmc_con).
-vsn("0.4.1").
-vsn("0.2.5").
-author("Craig Everett <craigeverett@qpq.swiss>").
-copyright("QPQ AG <craigeverett@qpq.swiss>").
-license("GPL-3.0-or-later").
@ -31,8 +31,7 @@
max_cores = 2 :: pos_integer(),
max_mem = 3550722201 :: pos_integer(),
prefs = #{} :: #{},
gmc_conf = none :: none | reference(),
toggle = {stop, 0} :: {start | stop, integer()}}).
gmc_conf = none :: none | reference()}).
-type state() :: #s{}.
@ -102,38 +101,18 @@ start_link() ->
init(none) ->
ok = log(info, "Starting"),
{AProcs, AMem} = proc_mem(),
TwoGraphs = default_spec(mem) * 2,
RProcs =
case AProcs >= 2 of
true -> 2;
false -> 1
end,
RMem =
case AMem >= TwoGraphs of
true -> TwoGraphs;
false -> default_spec(mem)
end,
{Acc, Keys, Network, MaxCores, MaxMem} =
case read_conf() of
{ok, C} ->
{maps:get(account, C, none),
maps:get(keys, C, []),
maps:get(network, C, <<"mainnet">>),
maps:get(max_cores, C, RProcs),
maps:get(max_mem, C, RMem)};
maps:get(max_cores, C, 2),
maps:get(max_mem, C, 3550722201)};
none ->
{none, [], <<"mainnet">>, RProcs, RMem}
{none, [], <<"mainnet">>, 2, 3550722201}
end,
State = #s{network = Network, acc = Acc, keys = Keys, max_cores = MaxCores, max_mem = MaxMem},
Events =
[pool_notification,
connected,
puzzle,
result,
error,
disconnected],
ok = lists:foreach(fun gmhc_events:ensure_subscribed/1, Events),
{ok, start_gui(State)}.
@ -145,11 +124,6 @@ start_gui(State = #s{acc = none}) ->
start_gui(State = #s{acc = AccID}) ->
Window = gmc_gui:start_link(#{}),
ok = gmc_gui:set_account(AccID),
ok =
case lists:member("autostart", zx_daemon:argv()) of
false -> ok;
true -> gmc_gui:start_stop()
end,
State#s{window = Window}.
@ -164,8 +138,8 @@ handle_call(Unexpected, From, State) ->
handle_cast(start_stop, State) ->
NewState = do_start_stop(State),
{noreply, NewState};
ok = do_start_stop(State),
{noreply, State};
handle_cast(gajudesk, State) ->
ok = do_gajudesk(),
{noreply, State};
@ -185,7 +159,7 @@ handle_cast(Unexpected, State) ->
handle_info({gproc_ps_event, Event, Data}, State) ->
ok = gproc_ps_event({Event, Data}),
ok = gmc_gui:message({Event, Data}),
{noreply, State};
handle_info({'DOWN', Mon, process, PID, Info}, State = #s{gmc_conf = Mon}) ->
ok = log(info, "gmc_conf ~p closed with ~p", [PID, Info]),
@ -196,14 +170,6 @@ handle_info(Unexpected, State) ->
{noreply, State}.
gproc_ps_event(Info = {disconnected, #{info := #{reconnecting := false, error := #{code := Code, message := Message}}}}) ->
ok = log(error, "Error terminal event received. Code: ~p. Message: ~p", [Code, Message]),
ok = gmc_gui:message(Info),
gmc_gui:start_stop();
gproc_ps_event(Info) ->
gmc_gui:message(Info).
code_change(_, State, _) ->
{ok, State}.
@ -221,25 +187,15 @@ terminate(Reason, State) ->
do_stop() ->
zx:stop().
case is_pid(whereis(gd_con)) of
false -> zx:stop();
true -> application:stop(gajumine)
end.
%%% Doers
do_start_stop(State = #s{toggle = {Last, TS}}) ->
Now = erlang:system_time(second),
Clicklimit = Now - 1,
case TS < Clicklimit of
true ->
case Last of
stop -> do_start(State#s{toggle = {start, Now}});
start -> do_stop(State#s{toggle = {stop, Now}})
end;
false -> State
end.
do_start(State = #s{acc = PubKey, keys = Keys, network = Network, max_cores = MaxCores, max_mem = MaxMem}) ->
do_start_stop(#s{acc = PubKey, keys = Keys, network = Network, max_cores = MaxCores, max_mem = MaxMem}) ->
% smrt guy stuff happens here
{Bits, Eureka} =
case Network of
@ -249,10 +205,7 @@ do_start(State = #s{acc = PubKey, keys = Keys, network = Network, max_cores = Ma
{Fatness, Type} =
case os:type() of
{unix, linux} ->
case Network of
<<"mainnet">> -> {"mean", "avx2"};
<<"testnet">> -> {"mean", "generic"}
end;
{"mean", "generic"};
{unix, darwin} ->
% Check memory. >7gb gets mean, <7gb gets lean
{"mean", "generic"};
@ -260,11 +213,7 @@ do_start(State = #s{acc = PubKey, keys = Keys, network = Network, max_cores = Ma
% Check memory. >7gb gets mean, <7gb gets lean
% Check avx2.
% Both should be provided by the F# start program
case Network of
% <<"mainnet">> -> {"mean", "avx2.exe"};
<<"mainnet">> -> {"mean", "generic.exe"};
<<"testnet">> -> {"mean", "generic.exe"}
end
{"mean", "generic"}
end,
Miner = filename:join(platform_dir(), unicode:characters_to_binary([Fatness, Bits, "-", Type])),
Count = optimize_count(MaxCores, MaxMem),
@ -278,35 +227,32 @@ do_start(State = #s{acc = PubKey, keys = Keys, network = Network, max_cores = Ma
ok = gmc_gui:message({notice, "Starting..."}),
ok = gmc_gui:message({notice, ["Miner: ", Miner]}),
{ok, Apps} = gmhc_app:start(Profile),
Started = io_lib:format("Apps started:~n ~p", [Apps]),
Started = io_lib:format("Apps started: ~p", [Apps]),
ok = log(info, Started),
ok = gmc_gui:message({notice, Started}),
State.
do_stop(State) ->
ok = gmc_gui:message({notice, "Stopping."}),
ok =
case application:stop(gmhive_client) of
ok -> ok;
Error -> log(warning, "application:stop(gmhive_client) returned: ~p", [Error])
end,
State.
Events =
[pool_notification,
connected,
puzzle,
result,
error,
disconnected],
lists:foreach(fun gmhc_events:ensure_subscribed/1, Events).
optimize_count(MaxC, MaxM) ->
GraphSize = 3550722201,
MapSize = 3550722201,
MaxCores = max(1, MaxC),
MaxMem = max(GraphSize, MaxM),
MaxMem = max(MapSize, MaxM),
{Procs, Memory} = proc_mem(),
MeanGraphs = min(MaxMem, Memory) div GraphSize,
Recommended = min(MaxCores, min(Procs, MeanGraphs)),
MeanMaps = min(MaxMem, Memory) div MapSize,
Recommended = min(MaxCores, max(min(Procs, MeanMaps) - 1, 1)),
Notice = fun(F, A) -> gmc_gui:message({notice, io_lib:format(F, A)}) end,
ok = Notice("Physical Processors: ~p", [Procs]),
ok = Notice("Physical Memory: ~p", [Memory]),
ok = Notice("Max Processor Commit: ~p", [MaxCores]),
ok = Notice("Max Memory Commit: ~p", [MaxMem]),
ok = Notice("29-bit Mean Graph Space: ~p", [MeanGraphs]),
ok = Notice("29-bit Mean Map Space: ~p", [MeanMaps]),
ok = Notice("Workers: ~p", [Recommended]),
Recommended.
@ -318,15 +264,8 @@ platform_dir() ->
{unix, linux} ->
"linux_x86_64";
{unix, darwin} ->
case string:trim(os:cmd("uname -m")) of
"arm64" ->
"mac_arm64";
"x86_64" ->
"mac_x86_64";
Other ->
ok = log(info, "uname -m: ~p", [Other]),
"mac_x86_64"
end;
% TODO: Check M2 vs x86
"mac_m2";
{win32, nt} ->
"win_x86_64"
end,
@ -374,26 +313,23 @@ win_mem() ->
do_gajudesk() ->
ok = log(info, "Running gajudesk"),
GajuDesk = "zx run gajudesk",
Command =
case os:type() of
{unix, darwin} -> detach_darwin(GajuDesk);
{unix, _} -> detach_unix(GajuDesk);
{win32, nt} -> detach_windows(GajuDesk)
end,
Out = os:cmd(Command),
log(info, "os:cmd(~s) -> ~s", [Command, Out]).
ok = tell(info, "Running gajudesk"),
PID = spawn(fun run_gajudesk/0),
tell(info, "GajuDesk launched at PID: ~p", [PID]).
detach_darwin(Command) ->
"nohup " ++ Command ++ " >/dev/null 2>&1 & disown".
detach_unix(Command) ->
"setsid sh -c 'exec nohup " ++ Command ++ " >/dev/null 2>&1' &".
detach_windows(Command) ->
PSCmd = "Start-Process -WindowStyle Hidden -FilePath cmd.exe -ArgumentList '/c " ++ Command ++ "'",
"powershell -NoProfile -Command \"" ++ PSCmd ++ "\"".
run_gajudesk() ->
R = "otpr",
N = "gajudesk",
{ok, V} = zx:latest({R, N}),
{ok, PackageString} = zx_lib:package_string({R, N, V}),
try
case zx:run(PackageString, []) of
ok -> ok;
Error -> tell(error, "gajudesk died with: ~p", [Error])
end
catch
E:R -> tell(error, "gajudesk died with: ~p", [{E, R}])
end.
run_gmc_conf(State = #s{gmc_conf = none, network = Net, acc = Acc, keys = Keys,

View File

@ -3,7 +3,7 @@
%%% @end
-module(gmc_conf).
-vsn("0.4.1").
-vsn("0.2.5").
-author("Craig Everett <craigeverett@qpq.swiss>").
-copyright("QPQ AG <craigeverett@qpq.swiss>").
-license("GPL-3.0-or-later").
@ -25,8 +25,8 @@
net = none :: none | wx:wx_object(),
acc = none :: none | wx:wx_object(),
keys = none :: none | wx:wx_object(),
cores = 2 :: pos_integer(),
memory = 3550722201 :: pos_integer()}).
cores = none :: none | wx:wx_object(),
memory = none :: none | wx:wx_object()}).
@ -60,30 +60,27 @@ init({Prefs, {Net, Acc, Keys, {AProcs, AMem, MProcs, MMem}}}) ->
WX = wx:new(),
Frame = wxFrame:new(WX, ?wxID_ANY, Label),
Panel = wxWindow:new(Frame, ?wxID_ANY),
TopSz = wxBoxSizer:new(?wxVERTICAL),
_ = wxBoxSizer:add(TopSz, Panel, zxw:flags(wide)),
MainSz = wxBoxSizer:new(?wxVERTICAL),
AccSz = wxStaticBoxSizer:new(?wxVERTICAL, Panel, [{label, J("GajuMining Account ID")}]),
AccTx = wxTextCtrl:new(Panel, ?wxID_ANY, [{value, acc(Acc)}]),
AccSz = wxStaticBoxSizer:new(?wxVERTICAL, Frame, [{label, J("GajuMining Account ID")}]),
AccTx = wxTextCtrl:new(Frame, ?wxID_ANY, [{value, acc(Acc)}]),
_ = wxStaticBoxSizer:add(AccSz, AccTx, wide(5)),
KeysSz = wxStaticBoxSizer:new(?wxVERTICAL, Panel, [{label, J("Additional Account IDs (optional)")}]),
KeysTx = wxTextCtrl:new(Panel, ?wxID_ANY, [{style, ?wxTE_MULTILINE}, {value, keys(Keys)}]),
KeysSz = wxStaticBoxSizer:new(?wxVERTICAL, Frame, [{label, J("Additional Account IDs (optional)")}]),
KeysTx = wxTextCtrl:new(Frame, ?wxID_ANY, [{style, ?wxTE_MULTILINE}, {value, keys(Keys)}]),
_ = wxStaticBoxSizer:add(KeysSz, KeysTx, wide(5)),
StatSz = wxStaticBoxSizer:new(?wxVERTICAL, Panel, [{label, J("Max System Committment (optional)")}]),
StatSz = wxStaticBoxSizer:new(?wxVERTICAL, Frame, [{label, J("Max System Committment (optional)")}]),
AProcsS = i_to_l(AProcs),
MProcsS = i_to_l(MProcs),
AMemS = gigs(AMem),
MMemS = gigs(MMem),
Labels = [{J("HW Cores"), J("Max Cores"), AProcsS, MProcsS}, {J("Memory (GB)"), J("Max Memory"), AMemS, MMemS}],
{Grid, [CoresTx, MemoryTx]} = display_box(Panel, Labels),
Network = wxRadioBox:new(Panel, ?wxID_ANY, J("Network"), {0, 0}, {50, 50}, [J("Mainnet"), J("Testnet")]),
{Grid, [CoresTx, MemoryTx]} = display_box(Frame, Labels),
Network = wxRadioBox:new(Frame, ?wxID_ANY, J("Network"), {0, 0}, {50, 50}, [J("Mainnet"), J("Testnet")]),
ok = wxRadioBox:setSelection(Network, net_num(Net)),
ButtSz = wxBoxSizer:new(?wxHORIZONTAL),
Affirm = wxButton:new(Panel, ?wxID_OK),
Cancel = wxButton:new(Panel, ?wxID_CANCEL),
Affirm = wxButton:new(Frame, ?wxID_OK),
Cancel = wxButton:new(Frame, ?wxID_CANCEL),
_ = wxBoxSizer:add(StatSz, Grid, wide(5)),
_ = wxBoxSizer:add(ButtSz, Affirm, wide(5)),
_ = wxBoxSizer:add(ButtSz, Cancel, wide(5)),
@ -92,8 +89,7 @@ init({Prefs, {Net, Acc, Keys, {AProcs, AMem, MProcs, MMem}}}) ->
_ = wxBoxSizer:add(MainSz, StatSz, base(5)),
_ = wxBoxSizer:add(MainSz, Network, base(5)),
_ = wxBoxSizer:add(MainSz, ButtSz, base(5)),
ok = wxWindow:setSizer(Panel, MainSz),
ok = wxFrame:setSizer(Frame, TopSz),
ok = wxFrame:setSizer(Frame, MainSz),
ok = wxBoxSizer:layout(MainSz),
ok = wxFrame:connect(Frame, command_button_clicked),
ok = wxFrame:connect(Frame, close_window),
@ -209,51 +205,24 @@ done(State = #s{net = Network, acc = AccTx, keys = KeysTx, cores = CoresTx, memo
1 -> <<"testnet">>;
_ -> <<"mainnet">>
end,
AccID = string:trim(wxTextCtrl:getValue(AccTx)),
AccID = wxTextCtrl:getValue(AccTx),
MOAR_IDs = wxTextCtrl:getValue(KeysTx),
CoreS = wxTextCtrl:getValue(CoresTx),
GigsS = wxTextCtrl:getValue(MemTx),
ok = gmc_con:conf({Net, list_to_binary(AccID), binify_keys(AccID, MOAR_IDs), cores(CoreS), bytes(GigsS)}),
ok = gmc_con:conf({Net, list_to_binary(AccID), binify_keys(MOAR_IDs), cores(CoreS), bytes(GigsS)}),
buh_bye(State).
% NOTE: 32 is space, 12288 is full-width space.
binify_keys(AccID, MOAR) ->
Unwashed = lists:usort([K || K <- string:lexemes(MOAR, [$\r, $\n, 32, 12288, $\t, $,, $;])]),
Scrubbed = lists:delete(AccID, Unwashed),
Keys =
case lists:partition(fun is_key/1, Scrubbed) of
{Cleaned, []} ->
Cleaned;
{Cleaned, Trash} ->
Message = io_lib:format("The following keys are invalid:~n~p", [Trash]),
ok = gmc_gui:message({notice, Message}),
Cleaned
end,
lists:map(fun list_to_binary/1, Keys).
is_key(Mystery) ->
try
MysteryBin = list_to_binary(Mystery),
{account_pubkey, _} = gmser_api_encoder:decode(MysteryBin),
true
catch
_:_ -> false
end.
cores("") ->
2;
none;
cores(CoreS) ->
try
list_to_integer(CoreS)
catch
_:_ -> 2
_:_ -> none
end.
bytes("") ->
3550722201;
none;
bytes(GigsS) ->
try
list_to_integer(GigsS) * gig()
@ -262,11 +231,16 @@ bytes(GigsS) ->
try
trunc(list_to_float(GigsS) * gig())
catch
_:_ -> 3550722201
_:_ -> none
end
end.
% NOTE: 32 is space, 12288 is full-width space.
binify_keys(MOAR) ->
[list_to_binary(K) || K <- string:lexemes(MOAR, [$\r, $\n, 32, 12288, $\t, $,, $;])].
acc(none) -> "";
acc(AKID) -> AKID.

View File

@ -3,14 +3,14 @@
%%% @end
-module(gmc_gui).
-vsn("0.4.1").
-vsn("0.2.5").
-author("Craig Everett <craigeverett@qpq.swiss>").
-copyright("QPQ AG <craigeverett@qpq.swiss>").
-license("GPL-3.0-or-later").
-behavior(wx_object).
-include_lib("wx/include/wx.hrl").
-export([ask_conf/0, set_account/1, difficulty/1, speed/1, candidate/1, message/1, start_stop/0]).
-export([ask_conf/0, set_account/1, difficulty/1, speed/1, candidate/1, message/1]).
-export([start_link/1]).
-export([init/1, terminate/2, code_change/3,
handle_call/3, handle_cast/2, handle_info/2, handle_event/2]).
@ -37,9 +37,7 @@
% solved = 0 :: non_neg_integer(), % TODO: Add a widget to show this. Maybe
mess = none :: none | wx:wx_object(),
buff = new_buff() :: buff(),
buttons = [] :: [#w{}],
toggle = start :: stop | start,
toggle_t = none :: none | reference()}).
buttons = [] :: [#w{}]}).
ts() ->
erlang:system_time(microsecond).
@ -81,10 +79,6 @@ message(Terms) ->
wx_object:cast(?MODULE, {message, Terms}).
start_stop() ->
wx_object:cast(?MODULE, start_stop).
%%% Startup Functions
@ -101,21 +95,18 @@ init(Prefs) ->
VSN = proplists:get_value(vsn, ?MODULE:module_info(attributes)),
WX = wx:new(),
Frame = wxFrame:new(WX, ?wxID_ANY, AppName ++ " v" ++ VSN),
Panel = wxWindow:new(Frame, ?wxID_ANY),
TopSz = wxBoxSizer:new(?wxVERTICAL),
_ = wxBoxSizer:add(TopSz, Panel, zxw:flags(wide)),
MainSz = wxBoxSizer:new(?wxVERTICAL),
LeftRight = wxBoxSizer:new(?wxHORIZONTAL),
Left = wxBoxSizer:new(?wxVERTICAL),
Right = wxBoxSizer:new(?wxVERTICAL),
Labels = [J("ID"), J("Target"), J("Graphs/s"), J("Candidate"), J("Height"), J("BlockHash")],
{Grid, [ID_C, DiffC, PerfC, CandyC, HeightC, BlockC]} = display_box(Panel, Labels),
Labels = [J("ID"), J("Target"), J("Maps/s"), J("Candidate"), J("Height"), J("BlockHash")],
{Grid, [ID_C, DiffC, PerfC, CandyC, HeightC, BlockC]} = display_box(Frame, Labels),
Style = ?wxTE_MULTILINE bor ?wxTE_READONLY,
MessSz = wxStaticBoxSizer:new(?wxVERTICAL, Panel, [{label, J("Messages")}]),
MessC = wxTextCtrl:new(Panel, ?wxID_ANY, [{style, Style}]),
_ = wxStaticBoxSizer:add(MessSz, MessC, zxw:flags({wide, 5})),
MessSz = wxStaticBoxSizer:new(?wxVERTICAL, Frame, [{label, J("Messages")}]),
MessC = wxTextCtrl:new(Frame, ?wxID_ANY, [{style, Style}]),
_ = wxStaticBoxSizer:add(MessSz, MessC, zxw:flags(wide)),
ButtonTemplates =
[{start_stop, J("Start")},
@ -126,27 +117,26 @@ init(Prefs) ->
MakeButton =
fun({Name, Label}) ->
B = wxButton:new(Panel, ?wxID_ANY, [{label, Label}]),
B = wxButton:new(Frame, ?wxID_ANY, [{label, Label}]),
#w{name = Name, id = wxButton:getId(B), wx = B}
end,
Buttons = lists:map(MakeButton, ButtonTemplates),
_ = wxBoxSizer:add(Left, Grid, zxw:flags({base, 5})),
_ = wxBoxSizer:add(Left, MessSz, zxw:flags({wide, 5})),
_ = wxBoxSizer:add(Left, Grid, zxw:flags(base)),
_ = wxBoxSizer:add(Left, MessSz, zxw:flags(wide)),
Add = fun(#w{wx = Button}) -> wxBoxSizer:add(Right, Button, zxw:flags(wide)) end,
ok = lists:foreach(Add, Buttons),
_ = wxBoxSizer:add(LeftRight, Left, zxw:flags(wide)),
_ = wxBoxSizer:add(LeftRight, Right, zxw:flags(base)),
_ = wxBoxSizer:add(MainSz, LeftRight, zxw:flags({wide, 5})),
_ = wxBoxSizer:add(MainSz, LeftRight, zxw:flags(wide)),
ok = wxWindow:setSizer(Panel, MainSz),
ok = wxFrame:setSizer(Frame, TopSz),
ok = wxBoxSizer:layout(MainSz),
ok = wxFrame:setSizer(Frame, MainSz),
ok = wxSizer:layout(MainSz),
ok = wxFrame:connect(Frame, command_button_clicked),
ok = wxFrame:connect(Frame, close_window),
ok = wxFrame:setSize(Frame, {780, 350}),
ok = wxFrame:setSize(Frame, {650, 300}),
ok = wxFrame:center(Frame),
true = wxFrame:show(Frame),
State =
@ -197,17 +187,11 @@ handle_cast({candidate, Block}, State) ->
handle_cast({message, Terms}, State) ->
NewState = do_message(Terms, State),
{noreply, NewState};
handle_cast(start_stop, State) ->
NewState = start_stop(State),
{noreply, NewState};
handle_cast(Unexpected, State) ->
ok = log(warning, "Unexpected cast: ~tp~n", [Unexpected]),
{noreply, State}.
handle_info(toggle, State) ->
NewState = toggle(State),
{noreply, NewState};
handle_info(Unexpected, State) ->
ok = log(warning, "Unexpected info: ~tp~n", [Unexpected]),
{noreply, State}.
@ -293,43 +277,17 @@ do_message({pool_notification, #{info := #{msg := MSG}}}, State = #s{height = He
ok = wxStaticText:setLabel(CandT, Candidate),
State;
#{solution_accepted := #{seq := Seq}} ->
Entry = io_lib:format("~nThe hive has produced a solution! Sequence: ~w", [Seq]),
Entry = io_lib:format("~nSolution Accepted! You solved one! Sequence: ~w", [Seq]),
do_message2(Entry, State);
Other ->
Entry = io_lib:format("~nUnexpected 'pool_notification': ~tp", [Other]),
do_message2(Entry, State)
end;
do_message({connected, _}, State) ->
Entry = "\nConnected",
do_message2(Entry, State);
do_message({disconnected, #{info := #{error := #{code := Code, message := Message}}}}, State = #s{}) ->
Format = "~nAn issue has been reported by the Hive Leader.~nError code: ~p '~s'",
Entry = io_lib:format(Format, [Code, Message]),
Entry = "\nConnected!",
do_message2(Entry, State);
do_message({disconnected, _}, State) ->
Entry = "\nDisconnected",
do_message2(Entry, State);
do_message({error, #{info := #{info := #{error := get_failed, data := {error, #{code := 404}}, url := URL}}}}, State) ->
ID =
case uri_string:parse(URL) of
#{path := Path} ->
lists:last(string:split(Path, "/", trailing));
{error, Reason, Info} ->
ok = log(warning, "uri_string:parse/1 failed with: ~p: ~p", [Reason, Info]),
"UNKNOWN"
end,
Format =
"\nLookup for mining ID ~s failed."
"\nCheck that you have joined the hive and have your account ID configured correctly.",
Entry = io_lib:format(Format, [ID]),
do_message2(Entry, State);
do_message({error, #{info := #{info := #{error := get_failed, data := {error, #{code := 443}}}}}}, State) ->
Entry =
"\nThis system is not providing the needed TLS CA Certificate."
"\nlease contact the support community and let them know you have a 443 error with GajuMine.",
do_message2(Entry, State);
do_message({error, #{info := #{info := #{error := connect_failure, data := {error, failed}}, module := gmhc_eureka}}}, State) ->
Entry = "\nConnection terminated. Retrying.",
Entry = "\nDisconnected!",
do_message2(Entry, State);
do_message(Terms, State) ->
tell(info, "~p", [Terms]),
@ -381,33 +339,11 @@ add_message2(Entry, {OMax, 0, IMax, 0, []}) ->
{append, {OMax, 1, IMax, 1, [[Entry]]}}.
start_stop(State = #s{buttons = Buttons, toggle = Last, toggle_t = T}) ->
ok = cancel_timer(T),
start_stop(State = #s{buttons = Buttons}) ->
#w{wx = SSB} = lists:keyfind(start_stop, #w.name, Buttons),
_ = wxButton:disable(SSB),
ok = gmc_con:start_stop(),
Timer = erlang:send_after(2000, self(), toggle),
Next =
case Last of
stop -> start;
start -> stop
end,
State#s{toggle = Next, toggle_t = Timer}.
cancel_timer(none) -> ok;
cancel_timer(Time) -> erlang:cancel_timer(Time).
toggle(State = #s{buttons = Buttons, toggle = Next, j = J}) ->
#w{wx = SSB} = lists:keyfind(start_stop, #w.name, Buttons),
Label =
case Next of
start -> J("Start");
stop -> J("Stop")
end,
ok = wxButton:setLabel(SSB, Label),
_ = wxButton:enable(SSB),
State#s{toggle_t = none}.
State.
gajudesk(State) ->

View File

@ -12,7 +12,7 @@
%%% @end
-module(gmc_sup).
-vsn("0.4.1").
-vsn("0.2.5").
-behaviour(supervisor).
-author("Craig Everett <craigeverett@qpq.swiss>").
-copyright("QPQ AG <craigeverett@qpq.swiss>").

View File

@ -4,19 +4,19 @@
{prefix,"gmc"}.
{author,"Craig Everett"}.
{desc,"Mining client for the Gajumaru Root"}.
{package_id,{"qpq","gajumine",{0,4,1}}}.
{deps,[{"uwiger","gmhive_client",{0,10,0}},
{"otpr","zxwidgets",{1,1,0}},
{"otpr","hakuzaru",{0,7,0}},
{"uwiger","gmhive_protocol",{0,2,0}},
{"uwiger","gmcuckoo",{1,2,4}},
{"uwiger","gmhive_worker",{0,5,1}},
{"qpq","cuckoo_cpu",{0,3,2}},
{package_id,{"qpq","gajumine",{0,2,5}}}.
{deps,[{"uwiger","gmhive_client",{0,4,4}},
{"uwiger","gmcuckoo",{1,2,3}},
{"qpq","cuckoo_cpu",{0,3,0}},
{"uwiger","gmhive_worker",{0,3,0}},
{"uwiger","gmconfig",{0,1,2}},
{"uwiger","gproc",{1,0,1}},
{"uwiger","gmhive_protocol",{0,1,1}},
{"uwiger","enoise",{1,3,0}},
{"uwiger","setup",{2,2,4}},
{"otpr","hakuzaru",{0,6,1}},
{"otpr","gajudesk",{0,5,3}},
{"otpr","zxwidgets",{1,0,1}},
{"otpr","ec_utils",{1,0,0}},
{"otpr","eblake2",{1,0,1}},
{"otpr","base58",{0,1,1}},