bitsplain 0.1.0-alpha.1

Bitsplain helps understand Bitcoin-related binary data
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
101
102
103
104
105
106
107
108
109
110

use lightning::ln::features::{ChannelFeatures, NodeFeatures};
use lightning::ln::msgs::*;

use crate::dsl::{ann, auto};
use crate::ln::{rgb_color, short_channel_id};
use crate::nom::combinator::{success, value};
use crate::nom::multi::length_count;
use crate::nom::number::complete::*;
use crate::parse::*;
use crate::types::*;
use crate::value::Value;

pub fn gossip_timestamp_filter(s: Span) -> Parsed<GossipTimestampFilter> {
    let (s, _) = value(265, be_u16)(s)?;
    let (s, chain_hash) = parse(chain_hash_be, ann("Chain hash", auto()))(s)?;
    let (s, first_timestamp) = parse(timestamp(be_u32), ann("First timestamp", auto()))(s)?;
    let (s, timestamp_range) = parse(be_u32, ann("Timestamp range", auto()))(s)?;

    Ok((
        s,
        GossipTimestampFilter {
            chain_hash: chain_hash.block_hash,
            first_timestamp: first_timestamp.unix_timestamp() as u32,
            timestamp_range,
        },
    ))
}

pub fn node_announcement(s: Span) -> Parsed<()> {
    let (s, _) = value(257, be_u16)(s)?;
    let (s, _signature) = parse(signature, ann("Signature", auto()))(s)?;
    let (s, len) = parse(be_u16, ann("Features length", auto()))(s)?;

    let (s, features) = parse(
        length_count(success(len), u8),
        ann("Features", |b: &Vec<u8>| Value::bytes(b.clone())),
    )(s)?;

    let _features = NodeFeatures::from_le_bytes({
        let mut b = features;
        b.reverse();
        b
    });

    let (s, _timestamp) = parse(timestamp(be_u32), ann("Timestamp", auto()))(s)?;
    let (s, _node_id) = parse(public_key, ann("Node ID", auto()))(s)?;
    let (s, _rgb_color) = parse(rgb_color, ann("RGB Color", auto()))(s)?;
    let (s, _alias) = parse(
        bytes(32usize),
        ann("Alias", |b: &Vec<u8>| {
            Value::text(String::from_utf8_lossy(b).trim_end_matches('\0'))
        }),
    )(s)?;
    let (s, addr_len) = parse(be_u16, ann("Addresses length", auto()))(s)?;
    let (s, _addresses) = parse(
        length_count(success(addr_len), u8),
        ann("Addresses", "TODO"),
    )(s)?;

    Ok((s, ()))
}

pub fn channel_update(s: Span) -> Parsed<()> {
    let (s, _) = value(258, be_u16)(s)?;
    let (s, _signature) = parse(signature, ann("Signature", auto()))(s)?;
    let (s, _chain_hash) = parse(chain_hash_be, ann("Chain hash", auto()))(s)?;
    let (s, _scid) = parse(short_channel_id, ann("Short channel ID", auto()))(s)?;
    let (s, _timestamp) = parse(timestamp(be_u32), ann("Timestamp", auto()))(s)?;
    let (s, _) = parse(u8, ann("Message flags", auto()))(s)?;
    let (s, _flags) = parse(u8, ann("Channel flags", auto()))(s)?;
    let (s, _cltv_expiry_delta) = parse(be_u16, ann("CLTV expiry delta", auto()))(s)?;
    let (s, _htlc_minimum_msat) = parse(be_u64, ann("HTLC minimum msat", auto()))(s)?;
    let (s, _fee_base_msat) = parse(be_u32, ann("Fee base msat", auto()))(s)?;
    let (s, _fee_proportional_millionths) =
        parse(be_u32, ann("Fee proportional millionths", auto()))(s)?;
    let (s, _htlc_maximum_msat) = parse(be_u64, ann("HTLC maximum msat", auto()))(s)?;

    Ok((s, ()))
}

pub fn channel_announcement(s: Span) -> Parsed<()> {
    let (s, _) = value(256, be_u16)(s)?;
    let (s, _node_signature_1) = parse(signature, ann("Node signature 1", auto()))(s)?;
    let (s, _node_signature_2) = parse(signature, ann("Node signature 2", auto()))(s)?;
    let (s, _bitcoin_signature_1) = parse(signature, ann("Bitcoin signature 1", auto()))(s)?;
    let (s, _bitcoin_signature_2) = parse(signature, ann("Bitcoin signature 2", auto()))(s)?;
    let (s, len) = parse(be_u16, ann("Features length", auto()))(s)?;

    let (s, features) = parse(
        length_count(success(len), u8),
        ann("Features", |b: &Vec<u8>| Value::bytes(b.to_vec())),
    )(s)?;

    let _features = ChannelFeatures::from_le_bytes({
        let mut b = features;
        b.reverse();
        b
    });

    // TODO: print interpeted features

    let (s, _chain_hash) = parse(chain_hash_be, ann("Chain hash", auto()))(s)?;
    let (s, _scid) = parse(short_channel_id, ann("Short channel ID", auto()))(s)?;
    let (s, _node_id_1) = parse(public_key, ann("Node 1 ID", auto()))(s)?;
    let (s, _node_id_2) = parse(public_key, ann("Node 2 ID", auto()))(s)?;
    let (s, _bitcoin_key_1) = parse(public_key, ann("Bitcoin key 1", auto()))(s)?;
    let (s, _bitcoin_key_2) = parse(public_key, ann("Bitcoin key 2", auto()))(s)?;

    Ok((s, ()))
}