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