package httpapi_test

import (

"bytes"

"encoding/json"

"net/http"

"net/http/httptest"

"strings"

"testing"

"github.com/stretchr/testify/assert"

"github.com/stretchr/testify/require"

"github.com/coder/coder/coderd/httpapi"

"github.com/coder/coder/codersdk"

)

func TestWrite(t *testing.T) {

t.Parallel()

t.Run("NoErrors", func(t *testing.T) {

t.Parallel()

rw := httptest.NewRecorder()

httpapi.Write(rw, http.StatusOK, codersdk.Response{

Message: "Wow.",

})

var m map[string]interface{}

err := json.NewDecoder(rw.Body).Decode(&m)

require.NoError(t, err)

_, ok := m["errors"]

require.False(t, ok)

})

}

func TestRead(t *testing.T) {

t.Parallel()

t.Run("EmptyStruct", func(t *testing.T) {

t.Parallel()

rw := httptest.NewRecorder()

r := httptest.NewRequest("POST", "/", bytes.NewBufferString("{}"))

v := struct{}{}

require.True(t, httpapi.Read(rw, r, &v))

})

t.Run("NoBody", func(t *testing.T) {

t.Parallel()

rw := httptest.NewRecorder()

r := httptest.NewRequest("POST", "/", nil)

var v json.RawMessage

require.False(t, httpapi.Read(rw, r, v))

})

t.Run("Validate", func(t *testing.T) {

t.Parallel()

type toValidate struct {

Value string `json:"value" validate:"required"`

}

rw := httptest.NewRecorder()

r := httptest.NewRequest("POST", "/", bytes.NewBufferString(`{"value":"hi"}`))

var validate toValidate

require.True(t, httpapi.Read(rw, r, &validate))

require.Equal(t, "hi", validate.Value)

})

t.Run("ValidateFailure", func(t *testing.T) {

t.Parallel()

type toValidate struct {

Value string `json:"value" validate:"required"`

}

rw := httptest.NewRecorder()

r := httptest.NewRequest("POST", "/", bytes.NewBufferString("{}"))

var validate toValidate

require.False(t, httpapi.Read(rw, r, &validate))

var v codersdk.Response

err := json.NewDecoder(rw.Body).Decode(&v)

require.NoError(t, err)

require.Len(t, v.Validations, 1)

require.Equal(t, "value", v.Validations[0].Field)

require.Equal(t, "Validation failed for tag \"required\" with value: \"\"", v.Validations[0].Detail)

})

}

func WebsocketCloseMsg(t *testing.T) {

t.Parallel()

t.Run("TruncateSingleByteCharacters", func(t *testing.T) {

t.Parallel()

msg := strings.Repeat("d", 255)

trunc := httpapi.WebsocketCloseSprintf(msg)

assert.LessOrEqual(t, len(trunc), 123)

})

t.Run("TruncateMultiByteCharacters", func(t *testing.T) {

t.Parallel()

msg := strings.Repeat("こんにちは", 10)

trunc := httpapi.WebsocketCloseSprintf(msg)

assert.LessOrEqual(t, len(trunc), 123)

})

}