X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=sdl_test.go;h=944edaae2073712a68ec83c2facaf3b5d6abfccd;hb=51847d2ee72873fca9de000b77c593a0503fdbcc;hp=832e8ebe5e6b8f7d309ba003e0e95a23ea8d5046;hpb=a10caff26de79e06caac2d00d3c11218e2d7ee87;p=ric-plt%2Fsdlgo.git diff --git a/sdl_test.go b/sdl_test.go index 832e8eb..944edaa 100644 --- a/sdl_test.go +++ b/sdl_test.go @@ -24,7 +24,6 @@ import ( "time" "gerrit.o-ran-sc.org/r/ric-plt/sdlgo" - "gerrit.o-ran-sc.org/r/ric-plt/sdlgo/internal/sdlgoredis" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/mock" ) @@ -33,7 +32,7 @@ type mockDB struct { mock.Mock } -func (m *mockDB) SubscribeChannelDB(cb sdlgoredis.ChannelNotificationCb, channelPrefix, eventSeparator string, channels ...string) { +func (m *mockDB) SubscribeChannelDB(cb func(string, ...string), channelPrefix, eventSeparator string, channels ...string) { m.Called(cb, channelPrefix, eventSeparator, channels) } @@ -142,7 +141,7 @@ func (m *mockDB) PExpireIE(key string, data interface{}, expiration time.Duratio func setup() (*mockDB, *sdlgo.SdlInstance) { m := new(mockDB) - i := sdlgo.NewSdlInstance("namespace", m) + i := sdlgo.NewSdlInstanceForTest("namespace", m) return m, i } @@ -171,7 +170,7 @@ func TestSubscribeChannel(t *testing.T) { expectedCB := func(channel string, events ...string) {} expectedChannels := []string{"{namespace},channel1", "{namespace},channel2"} - m.On("SubscribeChannelDB", mock.AnythingOfType("sdlgoredis.ChannelNotificationCb"), "{namespace},", "___", expectedChannels).Return() + m.On("SubscribeChannelDB", mock.AnythingOfType("func(string, ...string)"), "{namespace},", "___", expectedChannels).Return() i.SubscribeChannel(expectedCB, "channel1", "channel2") m.AssertExpectations(t) }