chore(deps): upgrade dependencies and modernize code

kaptinlin · kaptinlin · commit 6c086f0863cb · 2026-02-14T12:51:19.000+08:00
- Upgraded all dependencies to latest versions
- Replaced interface{} with any alias for cleaner code
- All tests passing with race detection
- golangci-lint v2.9.0 compliance verified
diff --git a/examples/simple/cmd/client/main.go b/examples/simple/cmd/client/main.go
@@ -18,7 +18,7 @@ func main() {
 	}
 
 	jobType := "example_job"
-	payload := map[string]interface{}{
+	payload := map[string]any{
 		"input": "Hello, Queue!",
 	}
 	_, err = client.Enqueue(jobType, payload, queue.WithQueue("critical"), queue.WithRetention(time.Hour))
diff --git a/info.go b/info.go
@@ -44,7 +44,7 @@ type ActiveJobInfo struct {
 	JobPayload string    `json:"job_payload"`
 	Queue      string    `json:"queue"`
 	StartedAt  time.Time `json:"started_at"`
-	DeadlineAt time.Time `json:"deadline_at,omitempty"`
+	DeadlineAt time.Time `json:"deadline_at"`
 }
 
 // Convert Asynq WorkerInfo to ActiveJobInfo.
diff --git a/manager.go b/manager.go
@@ -586,8 +586,8 @@ func (s *Manager) fetchQueueLocations() ([]*QueueLocation, error) {
 // parseRedisInfo parses the INFO command's output into a key-value map.
 func parseRedisInfo(infoStr string) map[string]string {
 	info := make(map[string]string)
-	lines := strings.Split(infoStr, "\r\n")
-	for _, line := range lines {
+	lines := strings.SplitSeq(infoStr, "\r\n")
+	for line := range lines {
 		if key, value, ok := strings.Cut(line, ":"); ok {
 			info[key] = value
 		}
diff --git a/tests/benchmarks_test.go b/tests/benchmarks_test.go
@@ -8,15 +8,15 @@ import (
 )
 
 func BenchmarkJobCreation(b *testing.B) {
-	payload := map[string]interface{}{"key": "value", "count": 123}
+	payload := map[string]any{"key": "value", "count": 123}
 
 	for b.Loop() {
 		_ = queue.NewJob("test_job", payload)
 	}
 }
 
 func BenchmarkJobCreationWithOptions(b *testing.B) {
-	payload := map[string]interface{}{"key": "value", "count": 123}
+	payload := map[string]any{"key": "value", "count": 123}
 
 	for b.Loop() {
 		_ = queue.NewJob("test_job", payload,
@@ -27,7 +27,7 @@ func BenchmarkJobCreationWithOptions(b *testing.B) {
 }
 
 func BenchmarkJobConvertToAsynqTask(b *testing.B) {
-	payload := map[string]interface{}{"key": "value", "count": 123}
+	payload := map[string]any{"key": "value", "count": 123}
 	job := queue.NewJob("test_job", payload, queue.WithQueue("default"))
 
 	for b.Loop() {
@@ -53,7 +53,7 @@ func BenchmarkHandlerProcess(b *testing.B) {
 		return nil
 	})
 
-	job := queue.NewJob("test_job", map[string]interface{}{"key": "value"})
+	job := queue.NewJob("test_job", map[string]any{"key": "value"})
 	ctx := context.Background()
 
 	for b.Loop() {
@@ -70,7 +70,7 @@ func BenchmarkJobDecodePayload(b *testing.B) {
 		Count int    `json:"count"`
 	}
 
-	payload := map[string]interface{}{"key": "value", "count": 123}
+	payload := map[string]any{"key": "value", "count": 123}
 	job := queue.NewJob("test_job", payload)
 
 	for b.Loop() {
@@ -90,7 +90,7 @@ func BenchmarkClientEnqueue(b *testing.B) {
 	}
 	defer func() { _ = client.Stop() }()
 
-	payload := map[string]interface{}{"key": "value"}
+	payload := map[string]any{"key": "value"}
 
 	for b.Loop() {
 		_, err := client.Enqueue("benchmark_job", payload)
@@ -109,7 +109,7 @@ func BenchmarkClientEnqueueJob(b *testing.B) {
 	defer func() { _ = client.Stop() }()
 
 	for b.Loop() {
-		job := queue.NewJob("benchmark_job", map[string]interface{}{"key": "value"})
+		job := queue.NewJob("benchmark_job", map[string]any{"key": "value"})
 		_, err := client.EnqueueJob(job)
 		if err != nil {
 			b.Fatal(err)
diff --git a/tests/client_test.go b/tests/client_test.go
@@ -20,7 +20,7 @@ func TestClientEnqueue(t *testing.T) {
 	}()
 
 	jobType := "testEnqueueJob"
-	payload := map[string]interface{}{"key": "value"}
+	payload := map[string]any{"key": "value"}
 
 	_, err = client.Enqueue(jobType, payload)
 	require.NoError(t, err, "Enqueue failed")
@@ -36,7 +36,7 @@ func TestClientEnqueueJob(t *testing.T) {
 	}()
 
 	jobType := "testEnqueueJobJob"
-	payload := map[string]interface{}{"key": "value"}
+	payload := map[string]any{"key": "value"}
 	job := queue.NewJob(jobType, payload)
 
 	_, err = client.EnqueueJob(job)
@@ -67,7 +67,7 @@ func TestClientWithClientErrorHandler(t *testing.T) {
 
 	// Create a job with an invalid configuration that is known to cause ConvertToAsynqTask to return an error
 	jobType := "" // Intentionally left blank to trigger an error in ConvertToAsynqTask
-	payload := map[string]interface{}{"key": "value"}
+	payload := map[string]any{"key": "value"}
 
 	// Attempt to enqueue the job, which should fail at the job conversion step
 	_, err = client.Enqueue(jobType, payload)
diff --git a/tests/group_test.go b/tests/group_test.go
@@ -62,8 +62,8 @@ func TestGroupMiddleware(t *testing.T) {
 	// Enqueue jobs to be processed by the handler within the email group.
 	client, err := queue.NewClient(redisConfig)
 	require.NoError(t, err, "Failed to create client")
-	for i := 0; i < 5; i++ {
-		_, err := client.Enqueue(jobType, map[string]interface{}{"key": "value"})
+	for range 5 {
+		_, err := client.Enqueue(jobType, map[string]any{"key": "value"})
 		require.NoError(t, err, "Failed to enqueue job")
 	}
 
diff --git a/tests/job_test.go b/tests/job_test.go
@@ -15,7 +15,7 @@ import (
 
 func TestNewJob(t *testing.T) {
 	jobType := "testJob"
-	payload := map[string]interface{}{"key": "value"}
+	payload := map[string]any{"key": "value"}
 	job := queue.NewJob(jobType, payload)
 
 	assert.Equal(t, jobType, job.Type, "Job type should match")
@@ -24,15 +24,15 @@ func TestNewJob(t *testing.T) {
 
 func TestJob_ConvertToAsynqTask(t *testing.T) {
 	jobType := "testConversion"
-	payload := map[string]interface{}{"key": "value"}
+	payload := map[string]any{"key": "value"}
 	job := queue.NewJob(jobType, payload)
 
 	task, _, err := job.ConvertToAsynqTask()
 	require.NoError(t, err, "ConvertToAsynqTask should not fail")
 
 	assert.Equal(t, jobType, task.Type(), "Task type should match job type")
 
-	var taskPayload map[string]interface{}
+	var taskPayload map[string]any
 	err = json.Unmarshal(task.Payload(), &taskPayload)
 	require.NoError(t, err, "json.Unmarshal should not fail")
 
@@ -150,7 +150,7 @@ func TestWriteResultAndRetrieve(t *testing.T) {
 	var wg sync.WaitGroup
 
 	// Define expected result
-	expectedResult := map[string]interface{}{
+	expectedResult := map[string]any{
 		"status": "completed",
 		"detail": "Job processed successfully",
 	}
@@ -202,7 +202,7 @@ func TestWriteResultAndRetrieve(t *testing.T) {
 	require.NoError(t, err, "Failed to get job info")
 
 	// Deserialize the job result to verify it
-	var result map[string]interface{}
+	var result map[string]any
 	err = json.Unmarshal([]byte(*jobInfo.Result), &result)
 	require.NoError(t, err, "Failed to unmarshal job result")
 
diff --git a/tests/middleware_test.go b/tests/middleware_test.go
@@ -59,8 +59,8 @@ func TestGlobalMiddleware(t *testing.T) {
 	// Enqueue a couple of jobs
 	client, err := queue.NewClient(redisConfig)
 	require.NoError(t, err, "Failed to create client")
-	for i := 0; i < 5; i++ {
-		_, err := client.Enqueue(jobType, map[string]interface{}{"key": "value"})
+	for range 5 {
+		_, err := client.Enqueue(jobType, map[string]any{"key": "value"})
 		require.NoError(t, err, "Failed to enqueue job")
 	}
 
@@ -122,8 +122,8 @@ func TestScopedMiddleware(t *testing.T) {
 	// Enqueue jobs to be processed by the scoped middleware-enhanced handler.
 	client, err := queue.NewClient(redisConfig)
 	require.NoError(t, err, "Failed to create client")
-	for i := 0; i < 3; i++ {
-		_, err := client.Enqueue(jobType, map[string]interface{}{"key": "value"})
+	for range 3 {
+		_, err := client.Enqueue(jobType, map[string]any{"key": "value"})
 		require.NoError(t, err, "Failed to enqueue job")
 	}
 
diff --git a/tests/scheduler_test.go b/tests/scheduler_test.go
@@ -20,20 +20,20 @@ type mockLogger struct {
 
 type mockLogEntry struct {
 	level string
-	args  []interface{}
+	args  []any
 }
 
-func (l *mockLogger) log(level string, args ...interface{}) {
+func (l *mockLogger) log(level string, args ...any) {
 	l.mu.Lock()
 	defer l.mu.Unlock()
 	l.messages = append(l.messages, mockLogEntry{level: level, args: args})
 }
 
-func (l *mockLogger) Debug(args ...interface{}) { l.log("debug", args...) }
-func (l *mockLogger) Info(args ...interface{})  { l.log("info", args...) }
-func (l *mockLogger) Warn(args ...interface{})  { l.log("warn", args...) }
-func (l *mockLogger) Error(args ...interface{}) { l.log("error", args...) }
-func (l *mockLogger) Fatal(args ...interface{}) { l.log("fatal", args...) }
+func (l *mockLogger) Debug(args ...any) { l.log("debug", args...) }
+func (l *mockLogger) Info(args ...any)  { l.log("info", args...) }
+func (l *mockLogger) Warn(args ...any)  { l.log("warn", args...) }
+func (l *mockLogger) Error(args ...any) { l.log("error", args...) }
+func (l *mockLogger) Fatal(args ...any) { l.log("fatal", args...) }
 
 func (l *mockLogger) hasLevel(level string) bool {
 	l.mu.Lock()
@@ -99,7 +99,7 @@ func TestSchedulerPreEnqueueHook(t *testing.T) {
 	require.NoError(t, err, "Failed to create scheduler with pre enqueue hook")
 
 	jobType := "pre_enqueue_test"
-	payload := map[string]interface{}{"data": "pre"}
+	payload := map[string]any{"data": "pre"}
 
 	_, err = scheduler.RegisterCron("@every 1s", jobType, payload)
 	require.NoError(t, err, "Failed to register cron job")
@@ -131,7 +131,7 @@ func TestSchedulerPostEnqueueHook(t *testing.T) {
 	require.NoError(t, err, "Failed to create scheduler with post enqueue hook")
 
 	jobType := "post_enqueue_test"
-	payload := map[string]interface{}{"data": "post"}
+	payload := map[string]any{"data": "post"}
 
 	_, err = scheduler.RegisterCron("@every 1s", jobType, payload)
 	require.NoError(t, err, "Failed to register cron job")
@@ -159,7 +159,7 @@ func TestSchedulerPostEnqueueUsesConfiguredLogger(t *testing.T) {
 	)
 	require.NoError(t, err, "Failed to create scheduler with custom logger")
 
-	_, err = scheduler.RegisterCron("@every 1s", "logger_test", map[string]interface{}{"key": "value"})
+	_, err = scheduler.RegisterCron("@every 1s", "logger_test", map[string]any{"key": "value"})
 	require.NoError(t, err, "Failed to register cron job")
 
 	go func() {
diff --git a/tests/worker_test.go b/tests/worker_test.go
@@ -92,7 +92,7 @@ func TestWorkerWithWorkerErrorHandler(t *testing.T) {
 
 	client, err := queue.NewClient(redisConfig)
 	require.NoError(t, err, "Failed to create client")
-	_, err = client.Enqueue(jobType, map[string]interface{}{"key": "value"})
+	_, err = client.Enqueue(jobType, map[string]any{"key": "value"})
 	require.NoError(t, err, "Failed to enqueue job")
 
 	time.Sleep(2 * time.Second) // Adjusted wait time for job processing

Original file line number	Diff line number	Diff line change
`@@ -18,7 +18,7 @@ func main() {`
`18`	`18`	`}`
`19`	`19`
`20`	`20`	`jobType := "example_job"`
`21`		`- payload := map[string]interface{}{`
	`21`	`+ payload := map[string]any{`
`22`	`22`	`"input": "Hello, Queue!",`
`23`	`23`	`}`
`24`	`24`	`_, err = client.Enqueue(jobType, payload, queue.WithQueue("critical"), queue.WithRetention(time.Hour))`
Original file line number	Diff line number	Diff line change
`@@ -44,7 +44,7 @@ type ActiveJobInfo struct {`
`44`	`44`	JobPayload string `json:"job_payload"`
`45`	`45`	Queue string `json:"queue"`
`46`	`46`	StartedAt time.Time `json:"started_at"`
`47`		- DeadlineAt time.Time `json:"deadline_at,omitempty"`
	`47`	+ DeadlineAt time.Time `json:"deadline_at"`
`48`	`48`	`}`
`49`	`49`
`50`	`50`	`// Convert Asynq WorkerInfo to ActiveJobInfo.`