Do retry when GET request return 429.

stripe/resource_stripe_coupon.go

@@ -3,9 +3,11 @@ package stripe
 import (
 	"fmt"
 	"log"
+	"net/http"
 	"strings"
 	"time"
 
+	"github.com/hashicorp/terraform/helper/resource"
 	"github.com/hashicorp/terraform/helper/schema"
 	stripe "github.com/stripe/stripe-go"
 	"github.com/stripe/stripe-go/client"
@@ -173,12 +175,17 @@ func resourceStripeCouponCreate(d *schema.ResourceData, m interface{}) error {
 }
 
 func resourceStripeCouponRead(d *schema.ResourceData, m interface{}) error {
-	client := m.(*client.API)
-	coupon, err := client.Coupons.Get(d.Id(), nil)
+	return resource.Retry(d.Timeout(schema.TimeoutRead), func() *resource.RetryError {
+		client := m.(*client.API)
+		coupon, err := client.Coupons.Get(d.Id(), nil)
+		if err != nil {
+			if sErr, ok := err.(*stripe.Error); ok && sErr.HTTPStatusCode == http.StatusTooManyRequests {
+				return resource.RetryableError(sErr)
+			}
+			d.SetId("")
+			return resource.NonRetryableError(err)
+		}
 
-	if err != nil {
-		d.SetId("")
-	} else {
 		d.Set("code", d.Id())
 		d.Set("amount_off", coupon.AmountOff)
 		d.Set("currency", coupon.Currency)
@@ -197,9 +204,9 @@ func resourceStripeCouponRead(d *schema.ResourceData, m interface{}) error {
 		d.Set("times_redeemed", coupon.TimesRedeemed)
 		d.Set("valid", coupon.Valid)
 		d.Set("created", coupon.Valid)
-	}
 
-	return err
+		return nil
+	})
 }
 
 func resourceStripeCouponUpdate(d *schema.ResourceData, m interface{}) error {

stripe/resource_stripe_plan.go

@@ -2,7 +2,9 @@ package stripe
 
 import (
 	"log"
+	"net/http"
 
+	"github.com/hashicorp/terraform/helper/resource"
 	"github.com/hashicorp/terraform/helper/schema"
 	stripe "github.com/stripe/stripe-go"
 	"github.com/stripe/stripe-go/client"
@@ -205,12 +207,17 @@ func resourceStripePlanCreate(d *schema.ResourceData, m interface{}) error {
 }
 
 func resourceStripePlanRead(d *schema.ResourceData, m interface{}) error {
-	client := m.(*client.API)
-	plan, err := client.Plans.Get(d.Id(), nil)
+	return resource.Retry(d.Timeout(schema.TimeoutRead), func() *resource.RetryError {
+		client := m.(*client.API)
+		plan, err := client.Plans.Get(d.Id(), nil)
+		if err != nil {
+			if sErr, ok := err.(*stripe.Error); ok && sErr.HTTPStatusCode == http.StatusTooManyRequests {
+				return resource.RetryableError(sErr)
+			}
+			d.SetId("")
+			return resource.NonRetryableError(err)
+		}
 
-	if err != nil {
-		d.SetId("")
-	} else {
 		d.Set("plan_id", plan.ID)
 		d.Set("active", plan.Active)
 		d.Set("aggregate_usage", plan.AggregateUsage)
@@ -226,9 +233,9 @@ func resourceStripePlanRead(d *schema.ResourceData, m interface{}) error {
 		d.Set("tier", flattenPlanTiers(plan.Tiers))
 		d.Set("trial_period_days", plan.TrialPeriodDays)
 		d.Set("usage_type", plan.UsageType)
-	}
 
-	return err
+		return nil
+	})
 }
 
 func flattenPlanTiers(in []*stripe.PlanTier) []map[string]interface{} {

stripe/resource_stripe_product.go

@@ -1,6 +1,9 @@
 package stripe
 
 import (
+	"net/http"
+
+	"github.com/hashicorp/terraform/helper/resource"
 	"github.com/hashicorp/terraform/helper/schema"
 	"github.com/stripe/stripe-go"
 	"github.com/stripe/stripe-go/client"
@@ -123,23 +126,28 @@ func resourceStripeProductCreate(d *schema.ResourceData, m interface{}) error {
 }
 
 func resourceStripeProductRead(d *schema.ResourceData, m interface{}) error {
-	client := m.(*client.API)
-	product, err := client.Products.Get(d.Id(), nil)
-
-	if err != nil {
-		return err
-	}
-
-	d.Set("product_id", product.ID)
-	d.Set("name", product.Name)
-	d.Set("type", product.Type)
-	d.Set("active", product.Active)
-	d.Set("attributes", product.Attributes)
-	d.Set("metadata", product.Metadata)
-	d.Set("statement_descriptor", product.StatementDescriptor)
-	d.Set("unit_label", product.UnitLabel)
-
-	return nil
+	return resource.Retry(d.Timeout(schema.TimeoutRead), func() *resource.RetryError {
+		client := m.(*client.API)
+		product, err := client.Products.Get(d.Id(), nil)
+		if err != nil {
+			if sErr, ok := err.(*stripe.Error); ok && sErr.HTTPStatusCode == http.StatusTooManyRequests {
+				return resource.RetryableError(sErr)
+			}
+			d.SetId("")
+			return resource.NonRetryableError(err)
+		}
+
+		d.Set("product_id", product.ID)
+		d.Set("name", product.Name)
+		d.Set("type", product.Type)
+		d.Set("active", product.Active)
+		d.Set("attributes", product.Attributes)
+		d.Set("metadata", product.Metadata)
+		d.Set("statement_descriptor", product.StatementDescriptor)
+		d.Set("unit_label", product.UnitLabel)
+
+		return nil
+	})
 }
 
 func resourceStripeProductUpdate(d *schema.ResourceData, m interface{}) error {

stripe/resource_stripe_webhook_endpoint.go

@@ -1,6 +1,9 @@
 package stripe
 
 import (
+	"net/http"
+
+	"github.com/hashicorp/terraform/helper/resource"
 	"github.com/hashicorp/terraform/helper/schema"
 	stripe "github.com/stripe/stripe-go"
 	"github.com/stripe/stripe-go/client"
@@ -65,18 +68,23 @@ func resourceStripeWebhookEndpointCreate(d *schema.ResourceData, m interface{})
 }
 
 func resourceStripeWebhookEndpointRead(d *schema.ResourceData, m interface{}) error {
-	client := m.(*client.API)
-	webhookEndpoint, err := client.WebhookEndpoints.Get(d.Id(), nil)
-
-	if err != nil {
-		return err
-	}
-
-	d.Set("url", webhookEndpoint.URL)
-	d.Set("enabled_events", webhookEndpoint.EnabledEvents)
-	d.Set("connect", webhookEndpoint.Connect)
-
-	return nil
+	return resource.Retry(d.Timeout(schema.TimeoutRead), func() *resource.RetryError {
+		client := m.(*client.API)
+		webhookEndpoint, err := client.WebhookEndpoints.Get(d.Id(), nil)
+		if err != nil {
+			if sErr, ok := err.(*stripe.Error); ok && sErr.HTTPStatusCode == http.StatusTooManyRequests {
+				return resource.RetryableError(sErr)
+			}
+			d.SetId("")
+			return resource.NonRetryableError(err)
+		}
+
+		d.Set("url", webhookEndpoint.URL)
+		d.Set("enabled_events", webhookEndpoint.EnabledEvents)
+		d.Set("connect", webhookEndpoint.Connect)
+
+		return nil
+	})
 }
 
 func resourceStripeWebhookEndpointUpdate(d *schema.ResourceData, m interface{}) error {