Compare commits
1 Commits
release/0.
...
release/0.
| Author | SHA1 | Date | |
|---|---|---|---|
|
2f5ac99fee |
26
.github/ISSUE_TEMPLATE/bug_report.md
vendored
26
.github/ISSUE_TEMPLATE/bug_report.md
vendored
@@ -1,26 +0,0 @@
|
|||||||
---
|
|
||||||
name: Bug report
|
|
||||||
about: Create a report to help us improve
|
|
||||||
title: ''
|
|
||||||
labels: 'bug'
|
|
||||||
assignees: ''
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
**Describe the bug**
|
|
||||||
<!-- A clear and concise description of what the bug is. -->
|
|
||||||
|
|
||||||
**To Reproduce**
|
|
||||||
<!-- Steps or code to reproduce the behavior. -->
|
|
||||||
|
|
||||||
**Expected behavior**
|
|
||||||
<!-- A clear and concise description of what you expected to happen. -->
|
|
||||||
|
|
||||||
**Build environment**
|
|
||||||
- BDK tag/commit: <!-- e.g. v0.13.0, 3a07614 -->
|
|
||||||
- OS+version: <!-- e.g. ubuntu 20.04.01, macOS 12.0.1, windows -->
|
|
||||||
- Rust/Cargo version: <!-- e.g. 1.56.0 -->
|
|
||||||
- Rust/Cargo target: <!-- e.g. x86_64-apple-darwin, x86_64-unknown-linux-gnu, etc. -->
|
|
||||||
|
|
||||||
**Additional context**
|
|
||||||
<!-- Add any other context about the problem here. -->
|
|
||||||
77
.github/ISSUE_TEMPLATE/summer_project.md
vendored
77
.github/ISSUE_TEMPLATE/summer_project.md
vendored
@@ -1,77 +0,0 @@
|
|||||||
---
|
|
||||||
name: Summer of Bitcoin Project
|
|
||||||
about: Template to suggest a new https://www.summerofbitcoin.org/ project.
|
|
||||||
title: ''
|
|
||||||
labels: 'summer-of-bitcoin'
|
|
||||||
assignees: ''
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
<!--
|
|
||||||
## Overview
|
|
||||||
|
|
||||||
Project ideas are scoped for a university-level student with a basic background in CS and bitcoin
|
|
||||||
fundamentals - achievable over 12-weeks. Below are just a few types of ideas:
|
|
||||||
|
|
||||||
- Low-hanging fruit: Relatively short projects with clear goals; requires basic technical knowledge
|
|
||||||
and minimal familiarity with the codebase.
|
|
||||||
- Core development: These projects derive from the ongoing work from the core of your development
|
|
||||||
team. The list of features and bugs is never-ending, and help is always welcome.
|
|
||||||
- Risky/Exploratory: These projects push the scope boundaries of your development effort. They
|
|
||||||
might require expertise in an area not covered by your current development team. They might take
|
|
||||||
advantage of a new technology. There is a reasonable chance that the project might be less
|
|
||||||
successful, but the potential rewards make it worth the attempt.
|
|
||||||
- Infrastructure/Automation: These projects are the code that your organization uses to get its
|
|
||||||
development work done; for example, projects that improve the automation of releases, regression
|
|
||||||
tests and automated builds. This is a category where a Summer of Bitcoin student can be really
|
|
||||||
helpful, doing work that the development team has been putting off while they focus on core
|
|
||||||
development.
|
|
||||||
- Quality Assurance/Testing: Projects that work on and test your project's software development
|
|
||||||
process. Additionally, projects that involve a thorough test and review of individual PRs.
|
|
||||||
- Fun/Peripheral: These projects might not be related to the current core development focus, but
|
|
||||||
create new innovations and new perspectives for your project.
|
|
||||||
-->
|
|
||||||
|
|
||||||
**Description**
|
|
||||||
<!-- Description: 3-7 sentences describing the project background and tasks to be done. -->
|
|
||||||
|
|
||||||
**Expected Outcomes**
|
|
||||||
<!-- Short bullet list describing what is to be accomplished -->
|
|
||||||
|
|
||||||
**Resources**
|
|
||||||
<!-- 2-3 reading materials for candidate to learn about the repo, project, scope etc -->
|
|
||||||
<!-- Recommended reading such as a developer/contributor guide -->
|
|
||||||
<!-- [Another example a paper citation](https://arxiv.org/pdf/1802.08091.pdf) -->
|
|
||||||
<!-- [Another example an existing issue](https://github.com/opencv/opencv/issues/11013) -->
|
|
||||||
<!-- [An existing related module](https://github.com/opencv/opencv_contrib/tree/master/modules/optflow) -->
|
|
||||||
|
|
||||||
**Skills Required**
|
|
||||||
<!-- 3-4 technical skills that the candidate should know -->
|
|
||||||
<!-- hands on experience with git -->
|
|
||||||
<!-- mastery plus experience coding in C++ -->
|
|
||||||
<!-- basic knowledge in matrix and tensor computations, college course work in cryptography -->
|
|
||||||
<!-- strong mathematical background -->
|
|
||||||
<!-- Bonus - has experience with React Native. Best if you have also worked with OSSFuzz -->
|
|
||||||
|
|
||||||
**Mentor(s)**
|
|
||||||
<!-- names of mentor(s) for this project go here -->
|
|
||||||
|
|
||||||
**Difficulty**
|
|
||||||
<!-- Easy, Medium, Hard -->
|
|
||||||
|
|
||||||
**Competency Test (optional)**
|
|
||||||
<!-- 2-3 technical tasks related to the project idea or repository you’d like a candidate to
|
|
||||||
perform in order to demonstrate competency, good first bugs, warm-up exercises -->
|
|
||||||
<!-- ex. Read the instructions here to get Bitcoin core running on your machine -->
|
|
||||||
<!-- ex. pick an issue labeled as “newcomer” in the repository, and send a merge request to the
|
|
||||||
repository. You can also suggest some other improvement that we did not think of yet, or
|
|
||||||
something that you find interesting or useful -->
|
|
||||||
<!-- ex. fixes for coding style are usually easy to do, and are good issues for first time
|
|
||||||
contributions for those learning how to interact with the project. After you are done with the
|
|
||||||
coding style issue, try making a different contribution. -->
|
|
||||||
<!-- ex. setup a full Debian packaging development environment and learn the basics of Debian
|
|
||||||
packaging. Then identify and package the missing dependencies to package Specter Desktop -->
|
|
||||||
<!-- ex. write a pull parser for CSV files. You'll be judged by the decisions to store the parser
|
|
||||||
state and how flexible it is to wrap this parser in other scenarios. -->
|
|
||||||
<!-- ex. Stretch Goal: Implement some basic metaprogram/app to prove you're very familiar with BDK.
|
|
||||||
Be prepared to make adjustments as we judge your solution. -->
|
|
||||||
30
.github/pull_request_template.md
vendored
30
.github/pull_request_template.md
vendored
@@ -1,30 +0,0 @@
|
|||||||
<!-- You can erase any parts of this template not applicable to your Pull Request. -->
|
|
||||||
|
|
||||||
### Description
|
|
||||||
|
|
||||||
<!-- Describe the purpose of this PR, what's being adding and/or fixed -->
|
|
||||||
|
|
||||||
### Notes to the reviewers
|
|
||||||
|
|
||||||
<!-- In this section you can include notes directed to the reviewers, like explaining why some parts
|
|
||||||
of the PR were done in a specific way -->
|
|
||||||
|
|
||||||
### Checklists
|
|
||||||
|
|
||||||
#### All Submissions:
|
|
||||||
|
|
||||||
* [ ] I've signed all my commits
|
|
||||||
* [ ] I followed the [contribution guidelines](https://github.com/bitcoindevkit/bdk/blob/master/CONTRIBUTING.md)
|
|
||||||
* [ ] I ran `cargo fmt` and `cargo clippy` before committing
|
|
||||||
|
|
||||||
#### New Features:
|
|
||||||
|
|
||||||
* [ ] I've added tests for the new feature
|
|
||||||
* [ ] I've added docs for the new feature
|
|
||||||
* [ ] I've updated `CHANGELOG.md`
|
|
||||||
|
|
||||||
#### Bugfixes:
|
|
||||||
|
|
||||||
* [ ] This pull request breaks the existing API
|
|
||||||
* [ ] I've added tests to reproduce the issue which are now passing
|
|
||||||
* [ ] I'm linking the issue being fixed by this PR
|
|
||||||
19
.github/workflows/audit.yml
vendored
19
.github/workflows/audit.yml
vendored
@@ -1,19 +0,0 @@
|
|||||||
name: Audit
|
|
||||||
|
|
||||||
on:
|
|
||||||
push:
|
|
||||||
paths:
|
|
||||||
- '**/Cargo.toml'
|
|
||||||
- '**/Cargo.lock'
|
|
||||||
schedule:
|
|
||||||
- cron: '0 0 * * 0' # Once per week
|
|
||||||
|
|
||||||
jobs:
|
|
||||||
|
|
||||||
security_audit:
|
|
||||||
runs-on: ubuntu-20.04
|
|
||||||
steps:
|
|
||||||
- uses: actions/checkout@v2
|
|
||||||
- uses: actions-rs/audit-check@v1
|
|
||||||
with:
|
|
||||||
token: ${{ secrets.GITHUB_TOKEN }}
|
|
||||||
61
.github/workflows/cont_integration.yml
vendored
61
.github/workflows/cont_integration.yml
vendored
@@ -1,61 +0,0 @@
|
|||||||
on: [push, pull_request]
|
|
||||||
|
|
||||||
name: CI
|
|
||||||
|
|
||||||
jobs:
|
|
||||||
|
|
||||||
build-test:
|
|
||||||
name: Build and test
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
strategy:
|
|
||||||
matrix:
|
|
||||||
rust:
|
|
||||||
- version: 1.60.0 # STABLE
|
|
||||||
clippy: true
|
|
||||||
- version: 1.57.0 # MSRV
|
|
||||||
steps:
|
|
||||||
- name: checkout
|
|
||||||
uses: actions/checkout@v2
|
|
||||||
- name: Generate cache key
|
|
||||||
run: echo "${{ matrix.rust.version }} ${{ matrix.features }}" | tee .cache_key
|
|
||||||
- name: cache
|
|
||||||
uses: actions/cache@v2
|
|
||||||
with:
|
|
||||||
path: |
|
|
||||||
~/.cargo/registry
|
|
||||||
~/.cargo/git
|
|
||||||
target
|
|
||||||
key: ${{ runner.os }}-cargo-${{ hashFiles('.cache_key') }}-${{ hashFiles('**/Cargo.toml','**/Cargo.lock') }}
|
|
||||||
- name: Set default toolchain
|
|
||||||
run: rustup default ${{ matrix.rust.version }}
|
|
||||||
- name: Set profile
|
|
||||||
run: rustup set profile minimal
|
|
||||||
- name: Add clippy
|
|
||||||
if: ${{ matrix.rust.clippy }}
|
|
||||||
run: rustup component add clippy
|
|
||||||
- name: Update toolchain
|
|
||||||
run: rustup update
|
|
||||||
- name: Build
|
|
||||||
run: cargo build
|
|
||||||
- name: Clippy
|
|
||||||
if: ${{ matrix.rust.clippy }}
|
|
||||||
run: cargo clippy --all-targets -- -D warnings
|
|
||||||
- name: Test
|
|
||||||
run: cargo test
|
|
||||||
|
|
||||||
fmt:
|
|
||||||
name: Rust fmt
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
steps:
|
|
||||||
- name: Checkout
|
|
||||||
uses: actions/checkout@v2
|
|
||||||
- name: Set default toolchain
|
|
||||||
run: rustup default nightly
|
|
||||||
- name: Set profile
|
|
||||||
run: rustup set profile minimal
|
|
||||||
- name: Add rustfmt
|
|
||||||
run: rustup component add rustfmt
|
|
||||||
- name: Update toolchain
|
|
||||||
run: rustup update
|
|
||||||
- name: Check fmt
|
|
||||||
run: cargo fmt --all -- --config format_code_in_doc_comments=true --check
|
|
||||||
1
.gitignore
vendored
1
.gitignore
vendored
@@ -14,4 +14,3 @@ testdb
|
|||||||
xcuserdata
|
xcuserdata
|
||||||
.lsp
|
.lsp
|
||||||
.clj-kondo
|
.clj-kondo
|
||||||
.idea/
|
|
||||||
|
|||||||
47
CHANGELOG.md
47
CHANGELOG.md
@@ -6,55 +6,20 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
|
|||||||
|
|
||||||
## [Unreleased]
|
## [Unreleased]
|
||||||
|
|
||||||
## [v0.8.0]
|
|
||||||
- Update BDK to version 0.20.0 [#169]
|
|
||||||
- APIs Added
|
|
||||||
- `TxBuilder.add_data(data: Vec<u8>)` [#163]
|
|
||||||
- `Wallet.list_unspent()` returns `Vec<LocalUtxo>` [#158]
|
|
||||||
- Add coin control methods on TxBuilder [#164]
|
|
||||||
|
|
||||||
[#163]: https://github.com/bitcoindevkit/bdk-ffi/pull/163
|
|
||||||
[#158]: https://github.com/bitcoindevkit/bdk-ffi/pull/158
|
|
||||||
[#164]: https://github.com/bitcoindevkit/bdk-ffi/pull/164
|
|
||||||
[#169]: https://github.com/bitcoindevkit/bdk-ffi/pull/169
|
|
||||||
|
|
||||||
## [v0.7.0]
|
|
||||||
- Update BDK to version 0.19.0
|
|
||||||
- fixes sqlite-db issue causing wrong balance
|
|
||||||
- adds experimental taproot descriptor and PSBT support
|
|
||||||
- APIs Removed
|
|
||||||
- `Wallet.get_new_address()`, returned String, [#137]
|
|
||||||
- `Wallet.get_last_unused_address()`, returned String [#137]
|
|
||||||
- APIs Added
|
|
||||||
- `Wallet.get_address(AddressIndex)`, returns `AddressInfo` [#137]
|
|
||||||
- APIs Changed
|
|
||||||
- `Wallet.sign(PartiallySignedBitcoinTransaction)` now returns a bool, true if finalized [#161]
|
|
||||||
|
|
||||||
[#137]: https://github.com/bitcoindevkit/bdk-ffi/pull/137
|
|
||||||
[#161]: https://github.com/bitcoindevkit/bdk-ffi/pull/161
|
|
||||||
|
|
||||||
## [v0.6.0]
|
|
||||||
- Update BDK to version 0.18.0
|
|
||||||
- Add BumpFeeTxBuilder to bump the fee on an unconfirmed tx created by the Wallet
|
|
||||||
- Change TxBuilder.build() to TxBuilder.finish() to align with bdk function name
|
|
||||||
|
|
||||||
## [v0.5.0]
|
|
||||||
- Fix Wallet.broadcast function, now returns a tx id as a hex string
|
- Fix Wallet.broadcast function, now returns a tx id as a hex string
|
||||||
- Remove creating a new spending Transaction via the PartiallySignedBitcoinTransaction constructor
|
|
||||||
- Add TxBuilder for creating new spending PartiallySignedBitcoinTransaction
|
|
||||||
- Add TxBuilder .add_recipient, .fee_rate, and .build functions
|
|
||||||
- Add TxBuilder .drain_wallet and .drain_to functions
|
|
||||||
- Update generate cli tool to generate all binding languages and rename to bdk-ffi-bindgen
|
|
||||||
|
|
||||||
## [v0.4.0]
|
## [v0.4.0]
|
||||||
|
|
||||||
- Add dual license MIT and Apache 2.0
|
- Add dual license MIT and Apache 2.0
|
||||||
- Add sqlite database support
|
- Add sqlite database support
|
||||||
- Fix memory database configuration enum, remove junk field
|
- Fix memory database configuration enum, remove junk field
|
||||||
|
|
||||||
## [v0.3.1]
|
## [v0.3.1]
|
||||||
|
|
||||||
- Remove hard coded sync progress value (was always returning 21.0)
|
- Remove hard coded sync progress value (was always returning 21.0)
|
||||||
|
|
||||||
## [v0.3.0]
|
## [v0.3.0]
|
||||||
|
|
||||||
- Move bdk-kotlin bindings and ios example to separate repos
|
- Move bdk-kotlin bindings and ios example to separate repos
|
||||||
- Add bin to generate Python bindings
|
- Add bin to generate Python bindings
|
||||||
- Add `PartiallySignedBitcoinTransaction::deserialize` function as named constructor to decode from a string per [BIP 0174]
|
- Add `PartiallySignedBitcoinTransaction::deserialize` function as named constructor to decode from a string per [BIP 0174]
|
||||||
@@ -65,11 +30,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
|
|||||||
|
|
||||||
## [v0.2.0]
|
## [v0.2.0]
|
||||||
|
|
||||||
[unreleased]: https://github.com/bitcoindevkit/bdk-ffi/compare/v0.8.0...HEAD
|
[unreleased]: https://github.com/bitcoindevkit/bdk-ffi/compare/v0.4.0...HEAD
|
||||||
[v0.8.0]: https://github.com/bitcoindevkit/bdk-ffi/compare/v0.7.0...v0.8.0
|
|
||||||
[v0.7.0]: https://github.com/bitcoindevkit/bdk-ffi/compare/v0.6.0...v0.7.0
|
|
||||||
[v0.6.0]: https://github.com/bitcoindevkit/bdk-ffi/compare/v0.5.0...v0.6.0
|
|
||||||
[v0.5.0]: https://github.com/bitcoindevkit/bdk-ffi/compare/v0.4.0...v0.5.0
|
|
||||||
[v0.4.0]: https://github.com/bitcoindevkit/bdk-ffi/compare/v0.3.1...v0.4.0
|
[v0.4.0]: https://github.com/bitcoindevkit/bdk-ffi/compare/v0.3.1...v0.4.0
|
||||||
[v0.3.1]: https://github.com/bitcoindevkit/bdk-ffi/compare/v0.3.0...v0.3.1
|
[v0.3.1]: https://github.com/bitcoindevkit/bdk-ffi/compare/v0.3.0...v0.3.1
|
||||||
[v0.3.0]: https://github.com/bitcoindevkit/bdk-ffi/compare/v0.2.0...v0.3.0
|
[v0.3.0]: https://github.com/bitcoindevkit/bdk-ffi/compare/v0.2.0...v0.3.0
|
||||||
|
|||||||
27
Cargo.toml
27
Cargo.toml
@@ -1,23 +1,32 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "bdk-ffi"
|
name = "bdk-ffi"
|
||||||
version = "0.8.1"
|
version = "0.4.1"
|
||||||
authors = ["Steve Myers <steve@notmandatory.org>", "Sudarsan Balaji <sudarsan.balaji@artfuldev.com>"]
|
authors = ["Steve Myers <steve@notmandatory.org>", "Sudarsan Balaji <sudarsan.balaji@artfuldev.com>"]
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
|
|
||||||
[workspace]
|
|
||||||
members = [".","bdk-ffi-bindgen"]
|
|
||||||
default-members = [".", "bdk-ffi-bindgen"]
|
|
||||||
|
|
||||||
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
||||||
[lib]
|
[lib]
|
||||||
crate-type = ["staticlib", "cdylib"]
|
crate-type = ["staticlib", "cdylib"]
|
||||||
name = "bdkffi"
|
name = "bdkffi"
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
bdk = { version = "0.20", features = ["all-keys", "use-esplora-ureq", "sqlite-bundled"] }
|
bdk = { version = "0.14", features = ["all-keys", "use-esplora-ureq", "sqlite"] }
|
||||||
|
|
||||||
uniffi_macros = { version = "0.19.3", features = ["builtin-bindgen"] }
|
# TODO remove when bdk "sqlite-bundled" feature added
|
||||||
uniffi = { version = "0.19.3", features = ["builtin-bindgen"] }
|
rusqlite = { version = "0.25.3", features = ["bundled"] }
|
||||||
|
|
||||||
|
uniffi_macros = { version = "0.16.0", features = ["builtin-bindgen"] }
|
||||||
|
uniffi = { version = "0.16.0", features = ["builtin-bindgen"] }
|
||||||
|
thiserror = "1.0"
|
||||||
|
anyhow = "=1.0.45" # remove after upgrading to next version of uniffi
|
||||||
|
|
||||||
|
uniffi_bindgen = { version = "0.16.0", optional = true }
|
||||||
|
|
||||||
[build-dependencies]
|
[build-dependencies]
|
||||||
uniffi_build = { version = "0.19.3", features = ["builtin-bindgen"] }
|
uniffi_build = { version = "0.16.0", features = ["builtin-bindgen"] }
|
||||||
|
|
||||||
|
[features]
|
||||||
|
generate-python = ["uniffi_bindgen"]
|
||||||
|
|
||||||
|
[[bin]]
|
||||||
|
name = "generate"
|
||||||
|
|||||||
23
README.md
23
README.md
@@ -1,10 +1,9 @@
|
|||||||
# Native language bindings for BDK
|
# Native language bindings for BDK
|
||||||
|
|
||||||
The workspace in this repository creates the `libbdkffi` multi-language library for the rust based
|
This repository contains source code for generating native language bindings for the rust based
|
||||||
[bdk] library from the [Bitcoin Dev Kit] project. The `bdk-ffi-bindgen` package builds a tool for
|
[bdk] library which is the central artifact of the [Bitcoin Dev Kit] project.
|
||||||
generating the actual language binding code used to access the `libbdkffi` library.
|
|
||||||
|
|
||||||
Each supported language has its own repository that includes this project as a [git submodule].
|
Each supported language has it's own repository that includes this project as a [git submodule].
|
||||||
The rust code in this project is a wrapper around the [bdk] library to expose it's APIs in a
|
The rust code in this project is a wrapper around the [bdk] library to expose it's APIs in a
|
||||||
uniform way using the [mozilla/uniffi-rs] bindings generator for each supported target language.
|
uniform way using the [mozilla/uniffi-rs] bindings generator for each supported target language.
|
||||||
|
|
||||||
@@ -20,14 +19,6 @@ language binding for [bdk] supported by this project.
|
|||||||
| Swift | iOS, macOS | [bdk-swift] |
|
| Swift | iOS, macOS | [bdk-swift] |
|
||||||
| Python | linux, macOS | [bdk-python] |
|
| Python | linux, macOS | [bdk-python] |
|
||||||
|
|
||||||
## Language bindings generator tool
|
|
||||||
|
|
||||||
Use the `bdk-ffi-bindgen` tool to generate language binding code for the above supported languages.
|
|
||||||
To run `bdk-ffi-bindgen` and see the available options use the command:
|
|
||||||
```shell
|
|
||||||
cargo run -p bdk-ffi-bindgen -- --help
|
|
||||||
```
|
|
||||||
|
|
||||||
[bdk]: https://github.com/bitcoindevkit/bdk
|
[bdk]: https://github.com/bitcoindevkit/bdk
|
||||||
[Bitcoin Dev Kit]: https://github.com/bitcoindevkit
|
[Bitcoin Dev Kit]: https://github.com/bitcoindevkit
|
||||||
[git submodule]: https://git-scm.com/book/en/v2/Git-Tools-Submodules
|
[git submodule]: https://git-scm.com/book/en/v2/Git-Tools-Submodules
|
||||||
@@ -39,6 +30,14 @@ cargo run -p bdk-ffi-bindgen -- --help
|
|||||||
|
|
||||||
## Contributing
|
## Contributing
|
||||||
|
|
||||||
|
### Install uniffi-bindgen cli tool
|
||||||
|
|
||||||
|
Install the uniffi-bindgen binary on your system using:
|
||||||
|
|
||||||
|
`cargo install uniffi_bindgen`
|
||||||
|
|
||||||
|
The version must be the same as the `uniffi` dependency in `Cargo.toml`.
|
||||||
|
|
||||||
### Adding new structs and functions
|
### Adding new structs and functions
|
||||||
|
|
||||||
See the [UniFFI User Guide](https://mozilla.github.io/uniffi-rs/)
|
See the [UniFFI User Guide](https://mozilla.github.io/uniffi-rs/)
|
||||||
|
|||||||
@@ -1,10 +0,0 @@
|
|||||||
[package]
|
|
||||||
name = "bdk-ffi-bindgen"
|
|
||||||
version = "0.2.0"
|
|
||||||
edition = "2021"
|
|
||||||
|
|
||||||
[dependencies]
|
|
||||||
anyhow = "=1.0.45" # remove after upgrading to next version of uniffi
|
|
||||||
structopt = "0.3"
|
|
||||||
uniffi_bindgen = "=0.19.3"
|
|
||||||
camino = "1.0.9"
|
|
||||||
@@ -1,137 +0,0 @@
|
|||||||
use camino::Utf8Path;
|
|
||||||
use std::fmt;
|
|
||||||
use std::path::{Path, PathBuf};
|
|
||||||
use std::str::FromStr;
|
|
||||||
use structopt::StructOpt;
|
|
||||||
|
|
||||||
#[derive(Debug, PartialEq)]
|
|
||||||
pub enum Language {
|
|
||||||
Kotlin,
|
|
||||||
Python,
|
|
||||||
Swift,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl fmt::Display for Language {
|
|
||||||
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
|
||||||
match self {
|
|
||||||
Language::Kotlin => write!(f, "kotlin"),
|
|
||||||
Language::Swift => write!(f, "swift"),
|
|
||||||
Language::Python => write!(f, "python"),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug)]
|
|
||||||
pub enum Error {
|
|
||||||
UnsupportedLanguage,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl fmt::Display for Error {
|
|
||||||
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
|
|
||||||
write!(f, "{:?}", self)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl FromStr for Language {
|
|
||||||
type Err = Error;
|
|
||||||
fn from_str(s: &str) -> Result<Self, Self::Err> {
|
|
||||||
match s {
|
|
||||||
"kotlin" => Ok(Language::Kotlin),
|
|
||||||
"python" => Ok(Language::Python),
|
|
||||||
"swift" => Ok(Language::Swift),
|
|
||||||
_ => Err(Error::UnsupportedLanguage),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn generate_bindings(opt: &Opt) -> anyhow::Result<(), anyhow::Error> {
|
|
||||||
let path: &Utf8Path = Utf8Path::from_path(&opt.udl_file).unwrap();
|
|
||||||
let out_dir: &Utf8Path = Utf8Path::from_path(&opt.out_dir).unwrap();
|
|
||||||
uniffi_bindgen::generate_bindings(
|
|
||||||
path,
|
|
||||||
None,
|
|
||||||
vec![opt.language.to_string().as_str()],
|
|
||||||
Some(out_dir),
|
|
||||||
false,
|
|
||||||
)?;
|
|
||||||
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
|
|
||||||
fn fixup_python_lib_path(
|
|
||||||
out_dir: &Path,
|
|
||||||
lib_name: &Path,
|
|
||||||
) -> Result<(), Box<dyn std::error::Error>> {
|
|
||||||
use std::fs;
|
|
||||||
use std::io::Write;
|
|
||||||
|
|
||||||
const LOAD_INDIRECT_DEF: &str = "def loadIndirect():";
|
|
||||||
|
|
||||||
let bindings_file = out_dir.join("bdk.py");
|
|
||||||
let mut data = fs::read_to_string(&bindings_file)?;
|
|
||||||
|
|
||||||
let pos = data
|
|
||||||
.find(LOAD_INDIRECT_DEF)
|
|
||||||
.unwrap_or_else(|| panic!("loadIndirect not found in `{}`", bindings_file.display()));
|
|
||||||
let range = pos..pos + LOAD_INDIRECT_DEF.len();
|
|
||||||
|
|
||||||
let replacement = format!(
|
|
||||||
r#"
|
|
||||||
def loadIndirect():
|
|
||||||
import glob
|
|
||||||
return getattr(ctypes.cdll, glob.glob(os.path.join(os.path.dirname(os.path.abspath(__file__)), '{}.*'))[0])
|
|
||||||
|
|
||||||
def _loadIndirectOld():"#,
|
|
||||||
&lib_name.to_str().expect("lib name")
|
|
||||||
);
|
|
||||||
data.replace_range(range, &replacement);
|
|
||||||
|
|
||||||
let mut file = fs::OpenOptions::new()
|
|
||||||
.write(true)
|
|
||||||
.truncate(true)
|
|
||||||
.open(&bindings_file)?;
|
|
||||||
file.write_all(data.as_bytes())?;
|
|
||||||
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, StructOpt)]
|
|
||||||
#[structopt(
|
|
||||||
name = "bdk-ffi-bindgen",
|
|
||||||
about = "A tool to generate bdk-ffi language bindings"
|
|
||||||
)]
|
|
||||||
struct Opt {
|
|
||||||
/// UDL file
|
|
||||||
#[structopt(env = "BDKFFI_BINDGEN_UDL", short, long, default_value("src/bdk.udl"), parse(try_from_str = PathBuf::from_str))]
|
|
||||||
udl_file: PathBuf,
|
|
||||||
|
|
||||||
/// Language to generate bindings for
|
|
||||||
#[structopt(env = "BDKFFI_BINDGEN_LANGUAGE", short, long, possible_values(&["kotlin","swift","python"]), parse(try_from_str = Language::from_str))]
|
|
||||||
language: Language,
|
|
||||||
|
|
||||||
/// Output directory to put generated language bindings
|
|
||||||
#[structopt(env = "BDKFFI_BINDGEN_OUTPUT_DIR", short, long, parse(try_from_str = PathBuf::from_str))]
|
|
||||||
out_dir: PathBuf,
|
|
||||||
|
|
||||||
/// Python fix up lib path
|
|
||||||
#[structopt(env = "BDKFFI_BINDGEN_PYTHON_FIXUP_PATH", short, long, parse(try_from_str = PathBuf::from_str))]
|
|
||||||
python_fixup_path: Option<PathBuf>,
|
|
||||||
}
|
|
||||||
|
|
||||||
fn main() -> Result<(), Box<dyn std::error::Error>> {
|
|
||||||
let opt = Opt::from_args();
|
|
||||||
|
|
||||||
println!("Input UDL file is {:?}", opt.udl_file);
|
|
||||||
println!("Chosen language is {}", opt.language);
|
|
||||||
println!("Output directory is {:?}", opt.out_dir);
|
|
||||||
|
|
||||||
generate_bindings(&opt)?;
|
|
||||||
|
|
||||||
if opt.language == Language::Python {
|
|
||||||
if let Some(path) = opt.python_fixup_path {
|
|
||||||
println!("Fixing up python lib path, {:?}", &path);
|
|
||||||
fixup_python_lib_path(&opt.out_dir, &path)?;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
215
src/bdk.udl
215
src/bdk.udl
@@ -1,7 +1,6 @@
|
|||||||
namespace bdk {
|
namespace bdk {
|
||||||
[Throws=BdkError]
|
[Throws=BdkError]
|
||||||
ExtendedKeyInfo generate_extended_key(Network network, WordCount word_count, string? password);
|
ExtendedKeyInfo generate_extended_key(Network network, WordCount word_count, string? password);
|
||||||
|
|
||||||
[Throws=BdkError]
|
[Throws=BdkError]
|
||||||
ExtendedKeyInfo restore_extended_key(Network network, string mnemonic, string? password);
|
ExtendedKeyInfo restore_extended_key(Network network, string mnemonic, string? password);
|
||||||
};
|
};
|
||||||
@@ -50,16 +49,6 @@ enum BdkError {
|
|||||||
"Rusqlite",
|
"Rusqlite",
|
||||||
};
|
};
|
||||||
|
|
||||||
dictionary AddressInfo {
|
|
||||||
u32 index;
|
|
||||||
string address;
|
|
||||||
};
|
|
||||||
|
|
||||||
enum AddressIndex {
|
|
||||||
"New",
|
|
||||||
"LastUnused",
|
|
||||||
};
|
|
||||||
|
|
||||||
enum Network {
|
enum Network {
|
||||||
"Bitcoin",
|
"Bitcoin",
|
||||||
"Testnet",
|
"Testnet",
|
||||||
@@ -84,15 +73,15 @@ interface DatabaseConfig {
|
|||||||
};
|
};
|
||||||
|
|
||||||
dictionary TransactionDetails {
|
dictionary TransactionDetails {
|
||||||
u64? fee;
|
u64? fees;
|
||||||
u64 received;
|
u64 received;
|
||||||
u64 sent;
|
u64 sent;
|
||||||
string txid;
|
string txid;
|
||||||
};
|
};
|
||||||
|
|
||||||
dictionary BlockTime {
|
dictionary BlockTime {
|
||||||
u32 height;
|
u32 height;
|
||||||
u64 timestamp;
|
u64 timestamp;
|
||||||
};
|
};
|
||||||
|
|
||||||
[Enum]
|
[Enum]
|
||||||
@@ -101,6 +90,58 @@ interface Transaction {
|
|||||||
Confirmed(TransactionDetails details, BlockTime confirmation);
|
Confirmed(TransactionDetails details, BlockTime confirmation);
|
||||||
};
|
};
|
||||||
|
|
||||||
|
dictionary ElectrumConfig {
|
||||||
|
string url;
|
||||||
|
string? socks5;
|
||||||
|
u8 retry;
|
||||||
|
u8? timeout;
|
||||||
|
u64 stop_gap;
|
||||||
|
};
|
||||||
|
|
||||||
|
dictionary EsploraConfig {
|
||||||
|
string base_url;
|
||||||
|
string? proxy;
|
||||||
|
u64 timeout_read;
|
||||||
|
u64 timeout_write;
|
||||||
|
u64 stop_gap;
|
||||||
|
};
|
||||||
|
|
||||||
|
[Enum]
|
||||||
|
interface BlockchainConfig {
|
||||||
|
Electrum(ElectrumConfig config);
|
||||||
|
Esplora(EsploraConfig config);
|
||||||
|
};
|
||||||
|
|
||||||
|
callback interface BdkProgress {
|
||||||
|
void update(f32 progress, string? message);
|
||||||
|
};
|
||||||
|
|
||||||
|
interface Wallet {
|
||||||
|
[Throws=BdkError]
|
||||||
|
constructor(string descriptor, string? change_descriptor, Network network, DatabaseConfig database_config, BlockchainConfig blockchain_config);
|
||||||
|
string get_new_address();
|
||||||
|
string get_last_unused_address();
|
||||||
|
[Throws=BdkError]
|
||||||
|
u64 get_balance();
|
||||||
|
[Throws=BdkError]
|
||||||
|
void sign([ByRef] PartiallySignedBitcoinTransaction psbt);
|
||||||
|
[Throws=BdkError]
|
||||||
|
sequence<Transaction> get_transactions();
|
||||||
|
Network get_network();
|
||||||
|
[Throws=BdkError]
|
||||||
|
void sync(BdkProgress progress_update, u32? max_address_param);
|
||||||
|
[Throws=BdkError]
|
||||||
|
string broadcast([ByRef] PartiallySignedBitcoinTransaction psbt);
|
||||||
|
};
|
||||||
|
|
||||||
|
interface PartiallySignedBitcoinTransaction {
|
||||||
|
[Throws=BdkError]
|
||||||
|
constructor([ByRef] Wallet wallet, string recipient, u64 amount, float? fee_rate);
|
||||||
|
[Name=deserialize,Throws=BdkError]
|
||||||
|
constructor(string psbt_base64);
|
||||||
|
string serialize();
|
||||||
|
};
|
||||||
|
|
||||||
dictionary ExtendedKeyInfo {
|
dictionary ExtendedKeyInfo {
|
||||||
string mnemonic;
|
string mnemonic;
|
||||||
string xprv;
|
string xprv;
|
||||||
@@ -114,143 +155,3 @@ enum WordCount {
|
|||||||
"Words21",
|
"Words21",
|
||||||
"Words24",
|
"Words24",
|
||||||
};
|
};
|
||||||
|
|
||||||
dictionary ElectrumConfig {
|
|
||||||
string url;
|
|
||||||
string? socks5;
|
|
||||||
u8 retry;
|
|
||||||
u8? timeout;
|
|
||||||
u64 stop_gap;
|
|
||||||
};
|
|
||||||
|
|
||||||
dictionary EsploraConfig {
|
|
||||||
string base_url;
|
|
||||||
string? proxy;
|
|
||||||
u8? concurrency;
|
|
||||||
u64 stop_gap;
|
|
||||||
u64? timeout;
|
|
||||||
};
|
|
||||||
|
|
||||||
[Enum]
|
|
||||||
interface BlockchainConfig {
|
|
||||||
Electrum(ElectrumConfig config);
|
|
||||||
Esplora(EsploraConfig config);
|
|
||||||
};
|
|
||||||
|
|
||||||
interface Blockchain {
|
|
||||||
[Throws=BdkError]
|
|
||||||
constructor(BlockchainConfig config);
|
|
||||||
|
|
||||||
[Throws=BdkError]
|
|
||||||
void broadcast([ByRef] PartiallySignedBitcoinTransaction psbt);
|
|
||||||
};
|
|
||||||
|
|
||||||
callback interface Progress {
|
|
||||||
void update(f32 progress, string? message);
|
|
||||||
};
|
|
||||||
|
|
||||||
dictionary OutPoint {
|
|
||||||
string txid;
|
|
||||||
u32 vout;
|
|
||||||
};
|
|
||||||
|
|
||||||
dictionary TxOut {
|
|
||||||
u64 value;
|
|
||||||
string address;
|
|
||||||
};
|
|
||||||
|
|
||||||
enum KeychainKind {
|
|
||||||
"External",
|
|
||||||
"Internal",
|
|
||||||
};
|
|
||||||
|
|
||||||
dictionary LocalUtxo {
|
|
||||||
OutPoint outpoint;
|
|
||||||
TxOut txout;
|
|
||||||
KeychainKind keychain;
|
|
||||||
boolean is_spent;
|
|
||||||
};
|
|
||||||
|
|
||||||
interface Wallet {
|
|
||||||
[Throws=BdkError]
|
|
||||||
constructor(string descriptor, string? change_descriptor, Network network, DatabaseConfig database_config);
|
|
||||||
|
|
||||||
[Throws=BdkError]
|
|
||||||
AddressInfo get_address(AddressIndex address_index);
|
|
||||||
|
|
||||||
[Throws=BdkError]
|
|
||||||
u64 get_balance();
|
|
||||||
|
|
||||||
[Throws=BdkError]
|
|
||||||
boolean sign([ByRef] PartiallySignedBitcoinTransaction psbt);
|
|
||||||
|
|
||||||
[Throws=BdkError]
|
|
||||||
sequence<Transaction> get_transactions();
|
|
||||||
|
|
||||||
Network get_network();
|
|
||||||
|
|
||||||
[Throws=BdkError]
|
|
||||||
void sync([ByRef] Blockchain blockchain, Progress? progress);
|
|
||||||
|
|
||||||
[Throws=BdkError]
|
|
||||||
sequence<LocalUtxo> list_unspent();
|
|
||||||
};
|
|
||||||
|
|
||||||
interface PartiallySignedBitcoinTransaction {
|
|
||||||
[Throws=BdkError]
|
|
||||||
constructor(string psbt_base64);
|
|
||||||
|
|
||||||
string serialize();
|
|
||||||
|
|
||||||
string txid();
|
|
||||||
};
|
|
||||||
|
|
||||||
interface TxBuilder {
|
|
||||||
constructor();
|
|
||||||
|
|
||||||
TxBuilder add_recipient(string address, u64 amount);
|
|
||||||
|
|
||||||
TxBuilder add_unspendable(OutPoint unspendable);
|
|
||||||
|
|
||||||
TxBuilder add_utxo(OutPoint outpoint);
|
|
||||||
|
|
||||||
TxBuilder add_utxos(sequence<OutPoint> outpoints);
|
|
||||||
|
|
||||||
TxBuilder do_not_spend_change();
|
|
||||||
|
|
||||||
TxBuilder manually_selected_only();
|
|
||||||
|
|
||||||
TxBuilder only_spend_change();
|
|
||||||
|
|
||||||
TxBuilder unspendable(sequence<OutPoint> unspendable);
|
|
||||||
|
|
||||||
TxBuilder fee_rate(float sat_per_vbyte);
|
|
||||||
|
|
||||||
TxBuilder fee_absolute(u64 fee_amount);
|
|
||||||
|
|
||||||
TxBuilder drain_wallet();
|
|
||||||
|
|
||||||
TxBuilder drain_to(string address);
|
|
||||||
|
|
||||||
TxBuilder enable_rbf();
|
|
||||||
|
|
||||||
TxBuilder enable_rbf_with_sequence(u32 nsequence);
|
|
||||||
|
|
||||||
TxBuilder add_data(sequence<u8> data);
|
|
||||||
|
|
||||||
[Throws=BdkError]
|
|
||||||
PartiallySignedBitcoinTransaction finish([ByRef] Wallet wallet);
|
|
||||||
};
|
|
||||||
|
|
||||||
interface BumpFeeTxBuilder {
|
|
||||||
constructor(string txid, float new_fee_rate);
|
|
||||||
|
|
||||||
BumpFeeTxBuilder allow_shrinking(string address);
|
|
||||||
|
|
||||||
BumpFeeTxBuilder enable_rbf();
|
|
||||||
|
|
||||||
BumpFeeTxBuilder enable_rbf_with_sequence(u32 nsequence);
|
|
||||||
|
|
||||||
[Throws=BdkError]
|
|
||||||
PartiallySignedBitcoinTransaction finish([ByRef] Wallet wallet);
|
|
||||||
};
|
|
||||||
|
|||||||
67
src/bin/generate.rs
Normal file
67
src/bin/generate.rs
Normal file
@@ -0,0 +1,67 @@
|
|||||||
|
pub const BDK_UDL: &str = "src/bdk.udl";
|
||||||
|
|
||||||
|
#[cfg(feature = "generate-python")]
|
||||||
|
fn fixup_python_lib_path<O: AsRef<std::path::Path>>(
|
||||||
|
out_dir: O,
|
||||||
|
lib_name: &str,
|
||||||
|
) -> Result<(), Box<dyn std::error::Error>> {
|
||||||
|
use std::fs;
|
||||||
|
use std::io::Write;
|
||||||
|
|
||||||
|
const LOAD_INDIRECT_DEF: &str = "def loadIndirect():";
|
||||||
|
|
||||||
|
let bindings_file = out_dir.as_ref().join("bdk.py");
|
||||||
|
let mut data = fs::read_to_string(&bindings_file)?;
|
||||||
|
|
||||||
|
let pos = data.find(LOAD_INDIRECT_DEF).expect(&format!(
|
||||||
|
"loadIndirect not found in `{}`",
|
||||||
|
bindings_file.display()
|
||||||
|
));
|
||||||
|
let range = pos..pos + LOAD_INDIRECT_DEF.len();
|
||||||
|
|
||||||
|
let replacement = format!(
|
||||||
|
r#"
|
||||||
|
def loadIndirect():
|
||||||
|
import glob
|
||||||
|
return getattr(ctypes.cdll, glob.glob(os.path.join(os.path.dirname(os.path.abspath(__file__)), '{}.*'))[0])
|
||||||
|
|
||||||
|
def _loadIndirectOld():"#,
|
||||||
|
lib_name
|
||||||
|
);
|
||||||
|
data.replace_range(range, &replacement);
|
||||||
|
|
||||||
|
let mut file = fs::OpenOptions::new()
|
||||||
|
.write(true)
|
||||||
|
.truncate(true)
|
||||||
|
.open(&bindings_file)?;
|
||||||
|
file.write(data.as_bytes())?;
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
#[cfg(feature = "generate-python")]
|
||||||
|
fn generate_python() -> Result<(), Box<dyn std::error::Error>> {
|
||||||
|
use std::env;
|
||||||
|
|
||||||
|
let out_path = env::var("GENERATE_PYTHON_BINDINGS_OUT")
|
||||||
|
.map_err(|_| String::from("`GENERATE_PYTHON_BINDINGS_OUT` env variable missing"))?;
|
||||||
|
uniffi_bindgen::generate_bindings(
|
||||||
|
&format!("{}/{}", env!("CARGO_MANIFEST_DIR"), BDK_UDL),
|
||||||
|
None,
|
||||||
|
vec!["python"],
|
||||||
|
Some(&out_path),
|
||||||
|
false,
|
||||||
|
)?;
|
||||||
|
|
||||||
|
if let Some(name) = env::var("GENERATE_PYTHON_BINDINGS_FIXUP_LIB_PATH").ok() {
|
||||||
|
fixup_python_lib_path(&out_path, &name)?;
|
||||||
|
}
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn main() -> Result<(), Box<dyn std::error::Error>> {
|
||||||
|
#[cfg(feature = "generate-python")]
|
||||||
|
generate_python()?;
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
717
src/lib.rs
717
src/lib.rs
@@ -1,63 +1,27 @@
|
|||||||
use bdk::bitcoin::hashes::hex::ToHex;
|
use bdk::bitcoin::hashes::hex::ToHex;
|
||||||
use bdk::bitcoin::secp256k1::Secp256k1;
|
use bdk::bitcoin::secp256k1::Secp256k1;
|
||||||
use bdk::bitcoin::util::psbt::PartiallySignedTransaction;
|
use bdk::bitcoin::util::psbt::PartiallySignedTransaction;
|
||||||
use bdk::bitcoin::{Address, Network, OutPoint as BdkOutPoint, Script, Txid};
|
use bdk::bitcoin::{Address, Network};
|
||||||
use bdk::blockchain::any::{AnyBlockchain, AnyBlockchainConfig};
|
use bdk::blockchain::any::{AnyBlockchain, AnyBlockchainConfig};
|
||||||
|
use bdk::blockchain::Progress;
|
||||||
use bdk::blockchain::{
|
use bdk::blockchain::{
|
||||||
electrum::ElectrumBlockchainConfig, esplora::EsploraBlockchainConfig, ConfigurableBlockchain,
|
electrum::ElectrumBlockchainConfig, esplora::EsploraBlockchainConfig, ConfigurableBlockchain,
|
||||||
};
|
};
|
||||||
use bdk::blockchain::{Blockchain as BdkBlockchain, Progress as BdkProgress};
|
|
||||||
use bdk::database::any::{AnyDatabase, SledDbConfiguration, SqliteDbConfiguration};
|
use bdk::database::any::{AnyDatabase, SledDbConfiguration, SqliteDbConfiguration};
|
||||||
use bdk::database::{AnyDatabaseConfig, ConfigurableDatabase};
|
use bdk::database::{AnyDatabaseConfig, ConfigurableDatabase};
|
||||||
use bdk::keys::bip39::{Language, Mnemonic, WordCount};
|
use bdk::keys::bip39::{Language, Mnemonic, WordCount};
|
||||||
use bdk::keys::{DerivableKey, ExtendedKey, GeneratableKey, GeneratedKey};
|
use bdk::keys::{DerivableKey, ExtendedKey, GeneratableKey, GeneratedKey};
|
||||||
use bdk::miniscript::BareCtx;
|
use bdk::miniscript::BareCtx;
|
||||||
use bdk::wallet::tx_builder::ChangeSpendPolicy;
|
use bdk::wallet::AddressIndex;
|
||||||
use bdk::wallet::AddressIndex as BdkAddressIndex;
|
use bdk::{BlockTime, Error, FeeRate, SignOptions, Wallet as BdkWallet};
|
||||||
use bdk::wallet::AddressInfo as BdkAddressInfo;
|
use std::convert::TryFrom;
|
||||||
use bdk::{
|
|
||||||
BlockTime, Error, FeeRate, KeychainKind, SignOptions, SyncOptions as BdkSyncOptions,
|
|
||||||
Wallet as BdkWallet,
|
|
||||||
};
|
|
||||||
use std::collections::HashSet;
|
|
||||||
use std::convert::{From, TryFrom};
|
|
||||||
use std::fmt;
|
|
||||||
use std::ops::Deref;
|
|
||||||
use std::str::FromStr;
|
use std::str::FromStr;
|
||||||
use std::sync::{Arc, Mutex, MutexGuard};
|
use std::sync::{Mutex, MutexGuard};
|
||||||
|
|
||||||
uniffi_macros::include_scaffolding!("bdk");
|
uniffi_macros::include_scaffolding!("bdk");
|
||||||
|
|
||||||
type BdkError = Error;
|
type BdkError = Error;
|
||||||
|
|
||||||
pub struct AddressInfo {
|
|
||||||
pub index: u32,
|
|
||||||
pub address: String,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl From<BdkAddressInfo> for AddressInfo {
|
|
||||||
fn from(x: bdk::wallet::AddressInfo) -> AddressInfo {
|
|
||||||
AddressInfo {
|
|
||||||
index: x.index,
|
|
||||||
address: x.address.to_string(),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub enum AddressIndex {
|
|
||||||
New,
|
|
||||||
LastUnused,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl From<AddressIndex> for BdkAddressIndex {
|
|
||||||
fn from(x: AddressIndex) -> BdkAddressIndex {
|
|
||||||
match x {
|
|
||||||
AddressIndex::New => BdkAddressIndex::New,
|
|
||||||
AddressIndex::LastUnused => BdkAddressIndex::LastUnused,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub enum DatabaseConfig {
|
pub enum DatabaseConfig {
|
||||||
Memory,
|
Memory,
|
||||||
Sled { config: SledDbConfiguration },
|
Sled { config: SledDbConfiguration },
|
||||||
@@ -75,9 +39,9 @@ pub struct ElectrumConfig {
|
|||||||
pub struct EsploraConfig {
|
pub struct EsploraConfig {
|
||||||
pub base_url: String,
|
pub base_url: String,
|
||||||
pub proxy: Option<String>,
|
pub proxy: Option<String>,
|
||||||
pub concurrency: Option<u8>,
|
pub timeout_read: u64,
|
||||||
|
pub timeout_write: u64,
|
||||||
pub stop_gap: u64,
|
pub stop_gap: u64,
|
||||||
pub timeout: Option<u64>,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
pub enum BlockchainConfig {
|
pub enum BlockchainConfig {
|
||||||
@@ -85,9 +49,13 @@ pub enum BlockchainConfig {
|
|||||||
Esplora { config: EsploraConfig },
|
Esplora { config: EsploraConfig },
|
||||||
}
|
}
|
||||||
|
|
||||||
|
trait WalletHolder<B> {
|
||||||
|
fn get_wallet(&self) -> MutexGuard<BdkWallet<B, AnyDatabase>>;
|
||||||
|
}
|
||||||
|
|
||||||
#[derive(Debug, Clone, PartialEq, Eq, Default)]
|
#[derive(Debug, Clone, PartialEq, Eq, Default)]
|
||||||
pub struct TransactionDetails {
|
pub struct TransactionDetails {
|
||||||
pub fee: Option<u64>,
|
pub fees: Option<u64>,
|
||||||
pub received: u64,
|
pub received: u64,
|
||||||
pub sent: u64,
|
pub sent: u64,
|
||||||
pub txid: String,
|
pub txid: String,
|
||||||
@@ -107,7 +75,7 @@ pub enum Transaction {
|
|||||||
impl From<&bdk::TransactionDetails> for TransactionDetails {
|
impl From<&bdk::TransactionDetails> for TransactionDetails {
|
||||||
fn from(x: &bdk::TransactionDetails) -> TransactionDetails {
|
fn from(x: &bdk::TransactionDetails) -> TransactionDetails {
|
||||||
TransactionDetails {
|
TransactionDetails {
|
||||||
fee: x.fee,
|
fees: x.fee,
|
||||||
txid: x.txid.to_string(),
|
txid: x.txid.to_string(),
|
||||||
received: x.received,
|
received: x.received,
|
||||||
sent: x.sent,
|
sent: x.sent,
|
||||||
@@ -129,12 +97,130 @@ impl From<&bdk::TransactionDetails> for Transaction {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
struct Blockchain {
|
trait WalletOperations<B>: WalletHolder<B> {
|
||||||
blockchain_mutex: Mutex<AnyBlockchain>,
|
fn get_new_address(&self) -> String {
|
||||||
|
self.get_wallet()
|
||||||
|
.get_address(AddressIndex::New)
|
||||||
|
.unwrap()
|
||||||
|
.address
|
||||||
|
.to_string()
|
||||||
|
}
|
||||||
|
|
||||||
|
fn get_last_unused_address(&self) -> String {
|
||||||
|
self.get_wallet()
|
||||||
|
.get_address(AddressIndex::LastUnused)
|
||||||
|
.unwrap()
|
||||||
|
.address
|
||||||
|
.to_string()
|
||||||
|
}
|
||||||
|
|
||||||
|
fn get_balance(&self) -> Result<u64, Error> {
|
||||||
|
self.get_wallet().get_balance()
|
||||||
|
}
|
||||||
|
|
||||||
|
fn sign(&self, psbt: &PartiallySignedBitcoinTransaction) -> Result<(), Error> {
|
||||||
|
let mut psbt = psbt.internal.lock().unwrap();
|
||||||
|
let finalized = self.get_wallet().sign(&mut psbt, SignOptions::default())?;
|
||||||
|
match finalized {
|
||||||
|
true => Ok(()),
|
||||||
|
false => Err(BdkError::Generic(format!(
|
||||||
|
"transaction signing not finalized {:?}",
|
||||||
|
psbt
|
||||||
|
))),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn get_transactions(&self) -> Result<Vec<Transaction>, Error> {
|
||||||
|
let transactions = self.get_wallet().list_transactions(true)?;
|
||||||
|
Ok(transactions.iter().map(Transaction::from).collect())
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
impl Blockchain {
|
struct Wallet {
|
||||||
fn new(blockchain_config: BlockchainConfig) -> Result<Self, BdkError> {
|
wallet_mutex: Mutex<BdkWallet<AnyBlockchain, AnyDatabase>>,
|
||||||
|
}
|
||||||
|
|
||||||
|
pub trait BdkProgress: Send + Sync {
|
||||||
|
fn update(&self, progress: f32, message: Option<String>);
|
||||||
|
}
|
||||||
|
|
||||||
|
struct BdkProgressHolder {
|
||||||
|
progress_update: Box<dyn BdkProgress>,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl Progress for BdkProgressHolder {
|
||||||
|
fn update(&self, progress: f32, message: Option<String>) -> Result<(), Error> {
|
||||||
|
self.progress_update.update(progress, message);
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
struct PartiallySignedBitcoinTransaction {
|
||||||
|
internal: Mutex<PartiallySignedTransaction>,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl PartiallySignedBitcoinTransaction {
|
||||||
|
fn new(
|
||||||
|
wallet: &Wallet,
|
||||||
|
recipient: String,
|
||||||
|
amount: u64,
|
||||||
|
fee_rate: Option<f32>, // satoshis per vbyte
|
||||||
|
) -> Result<Self, Error> {
|
||||||
|
let wallet = wallet.get_wallet();
|
||||||
|
match Address::from_str(&recipient) {
|
||||||
|
Ok(address) => {
|
||||||
|
let (psbt, _details) = {
|
||||||
|
let mut builder = wallet.build_tx();
|
||||||
|
builder.add_recipient(address.script_pubkey(), amount);
|
||||||
|
if let Some(sat_per_vb) = fee_rate {
|
||||||
|
builder.fee_rate(FeeRate::from_sat_per_vb(sat_per_vb));
|
||||||
|
}
|
||||||
|
builder.finish()?
|
||||||
|
};
|
||||||
|
Ok(PartiallySignedBitcoinTransaction {
|
||||||
|
internal: Mutex::new(psbt),
|
||||||
|
})
|
||||||
|
}
|
||||||
|
Err(..) => Err(BdkError::Generic(
|
||||||
|
"failed to read wallet address".to_string(),
|
||||||
|
)),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn deserialize(psbt_base64: String) -> Result<Self, Error> {
|
||||||
|
let psbt: PartiallySignedTransaction = PartiallySignedTransaction::from_str(&psbt_base64)?;
|
||||||
|
Ok(PartiallySignedBitcoinTransaction {
|
||||||
|
internal: Mutex::new(psbt),
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn serialize(&self) -> String {
|
||||||
|
let psbt = self.internal.lock().unwrap().clone();
|
||||||
|
psbt.to_string()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl WalletHolder<AnyBlockchain> for Wallet {
|
||||||
|
fn get_wallet(&self) -> MutexGuard<BdkWallet<AnyBlockchain, AnyDatabase>> {
|
||||||
|
self.wallet_mutex.lock().expect("wallet")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl WalletOperations<AnyBlockchain> for Wallet {}
|
||||||
|
|
||||||
|
impl Wallet {
|
||||||
|
fn new(
|
||||||
|
descriptor: String,
|
||||||
|
change_descriptor: Option<String>,
|
||||||
|
network: Network,
|
||||||
|
database_config: DatabaseConfig,
|
||||||
|
blockchain_config: BlockchainConfig,
|
||||||
|
) -> Result<Self, BdkError> {
|
||||||
|
let any_database_config = match database_config {
|
||||||
|
DatabaseConfig::Memory => AnyDatabaseConfig::Memory(()),
|
||||||
|
DatabaseConfig::Sled { config } => AnyDatabaseConfig::Sled(config),
|
||||||
|
DatabaseConfig::Sqlite { config } => AnyDatabaseConfig::Sqlite(config),
|
||||||
|
};
|
||||||
let any_blockchain_config = match blockchain_config {
|
let any_blockchain_config = match blockchain_config {
|
||||||
BlockchainConfig::Electrum { config } => {
|
BlockchainConfig::Electrum { config } => {
|
||||||
AnyBlockchainConfig::Electrum(ElectrumBlockchainConfig {
|
AnyBlockchainConfig::Electrum(ElectrumBlockchainConfig {
|
||||||
@@ -149,205 +235,41 @@ impl Blockchain {
|
|||||||
AnyBlockchainConfig::Esplora(EsploraBlockchainConfig {
|
AnyBlockchainConfig::Esplora(EsploraBlockchainConfig {
|
||||||
base_url: config.base_url,
|
base_url: config.base_url,
|
||||||
proxy: config.proxy,
|
proxy: config.proxy,
|
||||||
concurrency: config.concurrency,
|
timeout_read: config.timeout_read,
|
||||||
|
timeout_write: config.timeout_write,
|
||||||
stop_gap: usize::try_from(config.stop_gap).unwrap(),
|
stop_gap: usize::try_from(config.stop_gap).unwrap(),
|
||||||
timeout: config.timeout,
|
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
let blockchain = AnyBlockchain::from_config(&any_blockchain_config)?;
|
|
||||||
Ok(Self {
|
|
||||||
blockchain_mutex: Mutex::new(blockchain),
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn get_blockchain(&self) -> MutexGuard<AnyBlockchain> {
|
|
||||||
self.blockchain_mutex.lock().expect("blockchain")
|
|
||||||
}
|
|
||||||
|
|
||||||
fn broadcast(&self, psbt: &PartiallySignedBitcoinTransaction) -> Result<(), Error> {
|
|
||||||
let tx = psbt.internal.lock().unwrap().clone().extract_tx();
|
|
||||||
self.get_blockchain().broadcast(&tx)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
struct Wallet {
|
|
||||||
wallet_mutex: Mutex<BdkWallet<AnyDatabase>>,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Clone, Debug, PartialEq, Eq, Hash)]
|
|
||||||
pub struct OutPoint {
|
|
||||||
txid: String,
|
|
||||||
vout: u32,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl From<&OutPoint> for BdkOutPoint {
|
|
||||||
fn from(x: &OutPoint) -> BdkOutPoint {
|
|
||||||
BdkOutPoint {
|
|
||||||
txid: Txid::from_str(&x.txid).unwrap(),
|
|
||||||
vout: x.vout,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub struct TxOut {
|
|
||||||
value: u64,
|
|
||||||
address: String,
|
|
||||||
}
|
|
||||||
|
|
||||||
pub struct LocalUtxo {
|
|
||||||
outpoint: OutPoint,
|
|
||||||
txout: TxOut,
|
|
||||||
keychain: KeychainKind,
|
|
||||||
is_spent: bool,
|
|
||||||
}
|
|
||||||
|
|
||||||
// This trait is used to convert the bdk TxOut type with field `script_pubkey: Script`
|
|
||||||
// into the bdk-ffi TxOut type which has a field `address: String` instead
|
|
||||||
trait NetworkLocalUtxo {
|
|
||||||
fn from_utxo(x: &bdk::LocalUtxo, network: Network) -> LocalUtxo;
|
|
||||||
}
|
|
||||||
|
|
||||||
impl NetworkLocalUtxo for LocalUtxo {
|
|
||||||
fn from_utxo(x: &bdk::LocalUtxo, network: Network) -> LocalUtxo {
|
|
||||||
LocalUtxo {
|
|
||||||
outpoint: OutPoint {
|
|
||||||
txid: x.outpoint.txid.to_string(),
|
|
||||||
vout: x.outpoint.vout,
|
|
||||||
},
|
|
||||||
txout: TxOut {
|
|
||||||
value: x.txout.value,
|
|
||||||
address: bdk::bitcoin::util::address::Address::from_script(
|
|
||||||
&x.txout.script_pubkey,
|
|
||||||
network,
|
|
||||||
)
|
|
||||||
.unwrap()
|
|
||||||
.to_string(),
|
|
||||||
},
|
|
||||||
keychain: x.keychain,
|
|
||||||
is_spent: x.is_spent,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub trait Progress: Send + Sync + 'static {
|
|
||||||
fn update(&self, progress: f32, message: Option<String>);
|
|
||||||
}
|
|
||||||
|
|
||||||
struct ProgressHolder {
|
|
||||||
progress: Box<dyn Progress>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl BdkProgress for ProgressHolder {
|
|
||||||
fn update(&self, progress: f32, message: Option<String>) -> Result<(), Error> {
|
|
||||||
self.progress.update(progress, message);
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl fmt::Debug for ProgressHolder {
|
|
||||||
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
|
|
||||||
f.debug_struct("ProgressHolder").finish_non_exhaustive()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug)]
|
|
||||||
struct PartiallySignedBitcoinTransaction {
|
|
||||||
internal: Mutex<PartiallySignedTransaction>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl PartiallySignedBitcoinTransaction {
|
|
||||||
fn new(psbt_base64: String) -> Result<Self, Error> {
|
|
||||||
let psbt: PartiallySignedTransaction = PartiallySignedTransaction::from_str(&psbt_base64)?;
|
|
||||||
Ok(PartiallySignedBitcoinTransaction {
|
|
||||||
internal: Mutex::new(psbt),
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn serialize(&self) -> String {
|
|
||||||
let psbt = self.internal.lock().unwrap().clone();
|
|
||||||
psbt.to_string()
|
|
||||||
}
|
|
||||||
|
|
||||||
fn txid(&self) -> String {
|
|
||||||
let tx = self.internal.lock().unwrap().clone().extract_tx();
|
|
||||||
let txid = tx.txid();
|
|
||||||
txid.to_hex()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl Wallet {
|
|
||||||
fn new(
|
|
||||||
descriptor: String,
|
|
||||||
change_descriptor: Option<String>,
|
|
||||||
network: Network,
|
|
||||||
database_config: DatabaseConfig,
|
|
||||||
) -> Result<Self, BdkError> {
|
|
||||||
let any_database_config = match database_config {
|
|
||||||
DatabaseConfig::Memory => AnyDatabaseConfig::Memory(()),
|
|
||||||
DatabaseConfig::Sled { config } => AnyDatabaseConfig::Sled(config),
|
|
||||||
DatabaseConfig::Sqlite { config } => AnyDatabaseConfig::Sqlite(config),
|
|
||||||
};
|
|
||||||
let database = AnyDatabase::from_config(&any_database_config)?;
|
let database = AnyDatabase::from_config(&any_database_config)?;
|
||||||
|
let blockchain = AnyBlockchain::from_config(&any_blockchain_config)?;
|
||||||
let wallet_mutex = Mutex::new(BdkWallet::new(
|
let wallet_mutex = Mutex::new(BdkWallet::new(
|
||||||
&descriptor,
|
&descriptor,
|
||||||
change_descriptor.as_ref(),
|
change_descriptor.to_owned().as_ref(),
|
||||||
network,
|
network,
|
||||||
database,
|
database,
|
||||||
|
blockchain,
|
||||||
)?);
|
)?);
|
||||||
Ok(Wallet { wallet_mutex })
|
Ok(Wallet { wallet_mutex })
|
||||||
}
|
}
|
||||||
|
|
||||||
fn get_wallet(&self) -> MutexGuard<BdkWallet<AnyDatabase>> {
|
|
||||||
self.wallet_mutex.lock().expect("wallet")
|
|
||||||
}
|
|
||||||
|
|
||||||
fn get_network(&self) -> Network {
|
fn get_network(&self) -> Network {
|
||||||
self.get_wallet().network()
|
self.get_wallet().network()
|
||||||
}
|
}
|
||||||
|
|
||||||
fn sync(
|
fn sync(
|
||||||
&self,
|
&self,
|
||||||
blockchain: &Blockchain,
|
progress_update: Box<dyn BdkProgress>,
|
||||||
progress: Option<Box<dyn Progress>>,
|
max_address_param: Option<u32>,
|
||||||
) -> Result<(), BdkError> {
|
) -> Result<(), BdkError> {
|
||||||
let bdk_sync_opts = BdkSyncOptions {
|
|
||||||
progress: progress.map(|p| {
|
|
||||||
Box::new(ProgressHolder { progress: p })
|
|
||||||
as Box<(dyn bdk::blockchain::Progress + 'static)>
|
|
||||||
}),
|
|
||||||
};
|
|
||||||
|
|
||||||
let blockchain = blockchain.get_blockchain();
|
|
||||||
self.get_wallet().sync(blockchain.deref(), bdk_sync_opts)
|
|
||||||
}
|
|
||||||
|
|
||||||
fn get_address(&self, address_index: AddressIndex) -> Result<AddressInfo, BdkError> {
|
|
||||||
self.get_wallet()
|
self.get_wallet()
|
||||||
.get_address(address_index.into())
|
.sync(BdkProgressHolder { progress_update }, max_address_param)
|
||||||
.map(AddressInfo::from)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
fn get_balance(&self) -> Result<u64, Error> {
|
fn broadcast(&self, psbt: &PartiallySignedBitcoinTransaction) -> Result<String, Error> {
|
||||||
self.get_wallet().get_balance()
|
let tx = psbt.internal.lock().unwrap().clone().extract_tx();
|
||||||
}
|
let txid = self.get_wallet().broadcast(&tx)?;
|
||||||
|
Ok(txid.to_hex())
|
||||||
fn sign(&self, psbt: &PartiallySignedBitcoinTransaction) -> Result<bool, Error> {
|
|
||||||
let mut psbt = psbt.internal.lock().unwrap();
|
|
||||||
self.get_wallet().sign(&mut psbt, SignOptions::default())
|
|
||||||
}
|
|
||||||
|
|
||||||
fn get_transactions(&self) -> Result<Vec<Transaction>, Error> {
|
|
||||||
let transactions = self.get_wallet().list_transactions(true)?;
|
|
||||||
Ok(transactions.iter().map(Transaction::from).collect())
|
|
||||||
}
|
|
||||||
|
|
||||||
fn list_unspent(&self) -> Result<Vec<LocalUtxo>, Error> {
|
|
||||||
let unspents = self.get_wallet().list_unspent()?;
|
|
||||||
Ok(unspents
|
|
||||||
.iter()
|
|
||||||
.map(|u| LocalUtxo::from_utxo(u, self.get_network()))
|
|
||||||
.collect())
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -391,347 +313,4 @@ fn restore_extended_key(
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
fn to_script_pubkey(address: &str) -> Result<Script, BdkError> {
|
|
||||||
Address::from_str(address)
|
|
||||||
.map(|x| x.script_pubkey())
|
|
||||||
.map_err(|e| BdkError::Generic(e.to_string()))
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Clone, Debug)]
|
|
||||||
enum RbfValue {
|
|
||||||
Default,
|
|
||||||
Value(u32),
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Clone, Debug)]
|
|
||||||
struct TxBuilder {
|
|
||||||
recipients: Vec<(String, u64)>,
|
|
||||||
utxos: Vec<OutPoint>,
|
|
||||||
unspendable: HashSet<OutPoint>,
|
|
||||||
change_policy: ChangeSpendPolicy,
|
|
||||||
manually_selected_only: bool,
|
|
||||||
fee_rate: Option<f32>,
|
|
||||||
fee_absolute: Option<u64>,
|
|
||||||
drain_wallet: bool,
|
|
||||||
drain_to: Option<String>,
|
|
||||||
rbf: Option<RbfValue>,
|
|
||||||
data: Vec<u8>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl TxBuilder {
|
|
||||||
fn new() -> Self {
|
|
||||||
TxBuilder {
|
|
||||||
recipients: Vec::new(),
|
|
||||||
utxos: Vec::new(),
|
|
||||||
unspendable: HashSet::new(),
|
|
||||||
change_policy: ChangeSpendPolicy::ChangeAllowed,
|
|
||||||
manually_selected_only: false,
|
|
||||||
fee_rate: None,
|
|
||||||
fee_absolute: None,
|
|
||||||
drain_wallet: false,
|
|
||||||
drain_to: None,
|
|
||||||
rbf: None,
|
|
||||||
data: Vec::new(),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn add_recipient(&self, recipient: String, amount: u64) -> Arc<Self> {
|
|
||||||
let mut recipients = self.recipients.to_vec();
|
|
||||||
recipients.append(&mut vec![(recipient, amount)]);
|
|
||||||
Arc::new(TxBuilder {
|
|
||||||
recipients,
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn add_unspendable(&self, unspendable: OutPoint) -> Arc<Self> {
|
|
||||||
let mut unspendable_hash_set = self.unspendable.clone();
|
|
||||||
unspendable_hash_set.insert(unspendable);
|
|
||||||
Arc::new(TxBuilder {
|
|
||||||
unspendable: unspendable_hash_set,
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn add_utxo(&self, outpoint: OutPoint) -> Arc<Self> {
|
|
||||||
self.add_utxos(vec![outpoint])
|
|
||||||
}
|
|
||||||
|
|
||||||
fn add_utxos(&self, mut outpoints: Vec<OutPoint>) -> Arc<Self> {
|
|
||||||
let mut utxos = self.utxos.to_vec();
|
|
||||||
utxos.append(&mut outpoints);
|
|
||||||
Arc::new(TxBuilder {
|
|
||||||
utxos,
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn do_not_spend_change(&self) -> Arc<Self> {
|
|
||||||
Arc::new(TxBuilder {
|
|
||||||
change_policy: ChangeSpendPolicy::ChangeForbidden,
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn manually_selected_only(&self) -> Arc<Self> {
|
|
||||||
Arc::new(TxBuilder {
|
|
||||||
manually_selected_only: true,
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn only_spend_change(&self) -> Arc<Self> {
|
|
||||||
Arc::new(TxBuilder {
|
|
||||||
change_policy: ChangeSpendPolicy::OnlyChange,
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn unspendable(&self, unspendable: Vec<OutPoint>) -> Arc<Self> {
|
|
||||||
Arc::new(TxBuilder {
|
|
||||||
unspendable: unspendable.into_iter().collect(),
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn fee_rate(&self, sat_per_vb: f32) -> Arc<Self> {
|
|
||||||
Arc::new(TxBuilder {
|
|
||||||
fee_rate: Some(sat_per_vb),
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn fee_absolute(&self, fee_amount: u64) -> Arc<Self> {
|
|
||||||
Arc::new(TxBuilder {
|
|
||||||
fee_absolute: Some(fee_amount),
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn drain_wallet(&self) -> Arc<Self> {
|
|
||||||
Arc::new(TxBuilder {
|
|
||||||
drain_wallet: true,
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn drain_to(&self, address: String) -> Arc<Self> {
|
|
||||||
Arc::new(TxBuilder {
|
|
||||||
drain_to: Some(address),
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn enable_rbf(&self) -> Arc<Self> {
|
|
||||||
Arc::new(TxBuilder {
|
|
||||||
rbf: Some(RbfValue::Default),
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn enable_rbf_with_sequence(&self, nsequence: u32) -> Arc<Self> {
|
|
||||||
Arc::new(TxBuilder {
|
|
||||||
rbf: Some(RbfValue::Value(nsequence)),
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn add_data(&self, data: Vec<u8>) -> Arc<Self> {
|
|
||||||
Arc::new(TxBuilder {
|
|
||||||
data,
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn finish(&self, wallet: &Wallet) -> Result<Arc<PartiallySignedBitcoinTransaction>, Error> {
|
|
||||||
let wallet = wallet.get_wallet();
|
|
||||||
let mut tx_builder = wallet.build_tx();
|
|
||||||
for (address, amount) in &self.recipients {
|
|
||||||
tx_builder.add_recipient(to_script_pubkey(address)?, *amount);
|
|
||||||
}
|
|
||||||
tx_builder.change_policy(self.change_policy);
|
|
||||||
if !self.utxos.is_empty() {
|
|
||||||
let bdk_utxos: Vec<BdkOutPoint> = self.utxos.iter().map(BdkOutPoint::from).collect();
|
|
||||||
let utxos: &[BdkOutPoint] = &bdk_utxos;
|
|
||||||
tx_builder.add_utxos(utxos)?;
|
|
||||||
}
|
|
||||||
if !self.unspendable.is_empty() {
|
|
||||||
let bdk_unspendable: Vec<BdkOutPoint> =
|
|
||||||
self.unspendable.iter().map(BdkOutPoint::from).collect();
|
|
||||||
tx_builder.unspendable(bdk_unspendable);
|
|
||||||
}
|
|
||||||
if self.manually_selected_only {
|
|
||||||
tx_builder.manually_selected_only();
|
|
||||||
}
|
|
||||||
if let Some(sat_per_vb) = self.fee_rate {
|
|
||||||
tx_builder.fee_rate(FeeRate::from_sat_per_vb(sat_per_vb));
|
|
||||||
}
|
|
||||||
if let Some(fee_amount) = self.fee_absolute {
|
|
||||||
tx_builder.fee_absolute(fee_amount);
|
|
||||||
}
|
|
||||||
if self.drain_wallet {
|
|
||||||
tx_builder.drain_wallet();
|
|
||||||
}
|
|
||||||
if let Some(address) = &self.drain_to {
|
|
||||||
tx_builder.drain_to(to_script_pubkey(address)?);
|
|
||||||
}
|
|
||||||
if let Some(rbf) = &self.rbf {
|
|
||||||
match *rbf {
|
|
||||||
RbfValue::Default => {
|
|
||||||
tx_builder.enable_rbf();
|
|
||||||
}
|
|
||||||
RbfValue::Value(nsequence) => {
|
|
||||||
tx_builder.enable_rbf_with_sequence(nsequence);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if !&self.data.is_empty() {
|
|
||||||
tx_builder.add_data(self.data.as_slice());
|
|
||||||
}
|
|
||||||
|
|
||||||
tx_builder
|
|
||||||
.finish()
|
|
||||||
.map(|(psbt, _)| PartiallySignedBitcoinTransaction {
|
|
||||||
internal: Mutex::new(psbt),
|
|
||||||
})
|
|
||||||
.map(Arc::new)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Clone)]
|
|
||||||
struct BumpFeeTxBuilder {
|
|
||||||
txid: String,
|
|
||||||
fee_rate: f32,
|
|
||||||
allow_shrinking: Option<String>,
|
|
||||||
rbf: Option<RbfValue>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl BumpFeeTxBuilder {
|
|
||||||
fn new(txid: String, fee_rate: f32) -> Self {
|
|
||||||
Self {
|
|
||||||
txid,
|
|
||||||
fee_rate,
|
|
||||||
allow_shrinking: None,
|
|
||||||
rbf: None,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn allow_shrinking(&self, address: String) -> Arc<Self> {
|
|
||||||
Arc::new(Self {
|
|
||||||
allow_shrinking: Some(address),
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn enable_rbf(&self) -> Arc<Self> {
|
|
||||||
Arc::new(Self {
|
|
||||||
rbf: Some(RbfValue::Default),
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn enable_rbf_with_sequence(&self, nsequence: u32) -> Arc<Self> {
|
|
||||||
Arc::new(Self {
|
|
||||||
rbf: Some(RbfValue::Value(nsequence)),
|
|
||||||
..self.clone()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn finish(&self, wallet: &Wallet) -> Result<Arc<PartiallySignedBitcoinTransaction>, Error> {
|
|
||||||
let wallet = wallet.get_wallet();
|
|
||||||
let txid = Txid::from_str(self.txid.as_str())?;
|
|
||||||
let mut tx_builder = wallet.build_fee_bump(txid)?;
|
|
||||||
tx_builder.fee_rate(FeeRate::from_sat_per_vb(self.fee_rate));
|
|
||||||
if let Some(allow_shrinking) = &self.allow_shrinking {
|
|
||||||
let address =
|
|
||||||
Address::from_str(allow_shrinking).map_err(|e| Error::Generic(e.to_string()))?;
|
|
||||||
let script = address.script_pubkey();
|
|
||||||
tx_builder.allow_shrinking(script)?;
|
|
||||||
}
|
|
||||||
if let Some(rbf) = &self.rbf {
|
|
||||||
match *rbf {
|
|
||||||
RbfValue::Default => {
|
|
||||||
tx_builder.enable_rbf();
|
|
||||||
}
|
|
||||||
RbfValue::Value(nsequence) => {
|
|
||||||
tx_builder.enable_rbf_with_sequence(nsequence);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
tx_builder
|
|
||||||
.finish()
|
|
||||||
.map(|(psbt, _)| PartiallySignedBitcoinTransaction {
|
|
||||||
internal: Mutex::new(psbt),
|
|
||||||
})
|
|
||||||
.map(Arc::new)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
uniffi::deps::static_assertions::assert_impl_all!(Wallet: Sync, Send);
|
uniffi::deps::static_assertions::assert_impl_all!(Wallet: Sync, Send);
|
||||||
|
|
||||||
// The goal of these tests to to ensure `bdk-ffi` intermediate code correctly calls `bdk` APIs.
|
|
||||||
// These tests should not be used to verify `bdk` behavior that is already tested in the `bdk`
|
|
||||||
// crate.
|
|
||||||
#[cfg(test)]
|
|
||||||
mod test {
|
|
||||||
use crate::{TxBuilder, Wallet};
|
|
||||||
use bdk::bitcoin::Address;
|
|
||||||
use bdk::bitcoin::Network::Testnet;
|
|
||||||
use bdk::wallet::get_funded_wallet;
|
|
||||||
use std::str::FromStr;
|
|
||||||
use std::sync::Mutex;
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn test_drain_wallet() {
|
|
||||||
let test_wpkh = "wpkh(cVpPVruEDdmutPzisEsYvtST1usBR3ntr8pXSyt6D2YYqXRyPcFW)";
|
|
||||||
let (funded_wallet, _, _) = get_funded_wallet(test_wpkh);
|
|
||||||
let test_wallet = Wallet {
|
|
||||||
wallet_mutex: Mutex::new(funded_wallet),
|
|
||||||
};
|
|
||||||
let drain_to_address = "tb1ql7w62elx9ucw4pj5lgw4l028hmuw80sndtntxt".to_string();
|
|
||||||
let tx_builder = TxBuilder::new()
|
|
||||||
.drain_wallet()
|
|
||||||
.drain_to(drain_to_address.clone());
|
|
||||||
//dbg!(&tx_builder);
|
|
||||||
assert!(tx_builder.drain_wallet);
|
|
||||||
assert_eq!(tx_builder.drain_to, Some(drain_to_address));
|
|
||||||
|
|
||||||
let psbt = tx_builder.finish(&test_wallet).unwrap();
|
|
||||||
let psbt = psbt.internal.lock().unwrap().clone();
|
|
||||||
|
|
||||||
// confirm one input with 50,000 sats
|
|
||||||
assert_eq!(psbt.inputs.len(), 1);
|
|
||||||
let input_value = psbt
|
|
||||||
.inputs
|
|
||||||
.get(0)
|
|
||||||
.cloned()
|
|
||||||
.unwrap()
|
|
||||||
.non_witness_utxo
|
|
||||||
.unwrap()
|
|
||||||
.output
|
|
||||||
.get(0)
|
|
||||||
.unwrap()
|
|
||||||
.value;
|
|
||||||
assert_eq!(input_value, 50_000_u64);
|
|
||||||
|
|
||||||
// confirm one output to correct address with all sats - fee
|
|
||||||
assert_eq!(psbt.outputs.len(), 1);
|
|
||||||
let output_address = Address::from_script(
|
|
||||||
&psbt
|
|
||||||
.unsigned_tx
|
|
||||||
.output
|
|
||||||
.get(0)
|
|
||||||
.cloned()
|
|
||||||
.unwrap()
|
|
||||||
.script_pubkey,
|
|
||||||
Testnet,
|
|
||||||
)
|
|
||||||
.unwrap();
|
|
||||||
assert_eq!(
|
|
||||||
output_address,
|
|
||||||
Address::from_str("tb1ql7w62elx9ucw4pj5lgw4l028hmuw80sndtntxt").unwrap()
|
|
||||||
);
|
|
||||||
let output_value = psbt.unsigned_tx.output.get(0).cloned().unwrap().value;
|
|
||||||
assert_eq!(output_value, 49_890_u64); // input - fee
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
Reference in New Issue
Block a user