bitcoinrpc-txn 0.1.16-alpha.0

rpc tools interacting with transactions
Documentation
crate::ix!();

//-------------------------------------------[.cpp/bitcoin/src/rpc/rawtransaction_util.h]
//-------------------------------------------[.cpp/bitcoin/src/rpc/rawtransaction_util.cpp]

/**
  | Create a transaction from univalue
  | parameters
  |
  */
pub fn construct_transaction(
        inputs_in:  &UniValue,
        outputs_in: &UniValue,
        locktime:   &UniValue,
        rbf:        bool) -> MutableTransaction {
    
    todo!();
        /*
            if (outputs_in.isNull()) {
            throw JSONRPCError(RPC_INVALID_PARAMETER, "Invalid parameter, output argument must be non-null");
        }

        UniValue inputs;
        if (inputs_in.isNull()) {
            inputs = UniValue::VARR;
        } else {
            inputs = inputs_in.get_array();
        }

        const bool outputs_is_obj = outputs_in.isObject();
        UniValue outputs = outputs_is_obj ? outputs_in.get_obj() : outputs_in.get_array();

        CMutableTransaction rawTx;

        if (!locktime.isNull()) {
            int64_t nLockTime = locktime.get_int64();
            if (nLockTime < 0 || nLockTime > LOCKTIME_MAX)
                throw JSONRPCError(RPC_INVALID_PARAMETER, "Invalid parameter, locktime out of range");
            rawTx.nLockTime = nLockTime;
        }

        for (unsigned int idx = 0; idx < inputs.size(); idx++) {
            const UniValue& input = inputs[idx];
            const UniValue& o = input.get_obj();

            uint256 txid = ParseHashO(o, "txid");

            const UniValue& vout_v = find_value(o, "vout");
            if (!vout_v.isNum())
                throw JSONRPCError(RPC_INVALID_PARAMETER, "Invalid parameter, missing vout key");
            int nOutput = vout_v.get_int();
            if (nOutput < 0)
                throw JSONRPCError(RPC_INVALID_PARAMETER, "Invalid parameter, vout cannot be negative");

            uint32_t nSequence;
            if (rbf) {
                nSequence = MAX_BIP125_RBF_SEQUENCE; /* CTxIn::SEQUENCE_FINAL - 2 */
            } else if (rawTx.nLockTime) {
                nSequence = CTxIn::SEQUENCE_FINAL - 1;
            } else {
                nSequence = CTxIn::SEQUENCE_FINAL;
            }

            // set the sequence number if passed in the parameters object
            const UniValue& sequenceObj = find_value(o, "sequence");
            if (sequenceObj.isNum()) {
                int64_t seqNr64 = sequenceObj.get_int64();
                if (seqNr64 < 0 || seqNr64 > CTxIn::SEQUENCE_FINAL) {
                    throw JSONRPCError(RPC_INVALID_PARAMETER, "Invalid parameter, sequence number is out of range");
                } else {
                    nSequence = (uint32_t)seqNr64;
                }
            }

            CTxIn in(OutPoint(txid, nOutput), CScript(), nSequence);

            rawTx.vin.push_back(in);
        }

        if (!outputs_is_obj) {
            // Translate array of key-value pairs into dict
            UniValue outputs_dict = UniValue(UniValue::VOBJ);
            for (size_t i = 0; i < outputs.size(); ++i) {
                const UniValue& output = outputs[i];
                if (!output.isObject()) {
                    throw JSONRPCError(RPC_INVALID_PARAMETER, "Invalid parameter, key-value pair not an object as expected");
                }
                if (output.size() != 1) {
                    throw JSONRPCError(RPC_INVALID_PARAMETER, "Invalid parameter, key-value pair must contain exactly one key");
                }
                outputs_dict.pushKVs(output);
            }
            outputs = std::move(outputs_dict);
        }

        // Duplicate checking
        std::set<TxDestination> destinations;
        bool has_data{false};

        for (const std::string& name_ : outputs.getKeys()) {
            if (name_ == "data") {
                if (has_data) {
                    throw JSONRPCError(RPC_INVALID_PARAMETER, "Invalid parameter, duplicate key: data");
                }
                has_data = true;
                std::vector<unsigned char> data = ParseHexV(outputs[name_].getValStr(), "Data");

                CTxOut out(0, CScript() << OP_RETURN << data);
                rawTx.vout.push_back(out);
            } else {
                TxDestination destination = DecodeDestination(name_);
                if (!IsValidDestination(destination)) {
                    throw JSONRPCError(RPC_INVALID_ADDRESS_OR_KEY, std::string("Invalid Bitcoin address: ") + name_);
                }

                if (!destinations.insert(destination).second) {
                    throw JSONRPCError(RPC_INVALID_PARAMETER, std::string("Invalid parameter, duplicated address: ") + name_);
                }

                CScript scriptPubKey = GetScriptForDestination(destination);
                CAmount nAmount = AmountFromValue(outputs[name_]);

                CTxOut out(nAmount, scriptPubKey);
                rawTx.vout.push_back(out);
            }
        }

        if (rbf && rawTx.vin.size() > 0 && !SignalsOptInRBF(CTransaction(rawTx))) {
            throw JSONRPCError(RPC_INVALID_PARAMETER, "Invalid parameter combination: Sequence number(s) contradict replaceable option");
        }

        return rawTx;
        */
}

