pipe-audit-core 0.1.12

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
54
55
56
57
58
59
60
61
62
63
64

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>> {

    init_logging();
    ensure_ledger_key_exists();

    let mut actions = Vec::new();

    let contracts_dir = Path::new("contracts");
    fs::create_dir_all(contracts_dir)?;

    if !Path::new(".env").exists() {
        fs::write(".env", "# .env file for project-specific environment variables")?;
        actions.push("Created .env file");
    }

    if !Path::new("profiles.toml").exists() {
        let profile_content = r#"# Pipe Audit profiles.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, etc.)
"#;
        fs::write("profiles.toml", profile_content)?;
        actions.push("Created profiles.toml");
    }

    // Use `join` to build paths robustly for any OS.
    let contract_path = contracts_dir.join("example.toml");
    if !contract_path.exists() {
        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
"#;
        fs::write(&contract_path, contract_content)?;
        actions.push("Created contracts/example.toml");
    }

    if actions.is_empty() {
        Ok("Project already initialized. No changes were made.".to_string())
    } else {
        Ok(format!("Successfully initialized project. {}", actions.join(". ")))
    }
}