Added google_apigee_api resource (#12036) (#8567)

[upstream:fc0e3024fda3fa86755fb3489c2501b27ea2a217]

Signed-off-by: Modular Magician <[email protected]>

Author: modular-magician

Diff for: .changelog/12036.txt

@@ -0,0 +1,3 @@
+```release-note:new-resource
+`google_apigee_api`
+```

Diff for: google-beta/provider/provider_mmv1_resources.go

@@ -1343,6 +1343,7 @@ var generatedResources = map[string]*schema.Resource{
 var handwrittenResources = map[string]*schema.Resource{
 	// ####### START handwritten resources ###########
 	"google_app_engine_application":                 appengine.ResourceAppEngineApplication(),
+	"google_apigee_api":                             apigee.ResourceApigeeApi(),
 	"google_apigee_sharedflow":                      apigee.ResourceApigeeSharedFlow(),
 	"google_apigee_sharedflow_deployment":           apigee.ResourceApigeeSharedFlowDeployment(),
 	"google_apigee_flowhook":                        apigee.ResourceApigeeFlowhook(),

Diff for: google-beta/services/apigee/apigee_utils.go

@@ -3,12 +3,16 @@
 package apigee
 
 import (
+	"encoding/json"
 	"fmt"
-	"log"
-
 	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
 	"github.com/hashicorp/terraform-provider-google-beta/google-beta/tpgresource"
 	transport_tpg "github.com/hashicorp/terraform-provider-google-beta/google-beta/transport"
+	"google.golang.org/api/googleapi"
+	"io"
+	"log"
+	"net/http"
+	"time"
 )
 
 func resourceApigeeNatAddressActivate(config *transport_tpg.Config, d *schema.ResourceData, billingProject string, userAgent string) error {
@@ -47,3 +51,71 @@ func resourceApigeeNatAddressActivate(config *transport_tpg.Config, d *schema.Re
 	}
 	return nil
 }
+
+// sendRequestRawBodyWithTimeout is derived from sendRequestWithTimeout with direct pass through of request body
+func sendRequestRawBodyWithTimeout(config *transport_tpg.Config, method, project, rawurl, userAgent string, body io.Reader, contentType string, timeout time.Duration, errorRetryPredicates ...transport_tpg.RetryErrorPredicateFunc) (map[string]interface{}, error) {
+	log.Printf("[DEBUG] sendRequestRawBodyWithTimeout start")
+	reqHeaders := make(http.Header)
+	reqHeaders.Set("User-Agent", userAgent)
+	reqHeaders.Set("Content-Type", contentType)
+
+	if config.UserProjectOverride && project != "" {
+		// Pass the project into this fn instead of parsing it from the URL because
+		// both project names and URLs can have colons in them.
+		reqHeaders.Set("X-Goog-User-Project", project)
+	}
+
+	if timeout == 0 {
+		timeout = time.Duration(1) * time.Minute
+	}
+
+	var res *http.Response
+
+	log.Printf("[DEBUG] sendRequestRawBodyWithTimeout sending request")
+
+	err := transport_tpg.Retry(transport_tpg.RetryOptions{
+		RetryFunc: func() error {
+			req, err := http.NewRequest(method, rawurl, body)
+			if err != nil {
+				return err
+			}
+
+			req.Header = reqHeaders
+			res, err = config.Client.Do(req)
+			if err != nil {
+				return err
+			}
+
+			if err := googleapi.CheckResponse(res); err != nil {
+				googleapi.CloseBody(res)
+				return err
+			}
+
+			return nil
+		},
+		Timeout:              timeout,
+		ErrorRetryPredicates: errorRetryPredicates,
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	if res == nil {
+		return nil, fmt.Errorf("Unable to parse server response. This is most likely a terraform problem, please file a bug at https://github.com/hashicorp/terraform-provider-google/issues.")
+	}
+
+	// The defer call must be made outside of the retryFunc otherwise it's closed too soon.
+	defer googleapi.CloseBody(res)
+
+	// 204 responses will have no body, so we're going to error with "EOF" if we
+	// try to parse it. Instead, we can just return nil.
+	if res.StatusCode == 204 {
+		return nil, nil
+	}
+	result := make(map[string]interface{})
+	if err := json.NewDecoder(res.Body).Decode(&result); err != nil {
+		return nil, err
+	}
+	log.Printf("[DEBUG] sendRequestRawBodyWithTimeout returning")
+	return result, nil
+}