diff options
author | Jeff Garzik <jgarzik@exmulti.com> | 2012-05-23 16:21:25 -0400 |
---|---|---|
committer | Jeff Garzik <jgarzik@redhat.com> | 2012-05-23 16:21:25 -0400 |
commit | 976c08b68a516514b7d987ea7dd3ec59ca166ba0 (patch) | |
tree | f0ccd128d914f7dd1bb41d96e31b982785c61d7a /src | |
parent | 7a99821377eb46a1cc8b0115daf3af01ddb26a16 (diff) |
JSON-RPC: Add 'sendrawtx' op, for sending pre-built TX's to network
Diffstat (limited to 'src')
-rw-r--r-- | src/bitcoinrpc.cpp | 35 | ||||
-rw-r--r-- | src/main.cpp | 2 | ||||
-rw-r--r-- | src/main.h | 1 |
3 files changed, 37 insertions, 1 deletions
diff --git a/src/bitcoinrpc.cpp b/src/bitcoinrpc.cpp index 24fa97588c..8f4fb93a5a 100644 --- a/src/bitcoinrpc.cpp +++ b/src/bitcoinrpc.cpp @@ -2217,6 +2217,40 @@ Value getblock(const Array& params, bool fHelp) (params.size() > 1) ? params[1].get_obj() : emptyobj); } +Value sendrawtx(const Array& params, bool fHelp) +{ + if (fHelp || params.size() < 1 || params.size() > 1) + throw runtime_error( + "sendrawtx <hex string>\n" + "Submits raw transaction (serialized, hex-encoded) to local node and network."); + + // parse hex string from parameter + vector<unsigned char> txData(ParseHex(params[0].get_str())); + CDataStream ssData(txData, SER_NETWORK, PROTOCOL_VERSION); + CTransaction tx; + + // deserialize binary data stream + try { + ssData >> tx; + } + catch (std::exception &e) { + throw JSONRPCError(-22, "TX decode failed"); + } + + // push to local node + CTxDB txdb("r"); + if (!tx.AcceptToMemoryPool(txdb)) + throw JSONRPCError(-22, "TX rejected"); + + SyncWithWallets(tx, NULL, true); + + // relay to network + CInv inv(MSG_TX, tx.GetHash()); + RelayInventory(inv); + + return true; +} + @@ -2280,6 +2314,7 @@ static const CRPCCommand vRPCCommands[] = { "listsinceblock", &listsinceblock, false }, { "dumpprivkey", &dumpprivkey, false }, { "importprivkey", &importprivkey, false }, + { "sendrawtx", &sendrawtx, false }, }; CRPCTable::CRPCTable() diff --git a/src/main.cpp b/src/main.cpp index 9a4d7abc8c..557f9dd99a 100644 --- a/src/main.cpp +++ b/src/main.cpp @@ -109,7 +109,7 @@ void static EraseFromWallets(uint256 hash) } // make sure all wallets know about the given transaction, in the given block -void static SyncWithWallets(const CTransaction& tx, const CBlock* pblock = NULL, bool fUpdate = false) +void SyncWithWallets(const CTransaction& tx, const CBlock* pblock, bool fUpdate) { BOOST_FOREACH(CWallet* pwallet, setpwalletRegistered) pwallet->AddToWalletIfInvolvingMe(tx, pblock, fUpdate); diff --git a/src/main.h b/src/main.h index c0fe63a32a..29c9a8bce3 100644 --- a/src/main.h +++ b/src/main.h @@ -81,6 +81,7 @@ class CTxIndex; void RegisterWallet(CWallet* pwalletIn); void UnregisterWallet(CWallet* pwalletIn); +void SyncWithWallets(const CTransaction& tx, const CBlock* pblock = NULL, bool fUpdate = false); bool ProcessBlock(CNode* pfrom, CBlock* pblock); bool CheckDiskSpace(uint64 nAdditionalBytes=0); FILE* OpenBlockFile(unsigned int nFile, unsigned int nBlockPos, const char* pszMode="rb"); |