solidity/test/RPCSession.h

146 lines
4.3 KiB
C
Raw Normal View History

/*
This file is part of solidity.
solidity 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.
solidity 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 solidity. If not, see <http://www.gnu.org/licenses/>.
*/
/** @file RPCSession.h
* @author Dimtiry Khokhlov <dimitry@ethdev.com>
* @date 2016
*/
2016-08-02 08:11:04 +00:00
#if defined(_WIN32)
2016-08-02 16:32:03 +00:00
#include <windows.h>
2016-08-02 08:11:04 +00:00
#else
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/un.h>
2016-08-02 08:11:04 +00:00
#endif
2016-08-02 16:32:03 +00:00
2017-02-24 23:11:26 +00:00
#include <json/value.h>
2017-03-03 17:30:36 +00:00
#include <boost/noncopyable.hpp>
2017-02-24 23:11:26 +00:00
#include <boost/test/unit_test.hpp>
2016-08-02 16:32:03 +00:00
#include <string>
#include <stdio.h>
#include <map>
2016-08-02 08:11:04 +00:00
#if defined(_WIN32)
class IPCSocket : public boost::noncopyable
{
public:
2017-08-30 21:43:01 +00:00
explicit IPCSocket(std::string const& _path);
2016-08-02 08:11:04 +00:00
std::string sendRequest(std::string const& _req);
2016-08-02 16:32:03 +00:00
~IPCSocket() { CloseHandle(m_socket); }
2016-08-02 08:11:04 +00:00
std::string const& path() const { return m_path; }
private:
std::string m_path;
HANDLE m_socket;
TCHAR m_readBuf[512000];
2016-08-02 08:11:04 +00:00
};
#else
2016-06-09 16:54:29 +00:00
class IPCSocket: public boost::noncopyable
{
public:
2017-08-30 21:43:01 +00:00
explicit IPCSocket(std::string const& _path);
2016-06-09 16:54:29 +00:00
std::string sendRequest(std::string const& _req);
2017-02-07 13:34:00 +00:00
~IPCSocket() { close(m_socket); }
2016-06-09 16:54:29 +00:00
std::string const& path() const { return m_path; }
2016-06-09 12:57:16 +00:00
private:
2017-02-24 23:11:26 +00:00
2016-06-09 16:54:29 +00:00
std::string m_path;
int m_socket;
2017-02-24 23:11:26 +00:00
/// Socket read timeout in milliseconds. Needs to be large because the key generation routine
/// might take long.
2017-04-11 13:52:56 +00:00
unsigned static constexpr m_readTimeOutMS = 300000;
char m_readBuf[512000];
};
2016-08-02 08:11:04 +00:00
#endif
2016-06-09 16:54:29 +00:00
class RPCSession: public boost::noncopyable
{
public:
2016-06-09 16:54:29 +00:00
struct TransactionData
{
2016-06-09 16:54:29 +00:00
std::string from;
std::string to;
std::string gas;
std::string gasPrice;
std::string value;
std::string data;
std::string toJson() const;
};
2016-06-13 15:10:58 +00:00
struct LogEntry {
std::string address;
std::vector<std::string> topics;
std::string data;
};
2016-06-09 12:57:16 +00:00
struct TransactionReceipt
{
2016-06-09 16:54:29 +00:00
std::string gasUsed;
std::string contractAddress;
2016-06-13 15:10:58 +00:00
std::vector<LogEntry> logEntries;
std::string blockNumber;
/// note: pre-byzantium the status field will be empty
std::string status;
};
2016-06-09 16:54:29 +00:00
static RPCSession& instance(std::string const& _path);
std::string eth_getCode(std::string const& _address, std::string const& _blockNumber);
2017-02-09 18:41:51 +00:00
Json::Value eth_getBlockByNumber(std::string const& _blockNumber, bool _fullObjects);
2016-06-09 16:54:29 +00:00
std::string eth_call(TransactionData const& _td, std::string const& _blockNumber);
TransactionReceipt eth_getTransactionReceipt(std::string const& _transactionHash);
std::string eth_sendTransaction(TransactionData const& _td);
2016-06-09 16:54:29 +00:00
std::string eth_sendTransaction(std::string const& _transaction);
std::string eth_getBalance(std::string const& _address, std::string const& _blockNumber);
2016-06-13 22:12:13 +00:00
std::string eth_getStorageRoot(std::string const& _address, std::string const& _blockNumber);
2016-06-09 16:54:29 +00:00
std::string personal_newAccount(std::string const& _password);
void personal_unlockAccount(std::string const& _address, std::string const& _password, int _duration);
2016-06-18 00:08:20 +00:00
void test_setChainParams(std::vector<std::string> const& _accounts);
2016-06-09 16:54:29 +00:00
void test_setChainParams(std::string const& _config);
void test_rewindToBlock(size_t _blockNr);
2016-06-18 00:08:20 +00:00
void test_modifyTimestamp(size_t _timestamp);
void test_mineBlocks(int _number);
2016-06-09 16:54:29 +00:00
Json::Value rpcCall(std::string const& _methodName, std::vector<std::string> const& _args = std::vector<std::string>(), bool _canFail = false);
std::string const& account(size_t _id) const { return m_accounts.at(_id); }
2017-10-20 11:41:50 +00:00
std::string const& accountCreate();
2016-06-18 00:08:20 +00:00
std::string const& accountCreateIfNotExists(size_t _id);
private:
2017-08-21 14:42:17 +00:00
explicit RPCSession(std::string const& _path);
2016-06-09 16:54:29 +00:00
inline std::string quote(std::string const& _arg) { return "\"" + _arg + "\""; }
/// Parse std::string replacing keywords to values
void parseString(std::string& _string, std::map<std::string, std::string> const& _varMap);
IPCSocket m_ipcSocket;
size_t m_rpcSequence = 1;
2017-04-11 13:52:56 +00:00
unsigned m_maxMiningTime = 6000000; // 600 seconds
unsigned m_sleepTime = 10; // 10 milliseconds
2016-08-06 11:18:00 +00:00
unsigned m_successfulMineRuns = 0;
bool m_receiptHasStatusField = false;
2016-06-09 16:54:29 +00:00
std::vector<std::string> m_accounts;
};