faasd/vendor/github.com/openfaas/faas-provider/httputil/write_interceptor.go

package httputil

import (
	"bufio"
	"net"
	"net/http"
)

func NewHttpWriteInterceptor(w http.ResponseWriter) *HttpWriteInterceptor {
	return &HttpWriteInterceptor{
		ResponseWriter: w,
		statusCode:     0,
		bytesWritten:   0,
	}
}

type HttpWriteInterceptor struct {
	http.ResponseWriter
	statusCode   int
	bytesWritten int64
}

func (c *HttpWriteInterceptor) Status() int {
	if c.statusCode == 0 {
		return http.StatusOK
	}
	return c.statusCode
}

func (c *HttpWriteInterceptor) BytesWritten() int64 {
	return c.bytesWritten
}

func (c *HttpWriteInterceptor) Header() http.Header {
	return c.ResponseWriter.Header()
}

func (c *HttpWriteInterceptor) Write(data []byte) (int, error) {
	if c.statusCode == 0 {
		c.WriteHeader(http.StatusOK)
	}

	c.bytesWritten += int64(len(data))

	return c.ResponseWriter.Write(data)
}

func (c *HttpWriteInterceptor) WriteHeader(code int) {
	c.statusCode = code
	c.ResponseWriter.WriteHeader(code)
}

func (c *HttpWriteInterceptor) Flush() {
	fl := c.ResponseWriter.(http.Flusher)
	fl.Flush()
}

func (c *HttpWriteInterceptor) Hijack() (net.Conn, *bufio.ReadWriter, error) {
	hj := c.ResponseWriter.(http.Hijacker)
	return hj.Hijack()
}

func (c *HttpWriteInterceptor) CloseNotify() <-chan bool {
	notifier, ok := c.ResponseWriter.(http.CloseNotifier)
	if ok == false {
		return nil
	}
	return notifier.CloseNotify()
}