如何将缓冲区转换为BSON格式？

Question

我正在尝试将一个文件（我打开并读取为缓冲区）将文件转换为有效的BSON格式。

我编写了客户端，以提出一个需要两个字段的请求。

1. 文件
2. 文件的名称（缓冲区）

这里的问题是我似乎无法在这里成功进行转换。

另一个问题是，在进行此转换后，是否有可能将此BSON请求转换为缓冲区，因为这是卷曲（易于）板条板的类型（易于）进行请求（即来自终端的请求，而不是表单的浏览器）

这是我提出此请求的代码

// It takes in a file path.
fn send_file_post(file_from_arg: &str) -> tide::Result {

    // initialise the connection to the server
    let mut easy = Easy::new();
    easy.url("http://0.0.0.0:8080/hi").unwrap();

    // Opens and reads the file path
    let mut file = File::open(file_from_arg)?;
    let mut buf = [0; 1096];

    // reads file into buffer
    loop {
        let n = file.read(&mut buf)?;

        if n == 0 {
            // reached end of file
            break;
        }

        // easy.write_all(&buf[..n])?;
    }


// attempted bson format
    let bson_data: Bson = bson!({
    "name": file_from_arg,
    "file": buf
});

// sending the request, this is only sending the file for now, I want to send a bson format that is buffered (in a buffer/bytes format) 
    easy.post_fields_copy(&buf).unwrap();
    easy.write_function(|data| {
        stdout().write_all(data).unwrap();
        Ok(data.len())
    })
    .unwrap();

    println!(" oh hi{:?}", easy.perform().unwrap());
    Ok(format!("okay sent!").into())
}

Answer 1

我意识到Serde_json有一个转换为VEC！方法，如果不相同，则可以比喻为字节。因此，我将文件转换为字节并将其作为缓冲区发送。这就是下面的功能。

// It takes in a file path.
fn send_file_post(file_from_arg: &str, port_addr: &str) -> tide::Result {
    // initialise
    let mut easy = Easy::new();
    let port = format!("{}/hi", port_addr);
    easy.url(&port).unwrap();
    
// reads file path
    let file = std::fs::read(file_from_arg)?;


    //extracts name of the file from file path
    let (.., file_name) = file_from_arg
        .rsplit_once(std::path::MAIN_SEPARATOR)
        .unwrap();

// creates the necessary type to send the file in bytes
    let new_post = FileSearch {
        file_name: file_name.to_string(),
        file_bytes: file,
    };

// Unwrap into a vector, which can be likened to bytes
    let send_file_body_req = serde_json::to_vec(&new_post).unwrap();

    // make and send request
    easy.post(true).unwrap();
    easy.post_field_size(send_file_body_req.len() as u64).unwrap();

    let mut transfer = easy.transfer();
    transfer
        .read_function(|buf| Ok(send_file_body_req.as_slice().read(buf).unwrap_or(0)))
        .unwrap();
    transfer.perform().unwrap();

    Ok(format!("okay sent!").into())
}