123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899 |
- package gogen
- import (
- "bytes"
- "fmt"
- "strings"
- "text/template"
- "github.com/tal-tech/go-zero/tools/goctl/api/spec"
- "github.com/tal-tech/go-zero/tools/goctl/api/util"
- ctlutil "github.com/tal-tech/go-zero/tools/goctl/util"
- "github.com/tal-tech/go-zero/tools/goctl/vars"
- )
- const (
- contextFilename = "servicecontext.go"
- contextTemplate = `package svc
- import (
- {{.configImport}}
- )
- type ServiceContext struct {
- Config {{.config}}
- {{.middleware}}
- }
- func NewServiceContext(c {{.config}}) *ServiceContext {
- return &ServiceContext{
- Config: c,
- {{.middlewareAssignment}}
- }
- }
- `
- )
- func genServiceContext(dir string, api *spec.ApiSpec) error {
- fp, created, err := util.MaybeCreateFile(dir, contextDir, contextFilename)
- if err != nil {
- return err
- }
- if !created {
- return nil
- }
- defer fp.Close()
- var authNames = getAuths(api)
- var auths []string
- for _, item := range authNames {
- auths = append(auths, fmt.Sprintf("%s config.AuthConfig", item))
- }
- parentPkg, err := getParentPackage(dir)
- if err != nil {
- return err
- }
- text, err := ctlutil.LoadTemplate(category, contextTemplateFile, contextTemplate)
- if err != nil {
- return err
- }
- var middlewareStr string
- var middlewareAssignment string
- var middlewares = getMiddleware(api)
- err = genMiddleware(dir, middlewares)
- if err != nil {
- return err
- }
- for _, item := range middlewares {
- middlewareStr += fmt.Sprintf("%s rest.Middleware\n", item)
- name := strings.TrimSuffix(item, "Middleware") + "Middleware"
- middlewareAssignment += fmt.Sprintf("%s: %s,\n", item, fmt.Sprintf("middleware.New%s().%s", strings.Title(name), "Handle"))
- }
- var configImport = "\"" + ctlutil.JoinPackages(parentPkg, configDir) + "\""
- if len(middlewareStr) > 0 {
- configImport += "\n\t\"" + ctlutil.JoinPackages(parentPkg, middlewareDir) + "\""
- configImport += fmt.Sprintf("\n\t\"%s/rest\"", vars.ProjectOpenSourceUrl)
- }
- t := template.Must(template.New("contextTemplate").Parse(text))
- buffer := new(bytes.Buffer)
- err = t.Execute(buffer, map[string]string{
- "configImport": configImport,
- "config": "config.Config",
- "middleware": middlewareStr,
- "middlewareAssignment": middlewareAssignment,
- })
- if err != nil {
- return err
- }
- formatCode := formatCode(buffer.String())
- _, err = fp.WriteString(formatCode)
- return err
- }
|