X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fsbi%2Fsbi.go;h=9d1380e0de0f56a34f8425e6efa44588c35d0ebe;hb=45b86cc64dc6071f160b0f2c9ab8dfb57d1ce039;hp=a2da825d5a5f5a1f20380910467bcbde3c62987a;hpb=871fa393844ce1b61b8d5218d27687d9fc05803a;p=ric-plt%2Frtmgr.git

diff --git a/pkg/sbi/sbi.go b/pkg/sbi/sbi.go
index a2da825..9d1380e 100644
--- a/pkg/sbi/sbi.go
+++ b/pkg/sbi/sbi.go
@@ -1,4 +1,5 @@
 /*
+w
 ==================================================================================
   Copyright (c) 2019 AT&T Intellectual Property.
   Copyright (c) 2019 Nokia
@@ -14,6 +15,10 @@
    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
+
+   This source code is part of the near-RT RIC (RAN Intelligent Controller)
+   platform project (RICP).
+
 ==================================================================================
 */
 /*
@@ -26,51 +31,143 @@ package sbi
 
 import (
 	"errors"
-	"fmt"
-	"rtmgr"
+	"gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
+	"routing-manager/pkg/rtmgr"
+	"strconv"
+	"strings"
 )
 
+const DefaultNngPipelineSocketPrefix = "tcp://"
+const DefaultNngPipelineSocketNumber = 4561
+const PlatformType = "platform"
+
 var (
-	SupportedSbis = []*SbiEngineConfig{
-		&SbiEngineConfig{
-			SbiEngine{
-				Name:     "nngpub",
-				Version:  "v1",
-				Protocol: "nngpubsub",
-			},
-			openSocket(openNngPub),
-			closeSocket(closeNngPub),
-			distributeAll(publishAll),
-			true,
-		},
-		&SbiEngineConfig{
-			SbiEngine{
-				Name:     "nngpush",
-				Version:  "v1",
-				Protocol: "nngpipeline",
-			},
-			openSocket(nil),
-			closeSocket(nil),
-			distributeAll(nil),
-			false,
+	SupportedSbis = []*EngineConfig{
+		{
+			Name:        "nngpush",
+			Version:     "v1",
+			Protocol:    "nngpipeline",
+			Instance:    NewNngPush(),
+			IsAvailable: true,
 		},
 	}
 )
 
-func ListSbis() {
-	fmt.Printf("SBI:\n")
+func GetSbi(sbiName string) (Engine, error) {
 	for _, sbi := range SupportedSbis {
-		if sbi.IsAvailable {
-			rtmgr.Logger.Info(sbi.Engine.Name + "/" + sbi.Engine.Version)
+		if sbi.Name == sbiName && sbi.IsAvailable {
+			return sbi.Instance, nil
 		}
 	}
+	return nil, errors.New("SBI:" + sbiName + " is not supported or still not available")
 }
 
-func GetSbi(sbiName string) (*SbiEngineConfig, error) {
-	for _, sbi := range SupportedSbis {
-		if sbi.Engine.Name == sbiName && sbi.IsAvailable {
-			return sbi, nil
+type Sbi struct {
+}
+
+func (s *Sbi) pruneEndpointList(sbi Engine) {
+	xapp.Logger.Debug("pruneEndpointList invoked.")
+	for _, ep := range rtmgr.Eps {
+		if !ep.Keepalive {
+			xapp.Logger.Debug("deleting %v", ep)
+			sbi.DeleteEndpoint(ep)
+			delete(rtmgr.Eps, ep.Uuid)
+		} else {
+			rtmgr.Eps[ep.Uuid].Keepalive = false
 		}
 	}
-	return nil, errors.New("SBI:" + sbiName + "is not supported or still not a available")
+}
+
+func (s *Sbi) updateEndpoints(rcs *rtmgr.RicComponents, sbi Engine) {
+	for _, xapps := range (*rcs).XApps {
+		for _, instance := range xapps.Instances {
+			uuid := instance.Ip + ":" + strconv.Itoa(int(instance.Port))
+			if _, ok := rtmgr.Eps[uuid]; ok {
+				rtmgr.Eps[uuid].Keepalive = true
+			} else {
+				ep := &rtmgr.Endpoint{
+					Uuid:       uuid,
+					Name:       instance.Name,
+					XAppType:   xapps.Name,
+					Ip:         instance.Ip,
+					Port:       instance.Port,
+					TxMessages: instance.TxMessages,
+					RxMessages: instance.RxMessages,
+					Policies:   instance.Policies,
+					Socket:     nil,
+					IsReady:    false,
+					Keepalive:  true,
+				}
+				if err := sbi.AddEndpoint(ep); err != nil {
+					xapp.Logger.Error("can't create socket for endpoint: " + ep.Name + " due to:" + err.Error())
+					continue
+				}
+				rtmgr.Eps[uuid] = ep
+			}
+		}
+	}
+	s.updatePlatformEndpoints(&((*rcs).Pcs), sbi)
+        s.updateE2TEndpoints(&((*rcs).E2Ts), sbi)
+	s.pruneEndpointList(sbi)
+}
+
+func (s *Sbi) updatePlatformEndpoints(pcs *rtmgr.PlatformComponents, sbi Engine) {
+	xapp.Logger.Debug("updatePlatformEndpoints invoked. PCS: %v", *pcs)
+	for _, pc := range *pcs {
+		uuid := pc.Fqdn + ":" + strconv.Itoa(int(pc.Port))
+		if _, ok := rtmgr.Eps[uuid]; ok {
+			rtmgr.Eps[uuid].Keepalive = true
+		} else {
+			ep := &rtmgr.Endpoint{
+				Uuid:       uuid,
+				Name:       pc.Name,
+				XAppType:   PlatformType,
+				Ip:         pc.Fqdn,
+				Port:       pc.Port,
+				TxMessages: rtmgr.PLATFORMMESSAGETYPES[pc.Name]["tx"],
+				RxMessages: rtmgr.PLATFORMMESSAGETYPES[pc.Name]["rx"],
+				Socket:     nil,
+				IsReady:    false,
+				Keepalive:  true,
+			}
+			xapp.Logger.Debug("ep created: %v", ep)
+			if err := sbi.AddEndpoint(ep); err != nil {
+				xapp.Logger.Error("can't create socket for endpoint: " + ep.Name + " due to:" + err.Error())
+				continue
+			}
+			rtmgr.Eps[uuid] = ep
+		}
+	}
+}
+
+func (s *Sbi) updateE2TEndpoints(E2Ts *map[string]rtmgr.E2TInstance, sbi Engine) {
+        xapp.Logger.Debug("updateE2TEndpoints invoked. E2T: %v", *E2Ts)
+        for _, e2t := range *E2Ts {
+                uuid := e2t.Fqdn
+                stringSlice := strings.Split(e2t.Fqdn, ":")
+                ipaddress := stringSlice[0]
+                port, _ := strconv.Atoi(stringSlice[1])
+                if _, ok := rtmgr.Eps[uuid]; ok {
+                        rtmgr.Eps[uuid].Keepalive = true
+                } else {
+                        ep := &rtmgr.Endpoint{
+                                Uuid:       uuid,
+                                Name:       e2t.Name,
+                                XAppType:   PlatformType,
+                                Ip:         ipaddress,
+                                Port:       uint16(port),
+                                TxMessages: rtmgr.PLATFORMMESSAGETYPES[e2t.Name]["tx"],
+                                RxMessages: rtmgr.PLATFORMMESSAGETYPES[e2t.Name]["rx"],
+                                Socket:     nil,
+                                IsReady:    false,
+                                Keepalive:  true,
+                        }
+                        xapp.Logger.Debug("ep created: %v", ep)
+                        if err := sbi.AddEndpoint(ep); err != nil {
+                                xapp.Logger.Error("can't create socket for endpoint: " + ep.Name + " due to:" + err.Error())
+                                continue
+                        }
+                        rtmgr.Eps[uuid] = ep
+                }
+        }
 }