X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Frestapi.go;h=00f8aba55617dcaf427a8b7727820a2b61930a10;hb=19abb43e9f9a21c0349b38c04d35a447a1dabeaf;hp=922e42d5fd26dd7e117c16d736e034d37ac416d3;hpb=5bd7273045e37ac20a0d79c03e9e9a24415b2b67;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/xapp/restapi.go b/pkg/xapp/restapi.go index 922e42d..00f8aba 100755 --- a/pkg/xapp/restapi.go +++ b/pkg/xapp/restapi.go @@ -21,13 +21,28 @@ package xapp import ( "encoding/json" - "github.com/gorilla/mux" + "fmt" + "io/ioutil" "net/http" + "os" + "path" + "strings" + + "github.com/gorilla/mux" + "github.com/spf13/viper" + + "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/models" ) const ( - ReadyURL = "/ric/v1/health/ready" - AliveURL = "/ric/v1/health/alive" + ReadyURL = "/ric/v1/health/ready" + AliveURL = "/ric/v1/health/alive" + ConfigURL = "/ric/v1/cm/{name}" + AppConfigURL = "/ric/v1/config" +) + +var ( + healthReady bool ) type StatusCb func() bool @@ -46,13 +61,15 @@ func NewRouter() *Router { // Inject default routes for health probes r.InjectRoute(ReadyURL, readyHandler, "GET") r.InjectRoute(AliveURL, aliveHandler, "GET") + r.InjectRoute(ConfigURL, configHandler, "POST") + r.InjectRoute(AppConfigURL, appconfigHandler, "GET") return r } func (r *Router) serviceChecker(inner http.HandlerFunc) http.HandlerFunc { return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { - Logger.Info("restapi: method=%s url=%s", req.Method, req.URL.RequestURI()) + Logger.Debug("restapi: method=%s url=%s", req.Method, req.URL.RequestURI()) if req.URL.RequestURI() == AliveURL || r.CheckStatus() { inner.ServeHTTP(w, req) } else { @@ -88,7 +105,130 @@ func (r *Router) CheckStatus() (status bool) { return } +func (r *Router) GetSymptomDataParams(w http.ResponseWriter, req *http.Request) SymptomDataParams { + params := SymptomDataParams{} + queryParams := req.URL.Query() + + Logger.Info("GetSymptomDataParams: %+v", queryParams) + + for p := range queryParams { + if p == "timeout" { + fmt.Sscanf(p, "%d", ¶ms.Timeout) + } + if p == "fromtime" { + fmt.Sscanf(p, "%d", ¶ms.FromTime) + } + if p == "totime" { + fmt.Sscanf(p, "%d", ¶ms.ToTime) + } + } + return params +} + +func (r *Router) CollectDefaultSymptomData(fileName string, data interface{}) string { + baseDir := Config.GetString("controls.symptomdata.baseDir") + if baseDir == "" { + baseDir = "/tmp/xapp/" + } + + if err := Util.CreateDir(baseDir); err != nil { + Logger.Error("CreateDir failed: %v", err) + return "" + } + + // + if metrics, err := r.GetLocalMetrics(GetPortData("http").Port); err == nil { + if err := Util.WriteToFile(baseDir+"metrics.json", metrics); err != nil { + Logger.Error("writeToFile failed for metrics.json: %v", err) + } + } + + // + if data != nil { + if b, err := json.MarshalIndent(data, "", " "); err == nil { + Util.WriteToFile(baseDir+fileName, string(b)) + } + } + + // + cfile := viper.ConfigFileUsed() + input, err := ioutil.ReadFile(cfile) + if err == nil { + Util.WriteToFile(baseDir+path.Base(cfile), string(input)) + } else { + Logger.Error("ioutil.ReadFile failed: %v", err) + } + + // + Util.WriteToFile(baseDir+"environment", strings.Join(os.Environ(), "\n")) + + // + rtPath := os.Getenv("RMR_STASH_RT") + if rtPath != "" { + input, err = ioutil.ReadFile(rtPath) + if err == nil { + Util.WriteToFile(baseDir+"rttable.txt", string(input)) + } else { + Logger.Error("ioutil.ReadFile failed: %v", err) + } + } + + return baseDir +} + +func (r *Router) SendSymptomDataJson(w http.ResponseWriter, req *http.Request, data interface{}, n string) { + w.Header().Set("Content-Type", "application/json") + w.Header().Set("Content-Disposition", "attachment; filename="+n) + w.WriteHeader(http.StatusOK) + if data != nil { + response, _ := json.MarshalIndent(data, "", " ") + w.Write(response) + } +} + +func (r *Router) SendSymptomDataFile(w http.ResponseWriter, req *http.Request, baseDir, zipFile string) { + + var fileList []string + fileList = Util.FetchFiles(baseDir, fileList) + tmpFileName, err := Util.ZipFilesToTmpFile(baseDir, "symptom", fileList) + if err != nil { + r.SendSymptomDataError(w, req, err.Error()) + return + } + defer os.Remove(tmpFileName) + + w.Header().Set("Content-Disposition", "attachment; filename="+zipFile) + http.ServeFile(w, req, tmpFileName) +} + +func (r *Router) SendSymptomDataError(w http.ResponseWriter, req *http.Request, message string) { + w.Header().Set("Content-Disposition", "attachment; filename=error_status.txt") + http.Error(w, message, http.StatusInternalServerError) +} + +func (r *Router) GetLocalMetrics(port int) (string, error) { + resp, err := http.Get(fmt.Sprintf("http://localhost:%d/ric/v1/metrics", port)) + if err != nil { + Logger.Error("GetLocalMetrics: http.Get failed: %v", err) + return "", err + } + defer resp.Body.Close() + + metrics, err := ioutil.ReadAll(resp.Body) + if err != nil { + Logger.Error("GetLocalMetrics: ioutil.ReadAll failed: %v", err) + return "", err + } + + return string(metrics), nil +} + +func IsHealthProbeReady() bool { + return healthReady +} + func readyHandler(w http.ResponseWriter, r *http.Request) { + healthReady = true respondWithJSON(w, http.StatusOK, nil) } @@ -96,6 +236,29 @@ func aliveHandler(w http.ResponseWriter, r *http.Request) { respondWithJSON(w, http.StatusOK, nil) } +func configHandler(w http.ResponseWriter, r *http.Request) { + xappName := mux.Vars(r)["name"] + if xappName == "" || r.Body == nil { + respondWithJSON(w, http.StatusBadRequest, nil) + return + } + defer r.Body.Close() + + body, err := ioutil.ReadAll(r.Body) + if err != nil { + Logger.Error("ioutil.ReadAll failed: %v", err) + respondWithJSON(w, http.StatusInternalServerError, nil) + return + } + + if err := PublishConfigChange(xappName, string(body)); err != nil { + respondWithJSON(w, http.StatusInternalServerError, nil) + return + } + + respondWithJSON(w, http.StatusOK, nil) +} + func respondWithJSON(w http.ResponseWriter, code int, payload interface{}) { w.Header().Set("Content-Type", "application/json") w.WriteHeader(code) @@ -104,3 +267,36 @@ func respondWithJSON(w http.ResponseWriter, code int, payload interface{}) { w.Write(response) } } + +func appconfigHandler(w http.ResponseWriter, r *http.Request) { + + Logger.Info("Inside appconfigHandler") + + var appconfig models.XappConfigList + var metadata models.ConfigMetadata + var xappconfig models.XAppConfig + name := viper.GetString("name") + configtype := "json" + metadata.XappName = &name + metadata.ConfigType = &configtype + + configFile, err := os.Open("/opt/ric/config/config-file.json") + if err != nil { + Logger.Error("Cannot open config file: %v", err) + respondWithJSON(w, http.StatusInternalServerError, nil) + // return nil,errors.New("Could Not parse the config file") + } + + body, err := ioutil.ReadAll(configFile) + + defer configFile.Close() + + xappconfig.Metadata = &metadata + xappconfig.Config = string(body) + + appconfig = append(appconfig, &xappconfig) + + respondWithJSON(w, http.StatusOK, appconfig) + + //return appconfig,nil +}