/tmp/bitcoin/src/common/run_command.cpp
Line | Count | Source |
1 | | // Copyright (c) 2022-present The Bitcoin Core developers |
2 | | // Distributed under the MIT software license, see the accompanying |
3 | | // file COPYING or http://www.opensource.org/licenses/mit-license.php. |
4 | | |
5 | | #include <common/run_command.h> |
6 | | |
7 | | #include <tinyformat.h> |
8 | | #include <univalue.h> |
9 | | #include <util/string.h> |
10 | | #include <util/subprocess.h> |
11 | | |
12 | | #include <sstream> |
13 | | #include <stdexcept> |
14 | | #include <utility> |
15 | | |
16 | | UniValue RunCommandParseJSON(const std::vector<std::string>& cmd_args, const std::string& str_std_in) |
17 | 41 | { |
18 | 41 | namespace sp = subprocess; |
19 | | |
20 | 41 | UniValue result_json; |
21 | 41 | std::istringstream stdout_stream; |
22 | 41 | std::istringstream stderr_stream; |
23 | | |
24 | 41 | if (cmd_args.empty()) return UniValue::VNULL; |
25 | | |
26 | 40 | auto c = sp::Popen(cmd_args, sp::input{sp::PIPE}, sp::output{sp::PIPE}, sp::error{sp::PIPE}); |
27 | 40 | if (!str_std_in.empty()) { |
28 | 4 | c.send(str_std_in); |
29 | 4 | } |
30 | 40 | auto [out_res, err_res] = c.communicate(); |
31 | 40 | stdout_stream.str(std::string{out_res.buf.begin(), out_res.buf.end()}); |
32 | 40 | stderr_stream.str(std::string{err_res.buf.begin(), err_res.buf.end()}); |
33 | | |
34 | 40 | std::string result; |
35 | 40 | std::string error; |
36 | 40 | std::getline(stdout_stream, result); |
37 | 40 | std::getline(stderr_stream, error); |
38 | | |
39 | 40 | const int n_error = c.retcode(); |
40 | 40 | if (n_error) throw std::runtime_error(strprintf("RunCommandParseJSON error: process(%s) returned %d: %s\n", util::Join(cmd_args, " "), n_error, error)); |
41 | 36 | if (!result_json.read(result)) throw std::runtime_error("Unable to parse JSON: " + result); |
42 | | |
43 | 34 | return result_json; |
44 | 36 | } |