Function TestBytesReadGzipRequest

rest/bytes_read_public_api_test.go:389–419

(t *testing.T)

}

func TestBytesReadGzipRequest(t *testing.T) {
	// Need default collection as request below doesn't work with {{.keyspace}}
	rt := NewRestTesterDefaultCollection(t, &RestTesterConfig{
		GuestEnabled: true,
	})
	defer rt.Close()

	rt.CreateUser("alice", []string{"ABC"})
	input := `{"channel":["ABC"]}`

	var buf bytes.Buffer
	gz := gzip.NewWriter(&buf)
	_, err := gz.Write([]byte(input))
	require.NoError(t, err)
	err = gz.Close()
	require.NoError(t, err)

	inputBytes := []byte(input)

	// {{.keyspace}} isn't supported so use default collection
	rq := Request("PUT", "/db/doc", buf.String())
	rq.Header.Set("Content-Encoding", "gzip")
	resp := rt.Send(rq)
	RequireStatus(t, resp, http.StatusCreated)

	base.RequireWaitForStat(t, func() int64 {
		fmt.Println(rt.GetDatabase().DbStats.DatabaseStats.PublicRestBytesRead.Value())
		return rt.GetDatabase().DbStats.DatabaseStats.PublicRestBytesRead.Value()
	}, int64(len(inputBytes)))

}

func TestPutDBBytesRead(t *testing.T) {
	if base.UnitTestUrlIsWalrus() {