feat: apply local rewrites from workflows (#390)

getgrit · Jun 30, 2024 · 4164fc0 · 4164fc0
1 parent b1d7139
commit 4164fc0
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/crates/cli/src/messenger_variant.rs b/crates/cli/src/messenger_variant.rs
@@ -142,10 +142,16 @@ impl<'a> WorkflowMessenger for MessengerVariant<'a> {
     ) -> anyhow::Result<()> {
         // This is meant to match what we do in the CLI server
         let level = VisibilityLevels::Debug;
+
         match self {
             MessengerVariant::Formatted(_)
             | MessengerVariant::Transformed(_)
-            | MessengerVariant::JsonLine(_) => self.emit(&message.result, &level),
+            | MessengerVariant::JsonLine(_) => {
+                // For local emitters,, we will also apply rewrites
+                self.emit(&message.result, &level)?;
+                self.apply_rewrite(&message.result, &level)?;
+                Ok(())
+            }
             #[cfg(feature = "remote_redis")]
             MessengerVariant::Redis(m) => m.emit_from_workflow(message),
             #[cfg(feature = "remote_pubsub")]

diff --git a/crates/marzano_messenger/src/workflows.rs b/crates/marzano_messenger/src/workflows.rs
@@ -3,7 +3,7 @@ use std::path::PathBuf;
 use marzano_core::api::MatchResult;
 use serde::{Deserialize, Serialize};
 
-use crate::emit::{Messager};
+use crate::emit::Messager;
 
 #[derive(Deserialize, Serialize, Debug)]
 pub struct PackagedWorkflowOutcome {