tests: add thumb handler subtests

Author: sirioneto-bling

internal/adapters/rest/handler/thumb_handler_test.go

@@ -3,6 +3,7 @@ package handler
 import (
 	"bytes"
 	"encoding/json"
+	"errors"
 	"net/http"
 	"net/http/httptest"
 	"testing"
@@ -52,6 +53,42 @@ func TestCreateProcess(t *testing.T) {
 
 		assert.Equal(t, http.StatusBadRequest, w.Code)
 	})
+
+	t.Run("service error", func(t *testing.T) {
+		mockService.On("CreateProcessAsync", mock.AnythingOfType("*ports.CreateProcessRequest")).
+			Return(errors.New("service error")).Once()
+
+		body := CreateProcessRequest{URL: "https://example.com/video.mp4"}
+		jsonBody, _ := json.Marshal(body)
+
+		w := httptest.NewRecorder()
+		req, _ := http.NewRequest("POST", "/thumbs", bytes.NewBuffer(jsonBody))
+		req.Header.Set("Content-Type", "application/json")
+		router.ServeHTTP(w, req)
+
+		assert.Equal(t, http.StatusInternalServerError, w.Code)
+
+		var response ErrorResponse
+		err := json.Unmarshal(w.Body.Bytes(), &response)
+		assert.NoError(t, err)
+		assert.Equal(t, "service error", response.Error)
+	})
+
+	t.Run("api bind json error", func(t *testing.T) {
+		invalidJSON := []byte(`{"url": invalid-json}`)
+
+		w := httptest.NewRecorder()
+		req, _ := http.NewRequest("POST", "/thumbs", bytes.NewBuffer(invalidJSON))
+		req.Header.Set("Content-Type", "application/json")
+		router.ServeHTTP(w, req)
+
+		assert.Equal(t, http.StatusBadRequest, w.Code)
+
+		var response ErrorResponse
+		err := json.Unmarshal(w.Body.Bytes(), &response)
+		assert.NoError(t, err)
+		assert.Equal(t, "Invalid request format", response.Error)
+	})
 }
 
 func TestUpdateProcess(t *testing.T) {
@@ -82,6 +119,66 @@ func TestUpdateProcess(t *testing.T) {
 
 		assert.Equal(t, http.StatusOK, w.Code)
 	})
+
+	t.Run("api bind ID param error", func(t *testing.T) {
+		body := UpdateProcessRequest{
+			Status:        "completed",
+			ThumbnailPath: "path/to/thumbnail.jpg",
+		}
+		jsonBody, _ := json.Marshal(body)
+
+		w := httptest.NewRecorder()
+
+		req, _ := http.NewRequest("PUT", "/thumbs/invalid-uuid", bytes.NewBuffer(jsonBody))
+		req.Header.Set("Content-Type", "application/json")
+		router.ServeHTTP(w, req)
+
+		assert.Equal(t, http.StatusBadRequest, w.Code)
+
+		var response ErrorResponse
+		err := json.Unmarshal(w.Body.Bytes(), &response)
+		assert.NoError(t, err)
+		assert.Equal(t, "Process ID is required", response.Error)
+	})
+
+	t.Run("api bind json error", func(t *testing.T) {
+		invalidJSON := []byte(`{"status": invalid-json}`)
+
+		w := httptest.NewRecorder()
+		req, _ := http.NewRequest("PUT", "/thumbs/"+mockedUUID.String(), bytes.NewBuffer(invalidJSON))
+		req.Header.Set("Content-Type", "application/json")
+		router.ServeHTTP(w, req)
+
+		assert.Equal(t, http.StatusBadRequest, w.Code)
+
+		var response ErrorResponse
+		err := json.Unmarshal(w.Body.Bytes(), &response)
+		assert.NoError(t, err)
+		assert.Equal(t, "Invalid request format", response.Error)
+	})
+
+	t.Run("service error", func(t *testing.T) {
+		mockService.On("UpdateProcess", mock.AnythingOfType("*ports.UpdateProcessRequest")).
+			Return(nil, errors.New("service error")).Once()
+
+		body := UpdateProcessRequest{
+			Status:        "completed",
+			ThumbnailPath: "path/to/thumbnail.jpg",
+		}
+		jsonBody, _ := json.Marshal(body)
+
+		w := httptest.NewRecorder()
+		req, _ := http.NewRequest("PUT", "/thumbs/"+mockedUUID.String(), bytes.NewBuffer(jsonBody))
+		req.Header.Set("Content-Type", "application/json")
+		router.ServeHTTP(w, req)
+
+		assert.Equal(t, http.StatusInternalServerError, w.Code)
+
+		var response ErrorResponse
+		err := json.Unmarshal(w.Body.Bytes(), &response)
+		assert.NoError(t, err)
+		assert.Equal(t, "service error", response.Error)
+	})
 }
 
 func TestListProcesses(t *testing.T) {

internal/config/config_test.go

@@ -89,23 +89,3 @@ func TestLoad(t *testing.T) {
 		})
 	}
 }
-
-// Example of a test for a function that uses the config
-func TestSomethingThatUsesConfig(t *testing.T) {
-	// Set necessary environment variables
-	os.Setenv("S3_BUCKET", "test-bucket")
-	os.Setenv("SQS_QUEUE_URL", "test-queue")
-	defer func() {
-		os.Unsetenv("S3_BUCKET")
-		os.Unsetenv("SQS_QUEUE_URL")
-	}()
-
-	cfg, err := Load()
-	assert.NoError(t, err)
-
-	// Now you can use cfg in your assertions or test logic
-	assert.Equal(t, "test-bucket", cfg.S3.Bucket)
-	assert.Equal(t, "test-queue", cfg.SQS.QueueURL)
-
-	// ... your test logic here ...
-}