golem-cli 1.3.1

// Copyright 2024-2025 Golem Cloud
//
// Licensed under the Golem Source License v1.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://license.golem.cloud/LICENSE
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

use crate::app::yaml_edit::AppYamlEditor;
use crate::command::api::definition::ApiDefinitionSubcommand;
use crate::command::shared_args::{DeployArgs, ProjectOptionalFlagArg};
use crate::command_handler::Handlers;
use crate::context::Context;
use crate::error::service::AnyhowMapServiceError;
use crate::error::NonSuccessfulExit;
use crate::log::{
    log_action, log_skipping_up_to_date, log_warn_action, logln, LogColorize, LogIndent,
};
use crate::model::api::{ApiDefinitionId, ApiDefinitionVersion, HttpApiDeployMode};
use crate::model::app::{
    ApplicationComponentSelectMode, DynamicHelpSections, HttpApiDefinitionName, WithSource,
};
use crate::model::app_raw::HttpApiDefinition;
use crate::model::component::Component;
use crate::model::deploy_diff::api_definition::DiffableHttpApiDefinition;
use crate::model::text::api_definition::{
    ApiDefinitionExportView, ApiDefinitionGetView, ApiDefinitionNewView, ApiDefinitionUpdateView,
};
use crate::model::text::fmt::{log_deploy_diff, log_error, log_warn};
use crate::model::{ComponentName, OpenApiDefinitionOutputFormat, ProjectRefAndId};
use anyhow::{bail, Context as AnyhowContext};
use golem_client::api::{ApiDefinitionClient, ApiDeploymentClient};
use golem_client::model::{HttpApiDefinitionRequest, HttpApiDefinitionResponseData};
use itertools::Itertools;
use serde::de::DeserializeOwned;
use std::collections::{BTreeMap, BTreeSet};
use std::sync::Arc;
use warp;
use webbrowser;

pub struct ApiDefinitionCommandHandler {
    ctx: Arc<Context>,
}

impl ApiDefinitionCommandHandler {
    pub fn new(ctx: Arc<Context>) -> Self {
        Self { ctx }
    }

    pub async fn handle_command(&self, command: ApiDefinitionSubcommand) -> anyhow::Result<()> {
        match command {
            ApiDefinitionSubcommand::Deploy {
                http_api_definition_name,
                deploy_args,
            } => self.cmd_deploy(http_api_definition_name, deploy_args).await,
            ApiDefinitionSubcommand::Get {
                project,
                id,
                version,
            } => self.cmd_get(project, id, version).await,
            ApiDefinitionSubcommand::Delete {
                project,
                id,
                version,
            } => self.cmd_delete(project, id, version).await,
            ApiDefinitionSubcommand::List { project, id } => self.cmd_list(project, id).await,
            ApiDefinitionSubcommand::Export {
                project,
                id,
                version,
                format,
                output_name,
            } => {
                self.cmd_export(project, id, version, format, output_name)
                    .await
            }
            ApiDefinitionSubcommand::Swagger {
                project,
                id,
                version,
                port,
            } => self.cmd_swagger(project, id, version, port).await,
        }
    }

    async fn cmd_deploy(
        &self,
        name: Option<HttpApiDefinitionName>,
        deploy_args: DeployArgs,
    ) -> anyhow::Result<()> {
        let project = self
            .ctx
            .cloud_project_handler()
            .opt_select_project(None)
            .await?;

        if deploy_args.reset {
            self.delete_all_for_reset_once(project.as_ref()).await?;
        }

        if let Some(name) = name.as_ref() {
            let app_ctx = self.ctx.app_context_lock().await;
            let app_ctx = app_ctx.some_or_err()?;
            if !app_ctx
                .application
                .http_api_definitions()
                .keys()
                .contains(name)
            {
                logln("");
                log_error(format!(
                    "HTTP API definition {} not found in the application manifest",
                    name.as_str().log_color_highlight()
                ));
                logln("");
                app_ctx.log_dynamic_help(&DynamicHelpSections::show_api_definitions())?;
                bail!(NonSuccessfulExit)
            }
        }

        let api_def_filter = name.as_ref().into_iter().cloned().collect::<BTreeSet<_>>();

        let lastest_used_components = self
            .deploy_required_components(project.as_ref(), &deploy_args, api_def_filter)
            .await?;

        match &name {
            Some(name) => {
                let definition = {
                    let app_ctx = self.ctx.app_context_lock().await;
                    let app_ctx = app_ctx.some_or_err()?;
                    app_ctx
                        .application
                        .http_api_definitions()
                        .get(name)
                        .unwrap()
                        .clone()
                };

                self.deploy_api_definition(
                    project.as_ref(),
                    HttpApiDeployMode::All,
                    &deploy_args,
                    &lastest_used_components,
                    name,
                    &definition,
                )
                .await?;

                Ok(())
            }
            None => {
                self.deploy(
                    project.as_ref(),
                    HttpApiDeployMode::All,
                    &deploy_args,
                    &lastest_used_components,
                )
                .await?;

                Ok(())
            }
        }
    }

