From 4d0cab1f3d1d7d99ee472f35ac6299eed3767ed3 Mon Sep 17 00:00:00 2001 From: Marat Salakhutdinov Date: Fri, 10 Jan 2025 12:38:33 -0500 Subject: [PATCH 1/2] add async option to organizations endpoint --- sysdig/internal/client/v2/organization.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sysdig/internal/client/v2/organization.go b/sysdig/internal/client/v2/organization.go index b7cc2ab8e..67c51a88e 100644 --- a/sysdig/internal/client/v2/organization.go +++ b/sysdig/internal/client/v2/organization.go @@ -7,8 +7,8 @@ import ( ) const ( - organizationsPath = "%s/api/cloudauth/v1/organizations" - organizationPath = "%s/api/cloudauth/v1/organizations/%s" + organizationsPath = "%s/api/cloudauth/v1/organizations?async=true" + organizationPath = "%s/api/cloudauth/v1/organizations/%s?async=true" ) type OrganizationSecureInterface interface { From aa2917c0ecd2ed3accbf9a727de2fd173e1b958f Mon Sep 17 00:00:00 2001 From: Marat Salakhutdinov Date: Thu, 16 Jan 2025 15:07:15 -0500 Subject: [PATCH 2/2] use async option when specific hidden environment variable is set --- sysdig/internal/client/v2/organization.go | 17 +++++++++++++---- 1 file changed, 13 insertions(+), 4 deletions(-) diff --git a/sysdig/internal/client/v2/organization.go b/sysdig/internal/client/v2/organization.go index 67c51a88e..54e8102ad 100644 --- a/sysdig/internal/client/v2/organization.go +++ b/sysdig/internal/client/v2/organization.go @@ -4,11 +4,12 @@ import ( "context" "fmt" "net/http" + "os" ) const ( - organizationsPath = "%s/api/cloudauth/v1/organizations?async=true" - organizationPath = "%s/api/cloudauth/v1/organizations/%s?async=true" + organizationsPath = "%s/api/cloudauth/v1/organizations" + organizationPath = "%s/api/cloudauth/v1/organizations/%s" ) type OrganizationSecureInterface interface { @@ -104,9 +105,17 @@ func (client *Client) UpdateOrganizationSecure(ctx context.Context, orgID string } func (client *Client) organizationsURL() string { - return fmt.Sprintf(organizationsPath, client.config.url) + url := fmt.Sprintf(organizationsPath, client.config.url) + if os.Getenv("SYSDIG_ORG_API_ASYNC") == "true" { + url += "?async=true" + } + return url } func (client *Client) organizationURL(orgId string) string { - return fmt.Sprintf(organizationPath, client.config.url, orgId) + url := fmt.Sprintf(organizationPath, client.config.url, orgId) + if os.Getenv("SYSDIG_ORG_API_ASYNC") == "true" { + url += "?async=true" + } + return url }