Method get_object

bridge/src/client/data_store/sftp.rs:74–107

(&self, key: &str, file_path: Option<&str>)

    }

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

        match connect(&self.credentials).await {
            Ok(sftp) => {
                let mut full_filename = key.to_string();
                if file_path.is_some() {
                    full_filename = format!("{}/{}", file_path.unwrap(), key);
                }
                match sftp.open(full_filename).await.map(TokioCompatFile::from) {
                    Ok(_file) => {
                        let mut file = Box::pin(_file);
                        let result = file.read_to_end(&mut buffer).await;
                        drop(file);
                        match result {
                            Ok(_) => {
                                disconnect(sftp).await;
                                Ok(buffer)
                            }
                            Err(err) => {
                                disconnect(sftp).await;
                                Err(format!("Unable to get {}: {}", key, err))
                            }
                        }
                    }
                    Err(err) => {
                        disconnect(sftp).await;
                        Err(format!("Unable to get {}: {}", key, err))
                    }
                }
            }
            Err(err) => Err(format!("Unable to get {}: {}", key, err)),
        }
    }

    async fn upload_object(
        &self,