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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161

use crate::*;
use bitcoin::hashes::hex::ToHex;
use chainseeker::*;
use crate::db::tx::TxDB;
use crate::db::block::BlockContentDBValue;
use crate::db::utxo_server::UtxoServerValue;

pub fn create_vin(txin: &bitcoin::TxIn, previous_txout: &Option<bitcoin::TxOut>, config: &Config) -> Vin {
    Vin {
        txid: txin.previous_output.txid.to_string(),
        vout: txin.previous_output.vout,
        script_sig: ScriptSig {
            asm: txin.script_sig.asm(),
            hex: hex::encode(txin.script_sig.as_bytes()),
        },
        txinwitness: txin.witness.iter().map(hex::encode).collect(),
        sequence: txin.sequence,
        value: match previous_txout {
            Some(pt) => pt.value,
            None => 0,
        },
        address: match previous_txout {
            Some(previous_txout) => script_to_address_string(&previous_txout.script_pubkey, config),
            None => None,
        },
    }
}

pub fn create_script_pub_key(script_pubkey: &bitcoin::Script, config: &Config) -> ScriptPubKey {
    let address = bitcoin::Address::from_script(&script_pubkey, bitcoin::Network::Bitcoin /* any */);
    let address_str = script_to_address_string(&script_pubkey, config);
    ScriptPubKey {
        asm: script_pubkey.asm(),
        hex: hex::encode(script_pubkey.as_bytes()),
        r#type: address.map_or("unknown", |address| address.address_type().map_or("unknown", |address_type| {
            match address_type {
                bitcoin::AddressType::P2pkh  => "pubkeyhash",
                bitcoin::AddressType::P2sh   => "scripthash",
                bitcoin::AddressType::P2wpkh => "witnesspubkeyhash",
                bitcoin::AddressType::P2wsh  => "witnessscripthash",
            }
        })).to_string(),
        address: address_str,
    }
}

pub fn create_utxo(value: &UtxoServerValue, tx: &bitcoin::Transaction, config: &Config) -> Utxo {
    let previous_output = &tx.output[value.vout as usize];
    Utxo {
        txid: value.txid.to_string(),
        vout: value.vout,
        script_pub_key: create_script_pub_key(&previous_output.script_pubkey, config),
        value: previous_output.value,
    }
}

pub fn create_vout(txout: &bitcoin::TxOut, n: usize, config: &Config) -> Vout {
    Vout {
        value: txout.value,
        n,
        script_pub_key: create_script_pub_key(&txout.script_pubkey, config),
    }
}

pub fn create_block_header(block_content: &BlockContentDBValue, config: &Config) -> chainseeker::BlockHeader {
    let block_header = &block_content.block_header;
    chainseeker::BlockHeader {
        height           : block_content.height,
        header           : hex::encode(consensus_encode(&block_header)),
        hash             : block_header.block_hash().to_string(),
        version          : block_header.version,
        previousblockhash: block_header.prev_blockhash.to_string(),
        merkleroot       : block_header.merkle_root.to_string(),
        time             : block_header.time,
        bits             : format!("{:x}", block_header.bits),
        difficulty       : get_difficulty(block_header, config),
        nonce            : block_header.nonce,
        size             : block_content.size,
        strippedsize     : block_content.strippedsize,
        weight           : block_content.weight,
        ntxs             : block_content.txids.len(),
    }
}

pub fn create_block_with_txids(block_content: &BlockContentDBValue, config: &Config) -> BlockWithTxids {
    let block_header = create_block_header(block_content, config);
    BlockWithTxids {
        height           : block_header.height,
        header           : block_header.header,
        hash             : block_header.hash,
        version          : block_header.version,
        previousblockhash: block_header.previousblockhash,
        merkleroot       : block_header.merkleroot,
        time             : block_header.time,
        bits             : block_header.bits,
        difficulty       : block_header.difficulty,
        nonce            : block_header.nonce,
        size             : block_header.size,
        strippedsize     : block_header.strippedsize,
        weight           : block_header.weight,
        txids            : block_content.txids.iter().map(|txid| txid.to_hex()).collect::<Vec<String>>(),
    }
}