    async fn cmd_get(
        &self,
        project: ProjectOptionalFlagArg,
        api_def_id: ApiDefinitionId,
        version: ApiDefinitionVersion,
    ) -> anyhow::Result<()> {
        let project = self
            .ctx
            .cloud_project_handler()
            .opt_select_project(project.project.as_ref())
            .await?;

        match self
            .api_definition(project.as_ref(), &api_def_id.0, &version.0)
            .await?
        {
            Some(result) => {
                self.ctx
                    .log_handler()
                    .log_view(&ApiDefinitionGetView(result));
                Ok(())
            }
            None => {
                log_error("Not found");
                bail!(NonSuccessfulExit)
            }
        }
    }

    async fn cmd_list(
        &self,
        project: ProjectOptionalFlagArg,
        api_definition_id: Option<ApiDefinitionId>,
    ) -> anyhow::Result<()> {
        let project = self
            .ctx
            .cloud_project_handler()
            .opt_select_project(project.project.as_ref())
            .await?;

        let clients = self.ctx.golem_clients().await?;

        let definitions = clients
            .api_definition
            .list_definitions(
                &self
                    .ctx
                    .cloud_project_handler()
                    .selected_project_id_or_default(project.as_ref())
                    .await?
                    .0,
                api_definition_id.as_ref().map(|id| id.0.as_str()),
            )
            .await
            .map_service_error()?;

        self.ctx.log_handler().log_view(&definitions);

        Ok(())
    }

    async fn cmd_delete(
        &self,
        project: ProjectOptionalFlagArg,
        api_def_id: ApiDefinitionId,
        version: ApiDefinitionVersion,
    ) -> anyhow::Result<()> {
        let project = self
            .ctx
            .cloud_project_handler()
            .opt_select_project(project.project.as_ref())
            .await?;

        let clients = self.ctx.golem_clients().await?;

        clients
            .api_definition
            .delete_definition(
                &self
                    .ctx
                    .cloud_project_handler()
                    .selected_project_id_or_default(project.as_ref())
                    .await?
                    .0,
                &api_def_id.0,
                &version.0,
            )
            .await
            .map_service_error()?;

        log_warn_action(
            "Deleted",
            format!(
                "API definition: {}/{}",
                api_def_id.0.log_color_highlight(),
                version.0.log_color_highlight()
            ),
        );

        Ok(())
    }

    async fn cmd_export(
        &self,
        project: ProjectOptionalFlagArg,
        id: ApiDefinitionId,
        version: ApiDefinitionVersion,
        format: OpenApiDefinitionOutputFormat,
        output_name: Option<String>,
    ) -> anyhow::Result<()> {
        let project = self
            .ctx
            .cloud_project_handler()
            .opt_select_project(project.project.as_ref())
            .await?;

        let clients = self.ctx.golem_clients().await?;

        let response = clients
            .api_definition
            .export_definition(
                &self
                    .ctx
                    .cloud_project_handler()
                    .selected_project_id_or_default(project.as_ref())
                    .await?
                    .0,
                &id.0,
                &version.0,
            )
            .await
            .map_service_error()?;

        let openapi_spec = response.openapi_yaml;
        let file_name = output_name.unwrap_or_else(|| format!("{}_{}", id.0, version.0));
        let file_path = match format {
            OpenApiDefinitionOutputFormat::Json => format!("{file_name}.json"),
            OpenApiDefinitionOutputFormat::Yaml => format!("{file_name}.yaml"),
        };

        match format {
            OpenApiDefinitionOutputFormat::Json => {
                // Convert YAML to JSON for the JSON format option
                let yaml_obj: serde_yaml::Value = serde_yaml::from_str(&openapi_spec)?;
                let json_obj: serde_json::Value = serde_json::to_value(yaml_obj)?;
                let json_str = serde_json::to_string_pretty(&json_obj)?;
                std::fs::write(&file_path, json_str)?;
            }
            OpenApiDefinitionOutputFormat::Yaml => {
                // Use YAML directly for the YAML format option
                std::fs::write(&file_path, openapi_spec)?;
            }
        }

        let result = format!("Exported to {file_path}");

        self.ctx
            .log_handler()
            .log_view(&ApiDefinitionExportView(result));

        Ok(())
    }

