wtx 0.44.3

A collection of different transport implementations and related tools focused primarily on web technologies.
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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90

use crate::{
  database::client::mysql::{Config, ExecutorBuffer, MysqlExecutor},
  misc::UriRef,
  rng::{ChaCha20, CryptoSeedableRng},
  tests::_vars,
};
use core::fmt::Debug;

#[test]
fn execute() {
  crate::database::client::integration_tests::execute(executor::<crate::Error>());
}

#[test]
fn execute_interleaved() {
  crate::database::client::integration_tests::execute_interleaved(executor::<crate::Error>());
}

#[test]
fn execute_stmt_inserts() {
  crate::database::client::integration_tests::execute_stmt_inserts(executor::<crate::Error>());
}

#[test]
fn execute_stmt_selects() {
  crate::database::client::integration_tests::execute_stmt_selects(
    executor::<crate::Error>(),
    "?",
    "?",
  );
}

#[test]
fn ping() {
  crate::database::client::integration_tests::ping(executor::<crate::Error>());
}

#[test]
fn records_after_prepare() {
  crate::database::client::integration_tests::records_after_prepare(executor::<crate::Error>());
}

#[test]
fn reuses_cached_statement() {
  crate::database::client::integration_tests::reuses_cached_statement(
    executor::<crate::Error>(),
    "?",
  );
}

#[cfg(feature = "tokio-rustls")]
#[tokio::test]
async fn tls() {
  let uri = UriRef::new(_vars().database_uri_mysql.as_str());
  let mut rng = ChaCha20::from_std_random().unwrap();
  let _executor = MysqlExecutor::<crate::Error, _, _>::connect_encrypted(
    &Config::from_uri(&uri).unwrap(),
    ExecutorBuffer::new(usize::MAX, &mut rng),
    &mut rng,
    tokio::net::TcpStream::connect(uri.hostname_with_implied_port()).await.unwrap(),
    |stream| async {
      Ok(
        crate::misc::TokioRustlsConnector::default()
          .push_certs(include_bytes!("../../../../../.certs/root-ca.crt"))
          .unwrap()
          .connect_without_client_auth(uri.hostname(), stream)
          .await
          .unwrap(),
      )
    },
  )
  .await
  .unwrap();
}

async fn executor<E>() -> MysqlExecutor<E, ExecutorBuffer, std::net::TcpStream>
where
  E: Debug + From<crate::Error>,
{
  let uri = UriRef::new(_vars().database_uri_mysql.as_str());
  let mut rng = ChaCha20::from_std_random().unwrap();
  MysqlExecutor::connect(
    &Config::from_uri(&uri).unwrap(),
    ExecutorBuffer::new(usize::MAX, &mut rng),
    &mut rng,
    std::net::TcpStream::connect(uri.hostname_with_implied_port()).unwrap(),
  )
  .await
  .unwrap()
}