93 lines
2.6 KiB
C++
93 lines
2.6 KiB
C++
/* XMRig
|
|
* Copyright 2018-2020 SChernykh <https://github.com/SChernykh>
|
|
* Copyright 2016-2020 XMRig <https://github.com/xmrig>, <support@xmrig.com>
|
|
*
|
|
* 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 <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
|
|
#include "base/net/stratum/AutoClient.h"
|
|
#include "3rdparty/rapidjson/document.h"
|
|
#include "base/io/json/Json.h"
|
|
#include "net/JobResult.h"
|
|
|
|
|
|
xmrig::AutoClient::AutoClient(int id, const char *agent, IClientListener *listener) :
|
|
EthStratumClient(id, agent, listener)
|
|
{
|
|
}
|
|
|
|
|
|
bool xmrig::AutoClient::handleResponse(int64_t id, const rapidjson::Value &result, const rapidjson::Value &error)
|
|
{
|
|
if (m_mode == DEFAULT_MODE) {
|
|
return Client::handleResponse(id, result, error);
|
|
}
|
|
|
|
return EthStratumClient::handleResponse(id, result, error);
|
|
}
|
|
|
|
|
|
bool xmrig::AutoClient::parseLogin(const rapidjson::Value &result, int *code)
|
|
{
|
|
if (result.HasMember("job")) {
|
|
return Client::parseLogin(result, code);
|
|
}
|
|
|
|
setRpcId(Json::getString(result, "id"));
|
|
if (rpcId().isNull()) {
|
|
*code = 1;
|
|
return false;
|
|
}
|
|
|
|
const Algorithm algo(Json::getString(result, "algo"));
|
|
if (algo.family() != Algorithm::KAWPOW) {
|
|
*code = 6;
|
|
return false;
|
|
}
|
|
|
|
try {
|
|
setExtraNonce(Json::getValue(result, "extra_nonce"));
|
|
} catch (const std::exception &ex) {
|
|
*code = 6;
|
|
return false;
|
|
}
|
|
|
|
m_mode = ETH_MODE;
|
|
setAlgo(algo);
|
|
|
|
return true;
|
|
}
|
|
|
|
|
|
int64_t xmrig::AutoClient::submit(const JobResult &result)
|
|
{
|
|
if (result.algorithm.family() != Algorithm::KAWPOW) {
|
|
return Client::submit(result);
|
|
}
|
|
|
|
return EthStratumClient::submit(result);
|
|
}
|
|
|
|
|
|
void xmrig::AutoClient::parseNotification(const char *method, const rapidjson::Value ¶ms, const rapidjson::Value &error)
|
|
{
|
|
if (strcmp(method, "job") == 0) {
|
|
m_mode = DEFAULT_MODE;
|
|
return Client::parseNotification(method, params, error);
|
|
}
|
|
|
|
m_mode = ETH_MODE;
|
|
return EthStratumClient::parseNotification(method, params, error);
|
|
}
|