this repo has no description
correctly update pds id in database (#419)
+5
-1
+5
-1
bgs/bgs.go
+5
-1
bgs/bgs.go
···
1109
1109
log.Debugw("lost the race to create a new user", "did", did, "handle", handle, "existing_hand", exu.Handle)
1110
1110
if exu.PDS != peering.ID {
1111
1111
// User is now on a different PDS, update
1112
-
if err := s.db.Model(User{}).Where("id = ?", exu.ID).Update("pds", peering.ID).Error; err != nil {
1112
+
if err := s.db.Model(User{}).Where("id = ?", exu.Uid).Update("pds", peering.ID).Error; err != nil {
1113
1113
return nil, fmt.Errorf("failed to update users pds: %w", err)
1114
+
}
1115
+
1116
+
if err := s.db.Model(models.ActorInfo{}).Where("uid = ?", exu.Uid).Update("pds", peering.ID).Error; err != nil {
1117
+
return nil, fmt.Errorf("failed to update users pds on actorInfo: %w", err)
1114
1118
}
1115
1119
1116
1120
exu.PDS = peering.ID