Relax criteria for closing families

This commit is contained in:
vishnukvmd
2025-04-03 18:57:39 +05:30
parent c981af5470
commit d86f4de8ce

View File

@@ -57,27 +57,18 @@ func (repo *FamilyRepository) CloseFamily(ctx context.Context, adminID int64) er
if err != nil {
return stacktrace.Propagate(err, "")
}
affectResult, err := tx.ExecContext(ctx, `DELETE FROM families WHERE admin_id = $1`, adminID)
_, err = tx.ExecContext(ctx, `DELETE FROM families WHERE admin_id = $1`, adminID)
if err != nil {
tx.Rollback()
return stacktrace.Propagate(err, "")
}
affected, err := affectResult.RowsAffected()
if err != nil {
tx.Rollback()
return stacktrace.Propagate(err, "")
}
if affected != 1 {
tx.Rollback()
return stacktrace.Propagate(errors.New("exactly one row should be deleted"), "")
}
affectedRows, err := tx.ExecContext(ctx, `UPDATE users SET family_admin_id = null WHERE family_admin_id = $1`, adminID)
if err != nil {
tx.Rollback()
return stacktrace.Propagate(err, "")
}
affected, err = affectedRows.RowsAffected()
affected, err := affectedRows.RowsAffected()
if err != nil {
tx.Rollback()
return stacktrace.Propagate(err, "")