Merge branch 'Bugsterapp:main' into main

Author: akabarki76

.github/workflows/release.yml

@@ -55,7 +55,7 @@ jobs:
     strategy:
       matrix:
         include:
-          - os: ubuntu-latest
+          - os: ubuntu-22.04
             asset_name: bugster-linux
           - os: windows-latest
             asset_name: bugster-windows.exe

CHANGELOG.md

@@ -5,6 +5,15 @@ All notable changes to Bugster CLI will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.3.26]
+
+### Added
+- Added  `bugster auth` command for setting up or cleaning existing api key
+- Added  `-- parallel` for  `bugster run` command. Accept both  `--parallel` and  `--max-concurrent`
+
+### Changed
+- Changed max test limit to 10 
+
 ## [0.3.25]
 
 ### Changed

bugster/__init__.py

@@ -2,4 +2,4 @@
 Bugster CLI - A command-line interface tool for managing test cases.
 """
 
-__version__ = "0.3.25"
+__version__ = "0.3.26"

bugster/cli.py

@@ -156,6 +156,21 @@ def init(
     )
 
 
+@app.command()
+def auth(
+    api_key: Optional[str] = typer.Option(
+        None, "--api-key", help="Bugster API key to set (starts with 'bugster_')"
+    ),
+    clear: bool = typer.Option(
+        False, "--clear", help="Clear the existing API key"
+    ),
+):
+    """Authenticate with Bugster API key."""
+    from bugster.commands.auth import auth_command
+
+    auth_command(api_key=api_key, clear=clear)
+
+
 def _run_tests(
     path: Optional[str] = typer.Argument(None, help="Path to test file or directory"),
     headless: Optional[bool] = typer.Option(
@@ -182,7 +197,7 @@ def _run_tests(
         None, "--only-affected", help="Only run tests for affected files or directories"
     ),
     max_concurrent: Optional[int] = typer.Option(
-        5, "--max-concurrent", help="Maximum number of concurrent tests"
+        5, "--max-concurrent", "--parallel", help="Maximum number of concurrent tests"
     ),
     verbose: Optional[bool] = typer.Option(False, "--verbose", help="Verbose output"),
 ):
@@ -384,7 +399,7 @@ def destructive(
     ),
     base_url: Optional[str] = typer.Option(None, help="Override base URL from config"),
     max_concurrent: Optional[int] = typer.Option(
-        None, help="Maximum number of concurrent agents (default: 3)"
+        None, "--max-concurrent", "--parallel", help="Maximum number of concurrent agents (default: 3)"
     ),
     verbose: bool = typer.Option(False, help="Show detailed agent execution logs"),
     run_id: Optional[str] = typer.Option(

bugster/clients/http_client.py

@@ -44,7 +44,7 @@ def patch(
         endpoint: str,
         data: Optional[Dict[str, Any]] = None,
         json: Optional[Dict[str, Any]] = None,
-        **kwargs,
+        **kwargs, 
     ) -> requests.Response:
         """Make a PATCH request."""
         return self._make_request("PATCH", endpoint, data=data, json=json, **kwargs)
@@ -123,4 +123,4 @@ class BugsterHTTPClient(HTTPClient):
 
     def __init__(self):
         """Initialize the HTTP client."""
-        super().__init__(base_url=libs_settings.bugster_api_url)
+        super().__init__(base_url=libs_settings.bugster_api_url)

bugster/commands/auth.py

@@ -3,22 +3,81 @@
 """
 
 from rich.console import Console
-from rich.prompt import Prompt, Confirm
-from bugster.analytics import track_command, BugsterAnalytics
-from bugster.utils.user_config import save_api_key
+from rich.prompt import Prompt
+from bugster.analytics import track_command
+from bugster.utils.user_config import save_api_key, get_api_key, load_user_config, save_user_config
 from bugster.utils.console_messages import AuthMessages
 import webbrowser
+from typing import Optional
 
 console = Console()
 
 DASHBOARD_URL = "https://gui.bugster.dev/"  # Update this with your actual dashboard URL
 API_KEY_HINT = "bugster_..."
 
+def clear_api_key():
+    """Remove the API key from the config file."""
+    config = load_user_config()
+    if "apiKey" in config:
+        del config["apiKey"]
+        save_user_config(config)
+        return True
+    return False
+
 @track_command("auth")
-def auth_command():
+def auth_command(api_key: Optional[str] = None, clear: bool = False):
     """Authenticate user with Bugster API key."""
     console.print()
 
