pkg/resthooks/resthooks.go

   1 //==================================================================================
   2 //  Copyright (c) 2022 Samsung
   3 //
   4 //   Licensed under the Apache License, Version 2.0 (the "License");
   5 //   you may not use this file except in compliance with the License.
   6 //   You may obtain a copy of the License at
   7 //
   8 //       http://www.apache.org/licenses/LICENSE-2.0
   9 //
  10 //   Unless required by applicable law or agreed to in writing, software
  11 //   distributed under the License is distributed on an "AS IS" BASIS,
  12 //   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13 //   See the License for the specific language governing permissions and
  14 //   limitations under the License.
  15 //
  16 //   This source code is part of the near-RT RIC (RAN Intelligent Controller)
  17 //   platform project (RICP).
  18 //==================================================================================
  19 //
  20
  21 package resthooks
  22
  23 import (
  24         ch "gerrit.o-ran-sc.org/r/ric-plt/ricdms/pkg/charts"
  25         "gerrit.o-ran-sc.org/r/ric-plt/ricdms/pkg/deploy"
  26         ph "gerrit.o-ran-sc.org/r/ric-plt/ricdms/pkg/health"
  27         "gerrit.o-ran-sc.org/r/ric-plt/ricdms/pkg/models"
  28         "gerrit.o-ran-sc.org/r/ric-plt/ricdms/pkg/onboard"
  29         "gerrit.o-ran-sc.org/r/ric-plt/ricdms/pkg/restapi/operations/charts"
  30         dp "gerrit.o-ran-sc.org/r/ric-plt/ricdms/pkg/restapi/operations/deploy"
  31         "gerrit.o-ran-sc.org/r/ric-plt/ricdms/pkg/restapi/operations/health"
  32         "gerrit.o-ran-sc.org/r/ric-plt/ricdms/pkg/ricdms"
  33         "github.com/go-openapi/runtime/middleware"
  34 )
  35
  36 func NewResthook(h ph.IHealthChecker, o onboard.IOnboarder, chMgr ch.IChartMgr, depMgr deploy.IDeploy) *Resthook {
  37         return &Resthook{
  38                 HealthChecker: h,
  39                 Onboarder:     o,
  40                 ChartMgr:      chMgr,
  41                 DeployMgr:     depMgr,
  42         }
  43 }
  44
  45 func (rh *Resthook) GetDMSHealth() (resp middleware.Responder) {
  46         ricdms.Logger.Debug("healthchecker : %v\n", rh.HealthChecker)
  47         return health.NewGetHealthCheckOK().WithPayload(rh.HealthChecker.GetStatus())
  48 }
  49
  50 func (rh *Resthook) OnBoard(params *models.Descriptor) (resp middleware.Responder) {
  51         ricdms.Logger.Debug("onboarder: invoked")
  52         return rh.Onboarder.Onboard(params)
  53 }
  54
  55 func (rh *Resthook) GetCharts() (resp middleware.Responder) {
  56         ricdms.Logger.Debug("getcharts: invoked")
  57         chartList, err := rh.ChartMgr.GetCharts()
  58
  59         if err != nil {
  60                 return charts.NewGetChartsListInternalServerError()
  61         }
  62         return charts.NewGetChartsListOK().WithPayload(chartList)
  63 }
  64
  65 func (rh *Resthook) DownloadChart(chartname, version string) (resp middleware.Responder) {
  66         ricdms.Logger.Debug("DownloadCharts: invoked")
  67         reader, err := rh.ChartMgr.DownloadChart(chartname, version)
  68
  69         if err != nil {
  70                 ricdms.Logger.Error("Error : %v", err)
  71                 return charts.NewDownloadHelmChartInternalServerError()
  72         }
  73
  74         return charts.NewDownloadHelmChartOK().WithPayload(reader)
  75 }
  76
  77 func (rh *Resthook) GetChartsByName(name string) middleware.Responder {
  78         ricdms.Logger.Debug("GetChartByName: invoked")
  79         res, err := rh.ChartMgr.GetChartsByName(name)
  80
  81         if err != nil {
  82                 ricdms.Logger.Error("error: %v", err)
  83                 return charts.NewGetChartInternalServerError()
  84         }
  85
  86         response := make([]interface{}, 0)
  87         for _, item := range res {
  88                 response = append(response, item)
  89         }
  90
  91         return charts.NewGetChartOK().WithPayload(response)
  92 }
  93
  94 func (rh *Resthook) GetChartByNameAndVersion(name, version string) middleware.Responder {
  95         ricdms.Logger.Debug("GetChartByNameAndVersion is invoked")
  96         resp, err := rh.ChartMgr.GetChartsByNameAndVersion(name, version)
  97
  98         if err != nil {
  99                 return charts.NewGetChartsFetcherInternalServerError()
 100         }
 101
 102         return charts.NewGetChartsFetcherOK().WithPayload(resp)
 103 }
 104
 105 func (rh *Resthook) DownloadAndInstallChart(appname, version, namespace string) middleware.Responder {
 106         ricdms.Logger.Debug("DownloadAndInstall Chart is invoked")
 107         reader, err := rh.ChartMgr.DownloadChart(appname, version)
 108
 109         if err != nil {
 110                 ricdms.Logger.Error("error in downloading the chart : %v", err)
 111                 return dp.NewPostDeployInternalServerError()
 112         }
 113
 114         err = rh.DeployMgr.Deploy(reader, appname, version, namespace)
 115         if err != nil {
 116                 return dp.NewPostDeployInternalServerError()
 117         }
 118         return dp.NewPostDeployCreated()
 119 }
 120
 121 func (rh *Resthook) UninstallChart(appname, version, namespace string) middleware.Responder {
 122         ricdms.Logger.Debug("Uninstall chart is invoked")
 123         err := rh.DeployMgr.Uninstall(appname, version, namespace)
 124         if err != nil {
 125                 ricdms.Logger.Error("Uninstall failed: %v", err)
 126                 return dp.NewDeleteDeployInternalServerError()
 127         }
 128
 129         return dp.NewDeleteDeployCreated()
 130 }