rustyschwab 0.3.0

Unofficial Rust SDK for the Charles Schwab Trader and Market Data APIs: OAuth, REST, streaming, journaled orders, risk limits and a paper venue
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

//! `wss://` must speak TLS. Schwab's streamer is only reachable over TLS, and
//! every other streaming test uses a plaintext `ws://` mock, so a build whose
//! WebSocket client has no TLS support would otherwise pass the whole suite.

use rustyschwab::transport::websocket::WebSocketTransport;
use tokio::io::AsyncReadExt;

#[tokio::test]
async fn wss_opens_with_a_tls_client_hello() {
    let listener = tokio::net::TcpListener::bind("127.0.0.1:0").await.unwrap();
    let port = listener.local_addr().unwrap().port();
    let server = tokio::spawn(async move {
        let (mut socket, _) = listener.accept().await.unwrap();
        let mut first = [0u8; 1];
        socket.read_exact(&mut first).await.unwrap();
        first[0]
    });

    let transport = WebSocketTransport::new(format!("wss://127.0.0.1:{port}/ws")).unwrap();
    let error = transport
        .connect()
        .await
        .expect_err("no TLS server is listening");

    // 0x16 is a TLS handshake record: the client sent a ClientHello.
    assert_eq!(
        server.await.unwrap(),
        0x16,
        "client did not start TLS: {error}"
    );
    assert!(
        !error.to_string().contains("not compiled in"),
        "TLS support missing: {error}"
    );
}