diff options
Diffstat (limited to 'src/simtest/policy.rs')
| -rw-r--r-- | src/simtest/policy.rs | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/simtest/policy.rs b/src/simtest/policy.rs index 4873b38..ba32615 100644 --- a/src/simtest/policy.rs +++ b/src/simtest/policy.rs @@ -217,7 +217,13 @@ async fn write_signed( Ok(Some(serde_json::Value::String(text))) if text.starts_with("cv1.") => Some(text), _ => None, }; + let swarm = store::read_path(&node.doc.read().await.doc, &path("_continuum/swarm")) + .ok() + .flatten() + .and_then(|swarm| swarm.as_str().map(str::to_owned)) + .unwrap_or_default(); let payload = envelope::Payload { + swarm, path: at.clone(), value, user: user.to_owned(), |