Merge pull request #66 from pusher/allow-20kb-requests

Allow larger requests as we sometimes do on dedicated clusters

Author: damdo

client_test.go

@@ -7,6 +7,7 @@ import (
 	"net/http/httptest"
 	"net/url"
 	"os"
+	"strings"
 	"testing"
 	"time"
 
@@ -512,14 +513,10 @@ func TestChannelFormatValidation(t *testing.T) {
 
 func TestDataSizeValidation(t *testing.T) {
 	client := Client{AppID: "id", Key: "key", Secret: "secret"}
-	var data string
-	for i := 0; i <= 10242; i++ {
-		data += "a"
-	}
+	data := strings.Repeat("a", 20481)
 	err := client.Trigger("channel", "event", data)
 
-	assert.EqualError(t, err, "Data must be smaller than 10kb")
-
+	assert.EqualError(t, err, "Event payload exceeded maximum size (20481 bytes is too much)")
 }
 
 func TestInitialisationFromURL(t *testing.T) {

encoder.go

@@ -7,7 +7,7 @@ import (
 )
 
 // maxEventPayloadSize indicates the max size allowed for the data content (payload) of each event
-const maxEventPayloadSize = 10240
+const maxEventPayloadSize = 20480 // on dedicated clusters we may allow 2x the usual limit
 
 type batchEvent struct {
 	Channel  string  `json:"channel"`
@@ -38,7 +38,7 @@ func encodeTriggerBody(channels []string, event string, data interface{}, socket
 		payloadData = string(dataBytes)
 	}
 	if len(payloadData) > maxEventPayloadSize {
-		return nil, errors.New("Data must be smaller than 10kb")
+		return nil, errors.New(fmt.Sprintf("Event payload exceeded maximum size (%d bytes is too much)", len(payloadData)))
 	}
 	return json.Marshal(&eventPayload{
 		Name:     event,