7 "e2mgr/services/rmrsender"
9 "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
12 type RanStatusChangeManager struct {
14 rmrSender *rmrsender.RmrSender
17 func NewRanStatusChangeManager(logger *logger.Logger, rmrSender *rmrsender.RmrSender) *RanStatusChangeManager {
18 return &RanStatusChangeManager{
24 type IRanStatusChangeManager interface {
25 Execute(msgType int, msgDirection enums.MessageDirection, nodebInfo *entities.NodebInfo) error
28 func (m *RanStatusChangeManager) Execute(msgType int, msgDirection enums.MessageDirection, nodebInfo *entities.NodebInfo) error {
30 resourceStatusPayload := models.NewResourceStatusPayload(nodebInfo.NodeType, msgDirection)
31 resourceStatusJson, err := json.Marshal(resourceStatusPayload)
34 m.logger.Errorf("#RanStatusChangeManager.Execute - RAN name: %s - Error marshaling resource status payload: %v", nodebInfo.RanName, err)
39 rmrMessage := models.NewRmrMessage(msgType, nodebInfo.RanName, resourceStatusJson, xAction)
40 return m.rmrSender.Send(rmrMessage)