Tests

internal/repository/forum/mongo_test.go

@@ -17,6 +17,7 @@ import (
 	"go.mongodb.org/mongo-driver/mongo/options"
 )
 
+
 // MockCollection es una implementación mock de MongoCollection
 type MockCollection struct {
 	mock.Mock
@@ -979,6 +980,11 @@ func TestAnswerDeleteCorrect(t *testing.T) {
 	})
 }
 
+type Cursor interface {
+    All(context.Context, interface{}) error
+    Close(context.Context) error
+}
+
 // MockCursor es una implementación mock de mongo.Cursor
 type MockCursor struct {
 	mock.Mock

internal/services/answers/answer_test.go

@@ -86,6 +86,19 @@ func TestAnswer_PostAnswer(t *testing.T) {
 	assert.NoError(t, err)
 }
 
+func TestAnswer_PostAnswer_QuestionNotFound(t *testing.T) {
+    uid := uuid.New()
+    binaryUUID := utils.UuidToBinary(uid)
+    a := models.Answer{
+        Content:  "respuesta a pregunta inexistente",
+        AuthorID: binaryUUID,
+    }
+    nonExistentQID := primitive.NewObjectID()
+
+    err := answerService.PostAnswer(t.Context(), &a, &nonExistentQID)
+    assert.Error(t, err)
+}
+
 
 /* EDIT ANSWER */
 
@@ -263,6 +276,15 @@ func TestAnswer_DeleteVoteAnswer(t *testing.T) {
 	assert.NoError(t, err2)
 }
 
+func TestAnswer_DeleteVoteAnswer_NeverVoted(t *testing.T) {
+    q_id := q_ids[1]
+    a_id := a_ids[1]
+    user := binaryUUIDs[2]
+
+    err := answerService.DeleteVoteAnswer(context.Background(), &q_id, &a_id, &user)
+    assert.Error(t, err)
+}
+
 
 /* ANSWER SELECT CORRECT */
 // TestAnswer_SelectCorrectAnswer tests the SelectCorrectAnswer method of the AnswerService.
@@ -281,7 +303,6 @@ func TestAnswer_SelectCorrectAnswer(t *testing.T) {
 	err := answerService.SelectCorrectAnswer(ctx, &q_id, &a_id, &userBinary)
 	assert.NoError(t, err)
 }
-
 func TestAnswer_SelectCorrectAnswer_NotFound(t *testing.T) {
 	// Tomamos una de las preguntas creadas en TestMain
 	q_id := q_ids[0]

internal/utils/notifications/push_test.go

@@ -0,0 +1,85 @@
+package notification
+
+import (
+    "net/http"
+    "net/http/httptest"
+    "testing"
+
+    "forum-microservice/config"
+    "forum-microservice/internal/dto"
+
+    "github.com/google/uuid"
+    "github.com/stretchr/testify/assert"
+    "go.mongodb.org/mongo-driver/bson/primitive"
+    "encoding/json"
+    "io"
+)
+
+func TestPushNotifier_SendUpvote(t *testing.T) {
+    var received dto.PushRequest
+    server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+        assert.Equal(t, "/push", r.URL.Path)
+        body, _ := io.ReadAll(r.Body)
+        _ = json.Unmarshal(body, &received)
+        w.WriteHeader(http.StatusOK)
+    }))
+    defer server.Close()
+
+    conf := &config.Config{}
+    url := server.URL
+    notifier := NewPushNotifier(&url, conf)
+
+    users := uuid.UUIDs{uuid.New()}
+    qid := primitive.NewObjectID()
+    notifier.SendUpvote(&users, &qid)
+
+    assert.Equal(t, "Forum Upvote", received.Title)
+    assert.Equal(t, "Your post has received a new upvote!", received.Body)
+    assert.Equal(t, qid.Hex(), received.ID)
+}
+
+func TestPushNotifier_SendCorrectAnswer(t *testing.T) {
+    var received dto.PushRequest
+    server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+        assert.Equal(t, "/push", r.URL.Path)
+        body, _ := io.ReadAll(r.Body)
+        _ = json.Unmarshal(body, &received)
+        w.WriteHeader(http.StatusOK)
+    }))
+    defer server.Close()
+
+    conf := &config.Config{}
+    url := server.URL
+    notifier := NewPushNotifier(&url, conf)
+
+    users := uuid.UUIDs{uuid.New()}
+    qid := primitive.NewObjectID()
+    notifier.SendCorrectAnswer(&users, &qid)
+
+    assert.Equal(t, "Forum Correct Answer", received.Title)
+    assert.Equal(t, "Your post has been selected as the correct answer!", received.Body)
+    assert.Equal(t, qid.Hex(), received.ID)
+}
+
+func TestPushNotifier_SendNewAnswer(t *testing.T) {
+    var received dto.PushRequest
+    server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+        assert.Equal(t, "/push", r.URL.Path)
+        body, _ := io.ReadAll(r.Body)
+        _ = json.Unmarshal(body, &received)
+        w.WriteHeader(http.StatusOK)
+    }))
+    defer server.Close()
+
+    conf := &config.Config{}
+    url := server.URL
+    notifier := NewPushNotifier(&url, conf)
+
+    users := uuid.UUIDs{uuid.New()}
+    qid := primitive.NewObjectID()
+    notifier.SendNewAnswer(&users, &qid)
+
+    assert.Equal(t, "Forum New Answer", received.Title)
+    assert.Equal(t, "Your question has received a new answer!", received.Body)
+    assert.Equal(t, qid.Hex(), received.ID)
+}

