New API settings.
This commit is contained in:
parent
1e0c410eea
commit
725796a1ab
14 changed files with 474 additions and 236 deletions
|
@ -21,6 +21,7 @@ set(HEADERS_BASE
|
|||
src/base/kernel/Signals.h
|
||||
src/base/net/dns/Dns.h
|
||||
src/base/net/dns/DnsRecord.h
|
||||
src/base/net/http/Http.h
|
||||
src/base/net/stratum/Client.h
|
||||
src/base/net/stratum/Job.h
|
||||
src/base/net/stratum/Pool.h
|
||||
|
@ -50,6 +51,7 @@ set(SOURCES_BASE
|
|||
src/base/kernel/Signals.cpp
|
||||
src/base/net/dns/Dns.cpp
|
||||
src/base/net/dns/DnsRecord.cpp
|
||||
src/base/net/http/Http.cpp
|
||||
src/base/net/stratum/Client.cpp
|
||||
src/base/net/stratum/Job.cpp
|
||||
src/base/net/stratum/Pool.cpp
|
||||
|
@ -77,3 +79,24 @@ if (NOT WIN32)
|
|||
set(SOURCES_SYSLOG src/base/io/log/backends/SysLog.h src/base/io/log/backends/SysLog.cpp)
|
||||
endif()
|
||||
endif()
|
||||
|
||||
|
||||
if (WITH_HTTPD)
|
||||
set(HEADERS_BASE_HTTP
|
||||
# src/base/net/http/Http.h
|
||||
)
|
||||
|
||||
set(SOURCES_BASE_HTTP
|
||||
# src/base/net/http/Http.cpp
|
||||
)
|
||||
|
||||
add_definitions(/DXMRIG_FEATURE_HTTP)
|
||||
add_definitions(/DXMRIG_FEATURE_API)
|
||||
else()
|
||||
set(HEADERS_BASE_HTTP "")
|
||||
set(SOURCES_BASE_HTTP "")
|
||||
remove_definitions(/DXMRIG_FEATURE_HTTP)
|
||||
remove_definitions(/DXMRIG_FEATURE_API)
|
||||
endif()
|
||||
|
||||
add_definitions(/DXMRIG_DEPRECATED)
|
||||
|
|
112
src/base/net/http/Http.cpp
Normal file
112
src/base/net/http/Http.cpp
Normal file
|
@ -0,0 +1,112 @@
|
|||
/* XMRig
|
||||
* Copyright 2010 Jeff Garzik <jgarzik@pobox.com>
|
||||
* Copyright 2012-2014 pooler <pooler@litecoinpool.org>
|
||||
* Copyright 2014 Lucas Jones <https://github.com/lucasjones>
|
||||
* Copyright 2014-2016 Wolf9466 <https://github.com/OhGodAPet>
|
||||
* Copyright 2016 Jay D Dee <jayddee246@gmail.com>
|
||||
* Copyright 2017-2018 XMR-Stak <https://github.com/fireice-uk>, <https://github.com/psychocrypt>
|
||||
* Copyright 2018-2019 SChernykh <https://github.com/SChernykh>
|
||||
* Copyright 2016-2019 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 "3rdparty/rapidjson/document.h"
|
||||
#include "base/io/Json.h"
|
||||
#include "base/io/log/Log.h"
|
||||
#include "base/net/http/Http.h"
|
||||
|
||||
|
||||
namespace xmrig {
|
||||
|
||||
static const char *kEnabled = "enabled";
|
||||
static const char *kHost = "host";
|
||||
static const char *kLocalhost = "127.0.0.1";
|
||||
static const char *kPort = "port";
|
||||
static const char *kRestricted = "restricted";
|
||||
static const char *kToken = "access-token";
|
||||
|
||||
}
|
||||
|
||||
|
||||
xmrig::Http::Http() :
|
||||
m_enabled(false),
|
||||
m_restricted(true),
|
||||
m_host(kLocalhost),
|
||||
m_port(0)
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
bool xmrig::Http::isEqual(const Http &other) const
|
||||
{
|
||||
return other.m_enabled == m_enabled &&
|
||||
other.m_restricted == m_restricted &&
|
||||
other.m_host == m_host &&
|
||||
other.m_token == m_token &&
|
||||
other.m_port == m_port;
|
||||
}
|
||||
|
||||
|
||||
rapidjson::Value xmrig::Http::toJSON(rapidjson::Document &doc) const
|
||||
{
|
||||
using namespace rapidjson;
|
||||
auto &allocator = doc.GetAllocator();
|
||||
|
||||
Value obj(kObjectType);
|
||||
|
||||
obj.AddMember(StringRef(kEnabled), m_enabled, allocator);
|
||||
obj.AddMember(StringRef(kHost), m_host.toJSON(), allocator);
|
||||
obj.AddMember(StringRef(kPort), m_port, allocator);
|
||||
obj.AddMember(StringRef(kToken), m_token.toJSON(), allocator);
|
||||
obj.AddMember(StringRef(kRestricted), m_restricted, allocator);
|
||||
|
||||
return obj;
|
||||
}
|
||||
|
||||
|
||||
void xmrig::Http::load(const rapidjson::Value &http)
|
||||
{
|
||||
if (!http.IsObject()) {
|
||||
return;
|
||||
}
|
||||
|
||||
m_enabled = Json::getBool(http, kEnabled);
|
||||
m_restricted = Json::getBool(http, kRestricted, true);
|
||||
m_host = Json::getString(http, kHost, kLocalhost);
|
||||
m_token = Json::getString(http, kToken);
|
||||
|
||||
setPort(Json::getInt(http, kPort));
|
||||
}
|
||||
|
||||
|
||||
void xmrig::Http::print() const
|
||||
{
|
||||
# ifdef XMRIG_FEATURE_API
|
||||
if (!isEnabled()) {
|
||||
return;
|
||||
}
|
||||
|
||||
Log::print(GREEN_BOLD(" * ") WHITE_BOLD("%-13s") BLUE_BOLD("http://%s:%d"), "HTTP API", host().data(), port());
|
||||
# endif
|
||||
}
|
||||
|
||||
|
||||
void xmrig::Http::setPort(int port)
|
||||
{
|
||||
if (port >= 0 && port <= 65536) {
|
||||
m_port = static_cast<uint16_t>(port);
|
||||
}
|
||||
}
|
73
src/base/net/http/Http.h
Normal file
73
src/base/net/http/Http.h
Normal file
|
@ -0,0 +1,73 @@
|
|||
/* XMRig
|
||||
* Copyright 2010 Jeff Garzik <jgarzik@pobox.com>
|
||||
* Copyright 2012-2014 pooler <pooler@litecoinpool.org>
|
||||
* Copyright 2014 Lucas Jones <https://github.com/lucasjones>
|
||||
* Copyright 2014-2016 Wolf9466 <https://github.com/OhGodAPet>
|
||||
* Copyright 2016 Jay D Dee <jayddee246@gmail.com>
|
||||
* Copyright 2017-2018 XMR-Stak <https://github.com/fireice-uk>, <https://github.com/psychocrypt>
|
||||
* Copyright 2018-2019 SChernykh <https://github.com/SChernykh>
|
||||
* Copyright 2016-2019 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/>.
|
||||
*/
|
||||
|
||||
|
||||
#ifndef XMRIG_HTTP_H
|
||||
#define XMRIG_HTTP_H
|
||||
|
||||
|
||||
#include "base/tools/String.h"
|
||||
|
||||
|
||||
namespace xmrig {
|
||||
|
||||
|
||||
class Http
|
||||
{
|
||||
public:
|
||||
Http();
|
||||
|
||||
inline bool isEnabled() const { return m_enabled; }
|
||||
inline bool isRestricted() const { return m_restricted; }
|
||||
inline const String &host() const { return m_host; }
|
||||
inline const String &token() const { return m_token; }
|
||||
inline uint16_t port() const { return m_port; }
|
||||
inline void setEnabled(bool enabled) { m_enabled = enabled; }
|
||||
inline void setHost(const char *host) { m_host = host; }
|
||||
inline void setRestricted(bool restricted) { m_restricted = restricted; }
|
||||
inline void setToken(const char *token) { m_token = token; }
|
||||
|
||||
inline bool operator!=(const Http &other) const { return !isEqual(other); }
|
||||
inline bool operator==(const Http &other) const { return isEqual(other); }
|
||||
|
||||
bool isEqual(const Http &other) const;
|
||||
rapidjson::Value toJSON(rapidjson::Document &doc) const;
|
||||
void load(const rapidjson::Value &http);
|
||||
void print() const;
|
||||
void setPort(int port);
|
||||
|
||||
private:
|
||||
bool m_enabled;
|
||||
bool m_restricted;
|
||||
String m_host;
|
||||
String m_token;
|
||||
uint16_t m_port;
|
||||
};
|
||||
|
||||
|
||||
} // namespace xmrig
|
||||
|
||||
|
||||
#endif // XMRIG_HTTP_H
|
||||
|
Loading…
Add table
Add a link
Reference in a new issue