Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| b9948c3a41 |
13
README.md
13
README.md
@@ -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
|
|
||||||
```
|
|
||||||
@@ -4,66 +4,30 @@ import (
|
|||||||
"flag"
|
"flag"
|
||||||
"git.gogacoder.ru/NTO/crudgen/internal"
|
"git.gogacoder.ru/NTO/crudgen/internal"
|
||||||
"log"
|
"log"
|
||||||
"os/exec"
|
|
||||||
"path/filepath"
|
"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"))
|
modelsNames, err := internal.GetStructNames(filepath.Join(mainPkgDir, "models"))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Printf("Error: %s\n", err)
|
log.Printf("Error: %s\n", err)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
var wasModified bool
|
|
||||||
|
|
||||||
log.Printf("Found models: %v\n", modelsNames)
|
log.Printf("Found models: %v\n", modelsNames)
|
||||||
|
|
||||||
for _, modelName := range modelsNames {
|
for _, modelName := range modelsNames {
|
||||||
codeModified, err := internal.ImplementService(mainPkgDir, modelName, reimplement)
|
err := internal.ImplementService(mainPkgDir, modelName, reimplement)
|
||||||
if codeModified {
|
|
||||||
wasModified = true
|
|
||||||
}
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Printf("Error implement service for model %s: %s\n", modelName, err)
|
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() {
|
func main() {
|
||||||
log.SetFlags(0)
|
log.SetFlags(0)
|
||||||
projectPath := flag.String("p", ".", "project path")
|
projectPath := flag.String("p", ".", "project path")
|
||||||
reimplement := flag.Bool("f", false, "pass -f to allow tool to overwrite exist functions and service structure")
|
reimplement := flag.Bool("f", false, "pass -f to allow tool to overwrite existing functions and service structure")
|
||||||
postHook := flag.String("h", "", "post hook to run command after code modifications")
|
|
||||||
|
|
||||||
flag.Parse()
|
flag.Parse()
|
||||||
wasModified := ImplementServices(*projectPath, *reimplement)
|
ImplementServices(*projectPath, *reimplement)
|
||||||
runPostHook(postHook, wasModified)
|
|
||||||
}
|
}
|
||||||
|
|||||||
11
go.mod
11
go.mod
@@ -1,13 +1,12 @@
|
|||||||
module git.gogacoder.ru/NTO/crudgen
|
module git.gogacoder.ru/NTO/crudgen
|
||||||
|
|
||||||
go 1.23.0
|
go 1.22.12
|
||||||
|
|
||||||
toolchain go1.24.1
|
|
||||||
|
|
||||||
require github.com/dave/dst v0.27.3
|
require github.com/dave/dst v0.27.3
|
||||||
|
|
||||||
require (
|
require (
|
||||||
golang.org/x/mod v0.24.0 // indirect
|
golang.org/x/mod v0.23.0 // indirect
|
||||||
golang.org/x/sync v0.12.0 // indirect
|
golang.org/x/sync v0.11.0 // indirect
|
||||||
golang.org/x/tools v0.31.0 // indirect
|
golang.org/x/sys v0.12.0 // indirect
|
||||||
|
golang.org/x/tools v0.13.0 // indirect
|
||||||
)
|
)
|
||||||
|
|||||||
16
go.sum
16
go.sum
@@ -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/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 h1:XU+rvMAioB0UC3q1MFrIQy4Vo5/4VsRDQQXHsEya6xQ=
|
||||||
github.com/sergi/go-diff v1.2.0/go.mod h1:STckp+ISIX8hZLjrqAeVduY0gWCT9IjLuqbuNXdaHfM=
|
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.23.0 h1:Zb7khfcRGKk+kqfxFaP5tZqCnDZMjC5VtUBs87Hr6QM=
|
||||||
golang.org/x/mod v0.24.0/go.mod h1:IXM97Txy2VM4PJ3gI61r1YEk/gAj6zAHN3AdZt6S9Ww=
|
golang.org/x/mod v0.23.0/go.mod h1:6SkKJ3Xj0I0BrPOZoBy3bdMptDDU9oJrpohJ3eWZ1fY=
|
||||||
golang.org/x/sync v0.12.0 h1:MHc5BpPuC30uJk597Ri8TV3CNZcTLu6B6z4lJy+g6Jw=
|
golang.org/x/sync v0.11.0 h1:GGz8+XQP4FvTTrjZPzNKTMFtSXH80RAzG+5ghFPgK9w=
|
||||||
golang.org/x/sync v0.12.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
|
golang.org/x/sync v0.11.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
|
||||||
golang.org/x/tools v0.31.0 h1:0EedkvKDbh+qistFTd0Bcwe/YLh4vHwWEkiI0toFIBU=
|
golang.org/x/sys v0.12.0 h1:CM0HF96J0hcLAwsHPJZjfdNzs0gftsLfgKt57wWHJ0o=
|
||||||
golang.org/x/tools v0.31.0/go.mod h1:naFTU+Cev749tSJRXJlna0T3WxKvb1kWEx15xA4SdmQ=
|
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=
|
||||||
|
|||||||
@@ -1,12 +1,7 @@
|
|||||||
package internal
|
package internal
|
||||||
|
|
||||||
const CreateRawTemplate = `func (service *{{.ServiceName}}) Create(item {{.EntityType}}) ({{.EntityType}}, error) {
|
const CreateRawTemplate = `func (service *{{.ServiceName}}) Create(item {{.EntityType}}) ({{.EntityType}}, error) {
|
||||||
utils.ReplaceEmptySlicesWithNil(&item)
|
err := dal.{{.EntityType}}.Preload(field.Associations).Create(&item)
|
||||||
err := dal.{{.EntityType}}.Create(&item)
|
|
||||||
if err != nil {
|
|
||||||
return item, err
|
|
||||||
}
|
|
||||||
err = utils.AppendAssociations(database.GetInstance(), &item)
|
|
||||||
return item, err
|
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) {
|
const UpdateRawTemplate = `func (service *{{.ServiceName}}) Update(item {{.EntityType}}) ({{.EntityType}}, error) {
|
||||||
utils.ReplaceEmptySlicesWithNil(&item)
|
err := dal.{{.EntityType}}.Preload(field.Associations).Save(&item)
|
||||||
|
|
||||||
_, err := dal.{{.EntityType}}.Updates(&item)
|
|
||||||
if err != nil {
|
|
||||||
return item, err
|
|
||||||
}
|
|
||||||
|
|
||||||
err = utils.UpdateAssociations(database.GetInstance(), &item)
|
|
||||||
|
|
||||||
if err != nil {
|
|
||||||
return item, err
|
|
||||||
}
|
|
||||||
|
|
||||||
return item, err
|
return item, err
|
||||||
}`
|
}`
|
||||||
|
|
||||||
const DeleteRawTemplate = `func (service *{{.ServiceName}}) Delete(id uint) error {
|
const DeleteRawTemplate = `func (service *{{.ServiceName}}) Delete(item {{.EntityType}}) ({{.EntityType}}, error) {
|
||||||
_, err := dal.{{.EntityType}}.Unscoped().Where(dal.{{.EntityType}}.Id.Eq(id)).Delete()
|
_, err := dal.{{.EntityType}}.Unscoped().Preload(field.Associations).Delete(&item)
|
||||||
return err
|
return item, err
|
||||||
}`
|
}`
|
||||||
|
|
||||||
const CountRawTemplate = `func (service *{{.ServiceName}}) Count() (int64, error) {
|
const CountRawTemplate = `func (service *{{.ServiceName}}) Count() (int64, error) {
|
||||||
amount, err := dal.{{.EntityType}}.Count()
|
amount, err := dal.{{.EntityType}}.Count()
|
||||||
return amount, err
|
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}
|
|
||||||
|
|||||||
@@ -8,9 +8,7 @@ type CrudTemplatesContext struct {
|
|||||||
|
|
||||||
var ServiceImports = []string{
|
var ServiceImports = []string{
|
||||||
"app/internal/dal",
|
"app/internal/dal",
|
||||||
"app/internal/database",
|
|
||||||
"app/internal/models",
|
"app/internal/models",
|
||||||
"app/internal/utils",
|
|
||||||
"errors",
|
"errors",
|
||||||
"gorm.io/gen/field",
|
"gorm.io/gen/field",
|
||||||
"gorm.io/gorm",
|
"gorm.io/gorm",
|
||||||
@@ -22,15 +20,12 @@ const GetByIdMethod = "GetById"
|
|||||||
const UpdateMethod = "Update"
|
const UpdateMethod = "Update"
|
||||||
const DeleteMethod = "Delete"
|
const DeleteMethod = "Delete"
|
||||||
const CountMethod = "Count"
|
const CountMethod = "Count"
|
||||||
const SortedByOrderMethod = "SortedByOrder"
|
|
||||||
|
|
||||||
var RawTemplates = map[string]string{
|
var RawTemplates = map[string]string{
|
||||||
CreateMethod: CreateRawTemplate,
|
CreateMethod: CreateRawTemplate,
|
||||||
GetAllMethod: GetAllRawTemplate,
|
GetAllMethod: GetAllRawTemplate,
|
||||||
GetByIdMethod: GetByIdRawTemplate,
|
GetByIdMethod: GetByIdRawTemplate,
|
||||||
UpdateMethod: UpdateRawTemplate,
|
UpdateMethod: UpdateRawTemplate,
|
||||||
DeleteMethod: DeleteRawTemplate,
|
DeleteMethod: DeleteRawTemplate,
|
||||||
CountMethod: CountRawTemplate,
|
CountMethod: CountRawTemplate,
|
||||||
SortedByOrderMethod: SortedByOrderTemplate,
|
|
||||||
SearchByAllStringFields: SearchByAllStringFields,
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -16,13 +16,11 @@ import (
|
|||||||
"github.com/dave/dst/decorator"
|
"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"
|
serviceName := modelName + "Service"
|
||||||
var (
|
isServiceStructDefined := false
|
||||||
isServiceStructDefined bool
|
var insertPos int
|
||||||
insertPos int
|
var decls []dst.Decl
|
||||||
decls []dst.Decl
|
|
||||||
)
|
|
||||||
|
|
||||||
for i, decl := range file.Decls {
|
for i, decl := range file.Decls {
|
||||||
genDecl, ok := decl.(*dst.GenDecl)
|
genDecl, ok := decl.(*dst.GenDecl)
|
||||||
@@ -55,7 +53,7 @@ func ImplementServiceStruct(modelName string, file *dst.File, reimplement bool)
|
|||||||
}
|
}
|
||||||
|
|
||||||
if isServiceStructDefined && !reimplement {
|
if isServiceStructDefined && !reimplement {
|
||||||
return false
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
serviceStruct := &dst.GenDecl{
|
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:]...)...)
|
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))
|
aliasTypeStandard := fmt.Sprintf("models.%s", CapitalizeFirst(modelName))
|
||||||
var (
|
var insertPos int
|
||||||
insertPos int
|
var decls []dst.Decl
|
||||||
decls []dst.Decl
|
|
||||||
isAliasDefined bool
|
|
||||||
)
|
|
||||||
|
|
||||||
for i, decl := range file.Decls {
|
for i, decl := range file.Decls {
|
||||||
genDecl, ok := decl.(*dst.GenDecl)
|
genDecl, ok := decl.(*dst.GenDecl)
|
||||||
@@ -152,7 +147,7 @@ func ImplementModelAlias(modelName string, file *dst.File) (wasModified bool) {
|
|||||||
Name: &dst.Ident{
|
Name: &dst.Ident{
|
||||||
Name: modelName,
|
Name: modelName,
|
||||||
},
|
},
|
||||||
Assign: true,
|
Assign: true, // quick and dirty
|
||||||
Type: &dst.Ident{
|
Type: &dst.Ident{
|
||||||
Name: aliasTypeStandard,
|
Name: aliasTypeStandard,
|
||||||
},
|
},
|
||||||
@@ -162,9 +157,6 @@ func ImplementModelAlias(modelName string, file *dst.File) (wasModified bool) {
|
|||||||
|
|
||||||
if !isAliasDefined {
|
if !isAliasDefined {
|
||||||
file.Decls = append(decls[:insertPos], append([]dst.Decl{&typeAlias}, decls[insertPos:]...)...)
|
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
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
func MaintainImports(file *dst.File) (wasModified bool, e error) {
|
func MaintainImports(file *dst.File) 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...)
|
|
||||||
}
|
|
||||||
|
|
||||||
for _, importPath := range ServiceImports {
|
for _, importPath := range ServiceImports {
|
||||||
if !importExists(file, importPath) {
|
if !importExists(file, importPath) {
|
||||||
modified = true
|
file.Imports = append(file.Imports, &dst.ImportSpec{
|
||||||
importDecl.Specs = append(importDecl.Specs, &dst.ImportSpec{
|
|
||||||
Path: &dst.BasicLit{
|
Path: &dst.BasicLit{
|
||||||
Kind: token.STRING,
|
Kind: token.STRING,
|
||||||
Value: `"` + importPath + `"`,
|
Value: `"` + importPath + `"`,
|
||||||
@@ -210,8 +180,7 @@ func MaintainImports(file *dst.File) (wasModified bool, e error) {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
return nil
|
||||||
return modified, nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func GenerateCrudMethodCode(methodName string, context CrudTemplatesContext) string {
|
func GenerateCrudMethodCode(methodName string, context CrudTemplatesContext) string {
|
||||||
@@ -251,15 +220,14 @@ func MethodCodeToDeclaration(methodCode string) (*dst.FuncDecl, error) {
|
|||||||
return methodDecl, nil
|
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{
|
templateContext := CrudTemplatesContext{
|
||||||
ServiceName: serviceName,
|
ServiceName: serviceName,
|
||||||
EntityType: modelName,
|
EntityType: modelName,
|
||||||
EntityPlural: ToPlural(modelName),
|
EntityPlural: ToPlural(modelName),
|
||||||
}
|
}
|
||||||
modified := reimplement
|
|
||||||
|
|
||||||
for _, methodName := range implementedMethods {
|
for _, methodName := range []string{CreateMethod, GetAllMethod, GetByIdMethod, UpdateMethod, DeleteMethod, CountMethod} {
|
||||||
methodCode := GenerateCrudMethodCode(methodName, templateContext)
|
methodCode := GenerateCrudMethodCode(methodName, templateContext)
|
||||||
methodDecl, err := MethodCodeToDeclaration(methodCode)
|
methodDecl, err := MethodCodeToDeclaration(methodCode)
|
||||||
fmt.Printf("%s\n", methodCode)
|
fmt.Printf("%s\n", methodCode)
|
||||||
@@ -267,27 +235,23 @@ func ImplementCrudMethods(modelName string, serviceName string, file *dst.File,
|
|||||||
fmt.Println(methodDecl)
|
fmt.Println(methodDecl)
|
||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
|
err = ImplementMethod(file, methodDecl, reimplement)
|
||||||
methodModified, err := ImplementMethod(file, methodDecl, reimplement)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return false, err
|
return err
|
||||||
}
|
|
||||||
if methodModified {
|
|
||||||
modified = true
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return modified, nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func ImplementMethod(file *dst.File, methodDecl *dst.FuncDecl, reimplement bool) (wasModified bool, e error) {
|
func ImplementMethod(file *dst.File, methodDecl *dst.FuncDecl, reimplement bool) error {
|
||||||
var (
|
var decls []dst.Decl
|
||||||
decls []dst.Decl
|
methodImplemented := false
|
||||||
methodImplemented bool
|
|
||||||
)
|
|
||||||
modified := reimplement
|
|
||||||
methodStructure := methodDecl.Recv.List[0].Names[0].Name
|
methodStructure := methodDecl.Recv.List[0].Names[0].Name
|
||||||
methodName := methodDecl.Name.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 {
|
for _, decl := range file.Decls {
|
||||||
decls = append(decls, decl)
|
decls = append(decls, decl)
|
||||||
@@ -296,14 +260,14 @@ func ImplementMethod(file *dst.File, methodDecl *dst.FuncDecl, reimplement bool)
|
|||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
if len(funcDecl.Recv.List) > 0 && len(funcDecl.Recv.List[0].Names) > 0 {
|
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)
|
fmt.Printf("Method structure: %s\n", funcDecl.Recv.List[0].Names[0].Name)
|
||||||
log.Printf("Method name: %s\n", funcDecl.Name.Name)
|
fmt.Printf("Method name: %s\n", funcDecl.Name.Name)
|
||||||
if funcDecl.Recv.List[0].Names[0].Name == methodStructure {
|
if funcDecl.Recv.List[0].Names[0].Name == methodStructure {
|
||||||
if funcDecl.Name != nil && funcDecl.Name.Name == methodName {
|
if funcDecl.Name != nil && funcDecl.Name.Name == methodName {
|
||||||
if methodImplemented {
|
if methodImplemented {
|
||||||
err := fmt.Sprintf("`%s` method redeclarated for struct `%s`", methodName, methodStructure)
|
err := fmt.Sprintf("`%s` method redeclarated for struct `%s`", methodName, methodStructure)
|
||||||
log.Println(err)
|
log.Println(err)
|
||||||
return false, errors.New(err)
|
return errors.New(err)
|
||||||
} else {
|
} else {
|
||||||
methodImplemented = true
|
methodImplemented = true
|
||||||
}
|
}
|
||||||
@@ -316,7 +280,6 @@ func ImplementMethod(file *dst.File, methodDecl *dst.FuncDecl, reimplement bool)
|
|||||||
}
|
}
|
||||||
|
|
||||||
if reimplement || !methodImplemented {
|
if reimplement || !methodImplemented {
|
||||||
modified = true
|
|
||||||
file.Decls = append(
|
file.Decls = append(
|
||||||
decls,
|
decls,
|
||||||
&dst.FuncDecl{
|
&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) {
|
func CreateServiceFileIfNotExists(filePath string) error {
|
||||||
var modified bool
|
|
||||||
if _, err := os.Stat(filePath); err != nil {
|
if _, err := os.Stat(filePath); err != nil {
|
||||||
// file wasn't created
|
// file wasn't created
|
||||||
f, err := os.Create(filePath)
|
f, err := os.Create(filePath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("Failed to create file: %s", filePath)
|
log.Fatalf("Failed to create file: %s", filePath)
|
||||||
return false, err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
_, err = f.Write([]byte("package services\n"))
|
_, err = f.Write([]byte("package services\n"))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("Failed to write file: %s", filePath)
|
log.Fatalf("Failed to write file: %s", filePath)
|
||||||
return false, err
|
return err
|
||||||
}
|
}
|
||||||
modified = true
|
|
||||||
|
|
||||||
defer f.Close()
|
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))
|
serviceRelativePath := fmt.Sprintf("services/%s.go", strings.ToLower(modelName))
|
||||||
filePath := filepath.Join(mainPkgPath, serviceRelativePath)
|
filePath := filepath.Join(mainPkgPath, serviceRelativePath)
|
||||||
serviceName := modelName + "Service"
|
serviceName := modelName + "Service"
|
||||||
modified := reimplement
|
|
||||||
|
|
||||||
fileModified, err := CreateServiceFileIfNotExists(filePath)
|
err := CreateServiceFileIfNotExists(filePath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return false, err
|
return err
|
||||||
}
|
|
||||||
if fileModified {
|
|
||||||
modified = true
|
|
||||||
}
|
}
|
||||||
|
|
||||||
fset := token.NewFileSet()
|
fset := token.NewFileSet()
|
||||||
serviceFile, err := decorator.ParseFile(fset, filePath, nil, parser.ParseComments)
|
serviceFile, err := decorator.ParseFile(fset, filePath, nil, parser.ParseComments)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("Parsing error: %s: %v", mainPkgPath, err)
|
log.Fatalf("Parsing error: %s: %v", mainPkgPath, err)
|
||||||
return false, err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
importsModified, err := MaintainImports(serviceFile)
|
err = MaintainImports(serviceFile)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return false, err
|
return err
|
||||||
}
|
|
||||||
if importsModified {
|
|
||||||
modified = true
|
|
||||||
}
|
}
|
||||||
|
|
||||||
aliasAdded := ImplementModelAlias(modelName, serviceFile)
|
ImplementModelAlias(modelName, serviceFile)
|
||||||
if aliasAdded {
|
ImplementServiceStruct(modelName, serviceFile, reimplement)
|
||||||
modified = true
|
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 {
|
if err != nil {
|
||||||
return false, err
|
return err
|
||||||
}
|
|
||||||
if methodsModified {
|
|
||||||
modified = true
|
|
||||||
}
|
}
|
||||||
|
|
||||||
file, err := os.Create(filePath)
|
file, err := os.Create(filePath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
errMessage := errors.New(fmt.Sprintf("Error occured to open `%s` service file: %v", modelName, err))
|
return errors.New(fmt.Sprintf("Error occured to open `%s` service file: %v", modelName, err))
|
||||||
return false, errMessage
|
|
||||||
}
|
}
|
||||||
|
|
||||||
err = decorator.Fprint(file, serviceFile)
|
err = decorator.Fprint(file, serviceFile)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
errMessage := errors.New(
|
return errors.New(
|
||||||
fmt.Sprintf("Error occurred to writing changes in `%s` service file: %v", modelName, err),
|
fmt.Sprintf("Error occurred to writing changes in `%s` service file: %v", modelName, err),
|
||||||
)
|
)
|
||||||
return false, errMessage
|
|
||||||
}
|
}
|
||||||
|
|
||||||
defer file.Close()
|
defer file.Close()
|
||||||
|
|
||||||
return modified, nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user