expose the preprocessing timeout

Author: rybit

go/porcelain/deploy.go

@@ -28,9 +28,8 @@ import (
 )
 
 const (
-	preProcessingTimeout = time.Minute * 5
-	jsRuntime            = "js"
-	goRuntime            = "go"
+	jsRuntime = "js"
+	goRuntime = "go"
 )
 
 type uploadType int
@@ -296,7 +295,7 @@ func (n *Netlify) WaitUntilDeployReady(ctx context.Context, d *models.Deploy) (*
 			return nil, fmt.Errorf("Error: preprocessing deploy failed")
 		}
 
-		if t.Sub(start) > preProcessingTimeout {
+		if t.Sub(start) > n.preProcessingTimeout {
 			return nil, fmt.Errorf("Error: preprocessing deploy timed out")
 		}
 	}

go/porcelain/netlify_client.go

@@ -1,6 +1,8 @@
 package porcelain
 
 import (
+	"time"
+
 	"github.com/go-openapi/runtime"
 	httptransport "github.com/go-openapi/runtime/client"
 	"github.com/go-openapi/strfmt"
@@ -11,6 +13,7 @@ import (
 const DefaultSyncFileLimit = 7000
 const DefaultConcurrentUploadLimit = 10
 const DefaultRetryAttempts = 3
+const DefaultPreProcessingTimeout = time.Minute * 5
 
 // Default netlify HTTP client.
 var Default = NewHTTPClient(nil)
@@ -41,17 +44,19 @@ func NewRetryable(transport runtime.ClientTransport, formats strfmt.Registry, at
 func New(transport runtime.ClientTransport, formats strfmt.Registry) *Netlify {
 	n := plumbing.New(transport, formats)
 	return &Netlify{
-		Netlify:       n,
-		syncFileLimit: DefaultSyncFileLimit,
-		uploadLimit:   DefaultConcurrentUploadLimit,
+		Netlify:              n,
+		syncFileLimit:        DefaultSyncFileLimit,
+		uploadLimit:          DefaultConcurrentUploadLimit,
+		preProcessingTimeout: DefaultPreProcessingTimeout,
 	}
 }
 
 // Netlify is a client for netlify
 type Netlify struct {
 	*plumbing.Netlify
-	syncFileLimit int
-	uploadLimit   int
+	syncFileLimit        int
+	uploadLimit          int
+	preProcessingTimeout time.Duration
 }
 
 func (n *Netlify) SetSyncFileLimit(limit int) {
@@ -63,3 +68,9 @@ func (n *Netlify) SetConcurrentUploadLimit(limit int) {
 		n.uploadLimit = limit
 	}
 }
+
+func (n *Netlify) SetPreProcessingTimeout(dur time.Duration) {
+	if dur > 0 {
+		n.preProcessingTimeout = dur
+	}
+}