get points for reaction

Author: Pazl27

rocket-backend/integration-tests/mocks/database_mock.go

@@ -52,6 +52,11 @@ type MockDB struct {
 	GetChallengeByIDFunc               func(challengeID uuid.UUID) (*types.Challenge, error)
 	SaveActivityFunc                   func(userID uuid.UUID, message string) error
 	GetActivitiesForUserAndFriendsFunc func(userID uuid.UUID) ([]types.ActivityWithUser, error)
+	SaveChatMessageFunc                func(userID uuid.UUID, message string, timestamp string) (uuid.UUID, error)
+	GetChatMessagesFunc                func(userID uuid.UUID) ([]types.ChatMessage, error)
+	AddReactionToChatMessageFunc       func(userID uuid.UUID, messageID uuid.UUID) error
+	CountReactionsForMessageFunc       func(messageID uuid.UUID) (int, error)
+	GetIDByMessageIDFunc               func(messageID uuid.UUID) (uuid.UUID, error)
 }
 
 func (m *MockDB) ExecuteRawSQL(query string) (sql.Result, error) {
@@ -347,3 +352,38 @@ func (m *MockDB) DeleteRun(runID uuid.UUID) error {
 	}
 	return nil
 }
+
+func (m *MockDB) SaveChatMessage(userID uuid.UUID, message string, timestamp string) (uuid.UUID, error) {
+	if m.SaveChatMessageFunc != nil {
+		return m.SaveChatMessageFunc(userID, message, timestamp)
+	}
+	return uuid.Nil, nil
+}
+
+func (m *MockDB) GetChatMessages(userID uuid.UUID) ([]types.ChatMessage, error) {
+	if m.GetChatMessagesFunc != nil {
+		return m.GetChatMessagesFunc(userID)
+	}
+	return nil, nil
+}
+
+func (m *MockDB) AddReactionToChatMessage(userID uuid.UUID, messageID uuid.UUID) error {
+	if m.AddReactionToChatMessageFunc != nil {
+		return m.AddReactionToChatMessageFunc(userID, messageID)
+	}
+	return nil
+}
+
+func (m *MockDB) CountReactionsForMessage(messageID uuid.UUID) (int, error) {
+	if m.CountReactionsForMessageFunc != nil {
+		return m.CountReactionsForMessageFunc(messageID)
+	}
+	return 0, nil
+}
+
+func (m *MockDB) GetIDByMessageID(messageID uuid.UUID) (uuid.UUID, error) {
+	if m.GetIDByMessageIDFunc != nil {
+		return m.GetIDByMessageIDFunc(messageID)
+	}
+	return uuid.Nil, nil
+}

rocket-backend/internal/database/chat_messages_table.go

@@ -91,3 +91,14 @@ func (s *service) CountReactionsForMessage(messageID uuid.UUID) (int, error) {
     err := s.db.QueryRow(query, messageID).Scan(&count)
     return count, err
 }
+
+func (s *service) GetIDByMessageID(messageID uuid.UUID) (uuid.UUID, error) {
+	query := `SELECT user_id FROM chat_messages WHERE id = $1`
+	var userID uuid.UUID
+	err := s.db.QueryRow(query, messageID).Scan(&userID)
+	if err != nil {
+		logger.Error("Failed to get user ID by message ID", err)
+		return uuid.Nil, fmt.Errorf("%w: %v", custom_error.ErrFailedToRetrieveData, err)
+	}
+	return userID, nil
+}

rocket-backend/internal/database/database.go

@@ -90,6 +90,7 @@ type Service interface {
 	GetChatMessages(userID uuid.UUID) ([]types.ChatMessage, error)
 	AddReactionToChatMessage(userID uuid.UUID, messageID uuid.UUID) error
 	CountReactionsForMessage(messageID uuid.UUID) (int, error)
+	GetIDByMessageID(messageID uuid.UUID) (uuid.UUID, error)
 }
 
 type service struct {

rocket-backend/internal/server/chat_ws.go

@@ -125,6 +125,14 @@ func (s *Server) ChatWebSocketHandler(hub *ChatHub) gin.HandlerFunc {
 				if countErr != nil {
 					logger.Error("Failed to count reactions for message:", countErr)
 				}
+				resiver, err := s.db.GetIDByMessageID(messageID)
+				if err != nil {
+					logger.Error("Failed to get user ID by message ID:", err)
+				}
+				err = s.db.UpdateRocketPoints(resiver, 10)
+				if err != nil {
+					logger.Error("Failed to add reaction points for user:", userUUID.String(), "error:", err)
+				}
 				// Broadcast reaction event
 				reactionEvent := map[string]any{
 					"type":      "reaction",