vuke 0.9.0

Research tool for studying vulnerable Bitcoin key generation practices
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

mod catalog;
mod error;
mod partition;
mod schema;

pub use catalog::RestCatalogClient;
pub use error::{IcebergError, Result};
pub use partition::build_partition_spec;
pub use schema::{build_iceberg_schema, timestamp_field_id, transform_field_id};

#[derive(Debug, Clone)]
pub struct IcebergConfig {
    pub catalog_url: String,
    pub namespace: String,
    pub table_name: String,
}

impl IcebergConfig {
    pub fn new(catalog_url: impl Into<String>) -> Self {
        Self {
            catalog_url: catalog_url.into(),
            namespace: "vuke".to_string(),
            table_name: "results".to_string(),
        }
    }

    pub fn with_namespace(mut self, namespace: impl Into<String>) -> Self {
        self.namespace = namespace.into();
        self
    }

    pub fn with_table_name(mut self, table_name: impl Into<String>) -> Self {
        self.table_name = table_name.into();
        self
    }
}

#[derive(Debug, Clone)]
pub struct SnapshotInfo {
    pub snapshot_id: i64,
    pub files_registered: usize,
}

/// Metadata about a Parquet file to register with Iceberg
#[derive(Debug, Clone)]
pub struct FileMetadata {
    /// Cloud URI (e.g., s3://bucket/path/file.parquet)
    pub uri: String,
    /// File size in bytes
    pub file_size: u64,
    /// Number of records in the file
    pub record_count: u64,
    /// Partition values extracted from Hive-style path
    pub partition_values: Option<PartitionValues>,
}

/// Partition values for Iceberg table (transform and timestamp_day)
#[derive(Debug, Clone)]
pub struct PartitionValues {
    /// Transform name (identity partition)
    pub transform: String,
    /// Timestamp day (days since epoch for day partition)
    pub timestamp_day: i32,
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn config_new_with_defaults() {
        let config = IcebergConfig::new("http://localhost:8181");
        assert_eq!(config.catalog_url, "http://localhost:8181");
        assert_eq!(config.namespace, "vuke");
        assert_eq!(config.table_name, "results");
    }

    #[test]
    fn config_builder_pattern() {
        let config = IcebergConfig::new("http://localhost:8181")
            .with_namespace("custom_ns")
            .with_table_name("custom_table");

        assert_eq!(config.namespace, "custom_ns");
        assert_eq!(config.table_name, "custom_table");
    }
}