| 1710 | } |
| 1711 | |
| 1712 | func (c *DatabaseCollection) updateAllPrincipalsSequences(ctx context.Context) error { |
| 1713 | users, roles, err := c.allPrincipalIDs(ctx) |
| 1714 | if err != nil { |
| 1715 | return err |
| 1716 | } |
| 1717 | |
| 1718 | authr := c.Authenticator(ctx) |
| 1719 | |
| 1720 | for _, role := range roles { |
| 1721 | role, err := authr.GetRole(role) |
| 1722 | if err != nil { |
| 1723 | return err |
| 1724 | } |
| 1725 | err = c.regeneratePrincipalSequences(ctx, authr, role) |
| 1726 | if err != nil { |
| 1727 | return err |
| 1728 | } |
| 1729 | } |
| 1730 | |
| 1731 | for _, user := range users { |
| 1732 | user, err := authr.GetUser(user) |
| 1733 | if err != nil { |
| 1734 | return err |
| 1735 | } |
| 1736 | err = c.regeneratePrincipalSequences(ctx, authr, user) |
| 1737 | if err != nil { |
| 1738 | return err |
| 1739 | } |
| 1740 | } |
| 1741 | return nil |
| 1742 | } |
| 1743 | |
| 1744 | func (c *DatabaseCollection) regeneratePrincipalSequences(ctx context.Context, authr *auth.Authenticator, princ auth.Principal) error { |
| 1745 | nextSeq, err := c.sequences().nextSequence(ctx) |