Merge pull request #111 from yunkon-kim/241115-02

Staging v0.0.16

Author: yunkon-kim

.gitignore

@@ -53,6 +53,7 @@ secrets/**
 !secrets/template-*
 !secrets/.keep
 !secrets/README.md
+!secrets/load-ncp-cred-env.sh
 
 # Ignore container volumes
 container-volume/

api/docs.go

@@ -925,8 +925,8 @@ const docTemplate = `{
                     }
                 ],
                 "responses": {
-                    "201": {
-                        "description": "Created",
+                    "200": {
+                        "description": "OK",
                         "schema": {
                             "$ref": "#/definitions/model.Response"
                         }

api/swagger.json

@@ -919,8 +919,8 @@
                     }
                 ],
                 "responses": {
-                    "201": {
-                        "description": "Created",
+                    "200": {
+                        "description": "OK",
                         "schema": {
                             "$ref": "#/definitions/model.Response"
                         }

api/swagger.yaml

@@ -897,8 +897,8 @@ paths:
       produces:
       - application/json
       responses:
-        "201":
-          description: Created
+        "200":
+          description: OK
           schema:
             $ref: '#/definitions/model.Response'
         "400":

docker-compose.yaml

@@ -4,7 +4,7 @@ networks:
 
 services:
   mc-terrarium:
-    image: cloudbaristaorg/mc-terrarium:0.0.10
+    image: cloudbaristaorg/mc-terrarium:0.0.16
     container_name: mc-terrarium
     build:
       context: .
@@ -18,6 +18,7 @@ services:
     env_file:
       - ./secrets/credentials           # AWS credentials
       - ./secrets/credential-azure.env  # Azure credentials
+      - ./secrets/credential-ncp.env    # NCP credentials
     volumes:
       - ./secrets:/app/secrets:ro       # GCP credentials
       - ./container-volume/mc-terrarium-container/.terrarium:/app/.terrarium

pkg/api/rest/handler/sql-db.go

@@ -75,7 +75,7 @@ func InitEnvForSqlDb(c echo.Context) error {
 	}
 
 	if !validProvidersForSqlDb[provider] {
-		err := fmt.Errorf("invalid request, provider must be one of [aws, azure, gcp, ncp]")
+		err := fmt.Errorf("invalid request, provider must be one of [aws, azure, gcp, ncpvpc]")
 		log.Warn().Msg(err.Error())
 		res := model.Response{
 			Success: false,
@@ -396,7 +396,7 @@ func CheckInfracodeForSqlDb(c echo.Context) error {
 	// subcommand: plan
 	ret, err := tofu.ExecuteTofuCommand(trId, reqId, "-chdir="+workingDir, "plan")
 	if err != nil {
-		err2 := fmt.Errorf("encountered an issue during the infracode checking process")
+		err2 := fmt.Errorf("returned: %s", ret)
 		log.Error().Err(err).Msg(err2.Error()) // error
 		res := model.Response{
 			Success: false,
@@ -424,7 +424,7 @@ func CheckInfracodeForSqlDb(c echo.Context) error {
 // @Produce  json
 // @Param trId path string true "Terrarium ID" default(tr01)
 // @Param x-request-id header string false "Custom request ID"
-// @Success 201 {object} model.Response "Created"
+// @Success 200 {object} model.Response "OK"
 // @Failure 400 {object} model.Response "Bad Request"
 // @Failure 500 {object} model.Response "Internal Server Error"
 // @Failure 503 {object} model.Response "Service Unavailable"
@@ -469,7 +469,7 @@ func CreateSqlDb(c echo.Context) error {
 
 	// global option to set working dir: -chdir=/home/ubuntu/dev/cloud-barista/mc-terrarium/.terrarium/{trId}/vpn/gcp-aws
 	// subcommand: apply
-	ret, err := tofu.ExecuteTofuCommandAsync(trId, reqId, "-chdir="+workingDir, "apply", "-auto-approve")
+	_, err = tofu.ExecuteTofuCommand(trId, reqId, "-chdir="+workingDir, "apply", "-auto-approve")
 	if err != nil {
 		err2 := fmt.Errorf("failed, previous request in progress")
 		log.Error().Err(err).Msg(err2.Error()) // error
@@ -479,15 +479,39 @@ func CreateSqlDb(c echo.Context) error {
 		}
 		return c.JSON(http.StatusInternalServerError, res)
 	}
+
+	// global option to set working dir: -chdir=/home/ubuntu/dev/cloud-barista/mc-terrarium/.terrarium/{trId}/sql-db
+	// show: subcommand
+	ret, err := tofu.ExecuteTofuCommand(trId, reqId, "-chdir="+workingDir, "output", "-json", "sql_db_info")
+	if err != nil {
+		err2 := fmt.Errorf("failed to read resource info (detail: %s) specified as 'output' in the state file", "refined")
+		log.Error().Err(err).Msg(err2.Error())
+		res := model.Response{
+			Success: false,
+			Message: err2.Error(),
+		}
+		return c.JSON(http.StatusInternalServerError, res)
+	}
+
+	var resourceInfo map[string]interface{}
+	err = json.Unmarshal([]byte(ret), &resourceInfo)
+	if err != nil {
+		log.Error().Err(err).Msg("") // error
+		res := model.Response{
+			Success: false,
+			Message: "failed to unmarshal resource info",
+		}
+		return c.JSON(http.StatusInternalServerError, res)
+	}
+
 	res := model.Response{
 		Success: true,
-		Message: "the request (id: " + reqId + ") is successfully accepted and still deploying resource",
-		Detail:  ret,
+		Message: "refined read resource info (map)",
+		Object:  resourceInfo,
 	}
-
 	log.Debug().Msgf("%+v", res) // debug
 
-	return c.JSON(http.StatusCreated, res)
+	return c.JSON(http.StatusOK, res)
 }
 
 // GetResourceInfoOfSqlDb godoc

pkg/api/rest/model/sql-db.go

@@ -11,8 +11,8 @@ type TfVarsSqlDb struct {
 	DBEnginePort     int    `json:"db_engine_port,omitempty" example:"3306"`
 	IngressCIDRBlock string `json:"ingress_cidr_block,omitempty" example:"0.0.0.0/0"`
 	EgressCIDRBlock  string `json:"egress_cidr_block,omitempty" example:"0.0.0.0/0"`
-	DBEngineVersion  string `json:"db_engine_version" example:"8.0.39"`
-	DBInstanceSpec   string `json:"db_instance_spec" example:"db.t3.micro"`
+	DBEngineVersion  string `json:"db_engine_version,omitempty" example:"8.0.39"`
+	DBInstanceSpec   string `json:"db_instance_spec,omitempty" example:"db.t3.micro"`
 	DBAdminUsername  string `json:"db_admin_username" example:"mydbadmin"`
 	DBAdminPassword  string `json:"db_admin_password" example:"Password1234!"`
 	// DBInstanceID     string `json:"db_instance_identifier" example:"mydbinstance"`

pkg/tofu/tofu.go

@@ -142,7 +142,7 @@ func ExecuteTofuCommand(trId, reqId string, args ...string) (string, error) {
 	if err != nil {
 		log.Error().Msgf("Command execution failed: %v", err)
 		setRunningStatus(trId, "Failed")
-		return "", err
+		return output, err
 	}
 	// log.Debug().Msgf("Command output: %s", output)
 	setRunningStatus(trId, "Success")

secrets/load-ncp-cred-env.sh

@@ -0,0 +1,17 @@
+#!/bin/bash
+
+# Find the script directory
+SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
+ENV_FILE="$SCRIPT_DIR/credential-ncp.env"
+
+# Check if .env file exists
+if [[ -f "$ENV_FILE" ]]; then
+    while IFS= read -r line; do
+        if [[ -n "$line" && ! "$line" =~ ^# ]]; then
+            eval export "$line"
+        fi
+    done < "$ENV_FILE"
+    echo "successfully loaded the NCP credential environment variables"
+else
+    echo "error: dose not exist file, $ENV_FILE"
+fi