Branch data Line data Source code
1 : : // Copyright (c) 2010 Satoshi Nakamoto
2 : : // Copyright (c) 2009-2022 The Bitcoin Core developers
3 : : // Distributed under the MIT software license, see the accompanying
4 : : // file COPYING or http://www.opensource.org/licenses/mit-license.php.
5 : :
6 : : #include <bitcoin-build-config.h> // IWYU pragma: keep
7 : :
8 : : #include <rpc/server.h>
9 : :
10 : : #include <common/args.h>
11 : : #include <common/system.h>
12 : : #include <logging.h>
13 : : #include <node/context.h>
14 : : #include <node/kernel_notifications.h>
15 : : #include <rpc/server_util.h>
16 : : #include <rpc/util.h>
17 : : #include <sync.h>
18 : : #include <util/signalinterrupt.h>
19 : : #include <util/strencodings.h>
20 : : #include <util/string.h>
21 : : #include <util/time.h>
22 : : #include <validation.h>
23 : :
24 : : #include <cassert>
25 : : #include <chrono>
26 : : #include <memory>
27 : : #include <mutex>
28 : : #include <unordered_map>
29 : :
30 : : using util::SplitString;
31 : :
32 : : static GlobalMutex g_rpc_warmup_mutex;
33 : : static std::atomic<bool> g_rpc_running{false};
34 : : static bool fRPCInWarmup GUARDED_BY(g_rpc_warmup_mutex) = true;
35 : : static std::string rpcWarmupStatus GUARDED_BY(g_rpc_warmup_mutex) = "RPC server started";
36 : : /* Timer-creating functions */
37 : : static RPCTimerInterface* timerInterface = nullptr;
38 : : /* Map of name to timer. */
39 : : static GlobalMutex g_deadline_timers_mutex;
40 : : static std::map<std::string, std::unique_ptr<RPCTimerBase> > deadlineTimers GUARDED_BY(g_deadline_timers_mutex);
41 : : static bool ExecuteCommand(const CRPCCommand& command, const JSONRPCRequest& request, UniValue& result, bool last_handler);
42 : :
43 : 405136 : struct RPCCommandExecutionInfo
44 : : {
45 : : std::string method;
46 : : SteadyClock::time_point start;
47 : : };
48 : :
49 : : struct RPCServerInfo
50 : : {
51 : : Mutex mutex;
52 : : std::list<RPCCommandExecutionInfo> active_commands GUARDED_BY(mutex);
53 : : };
54 : :
55 : : static RPCServerInfo g_rpc_server_info;
56 : :
57 : : struct RPCCommandExecution
58 : : {
59 : : std::list<RPCCommandExecutionInfo>::iterator it;
60 : 202568 : explicit RPCCommandExecution(const std::string& method)
61 : 202568 : {
62 : 202568 : LOCK(g_rpc_server_info.mutex);
63 [ + - + - ]: 202568 : it = g_rpc_server_info.active_commands.insert(g_rpc_server_info.active_commands.end(), {method, SteadyClock::now()});
64 [ + - + - ]: 607704 : }
65 : 202568 : ~RPCCommandExecution()
66 : : {
67 : 202568 : LOCK(g_rpc_server_info.mutex);
68 [ + - ]: 202568 : g_rpc_server_info.active_commands.erase(it);
69 : 202568 : }
70 : : };
71 : :
72 : 170 : std::string CRPCTable::help(const std::string& strCommand, const JSONRPCRequest& helpreq) const
73 : : {
74 [ + - ]: 170 : std::string strRet;
75 : 170 : std::string category;
76 [ + - ]: 170 : std::set<intptr_t> setDone;
77 : 170 : std::vector<std::pair<std::string, const CRPCCommand*> > vCommands;
78 [ + - ]: 170 : vCommands.reserve(mapCommands.size());
79 : :
80 [ + + ]: 27686 : for (const auto& entry : mapCommands)
81 [ + - + - ]: 55032 : vCommands.emplace_back(entry.second.front()->category + entry.first, entry.second.front());
82 : 170 : sort(vCommands.begin(), vCommands.end());
83 : :
84 [ + - ]: 170 : JSONRPCRequest jreq = helpreq;
85 : 170 : jreq.mode = JSONRPCRequest::GET_HELP;
86 : 170 : jreq.params = UniValue();
87 : :
88 [ + + ]: 27686 : for (const std::pair<std::string, const CRPCCommand*>& command : vCommands)
89 : : {
90 : 27516 : const CRPCCommand *pcmd = command.second;
91 [ + - ]: 27516 : std::string strMethod = pcmd->name;
92 [ + + + + : 27516 : if ((strCommand != "" || pcmd->category == "hidden") && strMethod != strCommand)
+ + ]
93 : 26527 : continue;
94 [ + - ]: 989 : jreq.strMethod = strMethod;
95 : 989 : try
96 : : {
97 [ + - ]: 989 : UniValue unused_result;
98 [ + - + - ]: 989 : if (setDone.insert(pcmd->unique_id).second)
99 [ - + ]: 989 : pcmd->actor(jreq, unused_result, /*last_handler=*/true);
100 : 989 : }
101 [ - + ]: 989 : catch (const std::exception& e)
102 : : {
103 : : // Help text is returned in an exception
104 [ + - ]: 989 : std::string strHelp = std::string(e.what());
105 [ + + ]: 989 : if (strCommand == "")
106 : : {
107 [ + - ]: 828 : if (strHelp.find('\n') != std::string::npos)
108 [ + - ]: 828 : strHelp = strHelp.substr(0, strHelp.find('\n'));
109 : :
110 [ + + ]: 828 : if (category != pcmd->category)
111 : : {
112 [ + + ]: 66 : if (!category.empty())
113 [ + - ]: 58 : strRet += "\n";
114 [ + - ]: 66 : category = pcmd->category;
115 [ + - + - : 198 : strRet += "== " + Capitalize(category) + " ==\n";
+ - + - ]
116 : : }
117 : : }
118 [ + - ]: 1978 : strRet += strHelp + "\n";
119 : 989 : }
120 : 27516 : }
121 [ + + ]: 170 : if (strRet == "")
122 [ + - ]: 1 : strRet = strprintf("help: unknown command: %s\n", strCommand);
123 [ + - ]: 170 : strRet = strRet.substr(0,strRet.size()-1);
124 : 340 : return strRet;
125 : 170 : }
126 : :
127 : 2673 : static RPCHelpMan help()
128 : : {
129 : 2673 : return RPCHelpMan{
130 : : "help",
131 : : "List all commands, or get help for a specified command.\n",
132 : : {
133 [ + - ]: 5346 : {"command", RPCArg::Type::STR, RPCArg::DefaultHint{"all commands"}, "The command to get help on"},
134 : : },
135 : : {
136 [ + - + - : 5346 : RPCResult{RPCResult::Type::STR, "", "The help text"},
+ - ]
137 [ + - + - : 5346 : RPCResult{RPCResult::Type::ANY, "", ""},
+ - ]
138 : : },
139 [ + - + - ]: 8019 : RPCExamples{""},
140 : 171 : [&](const RPCHelpMan& self, const JSONRPCRequest& jsonRequest) -> UniValue
141 : : {
142 [ + + ]: 171 : std::string strCommand;
143 [ + + ]: 171 : if (jsonRequest.params.size() > 0) {
144 [ + - + - : 163 : strCommand = jsonRequest.params[0].get_str();
+ - ]
145 : : }
146 [ + + ]: 171 : if (strCommand == "dump_all_command_conversions") {
147 : : // Used for testing only, undocumented
148 [ + - ]: 1 : return tableRPC.dumpArgMap(jsonRequest);
149 : : }
150 : :
151 [ + - + - ]: 340 : return tableRPC.help(strCommand, jsonRequest);
152 : 171 : },
153 [ + - + - : 37422 : };
+ - + - +
- + - + -
+ + + + -
- - - ]
154 [ + - + - : 16038 : }
+ - + - +
- - - ]
155 : :
156 : 3416 : static RPCHelpMan stop()
157 : : {
158 [ + + + - : 3416 : static const std::string RESULT{CLIENT_NAME " stopping"};
+ - ]
159 : 3416 : return RPCHelpMan{
160 : : "stop",
161 : : // Also accept the hidden 'wait' integer argument (milliseconds)
162 : : // For instance, 'stop 1000' makes the call wait 1 second before returning
163 : : // to the client (intended for testing)
164 : : "Request a graceful shutdown of " CLIENT_NAME ".",
165 : : {
166 [ + - + - ]: 6832 : {"wait", RPCArg::Type::NUM, RPCArg::Optional::OMITTED, "how long to wait in ms", RPCArgOptions{.hidden=true}},
167 : : },
168 [ + - + - : 10248 : RPCResult{RPCResult::Type::STR, "", "A string with the content '" + RESULT + "'"},
+ - ]
169 [ + - + - ]: 10248 : RPCExamples{""},
170 : 916 : [&](const RPCHelpMan& self, const JSONRPCRequest& jsonRequest) -> UniValue
171 : : {
172 : : // Event loop will exit after current HTTP requests have been handled, so
173 : : // this reply will get back to the client.
174 : 916 : CHECK_NONFATAL((CHECK_NONFATAL(EnsureAnyNodeContext(jsonRequest.context).shutdown_request))());
175 [ + + ]: 916 : if (jsonRequest.params[0].isNum()) {
176 : 915 : UninterruptibleSleep(std::chrono::milliseconds{jsonRequest.params[0].getInt<int>()});
177 : : }
178 : 916 : return RESULT;
179 : : },
180 [ + - + - : 30744 : };
+ - + - +
- + - + +
- - ]
181 [ + - + - ]: 6832 : }
182 : :
183 : 2501 : static RPCHelpMan uptime()
184 : : {
185 : 2501 : return RPCHelpMan{
186 : : "uptime",
187 : : "Returns the total uptime of the server.\n",
188 : : {},
189 : 0 : RPCResult{
190 : : RPCResult::Type::NUM, "", "The number of seconds that the server has been running"
191 [ + - + - : 5002 : },
+ - ]
192 : 2501 : RPCExamples{
193 [ + - + - : 5002 : HelpExampleCli("uptime", "")
+ - ]
194 [ + - + - : 10004 : + HelpExampleRpc("uptime", "")
+ - + - ]
195 [ + - ]: 2501 : },
196 : 1 : [&](const RPCHelpMan& self, const JSONRPCRequest& request) -> UniValue
197 : : {
198 : 1 : return GetTime() - GetStartupTime();
199 : : }
200 [ + - + - : 15006 : };
+ - + - ]
201 : : }
202 : :
203 : 2503 : static RPCHelpMan getrpcinfo()
204 : : {
205 : 2503 : return RPCHelpMan{
206 : : "getrpcinfo",
207 : : "Returns details of the RPC server.\n",
208 : : {},
209 : 0 : RPCResult{
210 : : RPCResult::Type::OBJ, "", "",
211 : : {
212 : : {RPCResult::Type::ARR, "active_commands", "All active commands",
213 : : {
214 : : {RPCResult::Type::OBJ, "", "Information about an active command",
215 : : {
216 : : {RPCResult::Type::STR, "method", "The name of the RPC command"},
217 : : {RPCResult::Type::NUM, "duration", "The running time in microseconds"},
218 : : }},
219 : : }},
220 : : {RPCResult::Type::STR, "logpath", "The complete file path to the debug log"},
221 : : }
222 [ + - + - : 22527 : },
+ - + - +
- + - + -
+ - + - +
- + - + -
+ - + - +
- + - + -
+ - + - +
+ + + + +
- - - - -
- ]
223 : 2503 : RPCExamples{
224 [ + - + - : 5006 : HelpExampleCli("getrpcinfo", "")
+ - ]
225 [ + - + - : 12515 : + HelpExampleRpc("getrpcinfo", "")},
+ - + - +
- ]
226 : 3 : [&](const RPCHelpMan& self, const JSONRPCRequest& request) -> UniValue
227 : : {
228 : 3 : LOCK(g_rpc_server_info.mutex);
229 : 3 : UniValue active_commands(UniValue::VARR);
230 [ + + ]: 7 : for (const RPCCommandExecutionInfo& info : g_rpc_server_info.active_commands) {
231 : 4 : UniValue entry(UniValue::VOBJ);
232 [ + - + - : 8 : entry.pushKV("method", info.method);
+ - ]
233 [ + - + - : 8 : entry.pushKV("duration", int64_t{Ticks<std::chrono::microseconds>(SteadyClock::now() - info.start)});
+ - ]
234 [ + - ]: 4 : active_commands.push_back(std::move(entry));
235 : 4 : }
236 : :
237 : 3 : UniValue result(UniValue::VOBJ);
238 [ + - + - ]: 6 : result.pushKV("active_commands", std::move(active_commands));
239 : :
240 [ + - + - ]: 3 : const std::string path = LogInstance().m_file_path.utf8string();
241 [ + - ]: 6 : UniValue log_path(UniValue::VSTR, path);
242 [ + - + - ]: 6 : result.pushKV("logpath", std::move(log_path));
243 : :
244 : 6 : return result;
245 [ + - ]: 6 : }
246 [ + - + - : 15018 : };
+ - + - ]
247 [ + - + - : 15018 : }
+ - + - +
- + - - -
- - ]
248 : :
249 : : static const CRPCCommand vRPCCommands[]{
250 : : /* Overall control/query calls */
251 : : {"control", &getrpcinfo},
252 : : {"control", &help},
253 : : {"control", &stop},
254 : : {"control", &uptime},
255 : : };
256 : :
257 : 1257 : CRPCTable::CRPCTable()
258 : : {
259 [ + + ]: 6285 : for (const auto& c : vRPCCommands) {
260 [ + - ]: 5028 : appendCommand(c.name, &c);
261 : : }
262 : 1257 : }
263 : :
264 : 157397 : void CRPCTable::appendCommand(const std::string& name, const CRPCCommand* pcmd)
265 : : {
266 : 157397 : CHECK_NONFATAL(!IsRPCRunning()); // Only add commands before rpc is running
267 : :
268 : 157397 : mapCommands[name].push_back(pcmd);
269 : 157397 : }
270 : :
271 : 23316 : bool CRPCTable::removeCommand(const std::string& name, const CRPCCommand* pcmd)
272 : : {
273 : 23316 : auto it = mapCommands.find(name);
274 [ + - ]: 23316 : if (it != mapCommands.end()) {
275 : 23316 : auto new_end = std::remove(it->second.begin(), it->second.end(), pcmd);
276 [ + - ]: 23316 : if (it->second.end() != new_end) {
277 : 23316 : it->second.erase(new_end, it->second.end());
278 : 23316 : return true;
279 : : }
280 : : }
281 : : return false;
282 : : }
283 : :
284 : 1034 : void StartRPC()
285 : : {
286 [ + - ]: 1034 : LogDebug(BCLog::RPC, "Starting RPC\n");
287 : 1034 : g_rpc_running = true;
288 : 1034 : }
289 : :
290 : 1074 : void InterruptRPC()
291 : : {
292 : 1074 : static std::once_flag g_rpc_interrupt_flag;
293 : : // This function could be called twice if the GUI has been started with -server=1.
294 : 1074 : std::call_once(g_rpc_interrupt_flag, []() {
295 [ + + ]: 1074 : LogDebug(BCLog::RPC, "Interrupting RPC\n");
296 : : // Interrupt e.g. running longpolls
297 : 1074 : g_rpc_running = false;
298 : 1074 : });
299 : 1074 : }
300 : :
301 : 1074 : void StopRPC()
302 : : {
303 : 1074 : static std::once_flag g_rpc_stop_flag;
304 : : // This function could be called twice if the GUI has been started with -server=1.
305 [ - + ]: 1074 : assert(!g_rpc_running);
306 : 1074 : std::call_once(g_rpc_stop_flag, [&]() {
307 [ + + ]: 1074 : LogDebug(BCLog::RPC, "Stopping RPC\n");
308 [ + - ]: 2148 : WITH_LOCK(g_deadline_timers_mutex, deadlineTimers.clear());
309 : 1074 : DeleteAuthCookie();
310 [ + + ]: 1074 : LogDebug(BCLog::RPC, "RPC stopped.\n");
311 : 1074 : });
312 : 1074 : }
313 : :
314 : 163331 : bool IsRPCRunning()
315 : : {
316 : 163331 : return g_rpc_running;
317 : : }
318 : :
319 : 5928 : void RpcInterruptionPoint()
320 : : {
321 [ - + - - : 5928 : if (!IsRPCRunning()) throw JSONRPCError(RPC_CLIENT_NOT_CONNECTED, "Shutting down");
- - ]
322 : 5928 : }
323 : :
324 : 7043 : void SetRPCWarmupStatus(const std::string& newStatus)
325 : : {
326 : 7043 : LOCK(g_rpc_warmup_mutex);
327 [ + - + - ]: 14086 : rpcWarmupStatus = newStatus;
328 : 7043 : }
329 : :
330 : 935 : void SetRPCWarmupFinished()
331 : : {
332 : 935 : LOCK(g_rpc_warmup_mutex);
333 [ - + ]: 935 : assert(fRPCInWarmup);
334 [ + - ]: 935 : fRPCInWarmup = false;
335 : 935 : }
336 : :
337 : 772 : bool RPCIsInWarmup(std::string *outStatus)
338 : : {
339 : 772 : LOCK(g_rpc_warmup_mutex);
340 [ + + ]: 772 : if (outStatus)
341 [ + - ]: 705 : *outStatus = rpcWarmupStatus;
342 [ + - ]: 772 : return fRPCInWarmup;
343 : 772 : }
344 : :
345 : 51708 : bool IsDeprecatedRPCEnabled(const std::string& method)
346 : : {
347 [ + - ]: 51708 : const std::vector<std::string> enabled_methods = gArgs.GetArgs("-deprecatedrpc");
348 : :
349 : 51708 : return find(enabled_methods.begin(), enabled_methods.end(), method) != enabled_methods.end();
350 : 51708 : }
351 : :
352 : 203593 : UniValue JSONRPCExec(const JSONRPCRequest& jreq, bool catch_errors)
353 : : {
354 [ + + ]: 203593 : UniValue result;
355 [ + + ]: 203593 : if (catch_errors) {
356 : 203559 : try {
357 [ + + ]: 203559 : result = tableRPC.execute(jreq);
358 [ - + - ]: 6909 : } catch (UniValue& e) {
359 [ + - + - : 6909 : return JSONRPCReplyObj(NullUniValue, std::move(e), jreq.id, jreq.m_json_version);
+ - ]
360 : 6909 : } catch (const std::exception& e) {
361 [ - - - - : 0 : return JSONRPCReplyObj(NullUniValue, JSONRPCError(RPC_MISC_ERROR, e.what()), jreq.id, jreq.m_json_version);
- - - - -
- ]
362 : 0 : }
363 : : } else {
364 [ + + ]: 34 : result = tableRPC.execute(jreq);
365 : : }
366 : :
367 [ + - + - : 196682 : return JSONRPCReplyObj(std::move(result), NullUniValue, jreq.id, jreq.m_json_version);
+ - ]
368 : 203593 : }
369 : :
370 : : /**
371 : : * Process named arguments into a vector of positional arguments, based on the
372 : : * passed-in specification for the RPC call's arguments.
373 : : */
374 : 100479 : static inline JSONRPCRequest transformNamedArguments(const JSONRPCRequest& in, const std::vector<std::pair<std::string, bool>>& argNames)
375 : : {
376 : 100479 : JSONRPCRequest out = in;
377 : 100479 : out.params = UniValue(UniValue::VARR);
378 : : // Build a map of parameters, and remove ones that have been processed, so that we can throw a focused error if
379 : : // there is an unknown one.
380 [ + - ]: 100479 : const std::vector<std::string>& keys = in.params.getKeys();
381 [ + - ]: 100479 : const std::vector<UniValue>& values = in.params.getValues();
382 : 100479 : std::unordered_map<std::string, const UniValue*> argsIn;
383 [ + + ]: 170988 : for (size_t i=0; i<keys.size(); ++i) {
384 [ + - + + ]: 70511 : auto [_, inserted] = argsIn.emplace(keys[i], &values[i]);
385 [ + + ]: 70511 : if (!inserted) {
386 [ + - + - ]: 6 : throw JSONRPCError(RPC_INVALID_PARAMETER, "Parameter " + keys[i] + " specified multiple times");
387 : : }
388 : : }
389 : : // Process expected parameters. If any parameters were left unspecified in
390 : : // the request before a parameter that was specified, null values need to be
391 : : // inserted at the unspecified parameter positions, and the "hole" variable
392 : : // below tracks the number of null values that need to be inserted.
393 : : // The "initial_hole_size" variable stores the size of the initial hole,
394 : : // i.e. how many initial positional arguments were left unspecified. This is
395 : : // used after the for-loop to add initial positional arguments from the
396 : : // "args" parameter, if present.
397 : 100477 : int hole = 0;
398 : 100477 : int initial_hole_size = 0;
399 : 100477 : const std::string* initial_param = nullptr;
400 : 100477 : UniValue options{UniValue::VOBJ};
401 [ + - + + ]: 238567 : for (const auto& [argNamePattern, named_only]: argNames) {
402 [ + - ]: 138091 : std::vector<std::string> vargNames = SplitString(argNamePattern, '|');
403 : 138091 : auto fr = argsIn.end();
404 [ + + ]: 209538 : for (const std::string & argName : vargNames) {
405 : 141309 : fr = argsIn.find(argName);
406 [ + + ]: 141309 : if (fr != argsIn.end()) {
407 : : break;
408 : : }
409 : : }
410 : :
411 : : // Handle named-only parameters by pushing them into a temporary options
412 : : // object, and then pushing the accumulated options as the next
413 : : // positional argument.
414 [ + + ]: 138091 : if (named_only) {
415 [ + + ]: 9057 : if (fr != argsIn.end()) {
416 [ + - - + ]: 357 : if (options.exists(fr->first)) {
417 [ # # # # ]: 0 : throw JSONRPCError(RPC_INVALID_PARAMETER, "Parameter " + fr->first + " specified multiple times");
418 : : }
419 [ + - + - : 714 : options.pushKVEnd(fr->first, *fr->second);
+ - ]
420 : 357 : argsIn.erase(fr);
421 : : }
422 : 9057 : continue;
423 : : }
424 : :
425 [ + + + + ]: 129034 : if (!options.empty() || fr != argsIn.end()) {
426 [ + + ]: 80417 : for (int i = 0; i < hole; ++i) {
427 : : // Fill hole between specified parameters with JSON nulls,
428 : : // but not at the end (for backwards compatibility with calls
429 : : // that act based on number of specified parameters).
430 [ + - ]: 10668 : out.params.push_back(UniValue());
431 : : }
432 : 69749 : hole = 0;
433 [ + + ]: 69749 : if (!initial_param) initial_param = &argNamePattern;
434 : : } else {
435 : 59285 : hole += 1;
436 [ + + ]: 59285 : if (out.params.empty()) initial_hole_size = hole;
437 : : }
438 : :
439 : : // If named input parameter "fr" is present, push it onto out.params. If
440 : : // options are present, push them onto out.params. If both are present,
441 : : // throw an error.
442 [ + + ]: 129034 : if (fr != argsIn.end()) {
443 [ + + ]: 69505 : if (!options.empty()) {
444 [ + - + - : 3 : throw JSONRPCError(RPC_INVALID_PARAMETER, "Parameter " + fr->first + " conflicts with parameter " + options.getKeys().front());
+ - + - ]
445 : : }
446 [ + - + - ]: 69504 : out.params.push_back(*fr->second);
447 : 69504 : argsIn.erase(fr);
448 : : }
449 [ + + ]: 129033 : if (!options.empty()) {
450 [ + - ]: 244 : out.params.push_back(std::move(options));
451 : 244 : options = UniValue{UniValue::VOBJ};
452 : : }
453 : 138091 : }
454 : : // If leftover "args" param was found, use it as a source of positional
455 : : // arguments and add named arguments after. This is a convenience for
456 : : // clients that want to pass a combination of named and positional
457 : : // arguments as described in doc/JSON-RPC-interface.md#parameter-passing
458 [ + - ]: 200952 : auto positional_args{argsIn.extract("args")};
459 [ + + + - ]: 100476 : if (positional_args && positional_args.mapped()->isArray()) {
460 [ + + + + ]: 640 : if (initial_hole_size < (int)positional_args.mapped()->size() && initial_param) {
461 [ + - + - ]: 18 : throw JSONRPCError(RPC_INVALID_PARAMETER, "Parameter " + *initial_param + " specified twice both as positional and named argument");
462 : : }
463 : : // Assign positional_args to out.params and append named_args after.
464 : 634 : UniValue named_args{std::move(out.params)};
465 [ + - ]: 634 : out.params = *positional_args.mapped();
466 [ + + ]: 1317 : for (size_t i{out.params.size()}; i < named_args.size(); ++i) {
467 [ + - + - : 683 : out.params.push_back(named_args[i]);
+ - ]
468 : : }
469 : 634 : }
470 : : // If there are still arguments in the argsIn map, this is an error.
471 [ + + ]: 100470 : if (!argsIn.empty()) {
472 [ + - + - ]: 10 : throw JSONRPCError(RPC_INVALID_PARAMETER, "Unknown named parameter " + argsIn.begin()->first);
473 : : }
474 : : // Return request with named arguments transformed to positional arguments
475 [ + + ]: 100465 : return out;
476 : 100491 : }
477 : :
478 : 202568 : static bool ExecuteCommands(const std::vector<const CRPCCommand*>& commands, const JSONRPCRequest& request, UniValue& result)
479 : : {
480 [ + - ]: 202568 : for (const auto& command : commands) {
481 [ - + ]: 202568 : if (ExecuteCommand(*command, request, result, &command == &commands.back())) {
482 : : return true;
483 : : }
484 : : }
485 : : return false;
486 : : }
487 : :
488 : 203660 : UniValue CRPCTable::execute(const JSONRPCRequest &request) const
489 : : {
490 : : // Return immediately if in warmup
491 : 203660 : {
492 : 203660 : LOCK(g_rpc_warmup_mutex);
493 [ + + ]: 203660 : if (fRPCInWarmup)
494 [ + - ]: 1249 : throw JSONRPCError(RPC_IN_WARMUP, rpcWarmupStatus);
495 : 1249 : }
496 : :
497 : : // Find method
498 : 202411 : auto it = mapCommands.find(request.strMethod);
499 [ + + ]: 202411 : if (it != mapCommands.end()) {
500 [ + + ]: 202400 : UniValue result;
501 [ + + - + ]: 202400 : if (ExecuteCommands(it->second, request, result)) {
502 : 196725 : return result;
503 : : }
504 : 5675 : }
505 [ + - + - ]: 22 : throw JSONRPCError(RPC_METHOD_NOT_FOUND, "Method not found");
506 : : }
507 : :
508 : 202568 : static bool ExecuteCommand(const CRPCCommand& command, const JSONRPCRequest& request, UniValue& result, bool last_handler)
509 : : {
510 : 202568 : try {
511 [ + - ]: 202568 : RPCCommandExecution execution(request.strMethod);
512 : : // Execute, convert arguments to array if necessary
513 [ + + ]: 202568 : if (request.params.isObject()) {
514 [ + + + + ]: 100479 : return command.actor(transformNamedArguments(request, command.argNames), result, last_handler);
515 : : } else {
516 [ + + ]: 102089 : return command.actor(request, result, last_handler);
517 : : }
518 [ + + + ]: 208243 : } catch (const UniValue::type_error& e) {
519 [ + - + - ]: 40 : throw JSONRPCError(RPC_TYPE_ERROR, e.what());
520 : 72 : } catch (const std::exception& e) {
521 [ + - + - ]: 104 : throw JSONRPCError(RPC_MISC_ERROR, e.what());
522 : 52 : }
523 : : }
524 : :
525 : 0 : std::vector<std::string> CRPCTable::listCommands() const
526 : : {
527 : 0 : std::vector<std::string> commandList;
528 [ # # ]: 0 : commandList.reserve(mapCommands.size());
529 [ # # # # ]: 0 : for (const auto& i : mapCommands) commandList.emplace_back(i.first);
530 : 0 : return commandList;
531 : 0 : }
532 : :
533 : 1 : UniValue CRPCTable::dumpArgMap(const JSONRPCRequest& args_request) const
534 : : {
535 : 1 : JSONRPCRequest request = args_request;
536 : 1 : request.mode = JSONRPCRequest::GET_ARGS;
537 : :
538 : 1 : UniValue ret{UniValue::VARR};
539 [ + + ]: 169 : for (const auto& cmd : mapCommands) {
540 [ + - ]: 168 : UniValue result;
541 [ + - + - ]: 168 : if (ExecuteCommands(cmd.second, request, result)) {
542 [ + - + + ]: 597 : for (const auto& values : result.getValues()) {
543 [ + - + - ]: 429 : ret.push_back(values);
544 : : }
545 : : }
546 : 168 : }
547 : 1 : return ret;
548 : 1 : }
549 : :
550 : 0 : void RPCSetTimerInterfaceIfUnset(RPCTimerInterface *iface)
551 : : {
552 [ # # ]: 0 : if (!timerInterface)
553 : 0 : timerInterface = iface;
554 : 0 : }
555 : :
556 : 1022 : void RPCSetTimerInterface(RPCTimerInterface *iface)
557 : : {
558 : 1022 : timerInterface = iface;
559 : 1022 : }
560 : :
561 : 1022 : void RPCUnsetTimerInterface(RPCTimerInterface *iface)
562 : : {
563 [ + - ]: 1022 : if (timerInterface == iface)
564 : 1022 : timerInterface = nullptr;
565 : 1022 : }
566 : :
567 : 44 : void RPCRunLater(const std::string& name, std::function<void()> func, int64_t nSeconds)
568 : : {
569 [ - + ]: 44 : if (!timerInterface)
570 [ # # # # ]: 0 : throw JSONRPCError(RPC_INTERNAL_ERROR, "No timer handler registered for RPC");
571 : 44 : LOCK(g_deadline_timers_mutex);
572 : 44 : deadlineTimers.erase(name);
573 [ + - + - : 44 : LogDebug(BCLog::RPC, "queue run of timer %s in %i seconds (using %s)\n", name, nSeconds, timerInterface->Name());
+ - + - ]
574 [ + - + - : 44 : deadlineTimers.emplace(name, std::unique_ptr<RPCTimerBase>(timerInterface->NewTimer(func, nSeconds*1000)));
+ - ]
575 : 44 : }
576 : :
577 : : CRPCTable tableRPC;
|
