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.
17 // This source code is part of the near-RT RIC (RAN Intelligent Controller)
18 // platform project (RICP).
24 "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/common"
28 type rsmWriterInstance struct {
29 sdl common.ISdlInstance
32 // RsmWriter interface allows inserting/updating data to/in redis BD with various keys
33 type RsmWriter interface {
34 SaveRsmRanInfo(rsmRanInfo *models.RsmRanInfo) error
35 SaveRsmGeneralConfiguration(cfg *models.RsmGeneralConfiguration) error
38 // GetRsmWriter returns reference to RsmWriter
39 func GetRsmWriter(sdl common.ISdlInstance) RsmWriter {
40 return &rsmWriterInstance{sdl: sdl}
43 // SaveRsmRanInfo saves the ran related rsm data with key RanName
44 func (r *rsmWriterInstance) SaveRsmRanInfo(rsmRanInfo *models.RsmRanInfo) error {
46 nodebNameKey, err := common.ValidateAndBuildNodeBNameKey(rsmRanInfo.RanName)
52 return r.SaveWithKeyAndMarshal(nodebNameKey, rsmRanInfo)
55 // SaveRsmGeneralConfiguration saves the resource status request related configuration
56 func (r *rsmWriterInstance) SaveRsmGeneralConfiguration(cfg *models.RsmGeneralConfiguration) error {
58 return r.SaveWithKeyAndMarshal(buildRsmGeneralConfigurationKey(), cfg)
62 // SaveWithKeyAndMarshal marshals the Go structure to json and saves it to the DB with key 'key'
63 func (r *rsmWriterInstance) SaveWithKeyAndMarshal(key string, entity interface{}) error {
65 data, err := json.Marshal(entity)
68 return common.NewInternalError(err)
71 var pairs []interface{}
72 pairs = append(pairs, key, data)
74 err = r.sdl.Set(pairs)
77 return common.NewInternalError(err)