kubelatte-ce

1
package grpc
2

3
import (
4
	"context"
5
	"github.com/stretchr/testify/mock"
6
	"gitverse.ru/synapse/kubelatte/pkg/observability/logger/lib"
7
	"gitverse.ru/synapse/kubelatte/pkg/sideeffect/grpc/proto"
8
	"gitverse.ru/synapse/kubelatte/pkg/sideeffect/sideeffect"
9
	"go.uber.org/zap"
10
	"testing"
11
)
12

13
var port = 8687
14

15
func TestStartExecServer(t *testing.T) {
16
	lib.ZapLogger = zap.NewNop()
17

18
	sideEffector := sideeffect.NewExecutor(nil)
19

20
	shutdown := StartExecuteServer(port, sideEffector)
21
	shutdown()
22
}
23

24
func TestExecutorServer_DoSideEffect(t *testing.T) {
25
	ex := NewExecutorI(t)
26
	ex.On("ApplySideEffect", mock.Anything, mock.Anything).Return()
27
	s := &ExecutorServer{
28
		ExecutorI: ex,
29
	}
30
	_, _ = s.DoSideEffect(context.Background(),
31
		&proto.SideEffectInfo{
32
			SeMode: 12,
33
			Configs: &proto.Configs{
34
				Kind:         "",
35
				ApiVersion:   "",
36
				ParentTag:    0,
37
				Metadata:     nil,
38
				TriggerRef:   nil,
39
				TemplateRefs: nil,
40
			}})
41
}
42