sparrow/services/controller/controller_test.go

package main

import (
	"sparrow/pkg/protocol"
	"sparrow/pkg/ruleEngine"
	"sparrow/pkg/server"
	"testing"
	"time"
)

func TestInit(t *testing.T) {
	server.InitLog("test", "debug")
	as, err := initActorSystem()
	if err != nil {
		t.Error(err)
	}
	time.Sleep(5 * time.Second)
	as.rootActor.Tell(&ruleEngine.QueueToRuleEngineMsg{
		TenantId: "tenant_1",
		Message: &protocol.Message{
			QueueName:  "",
			Id:         "",
			Ts:         nil,
			Type:       "POST_ATTRIBUTES_REQUEST",
			Data:       "",
			RuleChanId: "",
			RuleNodeId: "",
			Callback:   nil,
			MetaData:   nil,
			Originator: "",
		},
		RelationTypes:  nil,
		FailureMessage: nil,
	})
	select {}
}