fix: fix infra artifacts dockerfiles, wf commands

.vscode/rivet.code-workspace

@@ -1,13 +1,3 @@
 {
-	"folders": [
-		{
-			"path": "..",
-		},
-		{
-			"path": "../lib/bolt",
-		},
-		{
-			"path": "../svc",
-		}
-	],
+	"folders": []
 }

packages/cli/src/commands/wf/mod.rs

@@ -11,10 +11,9 @@ mod signal;
 
 #[derive(Parser)]
 pub enum SubCommand {
-	/// Prints the given workflow.
+	/// Prints the given workflow(s).
 	Get {
-		#[clap(index = 1)]
-		workflow_id: Uuid,
+		workflow_ids: Vec<Uuid>,
 	},
 	/// Finds workflows with the given tags, name and state.
 	List {
@@ -30,20 +29,23 @@ pub enum SubCommand {
 	},
 	/// Silences a workflow from showing up as dead or running again.
 	Ack {
-		#[clap(index = 1)]
-		workflow_id: Uuid,
+		workflow_ids: Vec<Uuid>,
 	},
 	/// Sets the wake immediate property of a workflow to true.
 	Wake {
-		#[clap(index = 1)]
-		workflow_id: Uuid,
+		workflow_ids: Vec<Uuid>,
 	},
 	/// Lists the entire event history of a workflow.
 	History {
 		#[clap(index = 1)]
 		workflow_id: Uuid,
+		/// Includes activity errors in graph.
+		#[clap(short = 'e', long)]
+		include_errors: bool,
+		/// Includes forgotten events in graph, shown in red.
 		#[clap(short = 'f', long)]
 		include_forgotten: bool,
+		/// Includes location numbers for events in graph.
 		#[clap(short = 'l', long)]
 		print_location: bool,
 	},
@@ -56,10 +58,10 @@ pub enum SubCommand {
 impl SubCommand {
 	pub async fn execute(self, config: rivet_config::Config) -> Result<()> {
 		match self {
-			Self::Get { workflow_id } => {
+			Self::Get { workflow_ids } => {
 				let pool = util::wf::build_pool(&config).await?;
-				let workflow = util::wf::get_workflow(pool, workflow_id).await?;
-				util::wf::print_workflows(workflow.into_iter().collect(), true).await
+				let workflows = util::wf::get_workflows(pool, workflow_ids).await?;
+				util::wf::print_workflows(workflows, true).await
 			}
 			Self::List {
 				tags,
@@ -71,21 +73,29 @@ impl SubCommand {
 				let workflows = util::wf::find_workflows(pool, tags, name, state).await?;
 				util::wf::print_workflows(workflows, pretty).await
 			}
-			Self::Ack { workflow_id } => {
+			Self::Ack { workflow_ids } => {
 				let pool = util::wf::build_pool(&config).await?;
-				util::wf::silence_workflow(pool, workflow_id).await
+				util::wf::silence_workflows(pool, workflow_ids).await
 			}
-			Self::Wake { workflow_id } => {
+			Self::Wake { workflow_ids } => {
 				let pool = util::wf::build_pool(&config).await?;
-				util::wf::wake_workflow(pool, workflow_id).await
+				util::wf::wake_workflows(pool, workflow_ids).await
 			}
 			Self::History {
 				workflow_id,
+				include_errors,
 				include_forgotten,
 				print_location,
 			} => {
 				let pool = util::wf::build_pool(&config).await?;
-				util::wf::print_history(pool, workflow_id, include_forgotten, print_location).await
+				util::wf::print_history(
+					pool,
+					workflow_id,
+					include_errors,
+					include_forgotten,
+					print_location,
+				)
+				.await
 			}
 			Self::Signal { command } => command.execute(config).await,
 		}

packages/cli/src/commands/wf/signal.rs

@@ -9,10 +9,9 @@ use crate::util::{
 
 #[derive(Parser)]
 pub enum SubCommand {
-	/// Prints the given signal.
+	/// Prints the given signal(s).
 	Get {
-		#[clap(index = 1)]
-		signal_id: Uuid,
+		signal_ids: Vec<Uuid>,
 	},
 	/// Finds signals that match the given tags.
 	List {
@@ -30,18 +29,17 @@ pub enum SubCommand {
 	},
 	/// Silences a signal from showing up as dead or running again.
 	Ack {
-		#[clap(index = 1)]
-		signal_id: Uuid,
+		signal_ids: Vec<Uuid>,
 	},
 }
 
 impl SubCommand {
 	pub async fn execute(self, config: rivet_config::Config) -> Result<()> {
 		match self {
-			Self::Get { signal_id } => {
+			Self::Get { signal_ids } => {
 				let pool = util::wf::build_pool(&config).await?;
-				let signal = util::wf::signal::get_signal(pool, signal_id).await?;
-				util::wf::signal::print_signals(signal.into_iter().collect(), true).await
+				let signals = util::wf::signal::get_signals(pool, signal_ids).await?;
+				util::wf::signal::print_signals(signals, true).await
 			}
 			Self::List {
 				tags,
@@ -55,9 +53,9 @@ impl SubCommand {
 					util::wf::signal::find_signals(pool, tags, workflow_id, name, state).await?;
 				util::wf::signal::print_signals(signals, pretty).await
 			}
-			Self::Ack { signal_id } => {
+			Self::Ack { signal_ids } => {
 				let pool = util::wf::build_pool(&config).await?;
-				util::wf::signal::silence_signal(pool, signal_id).await
+				util::wf::signal::silence_signals(pool, signal_ids).await
 			}
 		}
 	}