genmain.go 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. package gogen
  2. import (
  3. "bytes"
  4. "fmt"
  5. "strings"
  6. "text/template"
  7. "github.com/tal-tech/go-zero/tools/goctl/api/spec"
  8. "github.com/tal-tech/go-zero/tools/goctl/api/util"
  9. ctlutil "github.com/tal-tech/go-zero/tools/goctl/util"
  10. "github.com/tal-tech/go-zero/tools/goctl/vars"
  11. )
  12. const mainTemplate = `package main
  13. import (
  14. "flag"
  15. "fmt"
  16. {{.importPackages}}
  17. )
  18. var configFile = flag.String("f", "etc/{{.serviceName}}.yaml", "the config file")
  19. func main() {
  20. flag.Parse()
  21. var c config.Config
  22. conf.MustLoad(*configFile, &c)
  23. ctx := svc.NewServiceContext(c)
  24. server := rest.MustNewServer(c.RestConf)
  25. defer server.Stop()
  26. handler.RegisterHandlers(server, ctx)
  27. fmt.Printf("Starting server at %s:%d...\n", c.Host, c.Port)
  28. server.Start()
  29. }
  30. `
  31. func genMain(dir string, api *spec.ApiSpec) error {
  32. name := strings.ToLower(api.Service.Name)
  33. if strings.HasSuffix(name, "-api") {
  34. name = strings.ReplaceAll(name, "-api", "")
  35. }
  36. goFile := name + ".go"
  37. fp, created, err := util.MaybeCreateFile(dir, "", goFile)
  38. if err != nil {
  39. return err
  40. }
  41. if !created {
  42. return nil
  43. }
  44. defer fp.Close()
  45. parentPkg, err := getParentPackage(dir)
  46. if err != nil {
  47. return err
  48. }
  49. text, err := ctlutil.LoadTemplate(category, mainTemplateFile, mainTemplate)
  50. if err != nil {
  51. return err
  52. }
  53. t := template.Must(template.New("mainTemplate").Parse(text))
  54. buffer := new(bytes.Buffer)
  55. err = t.Execute(buffer, map[string]string{
  56. "importPackages": genMainImports(parentPkg),
  57. "serviceName": api.Service.Name,
  58. })
  59. if err != nil {
  60. return nil
  61. }
  62. formatCode := formatCode(buffer.String())
  63. _, err = fp.WriteString(formatCode)
  64. return err
  65. }
  66. func genMainImports(parentPkg string) string {
  67. var imports []string
  68. imports = append(imports, fmt.Sprintf("\"%s\"", ctlutil.JoinPackages(parentPkg, configDir)))
  69. imports = append(imports, fmt.Sprintf("\"%s\"", ctlutil.JoinPackages(parentPkg, handlerDir)))
  70. imports = append(imports, fmt.Sprintf("\"%s\"\n", ctlutil.JoinPackages(parentPkg, contextDir)))
  71. imports = append(imports, fmt.Sprintf("\"%s/core/conf\"", vars.ProjectOpenSourceUrl))
  72. imports = append(imports, fmt.Sprintf("\"%s/rest\"", vars.ProjectOpenSourceUrl))
  73. return strings.Join(imports, "\n\t")
  74. }