send notifications on upvote, new answer and correct answer

config/config.go

@@ -48,6 +48,8 @@ func LoadConfig() *Config {
 
 		MONGODB_URL:  getEnvOrDefault("MONGODB_URL", ""),
 		MONGODB_NAME: getEnvOrDefault("MONGODB_NAME", ""),
+
+		NOTIFICATIONS_SERVICE: "http://" + getEnvOrDefault("NOTIFICATIONS_SERVICE", "") + ":8000",
 	}
 }
 

docs/docs.go

@@ -275,13 +275,6 @@ const docTemplate = `{
                         "name": "questionId",
                         "in": "path",
                         "required": true
-                    },
-                    {
-                        "type": "string",
-                        "description": "Answer ID",
-                        "name": "answerId",
-                        "in": "path",
-                        "required": true
                     }
                 ],
                 "responses": {

docs/swagger.json

@@ -267,13 +267,6 @@
                         "name": "questionId",
                         "in": "path",
                         "required": true
-                    },
-                    {
-                        "type": "string",
-                        "description": "Answer ID",
-                        "name": "answerId",
-                        "in": "path",
-                        "required": true
                     }
                 ],
                 "responses": {

docs/swagger.yaml

@@ -641,11 +641,6 @@ paths:
         name: questionId
         required: true
         type: string
-      - description: Answer ID
-        in: path
-        name: answerId
-        required: true
-        type: string
       responses:
         "200":
           description: Answer without answers

helm-chart/values.yaml

@@ -9,3 +9,4 @@ service:
 
 env:
   MONGODB_NAME: "classconnect-forum"
+  NOTIFICATIONS_SERVICE: "notifications-microservice"

internal/dto/push_dto.go

@@ -0,0 +1,11 @@
+package dto
+
+import "github.com/google/uuid"
+
+type PushRequest struct {
+	Ids		uuid.UUIDs `json:"to"`
+	Title   string     `json:"title"`
+	Body    string     `json:"body"`
+	Type    string     `json:"type"`
+	ID      string     `json:"id"`
+}

internal/handlers/answers/answer_test.go

@@ -81,7 +81,7 @@ func TestMain(m *testing.M) {
 		MAX_FILE_UPLOAD_SIZE: 10 * 1024 * 1024,
 	}
 
-	service = answer_service.NewAnswerService(forumRepo, conf)
+	service = answer_service.NewAnswerService(forumRepo, nil, conf)
 	answerHandler = answer_handler.NewAnswerHandler(service, conf)
 
 	// router usando UUID válido del primer usuario

internal/handlers/questions/question_test.go

@@ -64,7 +64,7 @@ func TestMain(m *testing.M) {
 		MAX_FILE_UPLOAD_SIZE: 10 * 1024 * 1024,
 	}
 
-	service = question_service.NewQuestionService(forumRepo, conf)
+	service = question_service.NewQuestionService(forumRepo, nil, conf)
 	questionHandler = question_handler.NewQuestionHandler(service, conf)
 
 	// router usando UUID válido del primer usuario

internal/router/answer_router.go

@@ -5,14 +5,15 @@
 	answer_handler "forum-microservice/internal/handlers/answers"
 	forum_repository "forum-microservice/internal/repository/forum"
 	answer_service "forum-microservice/internal/services/answers"
-
+	notification "forum-microservice/internal/utils/notifications"
 	"github.com/gin-gonic/gin"
 	"go.mongodb.org/mongo-driver/mongo"
 )
 
 func InitAnswerRoutes(r *gin.Engine, db *mongo.Database, conf *config.Config) {
 	forumRepository := forum_repository.NewForumRepository(db.Collection("forum"), conf)
-	questionService := answer_service.NewAnswerService(forumRepository, conf)
+	pushNotifier := notification.NewPushNotifier(&conf.NOTIFICATIONS_SERVICE, conf)
+	questionService := answer_service.NewAnswerService(forumRepository, pushNotifier, conf)
 	answerHandler := answer_handler.NewAnswerHandler(questionService, conf)
 
 	group := r.Group("/question/:questionId/")

internal/router/question_router.go

@@ -5,14 +5,16 @@
 	question_handler "forum-microservice/internal/handlers/questions"
 	forum_repository "forum-microservice/internal/repository/forum"
 	question_service "forum-microservice/internal/services/questions"
+	notifications "forum-microservice/internal/utils/notifications"
 
 	"github.com/gin-gonic/gin"
 	"go.mongodb.org/mongo-driver/mongo"
 )
 
 func InitQuestionRoutes(r *gin.Engine, db *mongo.Database, conf *config.Config) {
 	forumRepository := forum_repository.NewForumRepository(db.Collection("forum"), conf)
-	questionService := question_service.NewQuestionService(forumRepository, conf)
+	pushNotifier := notifications.NewPushNotifier(&conf.NOTIFICATIONS_SERVICE, conf)
+	questionService := question_service.NewQuestionService(forumRepository, pushNotifier, conf)
 	questionHandler := question_handler.NewQuestionHandler(questionService, conf)
 
 	group := r.Group("/")

internal/services/answers/answer.go

@@ -7,18 +7,22 @@
 	"forum-microservice/internal/errors"
 	"forum-microservice/internal/models"
 	"forum-microservice/internal/repository/forum"
+	notification "forum-microservice/internal/utils/notifications"
 
+	"github.com/google/uuid"
 	"go.mongodb.org/mongo-driver/bson/primitive"
 )
 
 type answerService struct {
 	repo forum.ForumRepository
+	noti notification.Notifier
 	conf *config.Config
 }
 
-func NewAnswerService(repo forum.ForumRepository, conf *config.Config) AnswerService {
+func NewAnswerService(repo forum.ForumRepository, noti notification.Notifier, conf *config.Config) AnswerService {
 	return &answerService{
 		repo: repo,
+		noti: noti,
 		conf: conf,
 	}
 }
@@ -28,6 +32,23 @@
 		return err
 	}
 
+	// Get original question
+	question, err := s.repo.GetQuestionByID(ctx, questionId)
+	if err != nil {
+		return err
+	}
+
+	// Continue if answer is on itself
+	if question.AuthorID.Subtype == answer.AuthorID.Subtype && bytes.Equal(question.AuthorID.Data, answer.AuthorID.Data) {
+		return nil
+	}
+	users := uuid.UUIDs{uuid.UUID(question.AuthorID.Data)}
+
+
+	if s.noti != nil {
+		s.noti.SendNewAnswer(&users, questionId)
+	}
+
 	return nil
 }
 
@@ -69,6 +90,22 @@
 		return err
 	}
 
+	// Get upvoted question
+	answer, err := s.repo.GetAnswerByID(ctx, questionId, answerId)
+	if err != nil {
+		return err
+	}
+
+	// Continue if upvote is on itself
+	if answer.AuthorID.Subtype == user_id.Subtype && bytes.Equal(answer.AuthorID.Data, user_id.Data) {
+		return nil
+	}
+	users := uuid.UUIDs{uuid.UUID(answer.AuthorID.Data)}
+
+	if s.noti != nil{
+		s.noti.SendUpvote(&users, questionId)
+	}
+
 	return nil
 }
 
@@ -98,7 +135,7 @@
 		return errors.NewUnauthorizedError("unauthorized: user cant edit this answer")
 	}
 
-	_, err = s.repo.GetAnswerByID(ctx, questionId, answerId)
+	answer, err := s.repo.GetAnswerByID(ctx, questionId, answerId)
 	if err != nil {
 		return err
 	}
@@ -107,6 +144,12 @@
 		return err
 	}
 
+	users := uuid.UUIDs{uuid.UUID(answer.AuthorID.Data)}
+
+	if s.noti != nil {
+		s.noti.SendCorrectAnswer(&users, questionId)
+	}
+
 	return nil
 }
 

internal/services/answers/answer_test.go

@@ -65,7 +65,7 @@ func TestMain(m *testing.M) {
 		}
 	}
 
-	answerService = answer.NewAnswerService(forumRepo, nil)
+	answerService = answer.NewAnswerService(forumRepo, nil, nil)
 
 	m.Run()
 }
@@ -79,7 +79,7 @@ func TestAnswer_PostAnswer(t *testing.T) {
 	uid := uuid.New()
 	binaryUUID := utils.UuidToBinary(uid)
 	a := models.Answer{
-		Content:       "test-title-4",
+		Content:     "test-title-4",
 		AuthorID:    binaryUUID,
 	}
 	err := answerService.PostAnswer(t.Context(), &a, &q_ids[0])

internal/services/questions/question.go

@@ -9,18 +9,22 @@
 	"forum-microservice/internal/models"
 	"forum-microservice/internal/repository/forum"
 	"forum-microservice/internal/utils"
+	notification "forum-microservice/internal/utils/notifications"
 
+	"github.com/google/uuid"
 	"go.mongodb.org/mongo-driver/bson/primitive"
 )
 
 type questionService struct {
 	repo forum.ForumRepository
+	noti notification.Notifier
 	conf *config.Config
 }
 
-func NewQuestionService(repo forum.ForumRepository, conf *config.Config) QuestionService {
+func NewQuestionService(repo forum.ForumRepository, noti notification.Notifier, conf *config.Config) QuestionService {
 	return &questionService{
 		repo: repo,
+		noti: noti,
 		conf: conf,
 	}
 }
@@ -30,8 +34,6 @@
 		return err
 	}
 
-
-
 	return nil
 }
 
@@ -157,6 +159,22 @@
 		return err
 	}
 
+	// Get upvoted question
+	question, err := s.repo.GetQuestionByID(ctx, questionId)
+	if err != nil {
+		return err
+	}
+
+	// Continue if upvote is on itself
+	if question.AuthorID.Subtype == user_id.Subtype && bytes.Equal(question.AuthorID.Data, user_id.Data) {
+		return nil
+	}
+	users := uuid.UUIDs{uuid.UUID(question.AuthorID.Data)}
+
+	if s.noti != nil {
+		s.noti.SendUpvote(&users, questionId)
+	}
+
 	return nil
 }
 

internal/services/questions/question_test.go

@@ -50,7 +50,7 @@ func TestMain(m *testing.M) {
 		ids = append(ids, q.ID)
 	}
 
-	questionService = question.NewQuestionService(forumRepo, nil)
+	questionService = question.NewQuestionService(forumRepo, nil, nil)
 
 	m.Run()
 }
@@ -231,7 +231,7 @@ func TestQuestion_GetQuestionWithAnswersByID_SetDefaults(t *testing.T) {
 	}
 	_ = repo.CreateQuestion(context.Background(), &q)
 
-	service := question.NewQuestionService(repo, nil)
+	service := question.NewQuestionService(repo, nil, nil)
 
 	// filtros sin inicializar (Page y Limit nil)
 	var filters dto.FiltersDTO
@@ -279,7 +279,7 @@ func TestQuestion_GetQuestionsByCourse_SetDefaults(t *testing.T) {
 	}
 	_ = repo.CreateQuestion(context.Background(), &q)
 
-	service := question.NewQuestionService(repo, nil)
+	service := question.NewQuestionService(repo, nil, nil)
 
 	// filtros sin inicializar (Page y Limit nil)
 	var filters dto.FiltersDTO

internal/utils/notifications/notification.go

@@ -0,0 +1,14 @@
+package notification
+
+import (
+	"github.com/google/uuid"
+	"go.mongodb.org/mongo-driver/bson/primitive"
+)
+
+type Notifier interface {
+	SendUpvote(users *uuid.UUIDs, questionId *primitive.ObjectID)
+
+	SendCorrectAnswer(users *uuid.UUIDs, questionId *primitive.ObjectID)
+
+	SendNewAnswer(users *uuid.UUIDs, questionId *primitive.ObjectID)
+}