feat: Support coffee operator

Author: sbernauer

rust/stackablectl/src/cmds/operator.rs

@@ -38,6 +38,18 @@ const INSTALL_AFTER_HELP_TEXT: &str = "Examples:
 
 Use \"stackablectl operator install <OPERATOR> -c <OPTION>\" to create a local cluster";
 
+const COFFEE_ASCII_ART: &str = r#"
+      ) )
+     ( (
+   .------.
+   |      |]
+   \      /
+    `----'
+
+  Psst... "coffee" is not an operator, but we get it.
+  Stackable runs on coffee too. Have a great day! ☕
+"#;
+
 #[derive(Debug, Args)]
 pub struct OperatorArgs {
     #[command(subcommand)]
@@ -98,7 +110,7 @@ Possible valid values are:
 
 Use \"stackablectl operator list\" to list available versions for all operators
 Use \"stackablectl operator describe <OPERATOR>\" to get available versions for one operator")]
-    operators: Vec<operator::OperatorSpec>,
+    operators: Vec<String>,
 
     /// Namespace in the cluster used to deploy the operators
     #[arg(long, default_value = DEFAULT_OPERATOR_NAMESPACE, visible_aliases(["operator-ns"]))]
@@ -169,6 +181,9 @@ pub enum CmdError {
 
     #[snafu(display("OCI error"))]
     OciError { source: oci::Error },
+
+    #[snafu(display("failed to parse operator spec"))]
+    ParseOperatorSpec { source: operator::SpecParseError },
 }
 
 /// This list contains a list of operator version grouped by stable, test and
@@ -315,6 +330,25 @@ async fn install_cmd(args: &OperatorInstallArgs, cli: &Cli) -> Result<String, Cm
     info!("Installing operator(s)");
     Span::current().pb_set_message("Installing operator(s)");
 
+    let operators: Vec<operator::OperatorSpec> = args
+        .operators
+        .iter()
+        .filter_map(|operator| match operator.as_str() {
+            "coffee" | "coffe" => {
+                indicatif_println!("{COFFEE_ASCII_ART}");
+                None
+            }
+            _ => Some(operator),
+        })
+        .map(|s| s.parse().context(ParseOperatorSpecSnafu))
+        .collect::<Result<_, _>>()?;
+
+    // In case no operators need to be installed (e.g. coffee was already installed), there is no
+    // need to connect to Kubernetes and potentially produce error messages.
+    if operators.is_empty() {
+        return Ok(String::new());
+    }
+
     args.local_cluster
         .install_if_needed()
         .await
@@ -328,7 +362,7 @@ async fn install_cmd(args: &OperatorInstallArgs, cli: &Cli) -> Result<String, Cm
             namespace: args.operator_namespace.clone(),
         })?;
 
-    for operator in &args.operators {
+    for operator in &operators {
         operator
             .install(
                 &args.operator_namespace,
@@ -349,8 +383,8 @@ async fn install_cmd(args: &OperatorInstallArgs, cli: &Cli) -> Result<String, Cm
         )
         .with_output(format!(
             "Installed {num_of_operators} {suffix}",
-            num_of_operators = args.operators.len(),
-            suffix = if args.operators.len() == 1 {
+            num_of_operators = operators.len(),
+            suffix = if operators.len() == 1 {
                 "operator"
             } else {
                 "operators"