keyflux 0.1.11

A CLI tool and library for synchronizing environment secrets across multiple platforms including local files, GitHub Secrets, Supabase Vault, and Vercel Secrets. It facilitates secure management and automation of sensitive 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

use crate::Configs;
use crate::error::ActionError;
use crate::action::Action;
use log::{info, trace, warn};
use std::env;
use crate::config::SecretConfig;
use colored::*;

pub struct SecretManager {
    configs: Configs,
}

impl SecretManager {
    pub fn new(configs: Configs) -> Self {
        SecretManager {
            configs,
        }
    }

    pub async fn sync_secrets(&mut self) -> Result<(), ActionError> {
        for config in &self.configs.configs {
            for action_config in &config.actions {
                let action: Box<dyn Action> = action_config.to_action()?;
                action.initialize().await?;

                let mut secrets_to_sync = Vec::new();

                for (key, secret_config) in &config.secrets {
                    if let Some(value) = self.resolve_secret_value(key, secret_config) {
                        info!("🔑 Syncing key: {} with value: {}", key.green(), "******".blue());
                        secrets_to_sync.push((key.clone(), value));
                    } else {
                        warn!("⚠️  Key '{}' could not be resolved.", key.yellow());
                    }
                }

                if !secrets_to_sync.is_empty() {
                    action.batch(&secrets_to_sync).await?;
                }

                action.finalize().await?;
            }
        }
        Ok(())
    }

    pub fn resolve_secret_value(&self, key: &str, secret_config: &SecretConfig) -> Option<String> {
        match secret_config {
            SecretConfig::Direct(value) => {
                match env::var(value) {
                    Ok(env_value) => {
                        info!("{}", format!("🌿 Env var '{}' for key '{}' found.", value.green(), key));
                        Some(env_value)
                    }
                    Err(_) => {
                        warn!("{}", format!("🔍 Env var '{}' for key '{}' not found, using direct value.", value.yellow(), key));
                        Some(value.clone())
                    }
                }
            }
            SecretConfig::Structured { value, key: env_key, .. } => {
                if let Some(v) = value {
                    trace!("{}", format!("🏷️ Using provided direct value for key '{}'.", key));
                    Some(v.clone())
                } else if let Some(k) = env_key {
                    trace!("{}", format!("🔍 Trying to retrieve value for key '{}' from env var '{}'.", key, k));
                    match env::var(k) {
                        Ok(env_value) => {
                            info!("{}", format!("🌿 Env var '{}' for key '{}' found.", k.green(), key));
                            Some(env_value)
                        }
                        Err(_) => {
                            warn!("{}", format!("🔍 Env var '{}' for key '{}' not found.", k.yellow(), key));
                            None
                        }
                    }
                } else {
                    warn!("{}", format!("⚠️  No value or key provided in structured config for key '{}'.", key));
                    None
                }
            }
        }
    }
}