1 // Copyright (c) 2009-2012 Bitcoin Developers
2 // Distributed under the MIT/X11 software license, see the accompanying
3 // file COPYING or http://www.opensource.org/licenses/mit-license.php.
6 #include "bitcoinrpc.h"
12 using namespace json_spirit;
15 Value getconnectioncount(const Array& params, bool fHelp)
17 if (fHelp || params.size() != 0)
19 "getconnectioncount\n"
20 "Returns the number of connections to other nodes.");
23 return (int)vNodes.size();
26 static void CopyNodeStats(std::vector<CNodeStats>& vstats)
31 vstats.reserve(vNodes.size());
32 BOOST_FOREACH(CNode* pnode, vNodes) {
34 pnode->copyStats(stats);
35 vstats.push_back(stats);
39 Value getpeerinfo(const Array& params, bool fHelp)
41 if (fHelp || params.size() != 0)
44 "Returns data about each connected network node.");
46 vector<CNodeStats> vstats;
47 CopyNodeStats(vstats);
51 BOOST_FOREACH(const CNodeStats& stats, vstats) {
54 obj.push_back(Pair("addr", stats.addrName));
55 obj.push_back(Pair("services", strprintf("%08"PRI64x, stats.nServices)));
56 obj.push_back(Pair("lastsend", (boost::int64_t)stats.nLastSend));
57 obj.push_back(Pair("lastrecv", (boost::int64_t)stats.nLastRecv));
58 obj.push_back(Pair("bytessent", (boost::int64_t)stats.nSendBytes));
59 obj.push_back(Pair("bytesrecv", (boost::int64_t)stats.nRecvBytes));
60 obj.push_back(Pair("conntime", (boost::int64_t)stats.nTimeConnected));
61 obj.push_back(Pair("version", stats.nVersion));
62 obj.push_back(Pair("subver", stats.strSubVer));
63 obj.push_back(Pair("inbound", stats.fInbound));
64 obj.push_back(Pair("releasetime", (boost::int64_t)stats.nReleaseTime));
65 obj.push_back(Pair("startingheight", stats.nStartingHeight));
66 obj.push_back(Pair("banscore", stats.nMisbehavior));
68 obj.push_back(Pair("syncnode", true));
75 extern CCriticalSection cs_mapAlerts;
76 extern map<uint256, CAlert> mapAlerts;
78 // ppcoin: send alert.
79 // There is a known deadlock situation with ThreadMessageHandler
80 // ThreadMessageHandler: holds cs_vSend and acquiring cs_main in SendMessages()
81 // ThreadRPCServer: holds cs_main and acquiring cs_vSend in alert.RelayTo()/PushMessage()/BeginMessage()
82 Value sendalert(const Array& params, bool fHelp)
84 if (fHelp || params.size() < 6)
86 "sendalert <message> <privatekey> <minver> <maxver> <priority> <id> [cancelupto]\n"
87 "<message> is the alert text message\n"
88 "<privatekey> is hex string of alert master private key\n"
89 "<minver> is the minimum applicable internal client version\n"
90 "<maxver> is the maximum applicable internal client version\n"
91 "<priority> is integer priority number\n"
92 "<id> is the alert id\n"
93 "[cancelupto] cancels all alert id's up to this number\n"
94 "Returns true or false.");
99 alert.strStatusBar = params[0].get_str();
100 alert.nMinVer = params[2].get_int();
101 alert.nMaxVer = params[3].get_int();
102 alert.nPriority = params[4].get_int();
103 alert.nID = params[5].get_int();
104 if (params.size() > 6)
105 alert.nCancel = params[6].get_int();
106 alert.nVersion = PROTOCOL_VERSION;
107 alert.nRelayUntil = GetAdjustedTime() + 365*24*60*60;
108 alert.nExpiration = GetAdjustedTime() + 365*24*60*60;
110 CDataStream sMsg(SER_NETWORK, PROTOCOL_VERSION);
111 sMsg << (CUnsignedAlert)alert;
112 alert.vchMsg = vector<unsigned char>(sMsg.begin(), sMsg.end());
114 vector<unsigned char> vchPrivKey = ParseHex(params[1].get_str());
115 key.SetPrivKey(CPrivKey(vchPrivKey.begin(), vchPrivKey.end())); // if key is not correct openssl may crash
116 if (!key.Sign(Hash(alert.vchMsg.begin(), alert.vchMsg.end()), alert.vchSig))
118 "Unable to sign alert, check private key?\n");
119 if(!alert.ProcessAlert())
121 "Failed to process alert.\n");
125 BOOST_FOREACH(CNode* pnode, vNodes)
126 alert.RelayTo(pnode);
130 result.push_back(Pair("strStatusBar", alert.strStatusBar));
131 result.push_back(Pair("nVersion", alert.nVersion));
132 result.push_back(Pair("nMinVer", alert.nMinVer));
133 result.push_back(Pair("nMaxVer", alert.nMaxVer));
134 result.push_back(Pair("nPriority", alert.nPriority));
135 result.push_back(Pair("nID", alert.nID));
136 if (alert.nCancel > 0)
137 result.push_back(Pair("nCancel", alert.nCancel));