correctly update pds id in database (#419)

bluesky-social · Nov 6, 2023 · 3f7c1d3 · 3f7c1d3
2 parents 7be9693 + ed92df1
commit 3f7c1d3
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/bgs/bgs.go b/bgs/bgs.go
@@ -1109,10 +1109,14 @@ func (s *BGS) createExternalUser(ctx context.Context, did string) (*models.Actor
 		log.Debugw("lost the race to create a new user", "did", did, "handle", handle, "existing_hand", exu.Handle)
 		if exu.PDS != peering.ID {
 			// User is now on a different PDS, update
-			if err := s.db.Model(User{}).Where("id = ?", exu.ID).Update("pds", peering.ID).Error; err != nil {
+			if err := s.db.Model(User{}).Where("id = ?", exu.Uid).Update("pds", peering.ID).Error; err != nil {
 				return nil, fmt.Errorf("failed to update users pds: %w", err)
 			}
 
+			if err := s.db.Model(models.ActorInfo{}).Where("uid = ?", exu.Uid).Update("pds", peering.ID).Error; err != nil {
+				return nil, fmt.Errorf("failed to update users pds on actorInfo: %w", err)
+			}
+
 			exu.PDS = peering.ID
 		}