Remove /subscribe (#3402)

* Remove /subscribe

* Fixing fmt issues

---------

Co-authored-by: Akhilesh Bontala <bontalaa@amazon.com>

Author: akhileshb

crates/chat-cli/src/cli/chat/cli/mod.rs

@@ -16,7 +16,7 @@ pub mod persist;
 pub mod profile;
 pub mod prompts;
 pub mod reply;
-pub mod subscribe;
+
 pub mod tangent;
 pub mod todos;
 pub mod tools;
@@ -44,7 +44,6 @@ use tools::ToolsArgs;
 
 use crate::cli::chat::cli::checkpoint::CheckpointSubcommand;
 use crate::cli::chat::cli::context::ContextArgs;
-use crate::cli::chat::cli::subscribe::SubscribeArgs;
 use crate::cli::chat::cli::usage::UsageArgs;
 use crate::cli::chat::consts::AGENT_MIGRATION_DOC_URL;
 use crate::cli::chat::{
@@ -106,8 +105,7 @@ pub enum SlashCommand {
     Model(ModelArgs),
     /// Toggle experimental features
     Experiment(ExperimentArgs),
-    /// Upgrade to a Kiro Developer Pro subscription for increased query limits
-    Subscribe(SubscribeArgs),
+
     /// (Beta) Toggle tangent mode for isolated conversations. Requires "q settings
     /// chat.enableTangentMode true"
     #[command(hide = true)]
@@ -182,7 +180,7 @@ impl SlashCommand {
             Self::Mcp(args) => args.execute(session).await,
             Self::Model(args) => args.execute(os, session).await,
             Self::Experiment(args) => args.execute(os, session).await,
-            Self::Subscribe(args) => args.execute(os, session).await,
+
             Self::Tangent(args) => args.execute(os, session).await,
             Self::Persist(subcommand) => subcommand.execute(os, session).await,
             // Self::Root(subcommand) => {
@@ -221,7 +219,7 @@ impl SlashCommand {
             Self::Mcp(_) => "mcp",
             Self::Model(_) => "model",
             Self::Experiment(_) => "experiment",
-            Self::Subscribe(_) => "subscribe",
+
             Self::Tangent(_) => "tangent",
             Self::Persist(sub) => match sub {
                 PersistSubcommand::Save { .. } => "save",

crates/chat-cli/src/cli/chat/cli/subscribe.rs

@@ -51,11 +51,7 @@ async fn render_available_billing(
         style::SetAttribute(style::Attribute::Bold),
         style::Print("Usage details\n"),
         style::SetAttribute(style::Attribute::Reset),
-        style::Print("To manage your account, upgrade your plan or configure overages use "),
-        style::SetForegroundColor(Color::Blue),
-        style::Print("/subscribe"),
-        style::SetForegroundColor(Color::Reset),
-        style::Print(" to open admin hub\n\n"),
+        style::Print("To manage your account, upgrade your plan or configure overages, visit the admin hub\n\n"),
     )?;
 
     // Bonus credits

crates/chat-cli/src/cli/chat/cli/usage/usage_renderer.rs

@@ -3853,40 +3853,6 @@ async fn get_subscription_status(os: &mut Os) -> Result<ActualSubscriptionStatus
     }
 }
 
-async fn get_subscription_status_with_spinner(
-    os: &mut Os,
-    output: &mut (impl Write + Clone + Send + Sync + 'static),
-) -> Result<ActualSubscriptionStatus> {
-    return with_spinner(output, "Checking subscription status...", || async {
-        get_subscription_status(os).await
-    })
-    .await;
-}
-
-pub async fn with_spinner<T, E, F, Fut, S: std::io::Write + Clone + Send + Sync + 'static>(
-    output: &mut S,
-    spinner_text: &str,
-    f: F,
-) -> Result<T, E>
-where
-    F: FnOnce() -> Fut,
-    Fut: std::future::Future<Output = Result<T, E>>,
-{
-    queue!(output, cursor::Hide,).ok();
-    let spinner = Spinner::new(Spinners::Dots, spinner_text.to_owned());
-
-    let result = f().await;
-
-    drop(spinner);
-    let _ = queue!(
-        output,
-        terminal::Clear(terminal::ClearType::CurrentLine),
-        cursor::MoveToColumn(0),
-    );
-
-    result
-}
-
 /// Checks if an input may be referencing a file and should not be handled as a typical slash
 /// command. If true, then return [Option::Some<ChatState>], otherwise [Option::None].
 fn does_input_reference_file(input: &str) -> Option<ChatState> {
@@ -4377,38 +4343,6 @@ mod tests {
         }
     }
 
-    #[tokio::test]
-    #[cfg(unix)]
-    async fn test_subscribe_flow() {
-        let mut os = Os::new().await.unwrap();
-        os.client.set_mock_output(serde_json::Value::Array(vec![]));
-        let agents = get_test_agents(&os).await;
-
-        let tool_manager = ToolManager::default();
-        let tool_config = serde_json::from_str::<HashMap<String, ToolSpec>>(include_str!("tools/tool_index.json"))
-            .expect("Tools failed to load");
-        ChatSession::new(
-            &mut os,
-            "fake_conv_id",
-            agents,
-            None,
-            InputSource::new_mock(vec!["/subscribe".to_string(), "y".to_string(), "/quit".to_string()]),
-            false,
-            || Some(80),
-            tool_manager,
-            None,
-            tool_config,
-            true,
-            false,
-            None,
-        )
-        .await
-        .unwrap()
-        .spawn(&mut os)
-        .await
-        .unwrap();
-    }
-
     // Integration test for PreToolUse hook functionality.
     //
     // In this integration test we create a preToolUse hook that logs tool info into a file

crates/chat-cli/src/cli/chat/mod.rs

@@ -144,7 +144,6 @@ pub const COMMANDS: &[&str] = &[
     "/save",
     "/load",
     "/paste",
-    "/subscribe",
 ];
 
 /// Generate dynamic command list including experiment-based commands when enabled

crates/chat-cli/src/cli/chat/prompt.rs

@@ -171,26 +171,6 @@ pub mod ui_text {
     }
 }
 
-/// Subscription-related text constants
-pub mod subscription_text {
-    use super::PRODUCT_NAME;
-
-    /// Message for IDC users about subscription management
-    pub fn idc_subscription_message() -> String {
-        format!("Your {PRODUCT_NAME} Pro subscription is managed through IAM Identity Center.")
-    }
-
-    /// Message when user doesn't have an active subscription
-    pub fn no_subscription_message() -> String {
-        format!("You don't seem to have a {PRODUCT_NAME} Pro subscription.")
-    }
-
-    /// Message when user already has an active subscription
-    pub fn already_subscribed_message() -> String {
-        format!("Your Builder ID already has a {PRODUCT_NAME} Pro subscription.")
-    }
-}
-
 /// Context-related text constants
 pub mod context_text {
     use super::PRODUCT_NAME;