pub fn create_block_with_txs(tx_db: &TxDB, block_content: &BlockContentDBValue, config: &Config) -> BlockWithTxs {
    let block_header = create_block_header(block_content, config);
    // TODO: waiting upstream fix: https://github.com/rust-rocksdb/rust-rocksdb/issues/536
    //let txs = tx_db.multi_get_as_rest(block_content.txids.clone());
    let txs = block_content.txids.iter().map(|txid| {
        tx_db.get_as_rest(txid, config).unwrap()
    }).collect::<Vec<Transaction>>();
    BlockWithTxs {
        height           : block_header.height,
        header           : block_header.header,
        hash             : block_header.hash,
        version          : block_header.version,
        previousblockhash: block_header.previousblockhash,
        merkleroot       : block_header.merkleroot,
        time             : block_header.time,
        bits             : block_header.bits,
        difficulty       : block_header.difficulty,
        nonce            : block_header.nonce,
        size             : block_header.size,
        strippedsize     : block_header.strippedsize,
        weight           : block_header.weight,
        txs,
    }
}

pub fn create_block_summary(block: &BlockContentDBValue) -> BlockSummary {
    BlockSummary {
        hash        : block.block_header.block_hash().to_string(),
        time        : block.block_header.time,
        nonce       : block.block_header.nonce,
        size        : block.size,
        strippedsize: block.strippedsize,
        weight      : block.weight,
        txcount     : block.txids.len(),
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    #[test]
    fn rest() {
        let tx_db = TxDB::new("test/rest", true);
        let regtest_blocks = fixtures::regtest_blocks();
        for (height, block) in regtest_blocks.iter().enumerate() {
            for tx in block.txdata.iter() {
                tx_db.put_tx(tx, Some(height as u32)).unwrap();
            }
        }
        let config = config_example("rbtc");
        let block_rest = create_block_with_txs(&tx_db, &BlockContentDBValue::new(102, &regtest_blocks[102]), &config);
        let block_rest_json = serde_json::to_string(&block_rest).unwrap();
        println!("{}", block_rest_json);
        let block_json = r#"{"height":102,"header":"00000020f4a34bc39e46acbf6ad1cd786d978718b4ef94002eb080e86f383b77798b8b1e197bc47e4d72c8cc02c78a6c89a45db03f9906c1a60448bbeecf7b84566fc66eca41e560ffff7f2001000000","hash":"25263a195c89fae46d08558b1b501617aac630a6854000e19eb7ada6c39e6e0b","version":536870912,"previousblockhash":"1e8b8b79773b386fe880b02e0094efb41887976d78cdd16abfac469ec34ba3f4","merkleroot":"6ec66f56847bcfeebb4804a6c106993fb05da4896c8ac702ccc8724d7ec47b19","time":1625637322,"bits":"207fffff","difficulty":4.6565423739069247e-10,"nonce":1,"size":842,"strippedsize":481,"weight":2285,"txs":[{"confirmedHeight":102,"hex":"020000000001010000000000000000000000000000000000000000000000000000000000000000ffffffff0401660101ffffffff02547a062a0100000016001497033ca70d45fe6d49310859e132a9df98f976250000000000000000266a24aa21a9edaaed4e9155661fb1a2bfc87c1458ab0eebc25bf8f0b8126ccc9214c407ebd34f0120000000000000000000000000000000000000000000000000000000000000000000000000","txid":"b903046c3fb719a2a404e3b749609414b4f914b9cbf2eadf289c8ed2120aaebc","hash":"cb01519e3eee67593f7f0eb955a82a3aa6fc1c83364c50e7c6891b14320d88c7","size":169,"vsize":142,"weight":568,"version":2,"locktime":0,"vin":[{"txid":"0000000000000000000000000000000000000000000000000000000000000000","vout":4294967295,"scriptSig":{"asm":"OP_PUSHBYTES_1 66 OP_PUSHBYTES_1 01","hex":"01660101"},"txinwitness":["0000000000000000000000000000000000000000000000000000000000000000"],"sequence":4294967295,"value":0,"address":null}],"vout":[{"value":5000034900,"n":0,"scriptPubKey":{"asm":"OP_0 OP_PUSHBYTES_20 97033ca70d45fe6d49310859e132a9df98f97625","hex":"001497033ca70d45fe6d49310859e132a9df98f97625","type":"witnesspubkeyhash","address":"bcrt1qjupnefcdghlx6jf3ppv7zv4fm7v0ja39dzzwvd"}},{"value":0,"n":1,"scriptPubKey":{"asm":"OP_RETURN OP_PUSHBYTES_36 aa21a9edaaed4e9155661fb1a2bfc87c1458ab0eebc25bf8f0b8126ccc9214c407ebd34f","hex":"6a24aa21a9edaaed4e9155661fb1a2bfc87c1458ab0eebc25bf8f0b8126ccc9214c407ebd34f","type":"unknown","address":null}}],"fee":-5000034900},{"confirmedHeight":102,"hex":"02000000000101592f96fe043aaa22cdcb6f6e710946aa0af25dff4536759f6873965555a6660c0000000000fdffffff02ecd90f2401000000160014629ef06211f8e75e223b6338228a025bd15b0db900e1f50500000000160014f0e9ede24bceb0c16fdce952279d8094dc6b3f5802473044022057f0dde0e8d094034f47a136ae22a433e0216d5b1cfa3a03d8d259660148744702204377d2dbf3e442128c03097af4d4fa56b52b0cc7d9c24511b99d45a47e8df2d7012102b934d90a0aa5e0b73e04d00df3a8633ee16d24dad9ab21697f1dc5feb43fdbed65000000","txid":"e6a6a7db6faadbfc0815fd3a78c3b5d15cb733dde8aca0e911b6f565ea24ee73","hash":"4fdf235851b72bb7ddc8f6d86e43797bb42e3601ee1eb1e8d8a0e157b3c81af6","size":222,"vsize":141,"weight":561,"version":2,"locktime":101,"vin":[{"txid":"0c66a655559673689f753645ff5df20aaa4609716e6fcbcd22aa3a04fe962f59","vout":0,"scriptSig":{"asm":"","hex":""},"txinwitness":["3044022057f0dde0e8d094034f47a136ae22a433e0216d5b1cfa3a03d8d259660148744702204377d2dbf3e442128c03097af4d4fa56b52b0cc7d9c24511b99d45a47e8df2d701","02b934d90a0aa5e0b73e04d00df3a8633ee16d24dad9ab21697f1dc5feb43fdbed"],"sequence":4294967293,"value":5000000000,"address":"bcrt1qjupnefcdghlx6jf3ppv7zv4fm7v0ja39dzzwvd"}],"vout":[{"value":4899985900,"n":0,"scriptPubKey":{"asm":"OP_0 OP_PUSHBYTES_20 629ef06211f8e75e223b6338228a025bd15b0db9","hex":"0014629ef06211f8e75e223b6338228a025bd15b0db9","type":"witnesspubkeyhash","address":"bcrt1qv200qcs3lrn4ug3mvvuz9zszt0g4krde3uqyzy"}},{"value":100000000,"n":1,"scriptPubKey":{"asm":"OP_0 OP_PUSHBYTES_20 f0e9ede24bceb0c16fdce952279d8094dc6b3f58","hex":"0014f0e9ede24bceb0c16fdce952279d8094dc6b3f58","type":"witnesspubkeyhash","address":"bcrt1q7r57mcjte6cvzm7ua9fz08vqjnwxk06c2v6jdv"}}],"fee":14100},{"confirmedHeight":102,"hex":"0200000000010273ee24ea65f5b611e9a0ace8dd33b75cd1b5c3783afd1508fcdbaa6fdba7a6e60000000000fdffffff73ee24ea65f5b611e9a0ace8dd33b75cd1b5c3783afd1508fcdbaa6fdba7a6e60100000000fdffffff02001110240100000016001413bb0bcb776f3e15fa8800877552044d4db27b96ac58f50500000000160014261b6555a3cb5d3593c0275ff46f31c36e42a4c70247304402207a89cf2b2d7620ace221894746c4a72f5fd5dd5bbe9e56018b182eaf046e9766022050a14136c20402b281c244a918856b9e866b5fc77182334dd6242993e2144b7d0121034968df50370db27d51b294cba769ec47e0accb3a582c312549303c555ca834d102473044022058a1f0d9b8bde83c28954a1cfac6a3f43f8f8b53529df47d0ef2f7d66f8f42bb022026993b9ba88bedff19ec3f70d32bab177d35e0570f8c86a9b2eac5b359189c1d012103d0d5b793a8a23ff2e92b6204c15f72fd51765ad6c01f6ebd9e712adee11bda4065000000","txid":"29704e049abbacf3222cd8af9654afe6c7c91d5d9f2faa5d2f0f3cd5de3a812d","hash":"fb3551865d89fae25b8bcc5a02da25ad91d6fe1c0d4fd391b4c7b1b69e9ece63","size":370,"vsize":208,"weight":832,"version":2,"locktime":101,"vin":[{"txid":"e6a6a7db6faadbfc0815fd3a78c3b5d15cb733dde8aca0e911b6f565ea24ee73","vout":0,"scriptSig":{"asm":"","hex":""},"txinwitness":["304402207a89cf2b2d7620ace221894746c4a72f5fd5dd5bbe9e56018b182eaf046e9766022050a14136c20402b281c244a918856b9e866b5fc77182334dd6242993e2144b7d01","034968df50370db27d51b294cba769ec47e0accb3a582c312549303c555ca834d1"],"sequence":4294967293,"value":4899985900,"address":"bcrt1qv200qcs3lrn4ug3mvvuz9zszt0g4krde3uqyzy"},{"txid":"e6a6a7db6faadbfc0815fd3a78c3b5d15cb733dde8aca0e911b6f565ea24ee73","vout":1,"scriptSig":{"asm":"","hex":""},"txinwitness":["3044022058a1f0d9b8bde83c28954a1cfac6a3f43f8f8b53529df47d0ef2f7d66f8f42bb022026993b9ba88bedff19ec3f70d32bab177d35e0570f8c86a9b2eac5b359189c1d01","03d0d5b793a8a23ff2e92b6204c15f72fd51765ad6c01f6ebd9e712adee11bda40"],"sequence":4294967293,"value":100000000,"address":"bcrt1q7r57mcjte6cvzm7ua9fz08vqjnwxk06c2v6jdv"}],"vout":[{"value":4900000000,"n":0,"scriptPubKey":{"asm":"OP_0 OP_PUSHBYTES_20 13bb0bcb776f3e15fa8800877552044d4db27b96","hex":"001413bb0bcb776f3e15fa8800877552044d4db27b96","type":"witnesspubkeyhash","address":"bcrt1qzwashjmhdulpt75gqzrh25syf4xmy7uk6clm0p"}},{"value":99965100,"n":1,"scriptPubKey":{"asm":"OP_0 OP_PUSHBYTES_20 261b6555a3cb5d3593c0275ff46f31c36e42a4c7","hex":"0014261b6555a3cb5d3593c0275ff46f31c36e42a4c7","type":"witnesspubkeyhash","address":"bcrt1qycdk24dredwnty7qya0lgme3cdhy9fx83qc9wd"}}],"fee":20800}]}"#;
        assert_eq!(block_rest_json, block_json);
    }
}