Refactor video handler: integrate S3 client and update initialization

Author: Prateet-Github

cmd/worker/main.go

@@ -6,6 +6,7 @@ import (
 	"github.com/Prateet-Github/worker-go/internal/config"
 	"github.com/Prateet-Github/worker-go/internal/handlers"
 	"github.com/Prateet-Github/worker-go/internal/queue"
+	"github.com/Prateet-Github/worker-go/internal/s3"
 
 	"github.com/hibiken/asynq"
 )
@@ -15,7 +16,10 @@ func main() {
 
 	server := queue.NewServer(cfg)
 
-	videoHandler := handlers.NewVideoHandler()
+	s3Client := s3.NewClient(cfg)
+	videoHandler := handlers.NewVideoHandler(
+		s3Client,
+	)
 
 	mux := asynq.NewServeMux()
 

internal/handlers/video.go

@@ -6,13 +6,20 @@ import (
 	"log"
 
 	"github.com/Prateet-Github/worker-go/internal/queue"
+	"github.com/aws/aws-sdk-go-v2/service/s3"
 	"github.com/hibiken/asynq"
 )
 
-type VideoHandler struct{}
+type VideoHandler struct {
+	s3Client *s3.Client
+}
 
-func NewVideoHandler() *VideoHandler {
-	return &VideoHandler{}
+func NewVideoHandler(
+	s3Client *s3.Client,
+) *VideoHandler {
+	return &VideoHandler{
+		s3Client: s3Client,
+	}
 }
 
 func (h *VideoHandler) ProcessVideo(

internal/s3/client.go

@@ -0,0 +1,32 @@
+package s3
+
+import (
+	"context"
+	"log"
+
+	"github.com/Prateet-Github/worker-go/internal/config"
+
+	awsconfig "github.com/aws/aws-sdk-go-v2/config"
+	"github.com/aws/aws-sdk-go-v2/credentials"
+	awss3 "github.com/aws/aws-sdk-go-v2/service/s3"
+)
+
+func NewClient(cfg *config.Config) *awss3.Client {
+	awsCfg, err := awsconfig.LoadDefaultConfig(
+		context.Background(),
+		awsconfig.WithRegion(cfg.AWSRegion),
+		awsconfig.WithCredentialsProvider(
+			credentials.NewStaticCredentialsProvider(
+				cfg.AWSAccessKeyID,
+				cfg.AWSSecretAccessKey,
+				"",
+			),
+		),
+	)
+
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	return awss3.NewFromConfig(awsCfg)
+}