    async fn cmd_swagger(
        &self,
        project: ProjectOptionalFlagArg,
        id: ApiDefinitionId,
        version: ApiDefinitionVersion,
        port: u16,
    ) -> anyhow::Result<()> {
        let project = self
            .ctx
            .cloud_project_handler()
            .opt_select_project(project.project.as_ref())
            .await?;

        let clients = self.ctx.golem_clients().await?;

        // First export the API spec
        let response = clients
            .api_definition
            .export_definition(
                &self
                    .ctx
                    .cloud_project_handler()
                    .selected_project_id_or_default(project.as_ref())
                    .await?
                    .0,
                &id.0,
                &version.0,
            )
            .await
            .map_service_error()?;

        let openapi_spec = response.openapi_yaml;

        // Parse the YAML spec into JSON Value
        let mut spec: serde_json::Value = serde_yaml::from_str(&openapi_spec)?;

        // Filter paths to only include methods with binding-type: default
        filter_routes(&mut spec);

        // Fetch deployments
        let project_id = self
            .ctx
            .cloud_project_handler()
            .selected_project_id_or_default(project.as_ref())
            .await?
            .0;

        let deployments = clients
            .api_deployment
            .list_deployments(&project_id, Some(&id.0))
            .await
            .map_service_error()?;

        // Add server information if deployments exist
        if !deployments.is_empty() {
            // Initialize servers array if it doesn't exist
            if !spec.as_object().unwrap().contains_key("servers") {
                spec.as_object_mut()
                    .unwrap()
                    .insert("servers".to_string(), serde_json::Value::Array(Vec::new()));
            }

            // Add servers to the spec
            if let Some(servers) = spec.get_mut("servers") {
                if let Some(servers) = servers.as_array_mut() {
                    // Add deployment servers with HTTP
                    for deployment in &deployments {
                        let url = match &deployment.site.subdomain {
                            Some(subdomain) => {
                                format!("http://{}.{}", subdomain, deployment.site.host)
                            }
                            None => format!("http://{}", deployment.site.host),
                        };
                        servers.push(serde_json::json!({
                            "url": url,
                            "description": "Deployed instance"
                        }));
                    }
                }
            }
        }

        // Validate port
        if port == 0 {
            return Err(anyhow::anyhow!(
                "Port number must be greater than 0. Provided: {}",
                port
            ));
        }

        // Start local Swagger UI server
        self.start_local_swagger_ui(serde_yaml::to_string(&spec)?, port)
            .await?;

        self.ctx
            .log_handler()
            .log_view(&ApiDefinitionExportView(format!(
                "Swagger UI running at http://localhost:{}\n{}",
                port,
                if deployments.is_empty() {
                    "No deployments found - displaying API schema without server information"
                        .to_string()
                } else {
                    format!("API is deployed at {} locations", deployments.len())
                }
            )));

        // Wait for ctrl+c
        tokio::signal::ctrl_c().await?;

        Ok(())
    }

