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

use crate::traits::Flux;
use crate::error::ConfigError;
use serde_json::Value;
use lazy_static::lazy_static;
use log::{error, trace};
use std::collections::HashMap;
use std::sync::{Arc, Mutex};

pub type FluxConstructor = Box<dyn Fn(&Value) -> Result<Box<dyn Flux>, ConfigError> + Send + Sync>;

/// Registry for managing flux types and their constructors.
pub struct FluxRegistry {
    pub(crate) creators: HashMap<String, FluxConstructor>,
}

impl FluxRegistry {
    pub fn new() -> Self {
        FluxRegistry {
            creators: HashMap::new(),
        }
    }

    pub fn register(&mut self, flux_type: &str, constructor: FluxConstructor) {
        self.creators.insert(flux_type.to_string(), constructor);
    }

    pub fn create(&self, flux_type: &str, config: &Value) -> Result<Box<dyn Flux>, ConfigError> {
        trace!("Attempting to create flux of type '{}'", flux_type);
        self.creators
            .get(flux_type)
            .ok_or_else(|| {
                let err_msg = format!("Unknown flux type: {}", flux_type);
                error!("{}", err_msg);
                ConfigError::UnknownFluxType(err_msg)
            })?
            (config)
            .map_err(|e| {
                let err_msg = format!("Error creating flux '{}': {:?}", flux_type, e);
                error!("{}", err_msg);
                ConfigError::InvalidConfig(err_msg)
            })
    }
}

lazy_static! {
    pub static ref FLUX_REGISTRY: Arc<Mutex<FluxRegistry>> = Arc::new(Mutex::new(FluxRegistry::new()));
}