1 Commits

Author SHA1 Message Date
b9948c3a41 fix: grammar error 2025-02-16 22:28:50 +07:00
7 changed files with 75 additions and 211 deletions

View File

@@ -1,13 +0,0 @@
# Crudgen
> Generate crud's at speed of thought
## Install
```shell
go install git.gogacoder.ru/NTO/crudgen/cmd/crudgen@v1.0.16
```
## Run
Specify path to internal directory
```shell
crudgen -p internal
```

View File

@@ -4,66 +4,30 @@ import (
"flag"
"git.gogacoder.ru/NTO/crudgen/internal"
"log"
"os/exec"
"path/filepath"
"strings"
)
func ImplementServices(mainPkgDir string, reimplement bool) (modified bool) {
func ImplementServices(mainPkgDir string, reimplement bool) {
modelsNames, err := internal.GetStructNames(filepath.Join(mainPkgDir, "models"))
if err != nil {
log.Printf("Error: %s\n", err)
return
}
var wasModified bool
log.Printf("Found models: %v\n", modelsNames)
for _, modelName := range modelsNames {
codeModified, err := internal.ImplementService(mainPkgDir, modelName, reimplement)
if codeModified {
wasModified = true
}
err := internal.ImplementService(mainPkgDir, modelName, reimplement)
if err != nil {
log.Printf("Error implement service for model %s: %s\n", modelName, err)
}
}
return wasModified
}
func runPostHook(postHook *string, wasModified bool) {
if wasModified && postHook != nil && *postHook != "" {
log.Printf("Running post hook %s\n", *postHook)
args := strings.Fields(*postHook)
var cmd *exec.Cmd
if len(args) == 0 {
log.Printf("Empty post hook %s\n", *postHook)
return
}
if len(args) == 1 {
cmd = exec.Command(args[0])
} else {
cmd = exec.Command(args[0], args[1:]...)
}
output, err := cmd.CombinedOutput()
if err != nil {
log.Fatalf("Error running post hook for %s: %s\n", *postHook, err)
} else {
log.Printf("Post hook output: %s\n", string(output))
}
}
}
func main() {
log.SetFlags(0)
projectPath := flag.String("p", ".", "project path")
reimplement := flag.Bool("f", false, "pass -f to allow tool to overwrite exist functions and service structure")
postHook := flag.String("h", "", "post hook to run command after code modifications")
reimplement := flag.Bool("f", false, "pass -f to allow tool to overwrite existing functions and service structure")
flag.Parse()
wasModified := ImplementServices(*projectPath, *reimplement)
runPostHook(postHook, wasModified)
ImplementServices(*projectPath, *reimplement)
}

11
go.mod
View File

@@ -1,13 +1,12 @@
module git.gogacoder.ru/NTO/crudgen
go 1.23.0
toolchain go1.24.1
go 1.22.12
require github.com/dave/dst v0.27.3
require (
golang.org/x/mod v0.24.0 // indirect
golang.org/x/sync v0.12.0 // indirect
golang.org/x/tools v0.31.0 // indirect
golang.org/x/mod v0.23.0 // indirect
golang.org/x/sync v0.11.0 // indirect
golang.org/x/sys v0.12.0 // indirect
golang.org/x/tools v0.13.0 // indirect
)

16
go.sum
View File

@@ -6,9 +6,13 @@ github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
github.com/sergi/go-diff v1.2.0 h1:XU+rvMAioB0UC3q1MFrIQy4Vo5/4VsRDQQXHsEya6xQ=
github.com/sergi/go-diff v1.2.0/go.mod h1:STckp+ISIX8hZLjrqAeVduY0gWCT9IjLuqbuNXdaHfM=
golang.org/x/mod v0.24.0 h1:ZfthKaKaT4NrhGVZHO1/WDTwGES4De8KtWO0SIbNJMU=
golang.org/x/mod v0.24.0/go.mod h1:IXM97Txy2VM4PJ3gI61r1YEk/gAj6zAHN3AdZt6S9Ww=
golang.org/x/sync v0.12.0 h1:MHc5BpPuC30uJk597Ri8TV3CNZcTLu6B6z4lJy+g6Jw=
golang.org/x/sync v0.12.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
golang.org/x/tools v0.31.0 h1:0EedkvKDbh+qistFTd0Bcwe/YLh4vHwWEkiI0toFIBU=
golang.org/x/tools v0.31.0/go.mod h1:naFTU+Cev749tSJRXJlna0T3WxKvb1kWEx15xA4SdmQ=
golang.org/x/mod v0.23.0 h1:Zb7khfcRGKk+kqfxFaP5tZqCnDZMjC5VtUBs87Hr6QM=
golang.org/x/mod v0.23.0/go.mod h1:6SkKJ3Xj0I0BrPOZoBy3bdMptDDU9oJrpohJ3eWZ1fY=
golang.org/x/sync v0.11.0 h1:GGz8+XQP4FvTTrjZPzNKTMFtSXH80RAzG+5ghFPgK9w=
golang.org/x/sync v0.11.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
golang.org/x/sys v0.12.0 h1:CM0HF96J0hcLAwsHPJZjfdNzs0gftsLfgKt57wWHJ0o=
golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/tools v0.13.0 h1:Iey4qkscZuv0VvIt8E0neZjtPVQFSc870HQ448QgEmQ=
golang.org/x/tools v0.13.0/go.mod h1:HvlwmtVNQAhOuCjW7xxvovg8wbNq7LwfXh/k7wXUl58=
golang.org/x/tools v0.30.0 h1:BgcpHewrV5AUp2G9MebG4XPFI1E2W41zU1SaqVA9vJY=
golang.org/x/tools v0.30.0/go.mod h1:c347cR/OJfw5TI+GfX7RUPNMdDRRbjvYTS0jPyvsVtY=

View File

@@ -1,12 +1,7 @@
package internal
const CreateRawTemplate = `func (service *{{.ServiceName}}) Create(item {{.EntityType}}) ({{.EntityType}}, error) {
utils.ReplaceEmptySlicesWithNil(&item)
err := dal.{{.EntityType}}.Create(&item)
if err != nil {
return item, err
}
err = utils.AppendAssociations(database.GetInstance(), &item)
err := dal.{{.EntityType}}.Preload(field.Associations).Create(&item)
return item, err
}`
@@ -29,38 +24,16 @@ const GetByIdRawTemplate = `func (service *{{.ServiceName}}) GetById(id uint) (*
}`
const UpdateRawTemplate = `func (service *{{.ServiceName}}) Update(item {{.EntityType}}) ({{.EntityType}}, error) {
utils.ReplaceEmptySlicesWithNil(&item)
_, err := dal.{{.EntityType}}.Updates(&item)
if err != nil {
return item, err
}
err = utils.UpdateAssociations(database.GetInstance(), &item)
if err != nil {
return item, err
}
err := dal.{{.EntityType}}.Preload(field.Associations).Save(&item)
return item, err
}`
const DeleteRawTemplate = `func (service *{{.ServiceName}}) Delete(id uint) error {
_, err := dal.{{.EntityType}}.Unscoped().Where(dal.{{.EntityType}}.Id.Eq(id)).Delete()
return err
const DeleteRawTemplate = `func (service *{{.ServiceName}}) Delete(item {{.EntityType}}) ({{.EntityType}}, error) {
_, err := dal.{{.EntityType}}.Unscoped().Preload(field.Associations).Delete(&item)
return item, err
}`
const CountRawTemplate = `func (service *{{.ServiceName}}) Count() (int64, error) {
amount, err := dal.{{.EntityType}}.Count()
return amount, err
}`
const SortedByOrderTemplate = `func (service *{{.ServiceName}}) SortedByOrder(fieldsSortingOrder []utils.SortField) ([]*{{.EntityType}}, error) {
return utils.SortByOrder(fieldsSortingOrder, {{.EntityType}}{})
}`
const SearchByAllStringFields = `func (service *{{.ServiceName}}) SearchByAllTextFields(phrase string) ([]*{{.EntityType}}, error) {
return utils.FindPhraseByStringFields[{{.EntityType}}](phrase, {{.EntityType}}{})
}`
var implementedMethods = []string{CreateMethod, GetAllMethod, GetByIdMethod, UpdateMethod, DeleteMethod, CountMethod, SortedByOrderMethod, SearchByAllStringFields}

View File

@@ -8,9 +8,7 @@ type CrudTemplatesContext struct {
var ServiceImports = []string{
"app/internal/dal",
"app/internal/database",
"app/internal/models",
"app/internal/utils",
"errors",
"gorm.io/gen/field",
"gorm.io/gorm",
@@ -22,15 +20,12 @@ const GetByIdMethod = "GetById"
const UpdateMethod = "Update"
const DeleteMethod = "Delete"
const CountMethod = "Count"
const SortedByOrderMethod = "SortedByOrder"
var RawTemplates = map[string]string{
CreateMethod: CreateRawTemplate,
GetAllMethod: GetAllRawTemplate,
GetByIdMethod: GetByIdRawTemplate,
UpdateMethod: UpdateRawTemplate,
DeleteMethod: DeleteRawTemplate,
CountMethod: CountRawTemplate,
SortedByOrderMethod: SortedByOrderTemplate,
SearchByAllStringFields: SearchByAllStringFields,
CreateMethod: CreateRawTemplate,
GetAllMethod: GetAllRawTemplate,
GetByIdMethod: GetByIdRawTemplate,
UpdateMethod: UpdateRawTemplate,
DeleteMethod: DeleteRawTemplate,
CountMethod: CountRawTemplate,
}

View File

@@ -16,13 +16,11 @@ import (
"github.com/dave/dst/decorator"
)
func ImplementServiceStruct(modelName string, file *dst.File, reimplement bool) (wasModified bool) {
func ImplementServiceStruct(modelName string, file *dst.File, reimplement bool) {
serviceName := modelName + "Service"
var (
isServiceStructDefined bool
insertPos int
decls []dst.Decl
)
isServiceStructDefined := false
var insertPos int
var decls []dst.Decl
for i, decl := range file.Decls {
genDecl, ok := decl.(*dst.GenDecl)
@@ -55,7 +53,7 @@ func ImplementServiceStruct(modelName string, file *dst.File, reimplement bool)
}
if isServiceStructDefined && !reimplement {
return false
return
}
serviceStruct := &dst.GenDecl{
@@ -71,16 +69,13 @@ func ImplementServiceStruct(modelName string, file *dst.File, reimplement bool)
}
file.Decls = append(decls[:insertPos], append([]dst.Decl{serviceStruct}, decls[insertPos:]...)...)
return true
}
func ImplementModelAlias(modelName string, file *dst.File) (wasModified bool) {
func ImplementModelAlias(modelName string, file *dst.File) {
isAliasDefined := false
aliasTypeStandard := fmt.Sprintf("models.%s", CapitalizeFirst(modelName))
var (
insertPos int
decls []dst.Decl
isAliasDefined bool
)
var insertPos int
var decls []dst.Decl
for i, decl := range file.Decls {
genDecl, ok := decl.(*dst.GenDecl)
@@ -152,7 +147,7 @@ func ImplementModelAlias(modelName string, file *dst.File) (wasModified bool) {
Name: &dst.Ident{
Name: modelName,
},
Assign: true,
Assign: true, // quick and dirty
Type: &dst.Ident{
Name: aliasTypeStandard,
},
@@ -162,9 +157,6 @@ func ImplementModelAlias(modelName string, file *dst.File) (wasModified bool) {
if !isAliasDefined {
file.Decls = append(decls[:insertPos], append([]dst.Decl{&typeAlias}, decls[insertPos:]...)...)
return true
} else {
return false
}
}
@@ -177,32 +169,10 @@ func importExists(file *dst.File, importPath string) bool {
return false
}
func MaintainImports(file *dst.File) (wasModified bool, e error) {
var (
modified bool
importDecl *dst.GenDecl
)
for _, decl := range file.Decls {
if genDecl, ok := decl.(*dst.GenDecl); ok && genDecl.Tok == token.IMPORT {
importDecl = genDecl
break
}
}
if importDecl == nil {
modified = true
importDecl = &dst.GenDecl{
Tok: token.IMPORT,
Specs: []dst.Spec{},
}
file.Decls = append([]dst.Decl{importDecl}, file.Decls...)
}
func MaintainImports(file *dst.File) error {
for _, importPath := range ServiceImports {
if !importExists(file, importPath) {
modified = true
importDecl.Specs = append(importDecl.Specs, &dst.ImportSpec{
file.Imports = append(file.Imports, &dst.ImportSpec{
Path: &dst.BasicLit{
Kind: token.STRING,
Value: `"` + importPath + `"`,
@@ -210,8 +180,7 @@ func MaintainImports(file *dst.File) (wasModified bool, e error) {
})
}
}
return modified, nil
return nil
}
func GenerateCrudMethodCode(methodName string, context CrudTemplatesContext) string {
@@ -251,15 +220,14 @@ func MethodCodeToDeclaration(methodCode string) (*dst.FuncDecl, error) {
return methodDecl, nil
}
func ImplementCrudMethods(modelName string, serviceName string, file *dst.File, reimplement bool) (wasModified bool, e error) {
func ImplementCrudMethods(modelName string, serviceName string, file *dst.File, reimplement bool) error {
templateContext := CrudTemplatesContext{
ServiceName: serviceName,
EntityType: modelName,
EntityPlural: ToPlural(modelName),
}
modified := reimplement
for _, methodName := range implementedMethods {
for _, methodName := range []string{CreateMethod, GetAllMethod, GetByIdMethod, UpdateMethod, DeleteMethod, CountMethod} {
methodCode := GenerateCrudMethodCode(methodName, templateContext)
methodDecl, err := MethodCodeToDeclaration(methodCode)
fmt.Printf("%s\n", methodCode)
@@ -267,27 +235,23 @@ func ImplementCrudMethods(modelName string, serviceName string, file *dst.File,
fmt.Println(methodDecl)
panic(err)
}
methodModified, err := ImplementMethod(file, methodDecl, reimplement)
err = ImplementMethod(file, methodDecl, reimplement)
if err != nil {
return false, err
}
if methodModified {
modified = true
return err
}
}
return modified, nil
return nil
}
func ImplementMethod(file *dst.File, methodDecl *dst.FuncDecl, reimplement bool) (wasModified bool, e error) {
var (
decls []dst.Decl
methodImplemented bool
)
modified := reimplement
func ImplementMethod(file *dst.File, methodDecl *dst.FuncDecl, reimplement bool) error {
var decls []dst.Decl
methodImplemented := false
methodStructure := methodDecl.Recv.List[0].Names[0].Name
methodName := methodDecl.Name.Name
log.Printf("Standard method structure: %s\n", methodStructure)
log.Printf("Standard method name: %s\n", methodName)
for _, decl := range file.Decls {
decls = append(decls, decl)
@@ -296,14 +260,14 @@ func ImplementMethod(file *dst.File, methodDecl *dst.FuncDecl, reimplement bool)
continue
}
if len(funcDecl.Recv.List) > 0 && len(funcDecl.Recv.List[0].Names) > 0 {
log.Printf("Method structure: %s\n", funcDecl.Recv.List[0].Names[0].Name)
log.Printf("Method name: %s\n", funcDecl.Name.Name)
fmt.Printf("Method structure: %s\n", funcDecl.Recv.List[0].Names[0].Name)
fmt.Printf("Method name: %s\n", funcDecl.Name.Name)
if funcDecl.Recv.List[0].Names[0].Name == methodStructure {
if funcDecl.Name != nil && funcDecl.Name.Name == methodName {
if methodImplemented {
err := fmt.Sprintf("`%s` method redeclarated for struct `%s`", methodName, methodStructure)
log.Println(err)
return false, errors.New(err)
return errors.New(err)
} else {
methodImplemented = true
}
@@ -316,7 +280,6 @@ func ImplementMethod(file *dst.File, methodDecl *dst.FuncDecl, reimplement bool)
}
if reimplement || !methodImplemented {
modified = true
file.Decls = append(
decls,
&dst.FuncDecl{
@@ -330,93 +293,72 @@ func ImplementMethod(file *dst.File, methodDecl *dst.FuncDecl, reimplement bool)
)
}
return modified, nil
return nil
}
func CreateServiceFileIfNotExists(filePath string) (wasModified bool, e error) {
var modified bool
func CreateServiceFileIfNotExists(filePath string) error {
if _, err := os.Stat(filePath); err != nil {
// file wasn't created
f, err := os.Create(filePath)
if err != nil {
log.Fatalf("Failed to create file: %s", filePath)
return false, err
return err
}
_, err = f.Write([]byte("package services\n"))
if err != nil {
log.Fatalf("Failed to write file: %s", filePath)
return false, err
return err
}
modified = true
defer f.Close()
}
return modified, nil
return nil
}
func ImplementService(mainPkgPath string, modelName string, reimplement bool) (wasModified bool, e error) {
func ImplementService(mainPkgPath string, modelName string, reimplement bool) error {
serviceRelativePath := fmt.Sprintf("services/%s.go", strings.ToLower(modelName))
filePath := filepath.Join(mainPkgPath, serviceRelativePath)
serviceName := modelName + "Service"
modified := reimplement
fileModified, err := CreateServiceFileIfNotExists(filePath)
err := CreateServiceFileIfNotExists(filePath)
if err != nil {
return false, err
}
if fileModified {
modified = true
return err
}
fset := token.NewFileSet()
serviceFile, err := decorator.ParseFile(fset, filePath, nil, parser.ParseComments)
if err != nil {
log.Fatalf("Parsing error: %s: %v", mainPkgPath, err)
return false, err
return err
}
importsModified, err := MaintainImports(serviceFile)
err = MaintainImports(serviceFile)
if err != nil {
return false, err
}
if importsModified {
modified = true
return err
}
aliasAdded := ImplementModelAlias(modelName, serviceFile)
if aliasAdded {
modified = true
}
ImplementModelAlias(modelName, serviceFile)
ImplementServiceStruct(modelName, serviceFile, reimplement)
err = ImplementCrudMethods(modelName, serviceName, serviceFile, reimplement)
serviceStructModified := ImplementServiceStruct(modelName, serviceFile, reimplement)
if serviceStructModified {
modified = true
}
methodsModified, err := ImplementCrudMethods(modelName, serviceName, serviceFile, reimplement)
if err != nil {
return false, err
}
if methodsModified {
modified = true
return err
}
file, err := os.Create(filePath)
if err != nil {
errMessage := errors.New(fmt.Sprintf("Error occured to open `%s` service file: %v", modelName, err))
return false, errMessage
return errors.New(fmt.Sprintf("Error occured to open `%s` service file: %v", modelName, err))
}
err = decorator.Fprint(file, serviceFile)
if err != nil {
errMessage := errors.New(
return errors.New(
fmt.Sprintf("Error occurred to writing changes in `%s` service file: %v", modelName, err),
)
return false, errMessage
}
defer file.Close()
return modified, nil
return nil
}