Merge branch 'main' into test

Author: cmworkato

docs/DEVELOPER_GUIDE.md

@@ -104,4 +104,27 @@ If you want to contribute to the Workato CLI codebase itself, use these developm
 make test      # Run tests and check code style
 ```
 
+### Testing with Test PyPI
+
+When testing pre-release versions from Test PyPI, you need to use both Test PyPI and regular PyPI to resolve dependencies:
+
+**Using pipx (Recommended):**
+```bash
+pipx install \
+  --index-url https://test.pypi.org/simple/ \
+  --pip-args="--extra-index-url https://pypi.org/simple/" \
+  workato-platform-cli
+```
+
+**Using pip:**
+```bash
+pip install \
+  --index-url https://test.pypi.org/simple/ \
+  --extra-index-url https://pypi.org/simple/ \
+  workato-platform-cli
+```
+
+**Why this is needed:**
+Some dependencies (like `aiohttp-retry`) are not available on Test PyPI. Using `--extra-index-url` tells pip to fall back to the regular PyPI index when a package is not found on Test PyPI.
+
 These commands are for CLI maintainers and contributors, not for developers using the CLI to build Workato integrations.

src/workato_platform_cli/cli/commands/assets.py

@@ -15,7 +15,9 @@
 
 @click.command()
 @click.option(
-    "--folder-id", help="Folder ID (uses current project folder if not specified)"
+    "--folder-id",
+    type=int,
+    help="Folder ID (uses current project folder if not specified)",
 )
 @handle_cli_exceptions
 @inject

src/workato_platform_cli/cli/commands/profiles.py

@@ -360,5 +360,53 @@ async def delete(
         click.echo(f"❌ Failed to delete profile '{profile_name}'")
 
 
+@profiles.command()
+@click.argument("profile_name")
+@handle_cli_exceptions
+@inject
+async def create(
+    profile_name: str,
+    config_manager: ConfigManager = Provide[Container.config_manager],
+) -> None:
+    """Create a new profile with API credentials"""
+    # Check if profile already exists
+    existing_profile = config_manager.profile_manager.get_profile(profile_name)
+    if existing_profile:
+        click.echo(f"❌ Profile '{profile_name}' already exists")
+        click.echo("💡 Use 'workato profiles use' to switch to it")
+        click.echo("💡 Or use 'workato profiles delete' to remove it first")
+        return
+
+    click.echo(f"🔧 Creating profile: {profile_name}")
+    click.echo()
+
+    # Create profile interactively
+    try:
+        (
+            profile_data,
+            token,
+        ) = await config_manager.profile_manager.create_profile_interactive(
+            profile_name
+        )
+    except click.ClickException:
+        click.echo("❌ Profile creation cancelled")
+        return
+
+    # Save profile
+    try:
+        config_manager.profile_manager.set_profile(profile_name, profile_data, token)
+    except ValueError as e:
+        click.echo(f"❌ Failed to save profile: {e}")
+        return
+
+    # Set as current profile
+    config_manager.profile_manager.set_current_profile(profile_name)
+
+    click.echo(f"✅ Profile '{profile_name}' created successfully")
+    click.echo(f"✅ Set '{profile_name}' as the active profile")
+    click.echo()
+    click.echo("💡 You can now use this profile with Workato CLI commands")
+
+
 # Add show as click argument command
 show = click.argument("profile_name")(show)

src/workato_platform_cli/cli/utils/config/manager.py

@@ -544,38 +544,9 @@ async def _prompt_and_validate_credentials(
 
     async def _create_new_profile(self, profile_name: str) -> None:
         """Create a new profile interactively"""
-        # Select region
-        click.echo("📍 Select your Workato region")
-        region_result = await self.profile_manager.select_region_interactive()
-
-        if not region_result:
-            raise click.ClickException("Setup cancelled")
-
-        selected_region = region_result
-
-        # Get API token
-        token = await asyncio.to_thread(
-            get_token_with_smart_paste,
-            prompt_text="API token",
-        )
-        if not token.strip():
-            raise click.ClickException("API token cannot be empty")
-
-        # Test authentication and get workspace info
-        api_config = Configuration(
-            access_token=token, host=selected_region.url, ssl_ca_cert=certifi.where()
-        )
-
-        async with Workato(configuration=api_config) as workato_api_client:
-            user_info = await workato_api_client.users_api.get_workspace_details()
-
-        # Create and save profile
-        if not selected_region.url:
-            raise click.ClickException("Region URL is required")
-        profile_data = ProfileData(
-            region=selected_region.region,
-            region_url=selected_region.url,
-            workspace_id=user_info.id,
+        # Create profile using shared helper
+        profile_data, token = await self.profile_manager.create_profile_interactive(
+            profile_name
         )
 
         # Save profile and token

src/workato_platform_cli/cli/utils/config/profiles.py

@@ -1,5 +1,6 @@
 """Profile management for multiple Workato environments."""
 
+import asyncio
 import contextlib
 import json
 import os
@@ -9,13 +10,18 @@
 from urllib.parse import urlparse
 
 import asyncclick as click
+import certifi
 import inquirer
 import keyring
 
 from keyring.backend import KeyringBackend
 from keyring.compat import properties
 from keyring.errors import KeyringError, NoKeyringError
 
+from workato_platform_cli import Workato
+from workato_platform_cli.cli.utils.token_input import get_token_with_smart_paste
+from workato_platform_cli.client.workato_api.configuration import Configuration
+
 from .models import AVAILABLE_REGIONS, ProfileData, ProfilesConfig, RegionInfo
 
 
@@ -489,3 +495,62 @@ async def select_region_interactive(
             return RegionInfo(region="custom", name="Custom URL", url=custom_url)
 
         return selected_region
+
+    async def create_profile_interactive(
+        self, profile_name: str
+    ) -> tuple[ProfileData, str]:
+        """Create a new profile with interactive prompts for region and token.
+
+        Performs region selection, token input, credential validation, and returns
+        the validated profile data and token.
+
+        Args:
+            profile_name: Name of the profile being created
+
+        Returns:
+            tuple[ProfileData, str]: The validated profile data and API token
+
+        Raises:
+            click.ClickException: If setup is cancelled, token is empty,
+                or validation fails
+        """
+        # Step 1: Select region
+        click.echo("📍 Select your Workato region")
+        selected_region = await self.select_region_interactive(profile_name)
+
+        if not selected_region:
+            raise click.ClickException("Setup cancelled")
+
+        # Step 2: Get API token
+        token = await asyncio.to_thread(
+            get_token_with_smart_paste,
+            prompt_text="API token",
+        )
+        if not token.strip():
+            raise click.ClickException("API token cannot be empty")
+
+        # Step 3: Test authentication and get workspace info
+        click.echo("🔄 Validating credentials...")
+        api_config = Configuration(
+            access_token=token, host=selected_region.url, ssl_ca_cert=certifi.where()
+        )
+
+        try:
+            async with Workato(configuration=api_config) as workato_api_client:
+                user_info = await workato_api_client.users_api.get_workspace_details()
+        except Exception as e:
+            raise click.ClickException(f"Authentication failed: {e}") from e
+
+        # Step 4: Create profile data
+        if not selected_region.url:
+            raise click.ClickException("Region URL is required")
+
+        profile_data = ProfileData(
+            region=selected_region.region,
+            region_url=selected_region.url,
+            workspace_id=user_info.id,
+        )
+
+        click.echo(f"✅ Authenticated as: {user_info.name}")
+
+        return profile_data, token

src/workato_platform_cli/client/workato_api/models/asset.py

@@ -42,8 +42,8 @@ class Asset(BaseModel):
     @field_validator('type')
     def type_validate_enum(cls, value):
         """Validates the enum"""
-        if value not in set(['recipe', 'connection', 'lookup_table', 'workato_db_table', 'account_property', 'project_property', 'workato_schema', 'workato_template', 'lcap_app', 'lcap_page', 'custom_adapter', 'topic', 'api_group', 'api_endpoint']):
-            raise ValueError("must be one of enum values ('recipe', 'connection', 'lookup_table', 'workato_db_table', 'account_property', 'project_property', 'workato_schema', 'workato_template', 'lcap_app', 'lcap_page', 'custom_adapter', 'topic', 'api_group', 'api_endpoint')")
+        if value not in set(['recipe', 'connection', 'lookup_table', 'workato_db_table', 'account_property', 'project_property', 'workato_schema', 'workato_template', 'lcap_app', 'lcap_page', 'custom_adapter', 'topic', 'api_group', 'api_endpoint', 'agentic_genie', 'agentic_skill', 'data_pipeline', 'decision_engine_model', 'agentic_knowledge_base', 'mcp_server']):
+            raise ValueError("must be one of enum values ('recipe', 'connection', 'lookup_table', 'workato_db_table', 'account_property', 'project_property', 'workato_schema', 'workato_template', 'lcap_app', 'lcap_page', 'custom_adapter', 'topic', 'api_group', 'api_endpoint', 'agentic_genie', 'agentic_skill', 'data_pipeline', 'decision_engine_model', 'agentic_knowledge_base', 'mcp_server')")
         return value
 
     @field_validator('status')

src/workato_platform_cli/client/workato_api/models/asset_reference.py

@@ -40,8 +40,8 @@ class AssetReference(BaseModel):
     @field_validator('type')
     def type_validate_enum(cls, value):
         """Validates the enum"""
-        if value not in set(['recipe', 'connection', 'lookup_table', 'workato_db_table', 'account_property', 'project_property', 'workato_schema', 'workato_template', 'lcap_app', 'lcap_page', 'custom_adapter', 'topic', 'api_group', 'api_endpoint']):
-            raise ValueError("must be one of enum values ('recipe', 'connection', 'lookup_table', 'workato_db_table', 'account_property', 'project_property', 'workato_schema', 'workato_template', 'lcap_app', 'lcap_page', 'custom_adapter', 'topic', 'api_group', 'api_endpoint')")
+        if value not in set(['recipe', 'connection', 'lookup_table', 'workato_db_table', 'account_property', 'project_property', 'workato_schema', 'workato_template', 'lcap_app', 'lcap_page', 'custom_adapter', 'topic', 'api_group', 'api_endpoint', 'agentic_genie', 'agentic_skill', 'data_pipeline', 'decision_engine_model', 'agentic_knowledge_base', 'mcp_server']):
+            raise ValueError("must be one of enum values ('recipe', 'connection', 'lookup_table', 'workato_db_table', 'account_property', 'project_property', 'workato_schema', 'workato_template', 'lcap_app', 'lcap_page', 'custom_adapter', 'topic', 'api_group', 'api_endpoint', 'agentic_genie', 'agentic_skill', 'data_pipeline', 'decision_engine_model', 'agentic_knowledge_base', 'mcp_server')")
         return value
 
     model_config = ConfigDict(