From fab9fabc18ce640aad2eae49e9c4359471a1c73b Mon Sep 17 00:00:00 2001 From: Zak Date: Mon, 8 Apr 2024 22:45:07 +0100 Subject: [PATCH] fix(badges): Mongo field is 'badges', not 'badge' --- internal/app/badge/service.go | 2 +- internal/repository/mongo_badge.go | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/app/badge/service.go b/internal/app/badge/service.go index abe5ba3..016e316 100644 --- a/internal/app/badge/service.go +++ b/internal/app/badge/service.go @@ -112,7 +112,7 @@ func (s *serviceImpl) RemoveBadgeFromPlayer(ctx context.Context, playerId uuid.U player.ActiveBadge = s.calculateActiveBadge(player.Badges) } - s.log.Debugw("Updating badge", "playerId", playerId, "badge", player.Badges, "activeBadge", player.ActiveBadge) + s.log.Debugw("Updating badge", "playerId", playerId, "badges", player.Badges, "activeBadge", player.ActiveBadge) if err := s.repo.UpdatePlayerBadgesAndActive(ctx, playerId, player.Badges, player.ActiveBadge); err != nil { return fmt.Errorf("failed to update player: %w", err) } diff --git a/internal/repository/mongo_badge.go b/internal/repository/mongo_badge.go index 8d1ea7b..a74da4a 100644 --- a/internal/repository/mongo_badge.go +++ b/internal/repository/mongo_badge.go @@ -29,7 +29,7 @@ func (m *mongoRepository) UpdatePlayerBadgesAndActive(ctx context.Context, playe ctx, cancel := context.WithTimeout(ctx, 5*time.Second) defer cancel() - update := bson.M{"$set": bson.M{"badge": badges}} + update := bson.M{"$set": bson.M{"badges": badges}} if activeBadge != nil { update["$set"].(bson.M)["activeBadge"] = activeBadge } else { @@ -49,7 +49,7 @@ func (m *mongoRepository) AddPlayerBadge(ctx context.Context, playerId uuid.UUID ctx, cancel := context.WithTimeout(ctx, 5*time.Second) defer cancel() - result, err := m.playerCollection.UpdateOne(ctx, bson.M{"_id": playerId}, bson.M{"$addToSet": bson.M{"badge": badgeId}}) + result, err := m.playerCollection.UpdateOne(ctx, bson.M{"_id": playerId}, bson.M{"$addToSet": bson.M{"badges": badgeId}}) if err != nil { return 0, err } @@ -61,7 +61,7 @@ func (m *mongoRepository) RemovePlayerBadge(ctx context.Context, playerId uuid.U ctx, cancel := context.WithTimeout(ctx, 5*time.Second) defer cancel() - result, err := m.playerCollection.UpdateOne(ctx, bson.M{"_id": playerId}, bson.M{"$pull": bson.M{"badge": badgeId}}) + result, err := m.playerCollection.UpdateOne(ctx, bson.M{"_id": playerId}, bson.M{"$pull": bson.M{"badges": badgeId}}) if err != nil { return 0, err }