Method new

bridge/src/client/data_store/sftp.rs:40–72

()

impl Sftp {
    pub async fn new() -> Option<Self> {
        dotenv::dotenv().ok();
        let host = dotenv::var("BRIDGE_SFTP_HOST");
        let port = dotenv::var("BRIDGE_SFTP_PORT");
        let username = dotenv::var("BRIDGE_SFTP_USERNAME");
        // let keyfile_path = dotenv::var("BRIDGE_SFTP_KEYFILE_PATH");
        let base_path = dotenv::var("BRIDGE_SFTP_BASE_PATH");

        if host.is_err()
            || port.is_err()
            || username.is_err()
            // || keyfile_path.is_err()
            || base_path.is_err()
        {
            return None;
        }

        let credentials = SftpCredentials {
            host: host.unwrap(),
            port: port.unwrap(),
            username: username.unwrap(),
            // keyfile_path: keyfile_path.unwrap(),
            base_path: base_path.unwrap(),
        };

        match test_connection(&credentials).await {
            Ok(_) => Some(Self { credentials }),
            Err(err) => {
                eprintln!("{err:?}");
                None
            }
        }
    }

    async fn get_object(&self, key: &str, file_path: Option<&str>) -> Result<Vec<u8>, String> {
        let mut buffer: Vec<u8> = vec![];