/**
  | Pushes a JSON object for script verification
  | or signing errors to vErrorsRet.
  |
  */
pub fn tx_in_error_tojson(
        txin:        &TxIn,
        errors_ret:  &mut UniValue,
        str_message: &String)  {
    
    todo!();
        /*
            UniValue entry(UniValue::VOBJ);
        entry.pushKV("txid", txin.prevout.hash.ToString());
        entry.pushKV("vout", (uint64_t)txin.prevout.n);
        UniValue witness(UniValue::VARR);
        for (unsigned int i = 0; i < txin.scriptWitness.stack.size(); i++) {
            witness.push_back(HexStr(txin.scriptWitness.stack[i]));
        }
        entry.pushKV("witness", witness);
        entry.pushKV("scriptSig", HexStr(txin.scriptSig));
        entry.pushKV("sequence", (uint64_t)txin.nSequence);
        entry.pushKV("error", strMessage);
        vErrorsRet.push_back(entry);
        */
}

/**
  | Parse a prevtxs UniValue array and get
  | the map of coins from it
  | 
  | -----------
  | @param prevTxsUnival
  | 
  | Array of previous txns outputs that
  | tx depends on but may not yet be in the
  | block chain
  | ----------
  | @param keystore
  | 
  | A pointer to the temporary keystore
  | if there is one
  | ----------
  | @param coins
  | 
  | Map of unspent outputs - coins in mempool
  | and current chain UTXO set, may be extended
  | by previous txns outputs after call
  |
  */
pub fn parse_prevouts<T>(
        prev_txs_unival: &UniValue,
        keystore:        *mut FillableSigningProvider<T>,
        coins:           &mut HashMap<OutPoint,Coin>)  {
    
    todo!();
        /*
            if (!prevTxsUnival.isNull()) {
            UniValue prevTxs = prevTxsUnival.get_array();
            for (unsigned int idx = 0; idx < prevTxs.size(); ++idx) {
                const UniValue& p = prevTxs[idx];
                if (!p.isObject()) {
                    throw JSONRPCError(RPC_DESERIALIZATION_ERROR, "expected object with {\"txid'\",\"vout\",\"scriptPubKey\"}");
                }

                UniValue prevOut = p.get_obj();

                RPCTypeCheckObj(prevOut,
                    {
                        {"txid", UniValueType(UniValue::VSTR)},
                        {"vout", UniValueType(UniValue::VNUM)},
                        {"scriptPubKey", UniValueType(UniValue::VSTR)},
                    });

                uint256 txid = ParseHashO(prevOut, "txid");

                int nOut = find_value(prevOut, "vout").get_int();
                if (nOut < 0) {
                    throw JSONRPCError(RPC_DESERIALIZATION_ERROR, "vout cannot be negative");
                }

                OutPoint out(txid, nOut);
                std::vector<unsigned char> pkData(ParseHexO(prevOut, "scriptPubKey"));
                CScript scriptPubKey(pkData.begin(), pkData.end());

                {
                    auto coin = coins.find(out);
                    if (coin != coins.end() && !coin->second.IsSpent() && coin->second.out.scriptPubKey != scriptPubKey) {
                        std::string err("Previous output scriptPubKey mismatch:\n");
                        err = err + ScriptToAsmStr(coin->second.out.scriptPubKey) + "\nvs:\n"+
                            ScriptToAsmStr(scriptPubKey);
                        throw JSONRPCError(RPC_DESERIALIZATION_ERROR, err);
                    }
                    Coin newcoin;
                    newcoin.out.scriptPubKey = scriptPubKey;
                    newcoin.out.nValue = MAX_MONEY;
                    if (prevOut.exists("amount")) {
                        newcoin.out.nValue = AmountFromValue(find_value(prevOut, "amount"));
                    }
                    newcoin.nHeight = 1;
                    coins[out] = std::move(newcoin);
                }

                // if redeemScript and private keys were given, add redeemScript to the keystore so it can be signed
                const bool is_p2sh = scriptPubKey.IsPayToScriptHash();
                const bool is_p2wsh = scriptPubKey.IsPayToWitnessScriptHash();
                if (keystore && (is_p2sh || is_p2wsh)) {
                    RPCTypeCheckObj(prevOut,
                        {
                            {"redeemScript", UniValueType(UniValue::VSTR)},
                            {"witnessScript", UniValueType(UniValue::VSTR)},
                        }, true);
                    UniValue rs = find_value(prevOut, "redeemScript");
                    UniValue ws = find_value(prevOut, "witnessScript");
                    if (rs.isNull() && ws.isNull()) {
                        throw JSONRPCError(RPC_INVALID_PARAMETER, "Missing redeemScript/witnessScript");
                    }

                    // work from witnessScript when possible
                    std::vector<unsigned char> scriptData(!ws.isNull() ? ParseHexV(ws, "witnessScript") : ParseHexV(rs, "redeemScript"));
                    CScript script(scriptData.begin(), scriptData.end());
                    keystore->AddCScript(script);
                    // Automatically also add the P2WSH wrapped version of the script (to deal with P2SH-P2WSH).
                    // This is done for redeemScript only for compatibility, it is encouraged to use the explicit witnessScript field instead.
                    CScript witness_output_script{GetScriptForDestination(WitnessV0ScriptHash(script))};
                    keystore->AddCScript(witness_output_script);

                    if (!ws.isNull() && !rs.isNull()) {
                        // if both witnessScript and redeemScript are provided,
                        // they should either be the same (for backwards compat),
                        // or the redeemScript should be the encoded form of
                        // the witnessScript (ie, for p2sh-p2wsh)
                        if (ws.get_str() != rs.get_str()) {
                            std::vector<unsigned char> redeemScriptData(ParseHexV(rs, "redeemScript"));
                            CScript redeemScript(redeemScriptData.begin(), redeemScriptData.end());
                            if (redeemScript != witness_output_script) {
                                throw JSONRPCError(RPC_INVALID_PARAMETER, "redeemScript does not correspond to witnessScript");
                            }
                        }
                    }

                    if (is_p2sh) {
                        const TxDestination p2sh{ScriptHash(script)};
                        const TxDestination p2sh_p2wsh{ScriptHash(witness_output_script)};
                        if (scriptPubKey == GetScriptForDestination(p2sh)) {
                            // traditional p2sh; arguably an error if
                            // we got here with rs.IsNull(), because
                            // that means the p2sh script was specified
                            // via witnessScript param, but for now
                            // we'll just quietly accept it
                        } else if (scriptPubKey == GetScriptForDestination(p2sh_p2wsh)) {
                            // p2wsh encoded as p2sh; ideally the witness
                            // script was specified in the witnessScript
                            // param, but also support specifying it via
                            // redeemScript param for backwards compat
                            // (in which case ws.IsNull() == true)
                        } else {
                            // otherwise, can't generate scriptPubKey from
                            // either script, so we got unusable parameters
                            throw JSONRPCError(RPC_INVALID_PARAMETER, "redeemScript/witnessScript does not match scriptPubKey");
                        }
                    } else if (is_p2wsh) {
                        // plain p2wsh; could throw an error if script
                        // was specified by redeemScript rather than
                        // witnessScript (ie, ws.IsNull() == true), but
                        // accept it for backwards compat
                        const TxDestination p2wsh{WitnessV0ScriptHash(script)};
                        if (scriptPubKey != GetScriptForDestination(p2wsh)) {
                            throw JSONRPCError(RPC_INVALID_PARAMETER, "redeemScript/witnessScript does not match scriptPubKey");
                        }
                    }
                }
            }
        }
        */
}

