You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
346 lines
8.8 KiB
346 lines
8.8 KiB
/*
|
|
This file is part of cpp-ethereum.
|
|
|
|
cpp-ethereum 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.
|
|
|
|
Foobar 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 Foobar. If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
/** @file main.cpp
|
|
* @author Gav Wood <i@gavwood.com>
|
|
* @date 2014
|
|
* Ethereum client.
|
|
*/
|
|
|
|
#include <thread>
|
|
#include <chrono>
|
|
#include <fstream>
|
|
#include "Defaults.h"
|
|
#include "Client.h"
|
|
#include "PeerNetwork.h"
|
|
#include "BlockChain.h"
|
|
#include "State.h"
|
|
#include "FileSystem.h"
|
|
using namespace std;
|
|
using namespace eth;
|
|
|
|
#define ADD_QUOTES_HELPER(s) #s
|
|
#define ADD_QUOTES(s) ADD_QUOTES_HELPER(s)
|
|
|
|
bytes contents(std::string const& _file)
|
|
{
|
|
std::ifstream is(_file, std::ifstream::binary);
|
|
if (!is)
|
|
return bytes();
|
|
// get length of file:
|
|
is.seekg (0, is.end);
|
|
int length = is.tellg();
|
|
is.seekg (0, is.beg);
|
|
bytes ret(length);
|
|
is.read((char*)ret.data(), length);
|
|
is.close();
|
|
return ret;
|
|
}
|
|
|
|
void writeFile(std::string const& _file, bytes const& _data)
|
|
{
|
|
ofstream(_file, ios::trunc).write((char const*)_data.data(), _data.size());
|
|
}
|
|
|
|
bool isTrue(std::string const& _m)
|
|
{
|
|
return _m == "on" || _m == "yes" || _m == "true" || _m == "1";
|
|
}
|
|
|
|
bool isFalse(std::string const& _m)
|
|
{
|
|
return _m == "off" || _m == "no" || _m == "false" || _m == "0";
|
|
}
|
|
|
|
void help()
|
|
{
|
|
cout
|
|
<< "Usage eth [OPTIONS] <remote-host>" << endl
|
|
<< "Options:" << endl
|
|
<< " -l,--listen <port> Listen on the given port for incoming connected (default: 30303)." << endl
|
|
<< " -l,--listen <port> Listen on the given port for incoming connected (default: 30303)." << endl
|
|
<< " -l,--listen <port> Listen on the given port for incoming connected (default: 30303)." << endl
|
|
;
|
|
/*
|
|
if ((arg == "-l" || arg == "--listen" || arg == "--listen-port") && i + 1 < argc)
|
|
listenPort = atoi(argv[++i]);
|
|
else if ((arg == "-u" || arg == "--public-ip" || arg == "--public") && i + 1 < argc)
|
|
publicIP = argv[++i];
|
|
else if ((arg == "-r" || arg == "--remote") && i + 1 < argc)
|
|
remoteHost = argv[++i];
|
|
else if ((arg == "-p" || arg == "--port") && i + 1 < argc)
|
|
remotePort = atoi(argv[++i]);
|
|
else if ((arg == "-n" || arg == "--upnp") && i + 1 < argc)
|
|
{
|
|
string m = argv[++i];
|
|
if (isTrue(m))
|
|
upnp = true;
|
|
else if (isFalse(m))
|
|
upnp = false;
|
|
else
|
|
{
|
|
cerr << "Invalid UPnP option: " << m << endl;
|
|
return -1;
|
|
}
|
|
}
|
|
else if ((arg == "-c" || arg == "--client-name") && i + 1 < argc)
|
|
clientName = argv[++i];
|
|
else if ((arg == "-a" || arg == "--address" || arg == "--coinbase-address") && i + 1 < argc)
|
|
coinbase = h160(fromUserHex(argv[++i]));
|
|
else if ((arg == "-s" || arg == "--secret") && i + 1 < argc)
|
|
us = KeyPair(h256(fromUserHex(argv[++i])));
|
|
else if (arg == "-i" || arg == "--interactive")
|
|
interactive = true;
|
|
else if ((arg == "-d" || arg == "--path" || arg == "--db-path") && i + 1 < argc)
|
|
dbPath = argv[++i];
|
|
else if ((arg == "-m" || arg == "--mining") && i + 1 < argc)
|
|
{
|
|
string m = argv[++i];
|
|
if (isTrue(m))
|
|
mining = ~(eth::uint)0;
|
|
else if (isFalse(m))
|
|
mining = 0;
|
|
else if (int i = stoi(m))
|
|
mining = i;
|
|
else
|
|
{
|
|
cerr << "Unknown mining option: " << m << endl;
|
|
return -1;
|
|
}
|
|
}
|
|
else if ((arg == "-v" || arg == "--verbosity") && i + 1 < argc)
|
|
g_logVerbosity = atoi(argv[++i]);
|
|
else if ((arg == "-x" || arg == "--peers") && i + 1 < argc)
|
|
peers = atoi(argv[++i]);
|
|
else if ((arg == "-o" || arg == "--mode") && i + 1 < argc)
|
|
{
|
|
string m = argv[++i];
|
|
if (m == "full")
|
|
mode = NodeMode::Full;
|
|
else if (m == "peer")
|
|
mode = NodeMode::PeerServer;
|
|
else
|
|
{
|
|
cerr << "Unknown mode: " << m << endl;
|
|
return -1;
|
|
}
|
|
}
|
|
else if (arg == "-h" || arg == "--help")
|
|
help();
|
|
else if (arg == "-V" || arg == "--version")
|
|
version();
|
|
*/
|
|
exit(0);
|
|
}
|
|
|
|
void version()
|
|
{
|
|
cout << "eth version " << ADD_QUOTES(ETH_VERSION) << endl;
|
|
cout << "Build: " << ADD_QUOTES(ETH_BUILD_PLATFORM) << "/" << ADD_QUOTES(ETH_BUILD_TYPE) << endl;
|
|
exit(0);
|
|
}
|
|
|
|
int main(int argc, char** argv)
|
|
{
|
|
short listenPort = 30303;
|
|
string remoteHost;
|
|
short remotePort = 30303;
|
|
bool interactive = false;
|
|
string dbPath;
|
|
eth::uint mining = ~(eth::uint)0;
|
|
NodeMode mode = NodeMode::Full;
|
|
unsigned peers = 5;
|
|
string publicIP;
|
|
bool upnp = true;
|
|
string clientName;
|
|
|
|
// Init defaults
|
|
Defaults::get();
|
|
|
|
// Our address.
|
|
KeyPair us = KeyPair::create();
|
|
Address coinbase = us.address();
|
|
|
|
string configFile = getDataDir() + "/config.rlp";
|
|
bytes b = contents(configFile);
|
|
if (b.size())
|
|
{
|
|
RLP config(b);
|
|
us = KeyPair(config[0].toHash<Secret>());
|
|
coinbase = config[1].toHash<Address>();
|
|
}
|
|
else
|
|
{
|
|
RLPStream config(2);
|
|
config << us.secret() << coinbase;
|
|
writeFile(configFile, config.out());
|
|
}
|
|
|
|
for (int i = 1; i < argc; ++i)
|
|
{
|
|
string arg = argv[i];
|
|
if ((arg == "-l" || arg == "--listen" || arg == "--listen-port") && i + 1 < argc)
|
|
listenPort = atoi(argv[++i]);
|
|
else if ((arg == "-u" || arg == "--public-ip" || arg == "--public") && i + 1 < argc)
|
|
publicIP = argv[++i];
|
|
else if ((arg == "-r" || arg == "--remote") && i + 1 < argc)
|
|
remoteHost = argv[++i];
|
|
else if ((arg == "-p" || arg == "--port") && i + 1 < argc)
|
|
remotePort = atoi(argv[++i]);
|
|
else if ((arg == "-n" || arg == "--upnp") && i + 1 < argc)
|
|
{
|
|
string m = argv[++i];
|
|
if (isTrue(m))
|
|
upnp = true;
|
|
else if (isFalse(m))
|
|
upnp = false;
|
|
else
|
|
{
|
|
cerr << "Invalid UPnP option: " << m << endl;
|
|
return -1;
|
|
}
|
|
}
|
|
else if ((arg == "-c" || arg == "--client-name") && i + 1 < argc)
|
|
clientName = argv[++i];
|
|
else if ((arg == "-a" || arg == "--address" || arg == "--coinbase-address") && i + 1 < argc)
|
|
coinbase = h160(fromUserHex(argv[++i]));
|
|
else if ((arg == "-s" || arg == "--secret") && i + 1 < argc)
|
|
us = KeyPair(h256(fromUserHex(argv[++i])));
|
|
else if (arg == "-i" || arg == "--interactive")
|
|
interactive = true;
|
|
else if ((arg == "-d" || arg == "--path" || arg == "--db-path") && i + 1 < argc)
|
|
dbPath = argv[++i];
|
|
else if ((arg == "-m" || arg == "--mining") && i + 1 < argc)
|
|
{
|
|
string m = argv[++i];
|
|
if (isTrue(m))
|
|
mining = ~(eth::uint)0;
|
|
else if (isFalse(m))
|
|
mining = 0;
|
|
else if (int i = stoi(m))
|
|
mining = i;
|
|
else
|
|
{
|
|
cerr << "Unknown mining option: " << m << endl;
|
|
return -1;
|
|
}
|
|
}
|
|
else if ((arg == "-v" || arg == "--verbosity") && i + 1 < argc)
|
|
g_logVerbosity = atoi(argv[++i]);
|
|
else if ((arg == "-x" || arg == "--peers") && i + 1 < argc)
|
|
peers = atoi(argv[++i]);
|
|
else if ((arg == "-o" || arg == "--mode") && i + 1 < argc)
|
|
{
|
|
string m = argv[++i];
|
|
if (m == "full")
|
|
mode = NodeMode::Full;
|
|
else if (m == "peer")
|
|
mode = NodeMode::PeerServer;
|
|
else
|
|
{
|
|
cerr << "Unknown mode: " << m << endl;
|
|
return -1;
|
|
}
|
|
}
|
|
else if (arg == "-h" || arg == "--help")
|
|
help();
|
|
else if (arg == "-V" || arg == "--version")
|
|
version();
|
|
else
|
|
remoteHost = argv[i];
|
|
}
|
|
|
|
if (!clientName.empty())
|
|
clientName += "/";
|
|
Client c("Ethereum(++)/" + clientName + "v" ADD_QUOTES(ETH_VERSION) "/" ADD_QUOTES(ETH_BUILD_TYPE) "/" ADD_QUOTES(ETH_BUILD_PLATFORM), coinbase, dbPath);
|
|
|
|
if (interactive)
|
|
{
|
|
cout << "Ethereum (++)" << endl;
|
|
cout << " Code by Gav Wood, (c) 2013, 2014." << endl;
|
|
cout << " Based on a design by Vitalik Buterin." << endl << endl;
|
|
|
|
while (true)
|
|
{
|
|
cout << "> " << flush;
|
|
std::string cmd;
|
|
cin >> cmd;
|
|
if (cmd == "netstart")
|
|
{
|
|
eth::uint port;
|
|
cin >> port;
|
|
c.startNetwork(port);
|
|
}
|
|
else if (cmd == "connect")
|
|
{
|
|
string addr;
|
|
eth::uint port;
|
|
cin >> addr >> port;
|
|
c.connect(addr, port);
|
|
}
|
|
else if (cmd == "netstop")
|
|
{
|
|
c.stopNetwork();
|
|
}
|
|
else if (cmd == "minestart")
|
|
{
|
|
c.startMining();
|
|
}
|
|
else if (cmd == "minestop")
|
|
{
|
|
c.stopMining();
|
|
}
|
|
else if (cmd == "transact")
|
|
{
|
|
string sechex;
|
|
string rechex;
|
|
u256 amount;
|
|
cin >> sechex >> rechex >> amount;
|
|
Secret secret = h256(fromUserHex(sechex));
|
|
Address dest = h160(fromUserHex(rechex));
|
|
c.transact(secret, dest, amount);
|
|
}
|
|
else if (cmd == "send")
|
|
{
|
|
string rechex;
|
|
u256 amount;
|
|
cin >> rechex >> amount;
|
|
Address dest = h160(fromUserHex(rechex));
|
|
c.transact(us.secret(), dest, amount);
|
|
}
|
|
else if (cmd == "exit")
|
|
{
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
c.startNetwork(listenPort, remoteHost, remotePort, mode, peers, publicIP, upnp);
|
|
eth::uint n = c.blockChain().details().number;
|
|
while (true)
|
|
{
|
|
if (c.blockChain().details().number - n >= mining)
|
|
c.stopMining();
|
|
else
|
|
c.startMining();
|
|
this_thread::sleep_for(chrono::milliseconds(100));
|
|
}
|
|
}
|
|
|
|
|
|
return 0;
|
|
}
|
|
|