    async fn start_local_swagger_ui(&self, spec: String, port: u16) -> anyhow::Result<()> {
        use std::net::TcpListener;
        use std::sync::Arc;
        use warp::Filter;

        // First check if the port is available
        let listener = TcpListener::bind(("127.0.0.1", port));
        if listener.is_err() {
            return Err(anyhow::anyhow!(
                "Port {} is already in use. Please choose a different port.",
                port
            ));
        }
        drop(listener); // Close the test connection

        // Parse the YAML to ensure it's valid
        let spec_value: serde_yaml::Value = serde_yaml::from_str(&spec)?;

        // Convert to JSON for Swagger UI
        let spec_json = serde_json::to_value(&spec_value)?;

        // Create a shared spec for the server
        let spec = Arc::new(spec_json);

        // Serve the OpenAPI spec as JSON
        let openapi_route =
            warp::path("openapi.json").map(move || warp::reply::json(spec.clone().as_ref()));

        // Serve the Swagger UI HTML
        let swagger_ui_html = r#"
            <!DOCTYPE html>
            <html lang="en">
            <head>
                <meta charset="UTF-8">
                <title>Swagger UI</title>
                <link rel="stylesheet" type="text/css" href="https://cdn.jsdelivr.net/npm/swagger-ui-dist@5/swagger-ui.css">
                <script src="https://cdn.jsdelivr.net/npm/swagger-ui-dist@5/swagger-ui-bundle.js"></script>
                <script src="https://cdn.jsdelivr.net/npm/swagger-ui-dist@5/swagger-ui-standalone-preset.js"></script>
            </head>
            <body>
                <div id="swagger-ui"></div>
                <script>
                    window.onload = () => {
                        window.ui = SwaggerUIBundle({
                            url: '/openapi.json',
                            dom_id: '#swagger-ui',
                            deepLinking: true,
                            presets: [
                                SwaggerUIBundle.presets.apis,
                                SwaggerUIStandalonePreset
                            ],
                            layout: "StandaloneLayout"
                        });
                    };
                </script>
            </body>
            </html>
        "#;

        let swagger_route = warp::path::end().map(move || warp::reply::html(swagger_ui_html));

        // Combine routes
        let routes = openapi_route.or(swagger_route);

        // Start server in a background task
        tokio::spawn(async move {
            warp::serve(routes).run(([127, 0, 0, 1], port)).await;
        });

        // Try to open browser
        match webbrowser::open(&format!("http://localhost:{port}")) {
            Ok(_) => println!("Browser opened successfully."),
            Err(_) => println!(
                "Could not open browser automatically. You can access the Swagger UI at: http://localhost:{port}"
            ),
        }

        Ok(())
    }

    pub async fn deploy(
        &self,
        project: Option<&ProjectRefAndId>,
        deploy_mode: HttpApiDeployMode,
        deploy_args: &DeployArgs,
        latest_component_versions: &BTreeMap<String, Component>,
    ) -> anyhow::Result<BTreeMap<String, String>> {
        let api_definitions = {
            let app_ctx = self.ctx.app_context_lock().await;
            let app_ctx = app_ctx.some_or_err()?;
            app_ctx.application.http_api_definitions().clone()
        };

        let mut latest_api_definition_versions = BTreeMap::new();

        if !api_definitions.is_empty() {
            log_action("Deploying", "HTTP API definitions");

            for (api_definition_name, api_definition) in api_definitions {
                let _indent = LogIndent::new();
                let version = self
                    .deploy_api_definition(
                        project,
                        deploy_mode,
                        deploy_args,
                        latest_component_versions,
                        &api_definition_name,
                        &api_definition,
                    )
                    .await?;

                if let Some(version) = version {
                    latest_api_definition_versions.insert(api_definition_name.to_string(), version);
                }
            }
        }

        Ok(latest_api_definition_versions)
    }

    pub async fn delete_all_for_reset_once(
        &self,
        project: Option<&ProjectRefAndId>,
    ) -> anyhow::Result<()> {
        self.ctx
            .reset_http_api_definitions_once(|| async { self.delete_all_for_reset(project).await })
            .await
    }