/**
  | Sign a transaction with the given keystore
  | and previous transactions
  | 
  | -----------
  | @param mtx
  | 
  | The transaction to-be-signed
  | ----------
  | @param keystore
  | 
  | Temporary keystore containing signing
  | keys
  | ----------
  | @param coins
  | 
  | Map of unspent outputs
  | ----------
  | @param hashType
  | 
  | The signature hash type
  | ----------
  | @param result
  | 
  | JSON object where signed transaction
  | results accumulate
  |
  */
pub fn sign_transaction(
        mtx:       &mut MutableTransaction,
        keystore:  *const SigningProvider,
        coins:     &HashMap<OutPoint,Coin>,
        hash_type: &UniValue,
        result:    &mut UniValue)  {
    
    todo!();
        /*
            int nHashType = ParseSighashString(hashType);

        // Script verification errors
        std::map<int, bilingual_str> input_errors;

        bool complete = SignTransaction(mtx, keystore, coins, nHashType, input_errors);
        SignTransactionResultToJSON(mtx, complete, coins, input_errors, result);
        */
}

pub fn sign_transaction_result_tojson(
        mtx:          &mut MutableTransaction,
        complete:     bool,
        coins:        &HashMap<OutPoint,Coin>,
        input_errors: &HashMap<i32,BilingualStr>,
        result:       &mut UniValue)  {
    
    todo!();
        /*
            // Make errors UniValue
        UniValue vErrors(UniValue::VARR);
        for (const auto& err_pair : input_errors) {
            if (err_pair.second.original == "Missing amount") {
                // This particular error needs to be an exception for some reason
                throw JSONRPCError(RPC_TYPE_ERROR, strprintf("Missing amount for %s", coins.at(mtx.vin.at(err_pair.first).prevout).out.ToString()));
            }
            TxInErrorToJSON(mtx.vin.at(err_pair.first), vErrors, err_pair.second.original);
        }

        result.pushKV("hex", EncodeHexTx(CTransaction(mtx)));
        result.pushKV("complete", complete);
        if (!vErrors.empty()) {
            if (result.exists("errors")) {
                vErrors.push_backV(result["errors"].getValues());
            }
            result.pushKV("errors", vErrors);
        }
        */
}