O-DU Slice Assurance App towards latest O-DU implementation

[nonrtric.git] / test / usecases / odusliceassurance / goversion / main.go

diff --git a/test/usecases/odusliceassurance/goversion/main.go b/test/usecases/odusliceassurance/goversion/main.go
index 05b5edf..337e4e0 100644 (file)
--- a/test/usecases/odusliceassurance/goversion/main.go
+++ b/test/usecases/odusliceassurance/goversion/main.go
@@ -22,13 +22,14 @@ package main
 
 import (
        "fmt"
+       "net/http"
 
        log "github.com/sirupsen/logrus"
        "oransc.org/usecase/oduclosedloop/internal/config"
        "oransc.org/usecase/oduclosedloop/internal/sliceassurance"
 )
 
-const TOPIC string = "/events/unauthenticated.PERFORMANCE_MEASUREMENTS"
+const TOPIC string = "/events/unauthenticated.VES_O_RAN_SC_HELLO_WORLD_PM_STREAMING_OUTPUT/myG/C1"
 
 var configuration *config.Config
 
@@ -36,18 +37,21 @@ func main() {
        configuration = config.New()
 
        log.SetLevel(configuration.LogLevel)
-       log.Debug("Using configuration: ", configuration)
+       log.SetFormatter(&log.JSONFormatter{})
 
-       dmaapUrl := configuration.MRHost + ":" + configuration.MRPort
+       log.Debug("Using configuration: ", configuration)
 
        if err := validateConfiguration(configuration); err != nil {
                log.Fatalf("Unable to start consumer due to configuration error: %v", err)
        }
 
        a := sliceassurance.App{}
-       a.Initialize(dmaapUrl, configuration.SDNRAddress)
-       a.Run(TOPIC, configuration.Polltime)
+       a.Initialize(configuration)
+       go a.Run(TOPIC, configuration.Polltime)
+
+       http.HandleFunc("/status", statusHandler)
 
+       log.Fatal(http.ListenAndServe(":40936", nil))
 }
 
 func validateConfiguration(configuration *config.Config) error {
@@ -56,3 +60,7 @@ func validateConfiguration(configuration *config.Config) error {
        }
        return nil
 }
+
+func statusHandler(w http.ResponseWriter, r *http.Request) {
+       // Just respond OK to show the service is alive for now. Might be extended later.
+}