Method UpsertUserByEmail

internal/services/user.go:30–67

(ctx context.Context, user *models.User)

}

func (s *UserService) UpsertUserByEmail(ctx context.Context, user *models.User) (*models.User, error) {
	if user == nil || user.Email == "" {
		return nil, shared.ErrInvalidUser()
	}

	existingUser, err := s.GetUserByEmail(ctx, user.Email)
	if err != nil && err != mongo.ErrNoDocuments {
		return nil, err
	}

	if err == mongo.ErrNoDocuments {
		user.ID = bson.NewObjectID()
		user.CreatedAt = bson.NewDateTimeFromTime(time.Now())
		user.UpdatedAt = bson.NewDateTimeFromTime(time.Now())

		// Initialize with default settings for new users
		user.Settings = s.GetDefaultSettings()

		_, err := s.userCollection.InsertOne(ctx, user)
		if err != nil {
			return nil, err
		}
		return user, nil
	} else {
		user.ID = existingUser.ID
		user.CreatedAt = existingUser.CreatedAt
		user.UpdatedAt = bson.NewDateTimeFromTime(time.Now())
		user.Settings = existingUser.Settings

		filter := bson.M{"email": user.Email}
		update := bson.M{"$set": user}
		_, err := s.userCollection.UpdateOne(ctx, filter, update)
		if err != nil {
			return nil, err
		}
		return user, nil
	}
}

func (s *UserService) GetUserByID(ctx context.Context, userID bson.ObjectID) (*models.User, error) {
	result := s.userCollection.FindOne(ctx, bson.M{"_id": userID})