chore: quick update feat/supervisor at 2025-09-13 21:05:06

Author: kooksee

.golangci.yaml

@@ -2,21 +2,38 @@ version: "2"
 linters:
   default: none
   enable:
+    - errcheck
     - govet
+    - staticcheck
   exclusions:
     presets:
       - comments
       - common-false-positives
       - legacy
       - std-error-handling
+    rules:
+      - linters:
+          - dupl
+          - errcheck
+          - gocyclo
+          - gosec
+        path: _test\.go
+      - linters:
+          - forbidigo
+        path-except: _test\.go
     paths:
-      - vendor
+      - .*_test\.go$
+      - examples/
       - third_party$
       - builtin$
       - examples$
 formatters:
+  enable:
+    - goimports
   exclusions:
     paths:
+      - .*_test\.go$
+      - examples/
       - third_party$
       - builtin$
       - examples$

.version

@@ -0,0 +1 @@
+v2.0.0

clients/grpcc/client.go

@@ -35,7 +35,7 @@ func New(cfg *grpccconfig.Cfg, p Params, middlewares ...lava.Middleware) Client
 		middlewares: middlewares,
 	}
 
-	vars.RegisterValue(fmt.Sprintf("%s-grpc-client-config", cfg.Service.Name), cfg)
+	vars.Register(fmt.Sprintf("%s-grpc-client-config", cfg.Service.Name), func() any { return cfg })
 	return c
 }
 

clients/grpcc/middleware.go

@@ -29,9 +29,9 @@ func md2Head(md metadata.MD, header interface{ Add(key, value string) }) {
 }
 
 func head2md(header *lava.RequestHeader, md metadata.MD) {
-	header.VisitAll(func(key, value []byte) {
+	for key, value := range header.All() {
 		md.Append(convert.BtoS(key), convert.BtoS(value))
-	})
+	}
 }
 
 func unaryInterceptor(middlewares []lava.Middleware) grpc.UnaryClientInterceptor {

clients/resty/jar.go

@@ -41,14 +41,14 @@ func (j *Jar) Middleware(next lava.HandlerFunc) lava.HandlerFunc {
 			return nil, err
 		}
 
-		rsp.Header().VisitAllCookie(func(key, value []byte) {
+		for _, value := range rsp.Header().All() {
 			acquireCookie := fasthttp.AcquireCookie()
 			if err := acquireCookie.ParseBytes(value); err != nil {
 				j.log.Err(err, ctx).Msg("failed to parse cookie")
 			} else {
 				j.cookies[string(acquireCookie.Key())] = acquireCookie
 			}
-		})
+		}
 
 		return rsp, err
 	}

cmds/depcmd/cmd.go

@@ -8,6 +8,7 @@ import (
 
 	"github.com/olekukonko/tablewriter"
 	"github.com/pubgo/dix"
+	"github.com/pubgo/funk/assert"
 	"github.com/pubgo/funk/pretty"
 	"github.com/pubgo/funk/recovery"
 	"github.com/pubgo/funk/running"
@@ -46,12 +47,12 @@ func New(di *dix.Dix) *cli.Command {
 			case "table", "tb", "t":
 				table := tablewriter.NewWriter(os.Stdout)
 				table.Header([]string{"path", "Version", "Replace"})
-				table.Append([]string{info.Main.Path, version.Version(), replace(info.Main.Replace)})
+				assert.Must(table.Append([]string{info.Main.Path, version.Version(), replace(info.Main.Replace)}))
 
 				for _, dep := range info.Deps {
-					table.Append([]string{dep.Path, dep.Version, replace(dep.Replace)})
+					assert.Must(table.Append([]string{dep.Path, dep.Version, replace(dep.Replace)}))
 				}
-				table.Render()
+				assert.Must(table.Render())
 			case "di":
 				fmt.Println(di.Graph().Objects)
 				fmt.Println(di.Graph().Providers)

cmds/grpcservercmd/cmd.go

@@ -30,7 +30,7 @@ func New(di *dix.Dix) *cli.Command {
 				assert.Exit(manager.Add(svc))
 			}
 
-			return manager.Run()
+			return manager.Run(ctx)
 		},
 	}
 }

cmds/httpservercmd/cmd.go

@@ -30,7 +30,7 @@ func New(di *dix.Dix) *cli.Command {
 				assert.Exit(manager.Add(svc))
 			}
 
-			return manager.Run()
+			return manager.Run(ctx)
 		},
 	}
 }

cmds/schedulercmd/cmd.go

@@ -37,7 +37,7 @@ func New(di *dix.Dix) *cli.Command {
 				assert.Exit(manager.Add(svc))
 			}
 
-			return manager.Run()
+			return manager.Run(ctx)
 		},
 	}
 }