blvm-node 0.1.2

Bitcoin Commons BLVM: Minimal Bitcoin node implementation using blvm-protocol and blvm-consensus
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

//! Mempool endpoints
//!
//! GET /api/v1/mempool
//! GET /api/v1/mempool/transactions/{txid}
//! GET /api/v1/mempool/transactions/{txid}/ancestors
//! GET /api/v1/mempool/transactions/{txid}/descendants
//! GET /api/v1/mempool/stats
//! POST /api/v1/mempool/save
//! POST /api/v1/mempool/transactions/{txid}/priority

use crate::rpc::mempool::MempoolRpc;
use anyhow::Result;
use serde_json::{json, Value};

/// Get mempool transactions
pub async fn get_mempool(mempool: &MempoolRpc, verbose: bool) -> Result<Value> {
    let params = json!([verbose]);
    let txs = mempool.getrawmempool(&params).await?;
    Ok(txs)
}

/// Get mempool transaction by ID
pub async fn get_mempool_transaction(mempool: &MempoolRpc, txid: &str) -> Result<Value> {
    let params = json!([txid]);
    let entry = mempool.getmempoolentry(&params).await?;
    Ok(entry)
}

/// Get mempool transaction ancestors
pub async fn get_mempool_ancestors(
    mempool: &MempoolRpc,
    txid: &str,
    verbose: bool,
) -> Result<Value> {
    let params = json!([txid, verbose]);
    let ancestors = mempool.getmempoolancestors(&params).await?;
    Ok(ancestors)
}

/// Get mempool transaction descendants
pub async fn get_mempool_descendants(
    mempool: &MempoolRpc,
    txid: &str,
    verbose: bool,
) -> Result<Value> {
    let params = json!([txid, verbose]);
    let descendants = mempool.getmempooldescendants(&params).await?;
    Ok(descendants)
}

/// Get mempool statistics
pub async fn get_mempool_stats(mempool: &MempoolRpc) -> Result<Value> {
    let params = json!([]);
    let info = mempool.getmempoolinfo(&params).await?;
    Ok(info)
}

/// Save mempool to disk
pub async fn save_mempool(mempool: &MempoolRpc) -> Result<Value> {
    let params = json!([]);
    let result = mempool.savemempool(&params).await?;
    Ok(result)
}

/// Prioritize transaction in mempool
pub async fn prioritize_transaction(
    mempool: &MempoolRpc,
    txid: &str,
    fee_delta: f64,
) -> Result<Value> {
    // `prioritisetransaction` is implemented on mining RPC; REST does not delegate yet.
    Err(anyhow::anyhow!(
        "prioritisetransaction not yet exposed via REST API"
    ))
}