Merge pull request #62 from pusher/add-lib-headers

add library name and version header

Author: damdo

client.go

@@ -16,6 +16,11 @@ import (
 var pusherPathRegex = regexp.MustCompile("^/apps/([0-9]+)$")
 var maxTriggerableChannels = 100
 
+const (
+	libraryVersion = "4.0.2"
+	libraryName    = "pusher-http-go"
+)
+
 /*
 Client to the HTTP API of Pusher.
 

client_test.go

@@ -25,6 +25,8 @@ func TestTriggerSuccessCase(t *testing.T) {
 		assert.Equal(t, expectedBody, string(actualBody))
 
 		assert.Equal(t, "application/json", req.Header["Content-Type"][0])
+		lib := fmt.Sprintf("%s %s", libraryName, libraryVersion)
+		assert.Equal(t, lib, req.Header["X-Pusher-Library"][0])
 		assert.NoError(t, err)
 	}))
 	defer server.Close()

request.go

@@ -9,10 +9,24 @@ import (
 	"strconv"
 )
 
+const (
+	contentTypeHeaderKey   = "Content-Type"
+	contentTypeHeaderValue = "application/json"
+)
+
+var headers = map[string]string{
+	"Content-Type":     "application/json",
+	"X-Pusher-Library": fmt.Sprintf("%s %s", libraryName, libraryVersion),
+}
+
 // change timeout to time.Duration
 func request(client *http.Client, method, url string, body []byte) ([]byte, error) {
 	req, err := http.NewRequest(method, url, bytes.NewBuffer(body))
-	req.Header.Set("Content-Type", "application/json")
+
+	for key, val := range headers {
+		req.Header.Set(http.CanonicalHeaderKey(key), val)
+	}
+
 	resp, err := client.Do(req)
 	if err != nil {
 		return nil, err