2 // Copyright 2019 AT&T Intellectual Property
3 // Copyright 2019 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.
21 "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/common"
25 type rsmWriterInstance struct {
26 sdl common.ISdlInstance
29 // RsmWriter interface allows inserting/updating data to/in redis BD with various keys
30 type RsmWriter interface {
31 SaveRsmRanInfo(rsmRanInfo *models.RsmRanInfo) error
32 SaveRsmGeneralConfiguration(cfg *models.RsmGeneralConfiguration) error
35 // GetRsmWriter returns reference to RsmWriter
36 func GetRsmWriter(sdl common.ISdlInstance) RsmWriter {
37 return &rsmWriterInstance{sdl: sdl}
40 // SaveRsmRanInfo saves the ran related rsm data with key RanName
41 func (r *rsmWriterInstance) SaveRsmRanInfo(rsmRanInfo *models.RsmRanInfo) error {
43 nodebNameKey, err := common.ValidateAndBuildNodeBNameKey(rsmRanInfo.RanName)
49 return r.SaveWithKeyAndMarshal(nodebNameKey, rsmRanInfo)
52 // SaveRsmGeneralConfiguration saves the resource status request related configuration
53 func (r *rsmWriterInstance) SaveRsmGeneralConfiguration(cfg *models.RsmGeneralConfiguration) error {
55 return r.SaveWithKeyAndMarshal(buildRsmGeneralConfigurationKey(), cfg)
59 // SaveWithKeyAndMarshal marshals the Go structure to json and saves it to the DB with key 'key'
60 func (r *rsmWriterInstance) SaveWithKeyAndMarshal(key string, entity interface{}) error {
62 data, err := json.Marshal(entity)
65 return common.NewInternalError(err)
68 var pairs []interface{}
69 pairs = append(pairs, key, data)
71 err = r.sdl.Set(pairs)
74 return common.NewInternalError(err)