restapi 1.1.14

A secure-by-default rest api using hyper, tokio, bb8, kafka-threadpool, postgres, and prometheus for monitoring
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

//! Module for asynchronously reading a local file into a ``Vec<u8>``
//!
use log::error;
use log::info;
use log::trace;

use std::fs::File;
use std::io::BufReader;
use std::io::Read;

/// read_file_to_buf
///
/// async file read function
///
/// # Arguments
///
/// * `file_path` - read this file path on disk
///
/// # Returns
///
/// `Vec<u8>` containing file contents as bytes
///
/// # Examples
///
/// ```rust
/// use restapi::utils::file_io::read_file_to_buf::read_file_to_buf;
/// let file_bytes = tokio_test::block_on(
///     read_file_to_buf(
///         "./README.md")
///     );
/// assert!(file_bytes.len() > 0);
/// ```
///
pub async fn read_file_to_buf(file_path: &str) -> Vec<u8> {
    let mut buf: Vec<u8> = Vec::new();
    if std::fs::metadata(&file_path).is_err() {
        error!("read_file_to_buf - file does not exist: {file_path}");
        return buf;
    }
    trace!("read_file_to_buf - file_path={file_path}");
    let loc_file_handle = File::open(file_path).expect("Unable to open file");
    let mut buf_reader_o = BufReader::new(loc_file_handle);
    buf_reader_o
        .read_to_end(&mut buf)
        .expect("Unable to read string");
    info!(
        "read_file_to_buf -  {} bytes from file {file_path}",
        buf.len()
    );
    buf
}