Remove spin crate from dependencies
This commit is contained in:
parent
a30dc64336
commit
9ab9a60ec0
|
@ -36,7 +36,6 @@ pin-project-lite = "0.2.6"
|
||||||
regex = "1.4.5"
|
regex = "1.4.5"
|
||||||
serde = { version = "1.0.125", features = ["derive"] }
|
serde = { version = "1.0.125", features = ["derive"] }
|
||||||
serde_json = "1.0.64"
|
serde_json = "1.0.64"
|
||||||
spin = "0.9.0"
|
|
||||||
thiserror = "1.0.24"
|
thiserror = "1.0.24"
|
||||||
static_assertions = "1.1.0"
|
static_assertions = "1.1.0"
|
||||||
http = "0.2.3"
|
http = "0.2.3"
|
||||||
|
|
|
@ -4,7 +4,7 @@ use std::any::{Any, TypeId};
|
||||||
use std::collections::HashMap;
|
use std::collections::HashMap;
|
||||||
use std::fmt::{self, Debug, Display, Formatter};
|
use std::fmt::{self, Debug, Display, Formatter};
|
||||||
use std::ops::Deref;
|
use std::ops::Deref;
|
||||||
use std::sync::Arc;
|
use std::sync::{Arc, Mutex};
|
||||||
|
|
||||||
use async_graphql_value::{Value as InputValue, Variables};
|
use async_graphql_value::{Value as InputValue, Variables};
|
||||||
use fnv::FnvHashMap;
|
use fnv::FnvHashMap;
|
||||||
|
@ -212,7 +212,7 @@ pub struct QueryEnvInner {
|
||||||
pub uploads: Vec<UploadValue>,
|
pub uploads: Vec<UploadValue>,
|
||||||
pub session_data: Arc<Data>,
|
pub session_data: Arc<Data>,
|
||||||
pub ctx_data: Arc<Data>,
|
pub ctx_data: Arc<Data>,
|
||||||
pub http_headers: spin::Mutex<HeaderMap<String>>,
|
pub http_headers: Mutex<HeaderMap<String>>,
|
||||||
pub disable_introspection: bool,
|
pub disable_introspection: bool,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -344,7 +344,11 @@ impl<'a, T> ContextBase<'a, T> {
|
||||||
/// }
|
/// }
|
||||||
/// ```
|
/// ```
|
||||||
pub fn http_header_contains(&self, key: impl AsHeaderName) -> bool {
|
pub fn http_header_contains(&self, key: impl AsHeaderName) -> bool {
|
||||||
self.query_env.http_headers.lock().contains_key(key)
|
self.query_env
|
||||||
|
.http_headers
|
||||||
|
.lock()
|
||||||
|
.unwrap()
|
||||||
|
.contains_key(key)
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Sets a HTTP header to response.
|
/// Sets a HTTP header to response.
|
||||||
|
@ -395,6 +399,7 @@ impl<'a, T> ContextBase<'a, T> {
|
||||||
self.query_env
|
self.query_env
|
||||||
.http_headers
|
.http_headers
|
||||||
.lock()
|
.lock()
|
||||||
|
.unwrap()
|
||||||
.insert(name, value.into())
|
.insert(name, value.into())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -434,6 +439,7 @@ impl<'a, T> ContextBase<'a, T> {
|
||||||
self.query_env
|
self.query_env
|
||||||
.http_headers
|
.http_headers
|
||||||
.lock()
|
.lock()
|
||||||
|
.unwrap()
|
||||||
.append(name, value.into())
|
.append(name, value.into())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -476,7 +476,7 @@ where
|
||||||
match res {
|
match res {
|
||||||
Ok(data) => {
|
Ok(data) => {
|
||||||
let resp = Response::new(data);
|
let resp = Response::new(data);
|
||||||
resp.http_headers(std::mem::take(&mut *env.http_headers.lock()))
|
resp.http_headers(std::mem::take(&mut *env.http_headers.lock().unwrap()))
|
||||||
}
|
}
|
||||||
Err(err) => Response::from_errors(vec![err]),
|
Err(err) => Response::from_errors(vec![err]),
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user