mirror of
https://github.com/silicoflare/envy.git
synced 2026-05-26 11:49:52 +05:30
feat: add env parsing before creating environment
This commit is contained in:
@@ -27,19 +27,19 @@ var createCmd = &cobra.Command{
|
|||||||
// file exists, create environment
|
// file exists, create environment
|
||||||
if err == nil {
|
if err == nil {
|
||||||
envy, err := utils.GetEnvy()
|
envy, err := utils.GetEnvy()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
utils.ErrPrint(err.Error())
|
utils.ErrPrint(err.Error())
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
project := envy.Get("envy.project").(string)
|
project := envy.Get("envy.project").(string)
|
||||||
if project == "" {
|
if project == "" {
|
||||||
utils.ErrPrint("Project name is empty. .envy file might have been modified.")
|
utils.ErrPrint("Project name is empty. .envy file might have been modified.")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
dbProject, err := utils.GetProject(project)
|
dbProject, err := utils.GetProject(project)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
utils.ErrPrint(err.Error())
|
utils.ErrPrint(err.Error())
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@@ -68,7 +68,7 @@ var createCmd = &cobra.Command{
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
env := utils.Environment{Name: environment, ProjectID: dbProject.ID, Data: string(envFile)}
|
env := utils.Environment{Name: environment, ProjectID: dbProject.ID, Data: utils.ParseEnv(string(envFile))}
|
||||||
utils.DB.Create(&env)
|
utils.DB.Create(&env)
|
||||||
|
|
||||||
fmt.Printf("Created environment %s for project %s.\n", environment, project)
|
fmt.Printf("Created environment %s for project %s.\n", environment, project)
|
||||||
@@ -107,7 +107,7 @@ var createCmd = &cobra.Command{
|
|||||||
utils.ErrPrint("Some error occured:", err.Error())
|
utils.ErrPrint("Some error occured:", err.Error())
|
||||||
}
|
}
|
||||||
|
|
||||||
if project == "" || environment == "" {
|
if project == "" || environment == "" {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -122,7 +122,7 @@ var createCmd = &cobra.Command{
|
|||||||
proj := utils.Project{Name: project}
|
proj := utils.Project{Name: project}
|
||||||
utils.DB.Create(&proj)
|
utils.DB.Create(&proj)
|
||||||
|
|
||||||
env := utils.Environment{Name: environment, ProjectID: proj.ID, Data: string(envFile)}
|
env := utils.Environment{Name: environment, ProjectID: proj.ID, Data: utils.ParseEnv(string(envFile))}
|
||||||
utils.DB.Create(&env)
|
utils.DB.Create(&env)
|
||||||
|
|
||||||
filePath := path.Join(cwd, ".envy")
|
filePath := path.Join(cwd, ".envy")
|
||||||
|
|||||||
@@ -2,21 +2,24 @@ package utils
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
"errors"
|
||||||
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
"path"
|
"path"
|
||||||
|
"regexp"
|
||||||
|
"strings"
|
||||||
|
|
||||||
"github.com/pelletier/go-toml"
|
"github.com/pelletier/go-toml"
|
||||||
"gorm.io/gorm"
|
"gorm.io/gorm"
|
||||||
)
|
)
|
||||||
|
|
||||||
func StopIfErr(err error) {
|
func StopIfErr(err error) {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
ErrPrint(err.Error())
|
ErrPrint(err.Error())
|
||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func GetEnvy() (*toml.Tree, error) {
|
func GetEnvy() (*toml.Tree, error) {
|
||||||
cwd, err := os.Getwd()
|
cwd, err := os.Getwd()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, errors.New("Not able to fetch working directory: " + err.Error())
|
return nil, errors.New("Not able to fetch working directory: " + err.Error())
|
||||||
@@ -27,63 +30,87 @@ func GetEnvy() (*toml.Tree, error) {
|
|||||||
// file exists
|
// file exists
|
||||||
if err == nil {
|
if err == nil {
|
||||||
envyFile, err := toml.LoadFile(path.Join(cwd, ".envy"))
|
envyFile, err := toml.LoadFile(path.Join(cwd, ".envy"))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, errors.New("Error occured while reading .envy file:" + err.Error())
|
return nil, errors.New("Error occured while reading .envy file:" + err.Error())
|
||||||
}
|
}
|
||||||
return envyFile, nil
|
return envyFile, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// file does not exist
|
// file does not exist
|
||||||
if os.IsNotExist(err) {
|
if os.IsNotExist(err) {
|
||||||
return nil, errors.New(".envy file doesn't exist in the current directory.")
|
return nil, errors.New(".envy file doesn't exist in the current directory")
|
||||||
} else {
|
} else {
|
||||||
return nil, errors.New("Some error occured:" + err.Error())
|
return nil, errors.New("Some error occured:" + err.Error())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func GetProject(name string) (Project, error) {
|
||||||
func GetProject(name string) (Project, error) {
|
|
||||||
InitDb()
|
InitDb()
|
||||||
|
|
||||||
var dbProject Project
|
var dbProject Project
|
||||||
result := DB.Where("name = ?", name).First(&dbProject)
|
result := DB.Where("name = ?", name).First(&dbProject)
|
||||||
|
|
||||||
if result.Error != nil {
|
if result.Error != nil {
|
||||||
if errors.Is(result.Error, gorm.ErrRecordNotFound) {
|
if errors.Is(result.Error, gorm.ErrRecordNotFound) {
|
||||||
return Project{}, errors.New("Project with the name " + name + " not found in the database.")
|
return Project{}, errors.New("Project with the name " + name + " not found in the database")
|
||||||
} else {
|
} else {
|
||||||
return Project{}, errors.New("Some error occured: " + result.Error.Error())
|
return Project{}, errors.New("Some error occured: " + result.Error.Error())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return dbProject, nil
|
return dbProject, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func GetEnvironments(project uint) ([]Environment, error) {
|
||||||
func GetEnvironments(project uint) ([]Environment, error) {
|
|
||||||
InitDb()
|
InitDb()
|
||||||
|
|
||||||
var dbEnvs []Environment
|
var dbEnvs []Environment
|
||||||
result := DB.Where("project_id = ?", project).Find(&dbEnvs)
|
result := DB.Where("project_id = ?", project).Find(&dbEnvs)
|
||||||
|
|
||||||
if result.Error != nil {
|
if result.Error != nil {
|
||||||
return nil, errors.New("Some error occured: " + result.Error.Error())
|
return nil, errors.New("Some error occured: " + result.Error.Error())
|
||||||
}
|
}
|
||||||
return dbEnvs, nil
|
return dbEnvs, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func GetEnvironment(project uint, environment string) (Environment, error) {
|
||||||
func GetEnvironment(project uint, environment string) (Environment, error) {
|
|
||||||
InitDb()
|
InitDb()
|
||||||
|
|
||||||
var dbEnv Environment
|
var dbEnv Environment
|
||||||
result := DB.Where("project_id = ? AND name = ?", project, environment).First(&dbEnv)
|
result := DB.Where("project_id = ? AND name = ?", project, environment).First(&dbEnv)
|
||||||
|
|
||||||
if result.Error != nil {
|
if result.Error != nil {
|
||||||
if errors.Is(result.Error, gorm.ErrRecordNotFound) {
|
if errors.Is(result.Error, gorm.ErrRecordNotFound) {
|
||||||
return Environment{}, errors.New("Environment with the name " + environment + " not found in the database.")
|
return Environment{}, errors.New("Environment with the name " + environment + " not found in the database")
|
||||||
} else {
|
} else {
|
||||||
return Environment{}, errors.New("Some error occured: " + result.Error.Error())
|
return Environment{}, errors.New("Some error occured: " + result.Error.Error())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return dbEnv, nil
|
return dbEnv, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func ParseEnv(env string) string {
|
||||||
|
re := regexp.MustCompile(`^\s*(#?)\s*([A-Z0-9_]+)\s*=\s*(?:"([^"\n]+)"|([^"\n]+))$`)
|
||||||
|
|
||||||
|
var envs string
|
||||||
|
|
||||||
|
for _, line := range strings.Split(string(env), "\n") {
|
||||||
|
matches := re.FindStringSubmatch(line)
|
||||||
|
var key, value string
|
||||||
|
var enabled bool
|
||||||
|
if matches != nil {
|
||||||
|
enabled = matches[1] == ""
|
||||||
|
key = matches[2] // the key
|
||||||
|
value = matches[3] // quoted value
|
||||||
|
if value == "" {
|
||||||
|
value = matches[4] // unquoted value
|
||||||
|
}
|
||||||
|
var comment = ""
|
||||||
|
if enabled {
|
||||||
|
comment = "# "
|
||||||
|
}
|
||||||
|
envs += fmt.Sprintf("%v%v=%v\n", comment, key, value)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return envs
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user