zenithsiz/dynatos
1
0
Fork 0
mirror of https://github.com/Zenithsiz/dynatos.git synced 2026-02-03 10:05:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added #[track_caller] to all QueryWrite impls.

Browse Source
This commit is contained in:
Filipe Rodrigues 2025-05-28 05:23:22 +01:00
parent 2e51dfe9c9
commit b2caabf5f3
Signed by: zenithsiz
SSH Key Fingerprint: SHA256:Mb5ppb3Sh7IarBO/sBTXLHbYEOz37hJAlslLQPPAPaU
2 changed files with 25 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
dynatos-router/src/query_signal.rs
View File

@ -277,6 +277,7 @@ pub trait QueryParse {
/// Query write
pub trait QueryWrite<T> {
/// Writes the value back into the query
#[track_caller]
fn write(&self, new_value: T);
}

49
dynatos-router/src/query_signal/single_query.rs
View File

@ -80,35 +80,34 @@ impl<T: FromStr<Err: StdError> + ToString> QueryWrite<&'_ Loadable<T, T::Err>> f
impl<T: FromStr<Err: StdError> + ToString> QueryWrite<Option<&'_ T>> for SingleQuery<T> {
fn write(&self, new_value: Option<&T>) {
dynatos_context::with_expect::<Location, _, _>(|location| {
let mut location = location.borrow_mut();
let mut added_query = false;
let mut queries = vec![];
for (key, value) in location.query_pairs().into_owned() {
// If it's another key, keep it
if key != *self.key {
queries.push((key, value));
continue;
}
// If we already added our query, this is a duplicate, so skip it
if added_query {
continue;
}
// If it's our key, check what we should do
if let Some(new_value) = new_value {
added_query = true;
queries.push((self.key.to_string(), new_value.to_string()));
}
let location = dynatos_context::expect_cloned::<Location>();
let mut location = location.borrow_mut();
let mut added_query = false;
let mut queries = vec![];
for (key, value) in location.query_pairs().into_owned() {
// If it's another key, keep it
if key != *self.key {
queries.push((key, value));
continue;
}
// If we haven't added ours yet by now, add it at the end
if !added_query && let Some(new_value) = new_value {
// If we already added our query, this is a duplicate, so skip it
if added_query {
continue;
}
// If it's our key, check what we should do
if let Some(new_value) = new_value {
added_query = true;
queries.push((self.key.to_string(), new_value.to_string()));
}
}
location.query_pairs_mut().clear().extend_pairs(queries);
});
// If we haven't added ours yet by now, add it at the end
if !added_query && let Some(new_value) = new_value {
queries.push((self.key.to_string(), new_value.to_string()));
}
location.query_pairs_mut().clear().extend_pairs(queries);
}
}