Fix/codes

core/entmigrates/migrate.go

@@ -19,7 +19,7 @@
 	"github.com/pubgo/funk/generic"
 	"github.com/pubgo/funk/log"
 	"github.com/pubgo/funk/version"
 	"github.com/testcontainers/testcontainers-go"
 	"github.com/testcontainers/testcontainers-go/modules/postgres"
 	"github.com/testcontainers/testcontainers-go/wait"
 	"github.com/urfave/cli/v3"
@@ -118,7 +118,7 @@
 	}
 
 	now := time.Now()
-	name := fmt.Sprintf("sql%d", now.UnixNano())
+	name := fmt.Sprintf("sql%s", now.Format("20060102150405"))
 	filename := fmt.Sprintf("%s.sql", name)
 	assert.Must(os.MkdirAll(g.config.MigrationPath, 0o755))
 	filename = filepath.Join(g.config.MigrationPath, filename)
@@ -127,20 +127,20 @@
 		return err
 	}
 
-	mmPkg := "github.com/pubgo/chameleon/internal/components/migrates"
+	mmPkg := "github.com/pubgo/lava/core/entmigrates"
 	genFile := jen.NewFile("migrations")
 	genFile.HeaderComment("DO NOT EDIT, THIS FILE IS GENERATED BY ENTORMIGRATE.")
 	genFile.HeaderComment("DO NOT EDIT, THIS FILE IS GENERATED BY ENTORMIGRATE.")
 	genFile.HeaderComment("DO NOT EDIT, THIS FILE IS GENERATED BY ENTORMIGRATE.")
 	genFile.Line()
 	genFile.Anon("embed")
-	genFile.ImportName(mmPkg, "migrates")
+	genFile.ImportName(mmPkg, "entmigrates")
 	genFile.Commentf("//go:embed %s.sql", name)
 	genFile.Var().Id(fmt.Sprintf("%sData string", name))
 	genFile.Var().Id("_").Qual(mmPkg, "Migration")
 	genFile.Id(fmt.Sprintf(`
-func %s() *migrates.Migration {
-	return &migrates.Migration{
+func %s() *entmigrates.Migration {
+	return &entmigrates.Migration{
 		Name:         "%s",
 		Description:  "%s",
 		MigrationSql: %sData,
@@ -185,44 +185,44 @@
 		Name:  "migrate",
 		Usage: "migrate database schema",
 		Commands: []*cli.Command{
-			&cli.Command{
+			{
 				Name:  "migrate",
 				Usage: "migrate all migrations",
 				Action: func(ctx context.Context, command *cli.Command) error {
 					return g.Migrate()
 				},
 			},
-			&cli.Command{
+			{
 				Name:      "migrate_to",
 				Usage:     "migrate_to <name>",
 				UsageText: "migrate migrate_to <name>",
 				Action: func(ctx context.Context, c *cli.Command) error {
 					return g.MigrateTo(c.Args().First())
 				},
 			},
-			&cli.Command{
+			{
 				Name:  "rollback",
 				Usage: "rollback last migration",
 				Action: func(ctx context.Context, command *cli.Command) error {
 					return g.RollbackLast()
 				},
 			},
-			&cli.Command{
+			{
 				Name:  "rollback_to",
 				Usage: "rollback_to <name>",
 				Action: func(ctx context.Context, c *cli.Command) error {
 					return g.RollbackTo(c.Args().First())
 				},
 			},
 
-			&cli.Command{
+			{
 				Name:  "create",
 				Usage: "create migration",
 				Action: func(ctx context.Context, command *cli.Command) error {
 					return g.Create(g.tables)
 				},
 			},
-			&cli.Command{
+			{
 				Name:  "list",
 				Usage: "list all migrations",
 				Action: func(ctx context.Context, command *cli.Command) error {
@@ -369,8 +369,8 @@
 		WithStartupTimeout(30 * time.Second)
 
 	ctr := assert.Must1(postgres.RunContainer(ctx,
 		testcontainers.WithImage("postgres:"+ver),
 		testcontainers.WithWaitStrategy(waitForLogs),
 	))
 
 	return assert.Must1(ctr.ConnectionString(ctx, "sslmode=disable"))

servers/grpcs/middleware.go

@@ -18,7 +18,6 @@ import (
 	"github.com/rs/xid"
 	"github.com/valyala/fasthttp"
 	"google.golang.org/grpc"
-	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/metadata"
 	"google.golang.org/grpc/peer"
 
@@ -161,7 +160,7 @@ func handlerUnaryMiddle(middlewares map[string][]lava.Middleware) grpc.UnaryServ
 
 			if pb.Code.Code == 0 {
 				pb.Code.StatusCode = errorpb.Code_Internal
-				pb.Code.Code = int32(errutil.GrpcCodeToHTTP(codes.Code(uint32(errorpb.Code_Internal))))
+				pb.Code.Code = int32(errorpb.Code_Internal)
 			}
 
 			return nil, errutil.ConvertErr2Status(pb).Err()
@@ -266,7 +265,7 @@ func handlerStreamMiddle(middlewares map[string][]lava.Middleware) grpc.StreamSe
 			}
 
 			if pb.Code.Code == 0 {
-				pb.Code.Code = int32(errutil.GrpcCodeToHTTP(codes.Code(pb.Code.StatusCode)))
+				pb.Code.Code = int32(errorpb.Code_Internal)
 				pb.Code.StatusCode = errorpb.Code_Internal
 			}
 

servers/grpcs/server.go

@@ -268,7 +268,7 @@ func (s *serviceImpl) DixInject(
 				pb = &errorpb.ErrCode{
 					Message:    err.Error(),
 					StatusCode: errorpb.Code_Internal,
-					Code:       500,
+					Code:       int32(errorpb.Code_Internal),
 					Name:       "lava.grpc.status",
 				}
 			} else {
@@ -280,15 +280,15 @@ func (s *serviceImpl) DixInject(
 				} else {
 					pb = &errorpb.ErrCode{
 						Message:    sts.Message(),
-						Code:       500,
+						Code:       int32(errorpb.Code(sts.Code())),
 						StatusCode: errorpb.Code(sts.Code()),
 						Name:       "lava.grpc.status",
 						Details:    sts.Proto().Details,
 					}
 				}
 			}
 
-			const fallback = `{"code":500, "name":"lava.grpc.status", "status_code": 13, "message": "failed to marshal error message"}`
+			const fallback = `{"code":13, "name":"lava.grpc.status", "status_code": 500, "message": "failed to marshal error message"}`
 
 			// skip error
 			if pb.StatusCode == errorpb.Code_OK {