/* XMRig * Copyright (c) 2018-2021 SChernykh * Copyright (c) 2016-2021 XMRig , * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ #ifndef XMRIG_ETHSTRATUMCLIENT_H #define XMRIG_ETHSTRATUMCLIENT_H #include "base/net/stratum/Client.h" #include namespace xmrig { class EthStratumClient : public Client { public: XMRIG_DISABLE_COPY_MOVE_DEFAULT(EthStratumClient) EthStratumClient(int id, const char *agent, IClientListener *listener); ~EthStratumClient() override = default; protected: int64_t submit(const JobResult &result) override; void login() override; void onClose() override; bool handleResponse(int64_t id, const rapidjson::Value &result, const rapidjson::Value &error) override; void parseNotification(const char *method, const rapidjson::Value ¶ms, const rapidjson::Value &error) override; void setExtraNonce(const rapidjson::Value &nonce); private: const char *errorMessage(const rapidjson::Value &error) const; void authorize(); void onAuthorizeResponse(const rapidjson::Value &result, bool success, uint64_t elapsed); void onSubscribeResponse(const rapidjson::Value &result, bool success, uint64_t elapsed); void subscribe(); bool m_authorized = false; std::pair m_extraNonce{}; }; } /* namespace xmrig */ #endif /* XMRIG_ETHSTRATUMCLIENT_H */