-func (s *Sbi) createEndpoint(payload string,rmrsrc string, sbi Engine) (*string,int) {
- xapp.Logger.Debug("CreateEndPoint %v", payload)
-// stringSlice := strings.Split(payload, " ")
-// uuid := stringSlice[0]
-// xapp.Logger.Debug(">>> uuid %v", stringSlice[0])
-
-/* if _, ok := rtmgr.Eps[uuid]; ok {
- ep := rtmgr.Eps[uuid]
- return ep
- }*/
+func (s *Sbi) checkEndpoint(payload string) *rtmgr.Endpoint {
+ /* Payload contains endpoint in the form of IP<domain name>:Port.
+ Port is data port of sender endpoint.
+ Eps contains the UUID in the form of IP<domain name>:Port.
+ Port is the Application Port(http) */
+
+ xapp.Logger.Debug("Invoked checkEndPoint %v", payload)
+ stringSlice := strings.Split(payload, " ")
+ uuid := stringSlice[0]
+ stringsubsplit := strings.Split(uuid, ":")
+ xapp.Logger.Debug(">>> uuid %v", stringSlice[0])
+ for _, ep := range rtmgr.Eps {
+ if strings.Contains(ep.Uuid, stringsubsplit[0]) == true {
+ endpoint := rtmgr.Eps[ep.Uuid]
+ return endpoint
+ }
+ }