2 // Copyright 2021 AT&T Intellectual Property
3 // Copyright 2021 Nokia
5 // Licensed under the Apache License, Version 2.0 (the "License");
6 // you may not use this file except in compliance with the License.
7 // You may obtain a copy of the License at
9 // http://www.apache.org/licenses/LICENSE-2.0
11 // Unless required by applicable law or agreed to in writing, software
12 // distributed under the License is distributed on an "AS IS" BASIS,
13 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 // See the License for the specific language governing permissions and
15 // limitations under the License.
17 // This source code is part of the near-RT RIC (RAN Intelligent Controller)
18 // platform project (RICP).
23 "github.com/stretchr/testify/assert"
24 "github.com/stretchr/testify/mock"
28 func initSdlSyncStorageMockTest() (sdlSyncStorageMockTest *MockSdlSyncStorage) {
29 sdlSyncStorageMockTest = new(MockSdlSyncStorage)
33 func TestRemoveAllMock(t *testing.T) {
35 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
36 sdlSyncStorageMockTest.On("RemoveAll", ns).Return(nil)
37 err := sdlSyncStorageMockTest.RemoveAll(ns)
41 func TestRemoveMock(t *testing.T) {
44 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
45 sdlSyncStorageMockTest.On("Remove", ns, []string(data)).Return(nil)
46 err := sdlSyncStorageMockTest.Remove(ns, data)
51 func TestRemoveIfMock(t *testing.T) {
52 var data map[string]interface{}
55 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
56 sdlSyncStorageMockTest.On("RemoveIf", ns, key, data).Return(true, nil)
57 res, err := sdlSyncStorageMockTest.RemoveIf(ns, key, data)
63 func TestRemoveGroupMock(t *testing.T) {
66 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
67 sdlSyncStorageMockTest.On("RemoveGroup", ns, group).Return(nil)
68 err := sdlSyncStorageMockTest.RemoveGroup(ns, group)
73 func TestRemoveIfAndPublishMock(t *testing.T) {
74 var data map[string]interface{}
75 var channelsAndEvents []string
78 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
79 sdlSyncStorageMockTest.On("RemoveIfAndPublish", ns, channelsAndEvents, key, data).Return(true, nil)
80 res, err := sdlSyncStorageMockTest.RemoveIfAndPublish(ns, channelsAndEvents, key, data)
86 func TestRemoveAndPublishMock(t *testing.T) {
87 var channelsAndEvents []string
91 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
92 sdlSyncStorageMockTest.On("RemoveAndPublish", ns, []string(channelsAndEvents), []string(keys)).Return(nil)
93 err := sdlSyncStorageMockTest.RemoveAndPublish(ns, channelsAndEvents, keys)
97 func TestRemoveAllAndPublishMock(t *testing.T) {
98 var channelsAndEvents []string
100 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
101 sdlSyncStorageMockTest.On("RemoveAllAndPublish", ns, []string(channelsAndEvents)).Return(nil)
102 err := sdlSyncStorageMockTest.RemoveAllAndPublish(ns, channelsAndEvents)
106 func TestIsMemberMock(t *testing.T) {
107 var ret map[string]interface{}
109 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
110 sdlSyncStorageMockTest.On("IsMember", ns, "group", ret).Return(true, nil)
111 res, err := sdlSyncStorageMockTest.IsMember(ns, "group", ret)
113 assert.NotNil(t, res)
116 func TestCloseMock(t *testing.T) {
117 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
118 sdlSyncStorageMockTest.On("Close").Return(nil)
119 err := sdlSyncStorageMockTest.Close()
123 func TestSetIfNotExistsMock(t *testing.T) {
124 var data map[string]interface{}
127 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
128 sdlSyncStorageMockTest.On("SetIfNotExists", ns, key, data).Return(true, nil)
129 res, err := sdlSyncStorageMockTest.SetIfNotExists(ns, key, data)
131 assert.NotNil(t, res)
134 func TestAddMemberMock(t *testing.T) {
135 var ret []interface{}
137 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
138 sdlSyncStorageMockTest.On("AddMember", ns, "group", []interface{}{ret}).Return(nil)
139 err := sdlSyncStorageMockTest.AddMember(ns, "group", ret)
143 func TestRemoveMemberMock(t *testing.T) {
144 var ret []interface{}
146 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
147 sdlSyncStorageMockTest.On("RemoveMember", ns, "group", []interface{}{ret}).Return(nil)
148 err := sdlSyncStorageMockTest.RemoveMember(ns, "group", ret)
152 func TestSetAndPublishMock(t *testing.T) {
153 var pairs []interface{}
154 var channelsAndEvents []string
156 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
157 sdlSyncStorageMockTest.On("SetAndPublish", ns, channelsAndEvents, []interface{}{pairs}).Return(nil)
158 err := sdlSyncStorageMockTest.SetAndPublish(ns, channelsAndEvents, pairs)
162 func TestSetIfAndPublishMock(t *testing.T) {
163 var newData map[string]interface{}
164 var oldData map[string]interface{}
167 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
168 sdlSyncStorageMockTest.On("SetIfAndPublish", ns, group, "key", oldData, newData).Return(true, nil)
169 res, err := sdlSyncStorageMockTest.SetIfAndPublish(ns, group, "key", oldData, newData)
171 assert.NotNil(t, res)
174 func TestSetMock(t *testing.T) {
175 var pairs []interface{}
177 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
178 sdlSyncStorageMockTest.On("Set", ns, []interface{}{pairs}).Return(nil)
179 err := sdlSyncStorageMockTest.Set(ns, pairs)
183 func TestSetIfMock(t *testing.T) {
184 var newData map[string]interface{}
185 var oldData map[string]interface{}
187 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
188 sdlSyncStorageMockTest.On("SetIf", ns, "key", newData, oldData).Return(true, nil)
189 res, err := sdlSyncStorageMockTest.SetIf(ns, "key", newData, oldData)
191 assert.NotNil(t, res)
194 func TestGetAllMock(t *testing.T) {
197 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
198 sdlSyncStorageMockTest.On("GetAll", ns).Return(data, nil)
199 res, err := sdlSyncStorageMockTest.GetAll(ns)
204 func TestSetIfNotExistsAndPublishMock(t *testing.T) {
205 var data map[string]interface{}
206 var channelsAndEvents []string
208 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
209 sdlSyncStorageMockTest.On("SetIfNotExistsAndPublish", ns, channelsAndEvents, "key", data).Return(true, nil)
210 res, err := sdlSyncStorageMockTest.SetIfNotExistsAndPublish(ns, channelsAndEvents, "key", data)
212 assert.NotNil(t, res)
215 func TestSubscribeChannelMock(t *testing.T) {
217 cb := func(channel string, events ...string) {}
219 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
220 sdlSyncStorageMockTest.On("SubscribeChannel", ns, mock.AnythingOfType("func(string, ...string)"),
221 []string{ch}).Return(nil)
222 err := sdlSyncStorageMockTest.SubscribeChannel(ns, cb, ch)
226 func TestUnsubscribeChannelMock(t *testing.T) {
229 sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
230 sdlSyncStorageMockTest.On("UnsubscribeChannel", ns, []string{ch}).Return(nil)
231 err := sdlSyncStorageMockTest.UnsubscribeChannel(ns, ch)