starter/sync_exchange_connect/sync_exchange_connect_test.go

package sync_exchange_connect

import (
	"github.com/ManyakRus/starter/config_main"
	"github.com/ManyakRus/starter/contextmain"
	"github.com/ManyakRus/starter/micro"
	"github.com/ManyakRus/starter/stopapp"
	"testing"
)

var SERVICE_NAME_TEST = "test_nikitin"

func TestConnect(t *testing.T) {
	config_main.LoadEnv()
	Connect(SERVICE_NAME_TEST)
	defer CloseConnection()

	micro.Pause(100)

}

func TestStartNats(t *testing.T) {
	config_main.LoadEnv()
	Start(SERVICE_NAME_TEST)
	defer CloseConnection()

	micro.Pause(100)

	contextmain.CancelContext()
	contextmain.GetNewContext()
}

func TestCloseConnection(t *testing.T) {
	config_main.LoadEnv()
	Connect(SERVICE_NAME_TEST)
	defer CloseConnection()
}

func TestWaitStop(t *testing.T) {

	stopapp.GetWaitGroup_Main().Add(1)
	go WaitStop()

	_ = contextmain.GetContext()
	contextmain.CancelContext()

	stopapp.GetWaitGroup_Main().Wait()

	contextmain.GetNewContext()
}