+    # Handle --clear flag
+    if clear:
+        existing_key = get_api_key()
+        if existing_key:
+            if clear_api_key():
+                console.print("✅ [green]API key cleared successfully![/green]")
+            else:
+                console.print("❌ [red]Error clearing API key.[/red]")
+        else:
+            console.print("ℹ️  [yellow]No API key found to clear.[/yellow]")
+        return
+    
+    # Clear existing API key before setting new one
+    existing_key = get_api_key()
+    if existing_key:
+        console.print("🔄 [yellow]Removing existing API key...[/yellow]")
+        clear_api_key()
+    
+    # Handle --api-key flag
+    if api_key:
+        # Validate provided API key
+        if not api_key.strip():
+            console.print("❌ [red]API key cannot be empty.[/red]")
+            return
+            
+        if not api_key.startswith("bugster_"):
+            console.print("⚠️  [yellow]Warning: API keys typically start with 'bugster_'[/yellow]")
+            if Prompt.ask(
+                "🤔 Continue anyway?",
+                choices=["y", "n"],
+                default="n"
+            ) == "n":
+                console.print("❌ [red]Authentication cancelled.[/red]")
+                return
+        
+        console.print("🔄 [yellow]Validating API key...[/yellow]")
+        
+        if validate_api_key(api_key):
+            try:
+                save_api_key(api_key)
+                console.print("✅ [green]API key saved successfully![/green]")
+                        
+            except Exception as e:
+                console.print(f"❌ [red]Error saving API key: {str(e)}[/red]")
+        else:
+            console.print("❌ [red]Invalid API key. Please check and try again.[/red]")
+        return
+    
+    # Interactive flow (original behavior)
     # Show authentication panel
     auth_panel = AuthMessages.create_auth_panel()
     console.print(auth_panel)
@@ -37,13 +96,13 @@ def auth_command():
     # Get API key with validation
     while True:
         AuthMessages.api_key_prompt()
-        api_key = Prompt.ask(AuthMessages.get_api_key_prompt()).strip()
+        user_api_key = Prompt.ask(AuthMessages.get_api_key_prompt()).strip()
 
-        if not api_key:
+        if not user_api_key:
             AuthMessages.empty_api_key_error()
             continue
 
