artiqwest

Crates.ioartiqwest
lib.rsartiqwest
version
sourcesrc
created_at2024-08-19 21:20:56.976299
updated_at2024-11-20 04:56:27.402247
descriptionA simple client for making http request over Tor with Arti.
homepage
repositoryhttps://github.com/basic-automation/artiqwest
max_upload_size
id1344465
Cargo.toml error:TOML parse error at line 17, column 1 | 17 | autolib = false | ^^^^^^^ unknown field `autolib`, expected one of `name`, `version`, `edition`, `authors`, `description`, `readme`, `license`, `repository`, `homepage`, `documentation`, `build`, `resolver`, `links`, `default-run`, `default_dash_run`, `rust-version`, `rust_dash_version`, `rust_version`, `license-file`, `license_dash_file`, `license_file`, `licenseFile`, `license_capital_file`, `forced-target`, `forced_dash_target`, `autobins`, `autotests`, `autoexamples`, `autobenches`, `publish`, `metadata`, `keywords`, `categories`, `exclude`, `include`
size0
Justin Icenhour (physics515)

documentation

README

logo

docs.rs Crates.io Total Downloads Crates.io License

Artiqwest is a simple HTTP client that routes *all (except localhost connects where it fallbacks to 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. Currently websockets only work over tor and are untested over clearnet.

Example

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;
 }
Commit count: 36

cargo fmt