pipe-audit-core 0.1.8

Universal data validation and compliance audit engine
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

use crate::logging::init::init_logging;
use crate::logging::ledger::ensure_ledger_key_exists;
use std::fs;
use std::path::Path;

pub fn init_project() -> Result<String, Box<dyn std::error::Error>> {
    // Initialize logging system once at project init
    init_logging();
    ensure_ledger_key_exists();
    fs::create_dir_all("contracts")?;
    if !Path::new(".env").exists() {
        fs::write(".env","#.env")?;
    }

    // Write example profile.toml if it doesn't exist
    let profile_content = r#"# Pipe Audit profile.toml example
# provider can be: "local", "s3", "azure", "gcs"
name = "example-profile"
provider = "local"
# For s3/azure/gcs, add provider-specific fields (endpoint, region, connection_string, service_account_json, etc.)
"#;
    if !Path::new("profile.toml").exists() {
        fs::write("profile.toml", profile_content)?;
    }

    // Write example contract if it doesn't exist
    let contract_content = r#"# contracts/example.toml
[contract]
name = "example-contract"
version = "0.1.0"

[source]
type = "local"
location = "data/example.csv"

[file.validation]
# row_count.min = 1
# completeness.min_ratio = 0.95

[[columns]]
name = "id"
[[columns.validation]]
type = { dtype = "i64" }
[[columns.validation]]
unique = true
"#;
    let contract_path = Path::new("contracts/example.toml");
    if !contract_path.exists() {
        fs::write(contract_path, contract_content)?;
    }

    Ok("Initialized logs/, contracts/, profile.toml, and example contract".into())
}