wasm-http-server/internal/whutil/response_writer.go

59 lines
1.3 KiB
Go
Raw Normal View History

2019-11-27 07:22:07 +01:00
package whutil
2019-11-26 23:35:43 +01:00
import (
"bytes"
"net/http"
"syscall/js"
)
// ResponseWriter implements http.ResponseWriter
type ResponseWriter struct {
header http.Header
buf *bytes.Buffer
statusCode int
}
// NewResponseWriter creates a new ResponseWriter
func NewResponseWriter() *ResponseWriter {
return &ResponseWriter{
header: http.Header{},
buf: bytes.NewBuffer(nil),
statusCode: 0,
}
}
var _ http.ResponseWriter = (*ResponseWriter)(nil)
2019-11-26 23:50:43 +01:00
// Header implements http.ResponseWriter.Header
2019-11-26 23:35:43 +01:00
func (rw *ResponseWriter) Header() http.Header {
return rw.header
}
2019-11-26 23:50:43 +01:00
// Write implements http.ResponseWriter.Write
2019-11-26 23:35:43 +01:00
func (rw *ResponseWriter) Write(p []byte) (int, error) {
return rw.buf.Write(p)
}
2019-11-26 23:50:43 +01:00
// WriteHeader implements http.ResponseWriter.WriteHeader
2019-11-26 23:35:43 +01:00
func (rw *ResponseWriter) WriteHeader(statusCode int) {
rw.statusCode = statusCode
}
2019-11-26 23:50:43 +01:00
// JSResponse builds and returns the equivalent JS Response
2019-11-26 23:35:43 +01:00
func (rw *ResponseWriter) JSResponse() js.Value {
init := js.Global().Get("Object").New()
if rw.statusCode != 0 {
init.Set("status", rw.statusCode)
}
2019-11-26 23:50:43 +01:00
if len(rw.header) != 0 {
init.Set("headers", map[string][]string(rw.header))
}
2019-11-26 23:35:43 +01:00
jsBody := js.Global().Get("Uint8Array").New(rw.buf.Len())
js.CopyBytesToJS(jsBody, rw.buf.Bytes())
return js.Global().Get("Response").New(jsBody, init)
}