anna/async-graphql
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #37 from vkill/async-graphql-tide3

Browse Source 
async-graphql-tide: replace async-std to smol for tests
This commit is contained in:
Sunli 2020-04-29 09:06:58 +08:00 committed by GitHub
commit d4b84de6d1
3 changed files with 45 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
async-graphql-tide/Cargo.toml
View File

@ -18,5 +18,6 @@ tide = "0.8"
[dev-dependencies]
async-std = "1.5.0"
surf = "2.0.0-alpha.1"
serde_json = "1.0.51"
smol = { version = "0.1", features = ["tokio02"] }
reqwest = "0.10.4"

66
async-graphql-tide/tests/graphql.rs
View File

@ -1,7 +1,6 @@
mod test_utils;
use async_std::prelude::*;
use async_std::task;
use serde_json::json;
use smol::{Task, Timer};
use std::time::Duration;
use tide::Request;
@ -11,10 +10,10 @@ type Result<T> = std::result::Result<T, Box<dyn std::error::Error + Send + Sync>
#[test]
fn quickstart() -> Result<()> {
task::block_on(async {
smol::run(async {
let listen_addr = test_utils::find_listen_addr().await;
let server: task::JoinHandle<Result<()>> = task::spawn(async move {
let server = Task::<Result<()>>::spawn(async move {
struct QueryRoot;
#[Object]
impl QueryRoot {
@ -34,21 +33,27 @@ fn quickstart() -> Result<()> {
Ok(())
});
let client: task::JoinHandle<Result<()>> = task::spawn(async move {
task::sleep(Duration::from_millis(300)).await;
let client = Task::<Result<()>>::spawn(async move {
Timer::after(Duration::from_millis(300)).await;
let string = surf::post(format!("http://{}", listen_addr))
.body_bytes(r#"{"query":"{ add(a: 10, b: 20) }"}"#)
.set_header("Content-Type".parse().unwrap(), "application/json")
.recv_string()
let resp = reqwest::Client::new()
.post(format!("http://{}", listen_addr).as_str())
.body(r#"{"query":"{ add(a: 10, b: 20) }"}"#)
.header(reqwest::header::CONTENT_TYPE, "application/json")
.send()
.await?;
assert_eq!(resp.status(), reqwest::StatusCode::OK);
let string = resp.text().await?;
println!("{}", string);
assert_eq!(string, json!({"data": {"add": 30}}).to_string());
Ok(())
});
server.race(client).await?;
client.await?;
server.cancel().await;
Ok(())
})
@ -56,10 +61,10 @@ fn quickstart() -> Result<()> {
#[test]
fn hello() -> Result<()> {
task::block_on(async {
smol::run(async {
let listen_addr = test_utils::find_listen_addr().await;
let server: task::JoinHandle<Result<()>> = task::spawn(async move {
let server = Task::<Result<()>>::spawn(async move {
struct Hello(String);
struct QueryRoot;
#[Object]
@ -98,24 +103,34 @@ fn hello() -> Result<()> {
Ok(())
});
let client: task::JoinHandle<Result<()>> = task::spawn(async move {
task::sleep(Duration::from_millis(300)).await;
let client = Task::<Result<()>>::spawn(async move {
Timer::after(Duration::from_millis(300)).await;
let string = surf::post(format!("http://{}", listen_addr))
.body_bytes(r#"{"query":"{ hello }"}"#)
.set_header("Content-Type".parse().unwrap(), "application/json")
.set_header("Name".parse().unwrap(), "Foo")
.recv_string()
let resp = reqwest::Client::new()
.post(format!("http://{}", listen_addr).as_str())
.body(r#"{"query":"{ hello }"}"#)
.header(reqwest::header::CONTENT_TYPE, "application/json")
.header("Name", "Foo")
.send()
.await?;
assert_eq!(resp.status(), reqwest::StatusCode::OK);
let string = resp.text().await?;
println!("{}", string);
assert_eq!(string, json!({"data":{"hello":"Hello, Foo!"}}).to_string());
let string = surf::post(format!("http://{}", listen_addr))
.body_bytes(r#"{"query":"{ hello }"}"#)
.set_header("Content-Type".parse().unwrap(), "application/json")
.recv_string()
let resp = reqwest::Client::new()
.post(format!("http://{}", listen_addr).as_str())
.body(r#"{"query":"{ hello }"}"#)
.header(reqwest::header::CONTENT_TYPE, "application/json")
.send()
.await?;
assert_eq!(resp.status(), reqwest::StatusCode::OK);
let string = resp.text().await?;
println!("{}", string);
assert_eq!(
string,
json!({"data":{"hello":"Hello, world!"}}).to_string()
@ -124,7 +139,8 @@ fn hello() -> Result<()> {
Ok(())
});
server.race(client).await?;
client.await?;
server.cancel().await;
Ok(())
})

5
async-graphql-tide/tests/test_utils.rs
View File

@ -1,6 +1,5 @@
pub async fn find_listen_addr() -> async_std::net::SocketAddr {
async_std::net::TcpListener::bind("localhost:0")
.await
pub async fn find_listen_addr() -> std::net::SocketAddr {
std::net::TcpListener::bind("localhost:0")
.unwrap()
.local_addr()
.unwrap()