reader/sdlSyncStorageMock_test.go

   1 //
   2 // Copyright 2021 AT&T Intellectual Property
   3 // Copyright 2021 Nokia
   4 //
   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
   8 //
   9 //      http://www.apache.org/licenses/LICENSE-2.0
  10 //
  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.
  16
  17 //  This source code is part of the near-RT RIC (RAN Intelligent Controller)
  18 //  platform project (RICP).
  19
  20 package reader
  21
  22 import (
  23         "github.com/stretchr/testify/assert"
  24         "github.com/stretchr/testify/mock"
  25         "testing"
  26 )
  27
  28 func initSdlSyncStorageMockTest() (sdlSyncStorageMockTest *MockSdlSyncStorage) {
  29         sdlSyncStorageMockTest = new(MockSdlSyncStorage)
  30         return
  31 }
  32
  33 func TestRemoveAllMock(t *testing.T) {
  34         ns := "some-ns"
  35         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
  36         sdlSyncStorageMockTest.On("RemoveAll", ns).Return(nil)
  37         err := sdlSyncStorageMockTest.RemoveAll(ns)
  38         assert.Nil(t, err)
  39 }
  40
  41 func TestRemoveMock(t *testing.T) {
  42         var data []string
  43         ns := "some-ns"
  44         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
  45         sdlSyncStorageMockTest.On("Remove", ns, []string(data)).Return(nil)
  46         err := sdlSyncStorageMockTest.Remove(ns, data)
  47         assert.Nil(t, err)
  48
  49 }
  50
  51 func TestRemoveIfMock(t *testing.T) {
  52         var data map[string]interface{}
  53         ns := "some-ns"
  54         key := "key"
  55         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
  56         sdlSyncStorageMockTest.On("RemoveIf", ns, key, data).Return(true, nil)
  57         res, err := sdlSyncStorageMockTest.RemoveIf(ns, key, data)
  58         assert.Nil(t, err)
  59         assert.NotNil(t, res)
  60
  61 }
  62
  63 func TestRemoveGroupMock(t *testing.T) {
  64         ns := "some-ns"
  65         group := "group"
  66         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
  67         sdlSyncStorageMockTest.On("RemoveGroup", ns, group).Return(nil)
  68         err := sdlSyncStorageMockTest.RemoveGroup(ns, group)
  69         assert.Nil(t, err)
  70
  71 }
  72
  73 func TestRemoveIfAndPublishMock(t *testing.T) {
  74         var data map[string]interface{}
  75         var channelsAndEvents []string
  76         ns := "some-ns"
  77         key := "key"
  78         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
  79         sdlSyncStorageMockTest.On("RemoveIfAndPublish", ns, channelsAndEvents, key, data).Return(true, nil)
  80         res, err := sdlSyncStorageMockTest.RemoveIfAndPublish(ns, channelsAndEvents, key, data)
  81         assert.Nil(t, err)
  82         assert.NotNil(t, res)
  83
  84 }
  85
  86 func TestRemoveAndPublishMock(t *testing.T) {
  87         var channelsAndEvents []string
  88         var keys []string
  89         ns := "some-ns"
  90
  91         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
  92         sdlSyncStorageMockTest.On("RemoveAndPublish", ns, []string(channelsAndEvents), []string(keys)).Return(nil)
  93         err := sdlSyncStorageMockTest.RemoveAndPublish(ns, channelsAndEvents, keys)
  94         assert.Nil(t, err)
  95 }
  96
  97 func TestRemoveAllAndPublishMock(t *testing.T) {
  98         var channelsAndEvents []string
  99         ns := "some-ns"
 100         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
 101         sdlSyncStorageMockTest.On("RemoveAllAndPublish", ns, []string(channelsAndEvents)).Return(nil)
 102         err := sdlSyncStorageMockTest.RemoveAllAndPublish(ns, channelsAndEvents)
 103         assert.Nil(t, err)
 104 }
 105
 106 func TestIsMemberMock(t *testing.T) {
 107         var ret map[string]interface{}
 108         ns := "some-ns"
 109         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
 110         sdlSyncStorageMockTest.On("IsMember", ns, "group", ret).Return(true, nil)
 111         res, err := sdlSyncStorageMockTest.IsMember(ns, "group", ret)
 112         assert.Nil(t, err)
 113         assert.NotNil(t, res)
 114 }
 115
 116 func TestCloseMock(t *testing.T) {
 117         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
 118         sdlSyncStorageMockTest.On("Close").Return(nil)
 119         err := sdlSyncStorageMockTest.Close()
 120         assert.Nil(t, err)
 121 }
 122
 123 func TestSetIfNotExistsMock(t *testing.T) {
 124         var data map[string]interface{}
 125         ns := "some-ns"
 126         key := "key"
 127         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
 128         sdlSyncStorageMockTest.On("SetIfNotExists", ns, key, data).Return(true, nil)
 129         res, err := sdlSyncStorageMockTest.SetIfNotExists(ns, key, data)
 130         assert.Nil(t, err)
 131         assert.NotNil(t, res)
 132 }
 133
 134 func TestAddMemberMock(t *testing.T) {
 135         var ret []interface{}
 136         ns := "some-ns"
 137         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
 138         sdlSyncStorageMockTest.On("AddMember", ns, "group", []interface{}{ret}).Return(nil)
 139         err := sdlSyncStorageMockTest.AddMember(ns, "group", ret)
 140         assert.Nil(t, err)
 141 }
 142
 143 func TestRemoveMemberMock(t *testing.T) {
 144         var ret []interface{}
 145         ns := "some-ns"
 146         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
 147         sdlSyncStorageMockTest.On("RemoveMember", ns, "group", []interface{}{ret}).Return(nil)
 148         err := sdlSyncStorageMockTest.RemoveMember(ns, "group", ret)
 149         assert.Nil(t, err)
 150 }
 151
 152 func TestSetAndPublishMock(t *testing.T) {
 153         var pairs []interface{}
 154         var channelsAndEvents []string
 155         ns := "some-ns"
 156         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
 157         sdlSyncStorageMockTest.On("SetAndPublish", ns, channelsAndEvents, []interface{}{pairs}).Return(nil)
 158         err := sdlSyncStorageMockTest.SetAndPublish(ns, channelsAndEvents, pairs)
 159         assert.Nil(t, err)
 160 }
 161
 162 func TestSetIfAndPublishMock(t *testing.T) {
 163         var newData map[string]interface{}
 164         var oldData map[string]interface{}
 165         var group []string
 166         ns := "some-ns"
 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)
 170         assert.Nil(t, err)
 171         assert.NotNil(t, res)
 172 }
 173
 174 func TestSetMock(t *testing.T) {
 175         var pairs []interface{}
 176         ns := "some-ns"
 177         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
 178         sdlSyncStorageMockTest.On("Set", ns, []interface{}{pairs}).Return(nil)
 179         err := sdlSyncStorageMockTest.Set(ns, pairs)
 180         assert.Nil(t, err)
 181 }
 182
 183 func TestSetIfMock(t *testing.T) {
 184         var newData map[string]interface{}
 185         var oldData map[string]interface{}
 186         ns := "some-ns"
 187         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
 188         sdlSyncStorageMockTest.On("SetIf", ns, "key", newData, oldData).Return(true, nil)
 189         res, err := sdlSyncStorageMockTest.SetIf(ns, "key", newData, oldData)
 190         assert.Nil(t, err)
 191         assert.NotNil(t, res)
 192 }
 193
 194 func TestGetAllMock(t *testing.T) {
 195         var data []string
 196         ns := "some-ns"
 197         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
 198         sdlSyncStorageMockTest.On("GetAll", ns).Return(data, nil)
 199         res, err := sdlSyncStorageMockTest.GetAll(ns)
 200         assert.Nil(t, err)
 201         assert.Nil(t, res)
 202 }
 203
 204 func TestSetIfNotExistsAndPublishMock(t *testing.T) {
 205         var data map[string]interface{}
 206         var channelsAndEvents []string
 207         ns := "some-ns"
 208         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
 209         sdlSyncStorageMockTest.On("SetIfNotExistsAndPublish", ns, channelsAndEvents, "key", data).Return(true, nil)
 210         res, err := sdlSyncStorageMockTest.SetIfNotExistsAndPublish(ns, channelsAndEvents, "key", data)
 211         assert.Nil(t, err)
 212         assert.NotNil(t, res)
 213 }
 214
 215 func TestSubscribeChannelMock(t *testing.T) {
 216         ns := "some-ns"
 217         cb := func(channel string, events ...string) {}
 218         ch := "some-channel"
 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)
 223         assert.Nil(t, err)
 224 }
 225
 226 func TestUnsubscribeChannelMock(t *testing.T) {
 227         ns := "some-ns"
 228         ch := "some-channel"
 229         sdlSyncStorageMockTest := initSdlSyncStorageMockTest()
 230         sdlSyncStorageMockTest.On("UnsubscribeChannel", ns, []string{ch}).Return(nil)
 231         err := sdlSyncStorageMockTest.UnsubscribeChannel(ns, ch)
 232         assert.Nil(t, err)
 233 }