rust-integration-services 0.5.26

A modern, fast, and lightweight integration library written in Rust, designed for memory safety and stability.
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

use crate::{common::stream::ByteStream, sftp::{sftp_client::SftpClient, sftp_client_config::SftpClientConfig}};

#[tokio::test]
async fn client_test() {
    tracing_subscriber::fmt().with_max_level(tracing::Level::INFO).init();
    let config = SftpClientConfig::builder().endpoint("127.0.0.1:2222").auth_basic("user", "password").build().unwrap();
    let mut client = SftpClient::new(config);

    let result = client.put_file("upload/file_bytes.txt").from_bytes("hello world").await;
    assert!(result.is_ok());

    let result = client.get_file("upload/file_bytes.txt").as_bytes().await;
    assert!(result.is_ok());
    tracing::info!("{:?}", result.unwrap());

    let result = client.delete_file("upload/file_bytes.txt").await;
    assert!(result.is_ok());

    let result = client.put_file("upload/file_stream.txt").from_stream(ByteStream::from("hello world")).await;
    assert!(result.is_ok());

    let result = client.get_file("upload/file_stream.txt").as_stream().await;
    assert!(result.is_ok());
    tracing::info!("{:?}", result.unwrap().as_bytes().await);

    let result = client.delete_file("upload/file_stream.txt").await;
    assert!(result.is_ok());
}