-        if not api_key.startswith("bugster_"):
+        if not user_api_key.startswith("bugster_"):
             AuthMessages.invalid_prefix_warning()
             if Prompt.ask(
                 AuthMessages.get_continue_anyway_prompt(),
@@ -54,38 +113,20 @@ def auth_command():
 
         AuthMessages.validating_api_key()
 
-        if validate_api_key(api_key):  
+        if validate_api_key(user_api_key):  
             break
         else:
             AuthMessages.invalid_api_key_error()
             continue
 
     # Save API key
     try:
-        save_api_key(api_key)
+        save_api_key(user_api_key)
         AuthMessages.auth_success()
     except Exception as e:
         AuthMessages.auth_error(e)
         raise
 
-    # Analytics opt-in/opt-out prompt (only if not already opted out)
-    if not BugsterAnalytics.is_opted_out():
-        analytics_panel = AuthMessages.create_analytics_panel()
-        console.print(analytics_panel)
-        console.print()
-        
-        enable_analytics = Confirm.ask(
-            f"🤔 Would you like to help improve Bugster by sharing anonymous usage analytics?", 
-            default=True
-        )
-        
-        if not enable_analytics:
-            BugsterAnalytics.create_opt_out_file()
-            AuthMessages.analytics_disabled()
-        else:
-            AuthMessages.analytics_enabled()
-        console.print()
-
 def validate_api_key(api_key: str) -> bool:
     """Validate API key by making a test request"""
     try:

bugster/commands/test.py

@@ -15,7 +15,6 @@
 from rich.table import Table
 
 from bugster.analytics import track_command
-from bugster.clients.http_client import BugsterHTTPClient
 from bugster.clients.mcp_client import MCPStdioClient
 from bugster.clients.ws_client import WebSocketClient
 from bugster.commands.middleware import require_api_key
@@ -24,7 +23,7 @@
 from bugster.libs.services.run_limits_service import (
     apply_test_limit,
     count_total_tests,
-    get_test_limit_from_config,
+    get_test_limit_from_config, 
 )
 from bugster.libs.services.update_service import DetectAffectedSpecsService
 from bugster.types import (
@@ -39,14 +38,15 @@
 from bugster.utils.console_messages import RunMessages
 from bugster.utils.file import (
     check_and_update_project_commands,
-    get_mcp_config_path,
-    load_always_run_tests,
-    load_config,
-    load_test_files,
-    merge_always_run_with_affected_tests,
+    get_mcp_config_path, 
+    load_config, 
+    load_test_files, 
+    load_always_run_tests, 
+    merge_always_run_with_affected_tests
 )
 from bugster.utils.user_config import get_api_key
-
+from bugster.clients.http_client import BugsterHTTPClient
+    
 console = Console()
 # Color palette for parallel test execution
 TEST_COLORS = [
@@ -715,24 +715,18 @@ async def test_command(
             try:
                 affected_tests = DetectAffectedSpecsService().run()
                 # Merge affected tests with always-run tests
-                test_files = merge_always_run_with_affected_tests(
-                    affected_tests, always_run_tests
-                )
+                test_files = merge_always_run_with_affected_tests(affected_tests, always_run_tests)
             except Exception as e:
                 RunMessages.error(
                     f"Failed to detect affected specs: {e}. \nRunning all tests..."
                 )
                 test_files = load_test_files(path)
                 # Still merge with always-run tests
-                test_files = merge_always_run_with_affected_tests(
-                    test_files, always_run_tests
-                )
+                test_files = merge_always_run_with_affected_tests(test_files, always_run_tests)
         else:
             test_files = load_test_files(path)
             # Merge all tests with always-run tests
-            test_files = merge_always_run_with_affected_tests(
-                test_files, always_run_tests
-            )
+            test_files = merge_always_run_with_affected_tests(test_files, always_run_tests)
 
         if not test_files:
             RunMessages.no_tests_found()
@@ -741,50 +735,42 @@ async def test_command(
         # Separate always-run tests from regular tests
         regular_tests = [tf for tf in test_files if not tf.get("always_run", False)]
         always_run_tests_list = [tf for tf in test_files if tf.get("always_run", False)]
-
+        
         # Apply limit only to regular tests (not always-run)
         original_count = count_total_tests(regular_tests)
-        limited_regular_tests, folder_distribution = apply_test_limit(
-            regular_tests, max_tests
-        )
+        limited_regular_tests, folder_distribution = apply_test_limit(regular_tests, max_tests)
         selected_count = count_total_tests(limited_regular_tests)
-
+        
         # Combine limited regular tests with always-run tests
         final_test_files = always_run_tests_list + limited_regular_tests
         total_final_count = count_total_tests(final_test_files)
-
+        
         # Print test limit information if limiting was applied
         if int(original_count) > int(max_tests):
             always_run_count = count_total_tests(always_run_tests_list)
-
+            
             # Calculate folder distribution for always-run tests
             always_run_distribution = {}
             for test_file in always_run_tests_list:
                 folder = test_file["file"].parent.name
-                always_run_distribution[folder] = always_run_distribution.get(
-                    folder, 0
-                ) + len(test_file["content"])
-
+                always_run_distribution[folder] = always_run_distribution.get(folder, 0) + len(test_file["content"])
+            
             console.print(
                 RunMessages.create_test_limit_panel(
                     original_count=original_count,
                     selected_count=selected_count,
                     max_tests=max_tests,
                     folder_distribution=folder_distribution,
                     always_run_count=always_run_count,
-                    always_run_distribution=always_run_distribution,
+                    always_run_distribution=always_run_distribution
                 )
             )
-
+        
         # Show always-run information
         if always_run_tests_list:
             always_run_count = count_total_tests(always_run_tests_list)
-            console.print(
-                f"[dim]Always-run tests: {always_run_count} (additional to limit)[/dim]"
-            )
-            console.print(
-                f"[dim]Total tests to run: {total_final_count} (regular: {selected_count} + always-run: {always_run_count})[/dim]"
-            )
+            console.print(f"[dim]Always-run tests: {always_run_count} (additional to limit)[/dim]")
+            console.print(f"[dim]Total tests to run: {total_final_count} (regular: {selected_count} + always-run: {always_run_count})[/dim]")
 
         # Use the final combined test files for execution
         test_files = final_test_files

bugster/libs/services/run_limits_service.py

@@ -158,6 +158,6 @@ def get_test_limit_from_config() -> Optional[int]:
     Returns:
         Maximum number of tests to run, or None if no limit
     """
-    return 5
+    return 10