Send lens query as a raw string

samply · Oct 10, 2023 · 2cda5a3 · 2cda5a3
1 parent b13adb0
commit 2cda5a3
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/beam.rs b/src/beam.rs
@@ -1,11 +1,11 @@
-use beam_lib::{TaskRequest, AppId};
+use beam_lib::{TaskRequest, AppId, RawString};
 use crate::CONFIG;
 
 pub fn create_beam_task(
     id: beam_lib::MsgId,
     target_sites: Vec<String>,
     query: String,
-) -> TaskRequest<String> {
+) -> TaskRequest<RawString> {
     let proxy_id = CONFIG.beam_app.proxy_id();
     let broker_id = proxy_id.as_ref().split_once('.').expect("Invalid beam id in config").1;
     let to = target_sites.into_iter().map(|site| AppId::new_unchecked(format!("focus.{site}.{broker_id}"))).collect();
@@ -14,7 +14,7 @@ pub fn create_beam_task(
         from: CONFIG.beam_app.clone(),
         to,
         metadata: serde_json::Value::Null,
-        body: query,
+        body: query.into(),
         failure_strategy: beam_lib::FailureStrategy::Retry {
             backoff_millisecs: 1000,
             max_tries: 5,