add test

Signed-off-by: aoiasd <[email protected]>

internal/proxy/impl.go

@@ -6947,7 +6947,6 @@ func (node *Proxy) RunAnalyzer(ctx context.Context, req *milvuspb.RunAnalyzerReq
 		tokens := []string{}
 		for stream.Advance() {
 			token := stream.Token()
-			log.Info("Test--", zap.String("token", token))
 			tokens = append(tokens, token)
 		}
 		results[i] = &milvuspb.AnalyzerResult{

internal/proxy/impl_test.go

@@ -29,6 +29,7 @@ import (
 	"github.com/gin-gonic/gin"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
+	"github.com/stretchr/testify/require"
 	"go.uber.org/zap"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/metadata"
@@ -2194,3 +2195,22 @@ func TestAlterCollectionReplicateProperty(t *testing.T) {
 	assert.NoError(t, err)
 	assert.True(t, merr.Ok(statusResp))
 }
+
+func TestRunAnalyzer(t *testing.T) {
+	p := &Proxy{}
+	// run analyzer with default params
+	resp, err := p.RunAnalyzer(context.Background(), &milvuspb.RunAnalyzerRequset{
+		Placeholder: [][]byte{[]byte("test doc")},
+	})
+	require.NoError(t, err)
+	require.NoError(t, merr.Error(resp.GetStatus()))
+	assert.Equal(t, len(resp.GetResults()[0].GetTokens()), 2)
+
+	// run analyzer with invalid params
+	resp, err = p.RunAnalyzer(context.Background(), &milvuspb.RunAnalyzerRequset{
+		Placeholder:    [][]byte{[]byte("test doc")},
+		AnalyzerParams: "invalid json",
+	})
+	require.NoError(t, err)
+	require.Error(t, merr.Error(resp.GetStatus()))
+}