    async fn delete_all_for_reset(&self, project: Option<&ProjectRefAndId>) -> anyhow::Result<()> {
        let api_definitions = {
            let app_ctx = self.ctx.app_context_lock().await;
            let app_ctx = app_ctx.some_or_err()?;
            app_ctx.application.http_api_definitions().clone()
        };

        let clients = self.ctx.golem_clients().await?;

        let project = &self
            .ctx
            .cloud_project_handler()
            .selected_project_id_or_default(project)
            .await?;

        let all_deployed_api_definitions = clients
            .api_definition
            .list_definitions(&project.0, None)
            .await
            .map_service_error()?;

        let (to_redeploy, to_delete): (Vec<_>, Vec<_>) = all_deployed_api_definitions
            .into_iter()
            .partition(|api_definition| {
                api_definitions
                    .contains_key(&HttpApiDefinitionName::from(api_definition.id.as_str()))
            });

        let steps = to_delete
            .iter()
            .map(|api_definition| {
                format!(
                    "{} API definition {}@{}",
                    "Delete".log_color_warn(),
                    api_definition.id.as_str().log_color_highlight(),
                    api_definition.version.as_str().log_color_highlight()
                )
            })
            .chain(to_redeploy.iter().map(|api_definition| {
                format!(
                    "{} and {} API definition {}@{}",
                    "Delete".log_color_warn(),
                    "redeploy".log_color_ok_highlight(),
                    api_definition.id.as_str().log_color_highlight(),
                    api_definition.version.as_str().log_color_highlight()
                )
            }))
            .collect::<Vec<_>>();

        if steps.is_empty() {
            return Ok(());
        }

        if !self
            .ctx
            .interactive_handler()
            .confirm_reset_http_api_defs(&steps)?
        {
            bail!(NonSuccessfulExit);
        }

        log_action("Deleting", "HTTP API definitions");
        let _indent = LogIndent::new();

        for api_def in to_redeploy.iter().chain(to_delete.iter()) {
            clients
                .api_definition
                .delete_definition(&project.0, &api_def.id, &api_def.version)
                .await
                .map_service_error()?;

            log_warn_action(
                "Deleted",
                format!(
                    "API definition: {}/{}",
                    api_def.id.log_color_highlight(),
                    api_def.version.log_color_highlight()
                ),
            );
        }

        Ok(())
    }

