pkg/httpjson: add minify_json template helper

CHANGELOG.md

@@ -6,6 +6,8 @@ This project adheres to [Semantic Versioning](http://semver.org/).
 
 ### Added
 
+- Added `minify_json` template helper function for minifying static JSON: [#x](https://github.com/elastic/stream/pull/x)
+
 ### Changed
 
 ### Fixed

pkg/httpserver/config.go

@@ -5,8 +5,10 @@
 package httpserver
 
 import (
+	"encoding/json"
 	"errors"
 	"os"
+	"strings"
 	"text/template"
 
 	ucfg "github.com/elastic/go-ucfg"
@@ -45,10 +47,11 @@ func (t *tpl) Unpack(in string) error {
 	parsed, err := template.New("").
 		Option("missingkey=zero").
 		Funcs(template.FuncMap{
-			"env":      env,
-			"hostname": hostname,
-			"sum":      sum,
-			"file":     file,
+			"env":         env,
+			"hostname":    hostname,
+			"sum":         sum,
+			"file":        file,
+			"minify_json": minify,
 		}).
 		Parse(in)
 	if err != nil {
@@ -98,3 +101,11 @@ func file(path string) (string, error) {
 	}
 	return string(b), nil
 }
+
+func minify(body string) (string, error) {
+	var buf strings.Builder
+	enc := json.NewEncoder(&buf)
+	enc.SetEscapeHTML(false)
+	err := enc.Encode(json.RawMessage(body))
+	return strings.TrimSpace(buf.String()), err
+}

pkg/httpserver/httpserver_test.go

@@ -44,6 +44,7 @@ func TestHTTPServer(t *testing.T) {
         status_code: 200
         body: |-
           {"next": "http://{{ hostname }}/page/{{ sum (.req_num) 1 }}"}
+
     - path: "/page/{pagenum:[0-9]}"
       methods: ["POST"]
 
@@ -52,6 +53,19 @@ func TestHTTPServer(t *testing.T) {
         body: "{{ .request.vars.pagenum }}"
         headers:
           content-type: ["text/plain"]
+
+    - path: "/static/minify"
+      methods: ["GET"]
+
+      responses:
+      - status_code: 200
+        body: |-
+          {{ minify_json ` + "`" + `
+          {
+          	"key1": "value1",
+          	"key2": "<value2>"
+          }
+          ` + "`" + `}}
 `
 
 	f, err := ioutil.TempFile("", "test")
@@ -136,6 +150,20 @@ func TestHTTPServer(t *testing.T) {
 
 		assert.Equal(t, []byte{}, body)
 	})
+
+	t.Run("minify static JSON", func(t *testing.T) {
+		req, err := http.NewRequest("GET", "http://"+addr+"/static/minify", nil)
+		require.NoError(t, err)
+
+		resp, err := http.DefaultClient.Do(req)
+		require.NoError(t, err)
+
+		body, err := ioutil.ReadAll(resp.Body)
+		require.NoError(t, err)
+		resp.Body.Close()
+
+		assert.Equal(t, `{"key1":"value1","key2":"<value2>"}`, string(body))
+	})
 }
 
 func TestRunAsSequence(t *testing.T) {