chore: [REL-8483] wrap some calls for concurrency i missed earlier (#340)

* wrap some missing client calls i missed to handle concurrency

* wrap some missing client calls i missed to handle concurrency

Author: sloloris

launchdarkly/resource_launchdarkly_access_token.go

@@ -348,8 +348,13 @@ func resourceAccessTokenExists(d *schema.ResourceData, metaRaw interface{}) (boo
 	return accessTokenExists(d.Id(), metaRaw.(*Client))
 }
 
-func accessTokenExists(accessTokenID string, meta *Client) (bool, error) {
-	_, res, err := meta.ld.AccessTokensApi.GetToken(meta.ctx, accessTokenID).Execute()
+func accessTokenExists(accessTokenID string, client *Client) (bool, error) {
+	var res *http.Response
+	var err error
+	err = client.withConcurrency(client.ctx, func() error {
+		_, res, err = client.ld.AccessTokensApi.GetToken(client.ctx, accessTokenID).Execute()
+		return err
+	})
 	if isStatusNotFound(res) {
 		return false, nil
 	}

launchdarkly/resource_launchdarkly_custom_role.go

@@ -215,8 +215,13 @@ func resourceCustomRoleExists(d *schema.ResourceData, metaRaw interface{}) (bool
 	return customRoleExists(d.Id(), metaRaw.(*Client))
 }
 
-func customRoleExists(customRoleKey string, meta *Client) (bool, error) {
-	_, res, err := meta.ld.CustomRolesApi.GetCustomRole(meta.ctx, customRoleKey).Execute()
+func customRoleExists(customRoleKey string, client *Client) (bool, error) {
+	var res *http.Response
+	var err error
+	err = client.withConcurrency(client.ctx, func() error {
+		_, res, err = client.ld.CustomRolesApi.GetCustomRole(client.ctx, customRoleKey).Execute()
+		return err
+	})
 	if isStatusNotFound(res) {
 		return false, nil
 	}

launchdarkly/resource_launchdarkly_environment.go

@@ -3,6 +3,7 @@ package launchdarkly
 import (
 	"context"
 	"fmt"
+	"net/http"
 	"strings"
 
 	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
@@ -167,8 +168,13 @@ func resourceEnvironmentExists(d *schema.ResourceData, metaRaw interface{}) (boo
 	return environmentExists(d.Get(PROJECT_KEY).(string), d.Get(KEY).(string), metaRaw.(*Client))
 }
 
-func environmentExists(projectKey string, key string, meta *Client) (bool, error) {
-	_, res, err := meta.ld.EnvironmentsApi.GetEnvironment(meta.ctx, projectKey, key).Execute()
+func environmentExists(projectKey string, key string, client *Client) (bool, error) {
+	var res *http.Response
+	var err error
+	err = client.withConcurrency(client.ctx, func() error {
+		_, res, err = client.ld.EnvironmentsApi.GetEnvironment(client.ctx, projectKey, key).Execute()
+		return err
+	})
 	if isStatusNotFound(res) {
 		return false, nil
 	}

launchdarkly/resource_launchdarkly_project.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"fmt"
 	"log"
+	"net/http"
 
 	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
 	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
@@ -319,8 +320,13 @@ func resourceProjectExists(d *schema.ResourceData, metaRaw interface{}) (bool, e
 	return projectExists(d.Get(KEY).(string), metaRaw.(*Client))
 }
 
-func projectExists(projectKey string, meta *Client) (bool, error) {
-	_, res, err := meta.ld.ProjectsApi.GetProject(meta.ctx, projectKey).Execute()
+func projectExists(projectKey string, client *Client) (bool, error) {
+	var res *http.Response
+	var err error
+	err = client.withConcurrency(client.ctx, func() error {
+		_, res, err = client.ld.ProjectsApi.GetProject(client.ctx, projectKey).Execute()
+		return err
+	})
 	if isStatusNotFound(res) {
 		log.Println("got 404 when getting project. returning false.")
 		return false, nil

launchdarkly/resource_launchdarkly_team.go

@@ -405,8 +405,13 @@ func resourceTeamExists(d *schema.ResourceData, metaRaw interface{}) (bool, erro
 	return teamExists(d.Id(), metaRaw.(*Client))
 }
 
-func teamExists(teamKey string, meta *Client) (bool, error) {
-	_, res, err := meta.ld.TeamsApi.GetTeam(meta.ctx, teamKey).Execute()
+func teamExists(teamKey string, client *Client) (bool, error) {
+	var res *http.Response
+	var err error
+	err = client.withConcurrency(client.ctx, func() error {
+		_, res, err = client.ld.TeamsApi.GetTeam(client.ctx, teamKey).Execute()
+		return err
+	})
 	if isStatusNotFound(res) {
 		return false, nil
 	}

launchdarkly/resource_launchdarkly_team_member.go

@@ -213,8 +213,13 @@ func resourceTeamMemberExists(d *schema.ResourceData, metaRaw interface{}) (bool
 	return teamMemberExists(d.Id(), metaRaw.(*Client))
 }
 
-func teamMemberExists(memberID string, meta *Client) (bool, error) {
-	_, res, err := meta.ld.AccountMembersApi.GetMember(meta.ctx, memberID).Execute()
+func teamMemberExists(memberID string, client *Client) (bool, error) {
+	var res *http.Response
+	var err error
+	err = client.withConcurrency(client.ctx, func() error {
+		_, res, err = client.ld.AccountMembersApi.GetMember(client.ctx, memberID).Execute()
+		return err
+	})
 	if isStatusNotFound(res) {
 		return false, nil
 	}

launchdarkly/resource_launchdarkly_webhook.go

@@ -3,6 +3,7 @@ package launchdarkly
 import (
 	"context"
 	"fmt"
+	"net/http"
 
 	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
 	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
@@ -162,8 +163,13 @@ func resourceWebhookExists(d *schema.ResourceData, metaRaw interface{}) (bool, e
 	return webhookExists(d.Id(), metaRaw.(*Client))
 }
 
-func webhookExists(webhookID string, meta *Client) (bool, error) {
-	_, res, err := meta.ld.WebhooksApi.GetWebhook(meta.ctx, webhookID).Execute()
+func webhookExists(webhookID string, client *Client) (bool, error) {
+	var res *http.Response
+	var err error
+	err = client.withConcurrency(client.ctx, func() error {
+		_, res, err = client.ld.WebhooksApi.GetWebhook(client.ctx, webhookID).Execute()
+		return err
+	})
 	if isStatusNotFound(res) {
 		return false, nil
 	}