package main

import (
	"fmt"
	protogen2 "git.diulo.com/mogfee/kit/protogen"
	"google.golang.org/protobuf/compiler/protogen"
	"google.golang.org/protobuf/types/descriptorpb"
	"strings"
)

func main() {
	u := &Kit{
		imports: map[string]string{},
	}
	protogen.Options{}.Run(u.Generate)
}

type Kit struct {
	imports map[string]string
}

func (u *Kit) addImports(imp string) {
	u.imports[imp] = imp
}

func (u *Kit) packageName(f *protogen.File) string {
	a := f.Desc.Options().(*descriptorpb.FileOptions)
	p := strings.Split(*a.GoPackage, ";")
	if len(p) == 2 {
		return p[1]
	}
	return fmt.Sprintf("%s", f.Desc.Name())
}
func (u *Kit) Generate(plugin *protogen.Plugin) error {
	if len(plugin.Files) < 1 {
		return nil
	}
	u.addImports("context")
	u.addImports("git.diulo.com/mogfee/kit/middleware")
	u.addImports("git.diulo.com/mogfee/kit/errors")
	u.addImports("git.diulo.com/mogfee/kit/response")
	u.addImports("github.com/gin-gonic/gin")
	for _, f := range plugin.Files {
		if len(f.Services) == 0 {
			continue
		}
		fname := f.GeneratedFilenamePrefix + ".http.go"
		t := plugin.NewGeneratedFile(fname, f.GoImportPath)
		t.P("package ", u.packageName(f))
		t.P("import (")
		for _, v := range u.imports {
			t.P(`"` + v + `"`)
		}
		t.P(")")

		for _, s := range f.Services {
			serverName := s.GoName
			t.P(`func Register`, serverName, `Handler(app *gin.Engine,srv `, serverName, `Server,m ...middleware.Middleware) {`)
			for _, m := range s.Methods {
				method, path := protogen2.GetProtoMethod(m)
				if method == "" {
					continue
				}
				t.P(`app.`, method, `("`, path, `",http`, m.GoName, `Handler(srv,m...))`)
			}
			t.P(`}`)
		}
		for _, s := range f.Services {
			serverName := s.GoName
			for _, m := range s.Methods {
				method, _ := protogen2.GetProtoMethod(m)
				if method == "" {
					continue
				}
				switch method {
				case protogen2.METHOD_GET:
					u.genGet(serverName, t, m)
				case protogen2.METHOD_POST:
					u.genPost(serverName, t, m)
				case protogen2.METHOD_DELETE:
					u.genDelete(serverName, t, m)
				case protogen2.METHOD_PUT:
					u.genPut(serverName, t, m)
				}
			}
		}
	}
	return nil
}

func (u *Kit) genGet(serverName string, t *protogen.GeneratedFile, m *protogen.Method) {
	t.P("func http", m.GoName, "Handler(srv ", serverName, "Server,m ...middleware.Middleware)func(c *gin.Context){")
	t.P(`return func(c *gin.Context) {
		var post `, m.Input.GoIdent.GoName, `
		resp := response.New(c)
		if err := resp.BindQuery(&post); err != nil {
			resp.Error(err)
			return
		}
		h := func(ctx context.Context, a any) (any, error) {
			return srv.`, m.GoName, `(ctx, a.(*`, m.Input.GoIdent.GoName, `))
		}
		out, err := middleware.HttpMiddleware(c, h, m...)(c, &post)
		if err != nil {
			resp.Error(err)
		} else {
			if v, ok := out.(*`, m.Output.GoIdent.GoName, `); ok {
				resp.Success(v)
			} else {
				resp.Error(errors.InternalServer("RESULT_TYPE_ERROR", "`, m.Output.GoIdent.GoName, `"))
			}
		}
	}`)
	t.P("}")
}
func (u *Kit) genPost(serverName string, t *protogen.GeneratedFile, m *protogen.Method) {
	t.P("func http", m.GoName, "Handler(srv ", serverName, "Server,m ...middleware.Middleware)func(c *gin.Context){")
	t.P(`return func(c *gin.Context) {
		var post `, m.Input.GoIdent.GoName, `
		resp := response.New(c)
		if err := resp.BindJSON(&post); err != nil {
			resp.Error(err)
			return
		}
		h := func(ctx context.Context, a any) (any, error) {
			return srv.`, m.GoName, `(ctx, a.(*`, m.Input.GoIdent.GoName, `))
		}
		out, err := middleware.HttpMiddleware(c, h, m...)(c, &post)
		if err != nil {
			resp.Error(err)
		} else {
			if v, ok := out.(*`, m.Output.GoIdent.GoName, `); ok {
				resp.Success(v)
			} else {
				resp.Error(errors.InternalServer("RESULT_TYPE_ERROR", "`, m.Output.GoIdent.GoName, `"))
			}
		}
	}`)
	t.P("}")
}
func (u *Kit) genDelete(serverName string, t *protogen.GeneratedFile, m *protogen.Method) {
	t.P("func http", m.GoName, "Handler(srv ", serverName, "Server,m ...middleware.Middleware)func(c *gin.Context){")
	t.P(`return func(c *gin.Context) {
		var post `, m.Input.GoIdent.GoName, `
		resp := response.New(c)
		if err := resp.BindJSON(&post); err != nil {
			resp.Error(err)
			return
		}
		h := func(ctx context.Context, a any) (any, error) {
			return srv.`, m.GoName, `(ctx, a.(*`, m.Input.GoIdent.GoName, `))
		}
		out, err := middleware.HttpMiddleware(c, h, m...)(c, &post)
		if err != nil {
			resp.Error(err)
		} else {
			if v, ok := out.(*`, m.Output.GoIdent.GoName, `); ok {
				resp.Success(v)
			} else {
				resp.Error(errors.InternalServer("RESULT_TYPE_ERROR", "`, m.Output.GoIdent.GoName, `"))
			}
		}
	}`)
	t.P("}")
}

func (u *Kit) genPut(serverName string, t *protogen.GeneratedFile, m *protogen.Method) {
	t.P("func http", m.GoName, "Handler(srv ", serverName, "Server,m ...middleware.Middleware)func(c *gin.Context){")
	t.P(`return func(c *gin.Context) {
		var post `, m.Input.GoIdent.GoName, `
		resp := response.New(c)
		if err := resp.BindJSON(&post); err != nil {
			resp.Error(err)
			return
		}
		h := func(ctx context.Context, a any) (any, error) {
			return srv.`, m.GoName, `(ctx, a.(*`, m.Input.GoIdent.GoName, `))
		}
		out, err := middleware.HttpMiddleware(c, h, m...)(c, &post)
		if err != nil {
			resp.Error(err)
		} else {
			if v, ok := out.(*`, m.Output.GoIdent.GoName, `); ok {
				resp.Success(v)
			} else {
				resp.Error(errors.InternalServer("RESULT_TYPE_ERROR", "`, m.Output.GoIdent.GoName, `"))
			}
		}
	}`)
	t.P("}")
}