fix errors

starfederation · Feb 1, 2025 · 2c05c19 · 2c05c19
1 parent 9139789
commit 2c05c19
Show file tree

Hide file tree

Showing 4 changed files with 2 additions and 19 deletions.
diff --git a/sdk/rust/src/execute_script.rs b/sdk/rust/src/execute_script.rs
@@ -91,11 +91,6 @@ impl Into<DatastarEvent> for ExecuteScript {
     fn into(self) -> DatastarEvent {
         let mut data: Vec<String> = Vec::new();
 
-        data.push(format!(
-            "event: {}",
-            consts::EventType::ExecuteScript.as_str()
-        ));
-
         if self.auto_remove != consts::DEFAULT_EXECUTE_SCRIPT_AUTO_REMOVE {
             data.push(format!(
                 "{} {}",

diff --git a/sdk/rust/src/lib.rs b/sdk/rust/src/lib.rs
@@ -59,6 +59,8 @@ impl Display for DatastarEvent {
             writeln!(f, "data: {}", line)?;
         }
 
+        write!(f, "\n\n")?;
+
         Ok(())
     }
 }
diff --git a/sdk/rust/src/merge_fragments.rs b/sdk/rust/src/merge_fragments.rs
@@ -131,14 +131,6 @@ impl Into<DatastarEvent> for MergeFragments {
             ));
         }
 
-        if let Some(selector) = &self.selector {
-            data.push(format!(
-                "{} {}",
-                consts::SELECTOR_DATALINE_LITERAL,
-                selector
-            ));
-        }
-
         if self.merge_mode != FragmentMergeMode::default() {
             data.push(format!(
                 "{} {}",

diff --git a/sdk/rust/src/merge_signals.rs b/sdk/rust/src/merge_signals.rs
@@ -80,12 +80,6 @@ impl Into<DatastarEvent> for MergeSignals {
     fn into(self) -> DatastarEvent {
         let mut data: Vec<String> = Vec::new();
 
-        data.push(format!(
-            "{} {}",
-            consts::SIGNALS_DATALINE_LITERAL,
-            self.signals
-        ));
-
         if self.only_if_missing != consts::DEFAULT_MERGE_SIGNALS_ONLY_IF_MISSING {
             data.push(format!(
                 "{} {}",
-Original file line number
+Diff line change
@@ Expand Up / @@ -59,6 +59,8 @@ impl Display for DatastarEvent { @@
                 writeln!(f, "data: {}", line)?;
             }
+            write!(f, "\n\n")?;
             Ok(())
         }
     }