format file

http_modifier_settings.go

@@ -233,7 +233,6 @@ func (r *HeaderRewriteMap) Set(value string) error {
 	return nil
 }
 
-
 //
 // Handling of --http-allow-url option
 //

http_prettifier_test.go

@@ -1,36 +1,36 @@
 package main
 
 import (
-    "compress/gzip"
-    "testing"
-    "strconv"
-    "bytes"
+	"bytes"
+	"compress/gzip"
+	"strconv"
+	"testing"
 )
 
 func TestHTTPPrettifierGzip(t *testing.T) {
-    b := bytes.NewBufferString("")
-    w := gzip.NewWriter(b)
-    w.Write([]byte("test"))
-    w.Close()
+	b := bytes.NewBufferString("")
+	w := gzip.NewWriter(b)
+	w.Write([]byte("test"))
+	w.Close()
 
-    size := strconv.Itoa(len(b.Bytes()))
+	size := strconv.Itoa(len(b.Bytes()))
 
-    payload := []byte("2 1 1\nHTTP/1.1 200 OK\r\nContent-Length: " + size + "\r\nContent-Encoding: gzip\r\n\r\n")
-    payload = append(payload, b.Bytes()...)
+	payload := []byte("2 1 1\nHTTP/1.1 200 OK\r\nContent-Length: " + size + "\r\nContent-Encoding: gzip\r\n\r\n")
+	payload = append(payload, b.Bytes()...)
 
-    newPayload := prettifyHTTP(payload)
+	newPayload := prettifyHTTP(payload)
 
-    if string(newPayload) != "2 1 1\nHTTP/1.1 200 OK\r\nContent-Length: 4\r\n\r\ntest" {
-        t.Error("Payload not match:", string(newPayload))
-    }
+	if string(newPayload) != "2 1 1\nHTTP/1.1 200 OK\r\nContent-Length: 4\r\n\r\ntest" {
+		t.Error("Payload not match:", string(newPayload))
+	}
 }
 
 func TestHTTPPrettifierChunked(t *testing.T) {
-    payload := []byte("POST / HTTP/1.1\r\nHost: www.w3.org\r\nTransfer-Encoding: chunked\r\n\r\n4\r\nWiki\r\n5\r\npedia\r\ne\r\n in\r\n\r\nchunks.\r\n0\r\n\r\n")
+	payload := []byte("POST / HTTP/1.1\r\nHost: www.w3.org\r\nTransfer-Encoding: chunked\r\n\r\n4\r\nWiki\r\n5\r\npedia\r\ne\r\n in\r\n\r\nchunks.\r\n0\r\n\r\n")
 
-    newPayload := prettifyHTTP(payload)
+	newPayload := prettifyHTTP(payload)
 
-    if string(newPayload) != "POST / HTTP/1.1\r\nHost: www.w3.org\r\nContent-Length: 23\r\n\r\nWikipedia in\r\n\r\nchunks." {
-        t.Error("Payload not match:", string(newPayload))
-    }
-}
+	if string(newPayload) != "POST / HTTP/1.1\r\nHost: www.w3.org\r\nContent-Length: 23\r\n\r\nWikipedia in\r\n\r\nchunks." {
+		t.Error("Payload not match:", string(newPayload))
+	}
+}

middleware.go

@@ -34,7 +34,7 @@ func NewMiddleware(command string) *Middleware {
 	m.Stdout, _ = cmd.StdoutPipe()
 	m.Stdin, _ = cmd.StdinPipe()
 
-    cmd.Stderr = os.Stderr
+	cmd.Stderr = os.Stderr
 
 	go m.read(m.Stdout)
 
@@ -67,11 +67,11 @@ func (m *Middleware) copy(to io.Writer, from io.Reader) {
 	for {
 		nr, _ := from.Read(buf)
 		if nr > 0 && len(buf) > nr {
-            payload := buf[0: nr]
+			payload := buf[0:nr]
 
 			if Settings.prettifyHTTP {
 				payload = prettifyHTTP(payload)
-                nr = len(payload)
+				nr = len(payload)
 			}
 
 			hex.Encode(dst, payload)

output_file_settings.go

@@ -37,4 +37,3 @@ func (u *unitSizeVar) Set(s string) error {
 	*u = unitSizeVar(parseDataUnit(s))
 	return nil
 }
-

output_file_test.go

@@ -321,7 +321,7 @@ func TestFileOutputAppendSizeLimitOverflow(t *testing.T) {
 
 	messageSize := len(message) + len(payloadSeparator)
 
-	output := NewFileOutput(name, &FileOutputConfig{append: false, flushInterval: time.Minute, sizeLimit: unitSizeVar(2 * messageSize) })
+	output := NewFileOutput(name, &FileOutputConfig{append: false, flushInterval: time.Minute, sizeLimit: unitSizeVar(2 * messageSize)})
 
 	output.Write([]byte("1 1 1\r\ntest"))
 	name1 := output.file.Name()
@@ -345,4 +345,4 @@ func TestFileOutputAppendSizeLimitOverflow(t *testing.T) {
 
 	os.Remove(name1)
 	os.Remove(name3)
-}
+}

output_http.go

@@ -173,9 +173,9 @@ func (o *HTTPOutput) Write(data []byte) (n int, err error) {
 func (o *HTTPOutput) Read(data []byte) (int, error) {
 	resp := <-o.responses
 
-    if Settings.debug {
-	    Debug("[OUTPUT-HTTP] Received response:", string(resp.payload))
-    }
+	if Settings.debug {
+		Debug("[OUTPUT-HTTP] Received response:", string(resp.payload))
+	}
 
 	header := payloadHeader(ReplayedResponsePayload, resp.uuid, resp.roundTripTime, resp.startedAt)
 	copy(data[0:len(header)], header)
@@ -187,9 +187,9 @@ func (o *HTTPOutput) Read(data []byte) (int, error) {
 func (o *HTTPOutput) sendRequest(client *HTTPClient, request []byte) {
 	meta := payloadMeta(request)
 
-    if Settings.debug {
-      Debug(meta)
-    }
+	if Settings.debug {
+		Debug(meta)
+	}
 
 	if len(meta) < 2 {
 		return

output_tcp.go

@@ -21,7 +21,7 @@ type TCPOutput struct {
 }
 
 type TCPOutputConfig struct {
-	secure	bool
+	secure bool
 }
 
 // NewTCPOutput constructor for TCPOutput