harmoniis-wallet 0.1.97

Smart-contract wallet for the Harmoniis marketplace for agents and robots (RGB contracts, Witness-backed bearer state, Webcash fees)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100

//! Actor wrapping [`DeterministicBitcoinWallet`] for thread-safe Bitcoin operations.
//!
//! The Bitcoin wallet uses blocking BDK operations (sync, send). This actor
//! owns the wallet and uses `SyncContext` for blocking I/O.

use actix::prelude::*;
use bdk_wallet::bitcoin::Txid;

use crate::error::Result;
use crate::wallet::bitcoin::{BitcoinAddressKind, BitcoinSyncSnapshot, DeterministicBitcoinWallet};

/// Actor that owns a [`DeterministicBitcoinWallet`].
///
/// All BDK operations (Esplora sync, signing, broadcast) run on the actor's
/// dedicated thread via `SyncContext`.
pub struct BitcoinActor {
    wallet: DeterministicBitcoinWallet,
}

impl BitcoinActor {
    pub fn new(wallet: DeterministicBitcoinWallet) -> Self {
        Self { wallet }
    }
}

impl Actor for BitcoinActor {
    type Context = SyncContext<Self>;
}

// ── Messages ────────────────────────────────────────────────────────────────

#[derive(Message)]
#[rtype(result = "Result<BitcoinSyncSnapshot>")]
pub struct SyncWallet {
    pub esplora_url: String,
    pub stop_gap: usize,
    pub parallel: usize,
}

#[derive(Message)]
#[rtype(result = "Result<String>")]
pub struct ReceiveAddress {
    pub index: u32,
    pub kind: BitcoinAddressKind,
}

#[derive(Message)]
#[rtype(result = "Result<(String, String)>")]
pub struct DescriptorStrings {
    pub kind: BitcoinAddressKind,
}

#[derive(Message)]
#[rtype(result = "Result<Txid>")]
pub struct CreateSpend {
    pub dest: String,
    pub amount_sats: u64,
    pub fee_rate: u64,
    pub esplora_url: String,
    pub stop_gap: usize,
    pub parallel: usize,
}

// ── Handlers ────────────────────────────────────────────────────────────────

impl Handler<SyncWallet> for BitcoinActor {
    type Result = Result<BitcoinSyncSnapshot>;
    fn handle(&mut self, msg: SyncWallet, _ctx: &mut SyncContext<Self>) -> Self::Result {
        self.wallet
            .sync(&msg.esplora_url, msg.stop_gap, msg.parallel)
    }
}

impl Handler<ReceiveAddress> for BitcoinActor {
    type Result = Result<String>;
    fn handle(&mut self, msg: ReceiveAddress, _ctx: &mut SyncContext<Self>) -> Self::Result {
        self.wallet.receive_address_at_kind(msg.index, msg.kind)
    }
}

impl Handler<DescriptorStrings> for BitcoinActor {
    type Result = Result<(String, String)>;
    fn handle(&mut self, msg: DescriptorStrings, _ctx: &mut SyncContext<Self>) -> Self::Result {
        self.wallet.descriptor_strings_for(msg.kind)
    }
}

impl Handler<CreateSpend> for BitcoinActor {
    type Result = Result<Txid>;
    fn handle(&mut self, msg: CreateSpend, _ctx: &mut SyncContext<Self>) -> Self::Result {
        self.wallet.send_taproot_onchain(
            &msg.esplora_url,
            &msg.dest,
            msg.amount_sats,
            msg.fee_rate,
            msg.stop_gap,
            msg.parallel,
        )
    }
}