    pub async fn deploy_api_definition(
        &self,
        project: Option<&ProjectRefAndId>,
        deploy_mode: HttpApiDeployMode,
        deploy_args: &DeployArgs,
        latest_component_versions: &BTreeMap<String, Component>,
        api_definition_name: &HttpApiDefinitionName,
        api_definition: &WithSource<HttpApiDefinition>,
    ) -> anyhow::Result<Option<String>> {
        let skip_by_component_filter = match deploy_mode {
            HttpApiDeployMode::All => false,
            HttpApiDeployMode::Matching => !api_definition.value.routes.iter().any(|route| {
                match &route.binding.component_name {
                    Some(component_name) => latest_component_versions.contains_key(component_name),
                    None => false,
                }
            }),
        };

        if skip_by_component_filter {
            log_warn_action(
                "Skipping",
                format!(
                    "deploying HTTP API definition {}, not matched by component selection",
                    api_definition_name.as_str().log_color_highlight()
                ),
            );
            return Ok(None);
        };

        let server_diffable_api_definition = self
            .api_definition(
                project,
                api_definition_name.as_str(),
                api_definition.value.version.as_str(),
            )
            .await?
            .map(DiffableHttpApiDefinition::from_server)
            .transpose()?;
        let manifest_api_definition = DiffableHttpApiDefinition::from_manifest(
            server_diffable_api_definition.as_ref(),
            api_definition_name,
            &api_definition.value,
            latest_component_versions,
        )?;

        match server_diffable_api_definition {
            Some(server_diffable_api_definition) => {
                if server_diffable_api_definition != manifest_api_definition {
                    log_warn_action(
                        "Found",
                        format!(
                            "changes in HTTP API definition {}@{}",
                            api_definition_name.as_str().log_color_highlight(),
                            manifest_api_definition
                                .0
                                .version
                                .as_str()
                                .log_color_highlight()
                        ),
                    );

                    {
                        let _indent = self.ctx.log_handler().nested_text_view_indent();
                        log_deploy_diff(&server_diffable_api_definition, &manifest_api_definition)?;
                    }

                    if server_diffable_api_definition.0.draft {
                        log_action(
                            "Updating",
                            format!(
                                "HTTP API definition {}",
                                api_definition_name.as_str().log_color_highlight()
                            ),
                        );

                        let result = self
                            .update_api_definition(project, &manifest_api_definition.0)
                            .await?;

                        self.ctx
                            .log_handler()
                            .log_view(&ApiDefinitionUpdateView(result));

                        Ok(Some(manifest_api_definition.0.version))
                    } else {
                        log_warn(
                            "The current version of the HTTP API is already deployed as non-draft.",
                        );

                        if deploy_args.redeploy_http_api(self.ctx.deploy_args()) {
                            self.ctx
                                .api_deployment_handler()
                                .undeploy_api_from_all_sites_for_redeploy(
                                    project,
                                    api_definition_name,
                                )
                                .await?;

                            log_action(
                                "Redeploying",
                                format!(
                                    "new HTTP API definition version {}@{}",
                                    api_definition_name.as_str().log_color_highlight(),
                                    manifest_api_definition
                                        .0
                                        .version
                                        .as_str()
                                        .log_color_highlight()
                                ),
                            );

                            let result = self
                                .update_api_definition(project, &manifest_api_definition.0)
                                .await?;

                            self.ctx
                                .log_handler()
                                .log_view(&ApiDefinitionNewView(result));

                            Ok(Some(manifest_api_definition.0.version))
                        } else {
                            match self
                                .ctx
                                .interactive_handler()
                                .select_new_api_definition_version(&manifest_api_definition.0)?
                            {
                                Some(new_version) => {
                                    let new_draft = true;
                                    let old_version = manifest_api_definition.0.version.clone();

                                    let manifest_api_definition = {
                                        let mut manifest_api_definition = manifest_api_definition;
                                        manifest_api_definition.0.version = new_version;
                                        manifest_api_definition.0.draft = new_draft;
                                        manifest_api_definition
                                    };

                                    {
                                        let app_ctx = self.ctx.app_context_lock().await;
                                        let app_ctx = app_ctx.some_or_err()?;

                                        let mut editor = AppYamlEditor::new(&app_ctx.application);
                                        editor.update_api_definition_version(
                                            api_definition_name,
                                            &manifest_api_definition.0.version,
                                        )?;
                                        editor.update_documents()?;
                                    }

                                    log_action(
                                        "Creating",
                                        format!(
                                            "new HTTP API definition version for {}, with version updated from {} to {}",
                                            api_definition_name.as_str().log_color_highlight(),
                                            old_version.log_color_highlight(),
                                            manifest_api_definition
                                                .0.version
                                                .as_str()
                                                .log_color_highlight()
                                        ),
                                    );

                                    let result = self
                                        .new_api_definition(project, &manifest_api_definition.0)
                                        .await?;

                                    self.ctx
                                        .log_handler()
                                        .log_view(&ApiDefinitionNewView(result));

                                    Ok(Some(manifest_api_definition.0.version))
                                }
                                None => {
                                    log_error(format!(
                                        "Please specify a new version for {} in {}",
                                        api_definition_name.as_str().log_color_highlight(),
                                        api_definition.source.log_color_highlight()
                                    ));
                                    bail!(NonSuccessfulExit)
                                }
                            }
                        }
                    }
                } else {
                    log_skipping_up_to_date(format!(
                        "deploying HTTP API definition {}",
                        api_definition_name.as_str().log_color_highlight()
                    ));
                    Ok(Some(server_diffable_api_definition.0.version))
                }
            }
            None => {
                log_action(
                    "Creating",
                    format!(
                        "new HTTP API definition version {}@{}",
                        api_definition_name.as_str().log_color_highlight(),
                        manifest_api_definition
                            .0
                            .version
                            .as_str()
                            .log_color_highlight()
                    ),
                );

                let result = self
                    .new_api_definition(project, &manifest_api_definition.0)
                    .await?;

                self.ctx
                    .log_handler()
                    .log_view(&ApiDefinitionNewView(result));

                Ok(Some(manifest_api_definition.0.version))
            }
        }
    }

