Refactor queue package: improve Redis address formatting and enhance video task creation

Author: Prateet-Github

internal/queue/server.go

@@ -1,14 +1,16 @@
 package queue
 
 import (
+	"fmt"
+
 	"github.com/Prateet-Github/worker-go/internal/config"
 	"github.com/hibiken/asynq"
 )
 
 func NewServer(cfg *config.Config) *asynq.Server {
 	return asynq.NewServer(
 		asynq.RedisClientOpt{
-			Addr: cfg.RedisHost + ":" + cfg.RedisPort,
+			Addr: fmt.Sprintf("%s:%s", cfg.RedisHost, cfg.RedisPort),
 		},
 		asynq.Config{
 			Concurrency: 5,

internal/queue/tasks.go

@@ -1,10 +1,24 @@
 package queue
 
-const (
-	TypeProcessVideo = "video:process"
+import (
+	"encoding/json"
+
+	"github.com/hibiken/asynq"
 )
 
+const TypeProcessVideo = "video:process"
+
 type VideoTask struct {
 	VideoID string `json:"videoId"`
 	S3Key   string `json:"s3Key"`
 }
+
+func NewProcessVideoTask(payload VideoTask) (*asynq.Task, error) {
+	data, err := json.Marshal(payload)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return asynq.NewTask(TypeProcessVideo, data), nil
+}