listAndCacheAllUsers is used for caching all users.
(ctx context.Context)
| 184 | |
| 185 | // listAndCacheAllUsers is used for caching all users. |
| 186 | func (s *Store) listAndCacheAllUsers(ctx context.Context) error { |
| 187 | tx, err := s.GetDB().BeginTx(ctx, nil) |
| 188 | if err != nil { |
| 189 | return err |
| 190 | } |
| 191 | defer tx.Rollback() |
| 192 | |
| 193 | users, err := listUserImpl(ctx, tx, &FindUserMessage{ShowDeleted: true}) |
| 194 | if err != nil { |
| 195 | return err |
| 196 | } |
| 197 | |
| 198 | if err := tx.Commit(); err != nil { |
| 199 | return err |
| 200 | } |
| 201 | |
| 202 | for _, user := range users { |
| 203 | s.userEmailCache.Add(user.Email, user) |
| 204 | } |
| 205 | return nil |
| 206 | } |
| 207 | |
| 208 | func listUserImpl(ctx context.Context, txn *sql.Tx, find *FindUserMessage) ([]*UserMessage, error) { |
| 209 | with := qb.Q() |
no test coverage detected