    pub async fn deploy_required_components(
        &self,
        project: Option<&ProjectRefAndId>,
        deploy_args: &DeployArgs,
        api_defs_filter: BTreeSet<HttpApiDefinitionName>,
    ) -> anyhow::Result<BTreeMap<String, Component>> {
        let used_component_names = {
            {
                let app_ctx = self.ctx.app_context_lock().await;
                let app_ctx = app_ctx.some_or_err()?;

                if api_defs_filter.is_empty() {
                    app_ctx
                        .application
                        .used_component_names_for_all_http_api_definition()
                } else {
                    api_defs_filter
                        .iter()
                        .flat_map(|name| {
                            app_ctx
                                .application
                                .used_component_names_for_http_api_definition(name)
                        })
                        .collect()
                }
            }
            .into_iter()
            .map(|component_name| ComponentName::from(component_name.to_string()))
            .collect::<Vec<_>>()
        };

        if used_component_names.is_empty() {
            return Ok(BTreeMap::new());
        }

        log_action("Deploying", "required components");
        let _indent = LogIndent::new();

        let latest_components = self
            .ctx
            .component_handler()
            .deploy(
                project,
                used_component_names,
                false,
                None,
                &ApplicationComponentSelectMode::All,
                deploy_args,
            )
            .await?
            .into_iter()
            .map(|component| (component.component_name.0.clone(), component))
            .collect::<BTreeMap<_, _>>();

        Ok(latest_components)
    }

    async fn api_definition(
        &self,
        project: Option<&ProjectRefAndId>,
        name: &str,
        version: &str,
    ) -> anyhow::Result<Option<HttpApiDefinitionResponseData>> {
        let clients = self.ctx.golem_clients().await?;

        clients
            .api_definition
            .get_definition(
                &self
                    .ctx
                    .cloud_project_handler()
                    .selected_project_id_or_default(project)
                    .await?
                    .0,
                name,
                version,
            )
            .await
            .map_service_error_not_found_as_opt()
    }

    async fn update_api_definition(
        &self,
        project: Option<&ProjectRefAndId>,
        manifest_api_definition: &HttpApiDefinitionRequest,
    ) -> anyhow::Result<HttpApiDefinitionResponseData> {
        let clients = self.ctx.golem_clients().await?;

        clients
            .api_definition
            .update_definition_json(
                &self
                    .ctx
                    .cloud_project_handler()
                    .selected_project_id_or_default(project)
                    .await?
                    .0,
                &manifest_api_definition.id,
                &manifest_api_definition.version,
                // TODO: would be nice to share the model between oss and cloud instead of "re-encoding"
                &parse_api_definition(&serde_yaml::to_string(&manifest_api_definition)?)?,
            )
            .await
            .map_service_error()
    }

    async fn new_api_definition(
        &self,
        project: Option<&ProjectRefAndId>,
        api_definition: &HttpApiDefinitionRequest,
    ) -> anyhow::Result<HttpApiDefinitionResponseData> {
        let clients = self.ctx.golem_clients().await?;

        clients
            .api_definition
            .create_definition_json(
                &self
                    .ctx
                    .cloud_project_handler()
                    .selected_project_id_or_default(project)
                    .await?
                    .0,
                // TODO: would be nice to share the model between oss and cloud instead of "re-encoding"
                &parse_api_definition(&serde_yaml::to_string(&api_definition)?)?,
            )
            .await
            .map_service_error()
    }
}

fn parse_api_definition<T: DeserializeOwned>(input: &str) -> anyhow::Result<T> {
    serde_yaml::from_str(input).context("Failed to parse API definition")
}

/// Filters the OpenAPI specification to only include methods with `binding-type: default`.
fn filter_routes(spec: &mut serde_json::Value) {
    if let Some(paths) = spec.get_mut("paths").and_then(|p| p.as_object_mut()) {
        let paths_to_remove: Vec<String> = paths
            .iter_mut()
            .filter_map(|(path, methods)| {
                if let Some(methods) = methods.as_object_mut() {
                    // Filter methods within this path
                    let methods_to_remove: Vec<String> = methods
                        .iter()
                        .filter_map(|(method, details)| {
                            // Check if the method has a binding-type and if it's not "default"
                            if let Some(binding) = details.get("x-golem-api-gateway-binding") {
                                if let Some(binding_type) = binding.get("binding-type") {
                                    if binding_type != "default" {
                                        return Some(method.clone());
                                    }
                                }
                            }
                            None
                        })
                        .collect();

                    // Remove filtered methods
                    for method in methods_to_remove {
                        methods.remove(&method);
                    }

                    // If no methods left in this path, mark it for removal
                    if methods.is_empty() {
                        return Some(path.clone());
                    }
                }
                None
            })
            .collect();

        // Remove empty paths
        for path in paths_to_remove {
            paths.remove(&path);
        }
    }
}