From 468e208fbe3bcf2524d3aa8ceaabc4324f242b4b Mon Sep 17 00:00:00 2001 From: Victor Morales Date: Fri, 25 Jan 2019 16:57:58 -0800 Subject: Move api.go functions CheckEnvVariables, CheckDatabaseConnection, LoadPlugins and CheckInitialSettings functions are utility functions which are not related with the API. These functions need to be moved to utils.go file. Change-Id: Ie6dfbafe8909962fba31534916a7e0f07ded116b Signed-off-by: Victor Morales Issue-ID: MULTICLOUD-301 --- src/k8splugin/api/api.go | 77 ------------------------------------------------ 1 file changed, 77 deletions(-) (limited to 'src/k8splugin/api') diff --git a/src/k8splugin/api/api.go b/src/k8splugin/api/api.go index f022614e..b566609b 100644 --- a/src/k8splugin/api/api.go +++ b/src/k8splugin/api/api.go @@ -15,87 +15,10 @@ package api import ( "k8splugin/internal/rb" - "os" - "path/filepath" - "plugin" - "strings" "github.com/gorilla/mux" - pkgerrors "github.com/pkg/errors" - - krd "k8splugin/internal" - "k8splugin/internal/db" ) -// CheckEnvVariables checks for required Environment variables -func CheckEnvVariables() error { - envList := []string{"CSAR_DIR", "KUBE_CONFIG_DIR", "PLUGINS_DIR", - "DATABASE_TYPE", "DATABASE_IP", "OVN_CENTRAL_ADDRESS"} - for _, env := range envList { - if _, ok := os.LookupEnv(env); !ok { - return pkgerrors.New("environment variable " + env + " not set") - } - } - - return nil -} - -// CheckDatabaseConnection checks if the database is up and running and -// plugin can talk to it -func CheckDatabaseConnection() error { - err := db.CreateDBClient(os.Getenv("DATABASE_TYPE")) - if err != nil { - return pkgerrors.Cause(err) - } - - err = db.DBconn.HealthCheck() - if err != nil { - return pkgerrors.Cause(err) - } - return nil -} - -// LoadPlugins loads all the compiled .so plugins -func LoadPlugins() error { - pluginsDir := os.Getenv("PLUGINS_DIR") - err := filepath.Walk(pluginsDir, - func(path string, info os.FileInfo, err error) error { - if strings.Contains(path, ".so") { - p, err := plugin.Open(path) - if err != nil { - return pkgerrors.Cause(err) - } - krd.LoadedPlugins[info.Name()[:len(info.Name())-3]] = p - } - return err - }) - if err != nil { - return err - } - - return nil -} - -// CheckInitialSettings is used to check initial settings required to start api -func CheckInitialSettings() error { - err := CheckEnvVariables() - if err != nil { - return pkgerrors.Cause(err) - } - - err = CheckDatabaseConnection() - if err != nil { - return pkgerrors.Cause(err) - } - - err = LoadPlugins() - if err != nil { - return pkgerrors.Cause(err) - } - - return nil -} - // NewRouter creates a router instance that serves the VNFInstance web methods func NewRouter(kubeconfig string) *mux.Router { router := mux.NewRouter() -- cgit 1.2.3-korg