You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
108 lines
3.0 KiB
108 lines
3.0 KiB
package user |
|
|
|
import ( |
|
"git.diulo.com/mogfee/kit/response" |
|
"github.com/gin-gonic/gin" |
|
"context" |
|
"git.diulo.com/mogfee/kit/middleware" |
|
"git.diulo.com/mogfee/kit/errors" |
|
) |
|
|
|
func RegisterUserHandler(app *gin.Engine, srv UserServer, m ...middleware.Middleware) { |
|
app.GET("/api/v1/user/list", httpListHandler(srv, m...)) |
|
app.GET("/api/v1/user/login", httpLoginHandler(srv, m...)) |
|
app.GET("/api/v1/user/delete", httpDeleteHandler(srv, m...)) |
|
app.GET("/api/v1/user/delete1", httpDelete1Handler(srv, m...)) |
|
} |
|
func httpListHandler(srv UserServer, m ...middleware.Middleware) func(c *gin.Context) { |
|
return func(c *gin.Context) { |
|
var post LoginRequest |
|
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.List(ctx, a.(*LoginRequest)) |
|
} |
|
out, err := middleware.HttpMiddleware(c, h, m...)(c, &post) |
|
if err != nil { |
|
resp.Error(err) |
|
} else { |
|
if v, ok := out.(*LoginResponse); ok { |
|
resp.Success(v) |
|
} else { |
|
resp.Error(errors.InternalServer("RESULT_TYPE_ERROR", "LoginResponse")) |
|
} |
|
} |
|
} |
|
} |
|
func httpLoginHandler(srv UserServer, m ...middleware.Middleware) func(c *gin.Context) { |
|
return func(c *gin.Context) { |
|
var post LoginRequest |
|
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.Login(ctx, a.(*LoginRequest)) |
|
} |
|
out, err := middleware.HttpMiddleware(c, h, m...)(c, &post) |
|
if err != nil { |
|
resp.Error(err) |
|
} else { |
|
if v, ok := out.(*LoginResponse); ok { |
|
resp.Success(v) |
|
} else { |
|
resp.Error(errors.InternalServer("RESULT_TYPE_ERROR", "LoginResponse")) |
|
} |
|
} |
|
} |
|
} |
|
func httpDeleteHandler(srv UserServer, m ...middleware.Middleware) func(c *gin.Context) { |
|
return func(c *gin.Context) { |
|
var post LoginRequest |
|
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.Delete(ctx, a.(*LoginRequest)) |
|
} |
|
out, err := middleware.HttpMiddleware(c, h, m...)(c, &post) |
|
if err != nil { |
|
resp.Error(err) |
|
} else { |
|
if v, ok := out.(*LoginResponse); ok { |
|
resp.Success(v) |
|
} else { |
|
resp.Error(errors.InternalServer("RESULT_TYPE_ERROR", "LoginResponse")) |
|
} |
|
} |
|
} |
|
} |
|
func httpDelete1Handler(srv UserServer, m ...middleware.Middleware) func(c *gin.Context) { |
|
return func(c *gin.Context) { |
|
var post LoginRequest |
|
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.Delete1(ctx, a.(*LoginRequest)) |
|
} |
|
out, err := middleware.HttpMiddleware(c, h, m...)(c, &post) |
|
if err != nil { |
|
resp.Error(err) |
|
} else { |
|
if v, ok := out.(*LoginResponse); ok { |
|
resp.Success(v) |
|
} else { |
|
resp.Error(errors.InternalServer("RESULT_TYPE_ERROR", "LoginResponse")) |
|
} |
|
} |
|
} |
|
}
|
|
|