![logo](./assets/artiqwest-logo.svg)
![docs.rs](https://img.shields.io/docsrs/artiqwest?style=for-the-badge) ![Crates.io Total Downloads](https://img.shields.io/crates/d/artiqwest?style=for-the-badge) ![Crates.io License](https://img.shields.io/crates/l/artiqwest?style=for-the-badge)
Artiqwest is a simple HTTP client that routes *all *(except localhost connects where it fallbacks to [reqwest](https://github.com/seanmonstar/reqwest))* requests through the Tor network using the `arti_client` and `hyper`.
It provides two basic primitives: `get` and `post`, functions.
Artiqwest also provides a `ws` function to create a websocket connection to a hidden service using [tokio-tungstenite](https://github.com/snapview/tokio-tungstenite). *Currently websockets only work over tor and are untested over clearnet.*
## Example
```rust
use artiqwest::get;
use artiqwest::post;
use artiqwest::ws;
use futures_util::future;
use futures_util::pin_mut;
use futures_util::SinkExt;
#[tokio::main]
async fn main() {
// Make a GET request to httpbin.org
let response = get("https://httpbin.org/get").await.unwrap();
assert_eq!(response.status(), 200);
// Make a POST request to a hidden service
let body = r#"{"test": "testing"}"#;
let headers = vec![("Content-Type", "application/json")];
let response = post("http://vpns6exmqmg5znqmgxa5c6rgzpt6imy5yzrbsoszovgfipdjypnchpyd.onion/echo", body, Some(headers)).await.unwrap();
assert_eq!(response.to_string(), body);
// Create a websocket connection to a hidden service.
let (mut write, read) = ws("wss://ydrkehoqxt2q5atkmiyw7gmphvrmp6fkaufvt525cjr4hma3pb75nyid.onion/events").await.unwrap();
let write_messages = {
async {
loop {
write.send(Message::Text("Hello WebSocket".to_string())).await.unwrap();
tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
}
}
};
let read_messages = {
read.for_each(|message| async {
let data = message.unwrap().into_data();
let text = String::from_utf8(data).unwrap();
println!("Received: {text}");
})
};
pin_mut!(read_messages, write_messages);
future::select(read_messages, write_messages).await;
}
```