internal/utils/utils_test.go

@@ -0,0 +1,80 @@
+package utils_test
+
+import (
+    "testing"
+
+    "forum-microservice/internal/utils"
+
+    "github.com/google/uuid"
+    "github.com/stretchr/testify/assert"
+    "go.mongodb.org/mongo-driver/bson/primitive"
+)
+
+func TestUuidToBinary(t *testing.T) {
+    u := uuid.New()
+    bin := utils.UuidToBinary(u)
+
+    assert.Equal(t, byte(4), bin.Subtype)
+    assert.Equal(t, u[:], bin.Data)
+}
+
+func TestBinaryToUUID_Success(t *testing.T) {
+    u := uuid.New()
+    bin := utils.UuidToBinary(u)
+
+    result, err := utils.BinaryToUUID(bin)
+    assert.NoError(t, err)
+    assert.Equal(t, u, result)
+}
+
+func TestBinaryToUUID_InvalidSubtype(t *testing.T) {
+    u := uuid.New()
+    bin := primitive.Binary{
+        Subtype: 0x00, // inválido
+        Data:    u[:],
+    }
+
+    result, err := utils.BinaryToUUID(bin)
+    assert.Error(t, err)
+    assert.Equal(t, uuid.Nil, result)
+}
+
+func TestBinaryToUUID_InvalidData(t *testing.T) {
+    bin := primitive.Binary{
+        Subtype: 0x04,
+        Data:    []byte{1, 2, 3}, // tamaño incorrecto
+    }
+
+    result, err := utils.BinaryToUUID(bin)
+    assert.Error(t, err)
+    assert.Equal(t, uuid.Nil, result)
+}
+
+func TestOrder_ToMongoSort(t *testing.T) {
+    assert.Equal(t, 1, utils.Ascending.ToMongoSort())
+    assert.Equal(t, -1, utils.Descending.ToMongoSort())
+
+    // Valor fuera de rango (default)
+    var invalidOrder utils.Order = 42
+    assert.Equal(t, 1, invalidOrder.ToMongoSort())
+}
+
+func TestGetUserVote(t *testing.T) {
+    user := primitive.Binary{Subtype: 4, Data: []byte{1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16}}
+    other := primitive.Binary{Subtype: 4, Data: []byte{9, 9, 9, 9, 9, 9, 9, 9, 9, 9, 9, 9, 9, 9, 9, 9}}
+
+    // Caso: upvote previo
+    upvotes := []primitive.Binary{user}
+    downvotes := []primitive.Binary{}
+    assert.Equal(t, 1, utils.GetUserVote(upvotes, downvotes, &user))
+
+    // Caso: downvote previo
+    upvotes = []primitive.Binary{}
+    downvotes = []primitive.Binary{user}
+    assert.Equal(t, -1, utils.GetUserVote(upvotes, downvotes, &user))
+
+    // Caso: user no voto
+    upvotes = []primitive.Binary{other}
+    downvotes = []primitive.Binary{other}
+    assert.Equal(t, 0, utils.GetUserVote(upvotes, downvotes, &user))
+}