File size: 2,575 Bytes
b110593
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
//                           _       _
// __      _____  __ ___   ___  __ _| |_ ___
// \ \ /\ / / _ \/ _` \ \ / / |/ _` | __/ _ \
//  \ V  V /  __/ (_| |\ V /| | (_| | ||  __/
//   \_/\_/ \___|\__,_| \_/ |_|\__,_|\__\___|
//
//  Copyright © 2016 - 2024 Weaviate B.V. All rights reserved.
//
//  CONTACT: [email protected]
//

package concepts

import (
	"context"
	"io"
	"net/http"
	"net/http/httptest"
	"testing"

	"github.com/pkg/errors"
	"github.com/stretchr/testify/assert"
	"github.com/stretchr/testify/require"
	"github.com/weaviate/weaviate/entities/models"
)

func TestHandlers(t *testing.T) {
	insp := newFakeInspector()
	h := NewRESTHandlers(insp)

	t.Run("without a concept", func(t *testing.T) {
		insp.reset()
		r := httptest.NewRequest("GET", "/", nil)
		w := httptest.NewRecorder()
		h.Handler().ServeHTTP(w, r)

		res := w.Result()
		defer res.Body.Close()
		assert.Equal(t, http.StatusNotFound, res.StatusCode)
	})

	t.Run("without any errors", func(t *testing.T) {
		insp.reset()
		r := httptest.NewRequest("GET", "/my-concept", nil)
		w := httptest.NewRecorder()
		h.Handler().ServeHTTP(w, r)

		res := w.Result()
		defer res.Body.Close()
		json, err := io.ReadAll(res.Body)
		require.Nil(t, err)
		expected := `{"individualWords":[{` +
			`"info":{"vector":[0.1,0.2]},"present":true,"word":"my-concept"}]}`

		assert.Equal(t, http.StatusOK, res.StatusCode)
		assert.Equal(t, expected, string(json))
	})

	t.Run("without an error from the UC", func(t *testing.T) {
		insp.reset()
		insp.err = errors.Errorf("invalid input")
		r := httptest.NewRequest("GET", "/my-concept", nil)
		w := httptest.NewRecorder()
		h.Handler().ServeHTTP(w, r)

		res := w.Result()
		defer res.Body.Close()
		json, err := io.ReadAll(res.Body)
		require.Nil(t, err)
		expected := `{"error":[{"message":"invalid input"}]}`

		assert.Equal(t, http.StatusBadRequest, res.StatusCode)
		assert.Equal(t, expected, string(json))
	})
}

type fakeInspector struct {
	err error
}

func (f *fakeInspector) reset() {
	f.err = nil
}

func (f *fakeInspector) GetWords(ctx context.Context,
	concept string,
) (*models.C11yWordsResponse, error) {
	return &models.C11yWordsResponse{
		IndividualWords: []*models.C11yWordsResponseIndividualWordsItems0{
			{
				Present: true,
				Word:    concept,
				Info: &models.C11yWordsResponseIndividualWordsItems0Info{
					Vector: []float32{0.1, 0.2},
				},
			},
		},
	}, f.err
}

func newFakeInspector() *fakeInspector {
	return &fakeInspector{}
}