X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=icsversion%2Finternal%2Fodusliceassurance%2Fapp.go;h=0504a1302421f8f5dfefad5d0fbe7f9dcc8929e0;hb=361894d226e2e8946a1e57bba2125a14ce84c009;hp=d313192825106d380633dbfec6b85ed85b5b62a3;hpb=16f26ec9bec7e406398340473de228706f75e97f;p=nonrtric%2Frapp%2Fransliceassurance.git

diff --git a/icsversion/internal/odusliceassurance/app.go b/icsversion/internal/odusliceassurance/app.go
index d313192..0504a13 100644
--- a/icsversion/internal/odusliceassurance/app.go
+++ b/icsversion/internal/odusliceassurance/app.go
@@ -43,6 +43,18 @@ const (
 	jobId                   = "14e7bb84-a44d-44c1-90b7-6995a92ad83d"
 )
 
+var jobRegistrationInfo = struct {
+	InfoTypeID    string      `json:"info_type_id"`
+	JobResultURI  string      `json:"job_result_uri"`
+	JobOwner      string      `json:"job_owner"`
+	JobDefinition interface{} `json:"job_definition"`
+}{
+	InfoTypeID:    "Performance_Measurement_Streaming",
+	JobResultURI:  "",
+	JobOwner:      "O-DU Slice Assurance Usecase",
+	JobDefinition: "{}",
+}
+
 type App struct {
 	client *restclient.Client
 	data   *structures.SliceAssuranceMeas
@@ -54,6 +66,7 @@ var sdnrConfig SdnrConfiguration
 
 func (a *App) Initialize(config *config.Configuration) {
 	consumerPort = fmt.Sprint(config.ConsumerPort)
+	jobRegistrationInfo.JobResultURI = config.ConsumerHost + ":" + consumerPort
 
 	sdnrConfig = SdnrConfiguration{
 		SDNRAddress:  config.SDNRAddress,
@@ -112,17 +125,7 @@ func (a *App) statusHandler(w http.ResponseWriter, r *http.Request) {
 
 func (a *App) startHandler(w http.ResponseWriter, r *http.Request) {
 	log.Debug("startHandler: Register job in ICS.")
-	jobRegistrationInfo := struct {
-		InfoTypeID    string      `json:"info_type_id"`
-		JobResultURI  string      `json:"job_result_uri"`
-		JobOwner      string      `json:"job_owner"`
-		JobDefinition interface{} `json:"job_definition"`
-	}{
-		InfoTypeID:    "Performance_Measurement_Streaming",
-		JobResultURI:  "",
-		JobOwner:      "O-DU Slice Assurance Usecase",
-		JobDefinition: "{}",
-	}
+
 	putErr := a.client.Put(icsAddr+"/data-consumer/v1/info-jobs/"+jobId, jobRegistrationInfo, nil)
 	if putErr != nil {
 		http.Error(w, fmt.Sprintf("Unable to register consumer job due to: %v.", putErr), http.StatusBadRequest)