X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=examples%2Fcmd%2Fexample-xapp.go;h=acb0b8d91448b1f88b2ced58892732d6b1d3744b;hb=c1f00b7d54ecd16ede9687b8cdb1d6517180e7c9;hp=8fe78738046ebfdd5bd5beb7fd9e2cfea3811803;hpb=bf6780bc2a998042027174a760fc12b8af9db3c1;p=ric-plt%2Fxapp-frame.git

diff --git a/examples/cmd/example-xapp.go b/examples/cmd/example-xapp.go
index 8fe7873..acb0b8d 100755
--- a/examples/cmd/example-xapp.go
+++ b/examples/cmd/example-xapp.go
@@ -14,21 +14,28 @@
    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).
 ==================================================================================
 */
 package main
 
 import (
+	"gerrit.o-ran-sc.org/r/ric-plt/alarm-go.git/alarm"
+	"gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/clientmodel"
 	"gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
 	"net/http"
 )
 
 // This could be defined in types.go
 type ExampleXapp struct {
-	msgChan    chan *xapp.RMRParams
-	stats      map[string]xapp.Counter
-	rmrReady   bool
-	waitForSdl bool
+	msgChan               chan *xapp.RMRParams
+	stats                 map[string]xapp.Counter
+	rmrReady              bool
+	waitForSdl            bool
+	subscriptionInstances []*clientmodel.SubscriptionInstance
+	subscriptionId        *string
 }
 
 func (e *ExampleXapp) handleRICIndication(ranName string, r *xapp.RMRParams) {
@@ -67,6 +74,47 @@ func (e *ExampleXapp) messageLoop() {
 	}
 }
 
+func (e *ExampleXapp) Subscribe() {
+	// Setup response callback to handle subscription response from SubMgr
+	xapp.Subscription.SetResponseCB(func(resp *clientmodel.SubscriptionResponse) {
+		if *e.subscriptionId == *resp.SubscriptionID {
+			for _, s := range resp.SubscriptionInstances {
+				e.subscriptionInstances = append(e.subscriptionInstances, s)
+			}
+		}
+	})
+
+	// Fill subscription parameters: type=REPORT
+	ranName := "en-gnb:369-11105-aaaaa8"
+	functionId := int64(1)
+	clientEndpoint := "localhost:4560"
+
+	reportParams := clientmodel.ReportParams{
+		Meid:           ranName,
+		RANFunctionID:  &functionId,
+		ClientEndpoint: &clientEndpoint,
+		EventTriggers: clientmodel.EventTriggerList{
+			&clientmodel.EventTrigger{
+				InterfaceDirection: int64(0),
+				ProcedureCode:      int64(27),
+				TypeOfMessage:      int64(1),
+			},
+		},
+	}
+
+	// Now subscribe ...
+	if resp, err := xapp.Subscription.SubscribeReport(&reportParams); err == nil {
+		e.subscriptionId = resp.SubscriptionID
+		xapp.Logger.Info("Subscriptions for RanName='%s' [subscriptionId=%s] done!", ranName, *resp.SubscriptionID)
+		return
+	}
+
+	// Subscription failed, raise alarm (only for demo purpose!)
+	if err := xapp.Alarm.Raise(8006, alarm.SeverityCritical, ranName, "subscriptionFailed"); err != nil {
+		xapp.Logger.Info("Raising alarm failed with error: %v", err)
+	}
+}
+
 func (e *ExampleXapp) Consume(rp *xapp.RMRParams) (err error) {
 	e.msgChan <- rp
 	return
@@ -87,7 +135,7 @@ func (u *ExampleXapp) StatusCB() bool {
 
 func (e *ExampleXapp) Run() {
 	// Set MDC (read: name visible in the logs)
-	xapp.Logger.SetMdc("example-xapp", "0.1.2")
+	xapp.Logger.SetMdc("example-xapp", "0.1.3")
 
 	// Register various callback functions for application management
 	xapp.SetReadyCB(func(d interface{}) { e.rmrReady = true }, true)