(ctx context.Context, create *WebRefreshTokenMessage)
| 17 | } |
| 18 | |
| 19 | func (s *Store) CreateWebRefreshToken(ctx context.Context, create *WebRefreshTokenMessage) error { |
| 20 | q := qb.Q().Space(` |
| 21 | INSERT INTO web_refresh_token (token_hash, user_email, expires_at) |
| 22 | VALUES (?, ?, ?) |
| 23 | `, create.TokenHash, create.UserEmail, create.ExpiresAt) |
| 24 | |
| 25 | query, args, err := q.ToSQL() |
| 26 | if err != nil { |
| 27 | return err |
| 28 | } |
| 29 | |
| 30 | if _, err := s.GetDB().ExecContext(ctx, query, args...); err != nil { |
| 31 | return errors.Wrap(err, "failed to create web refresh token") |
| 32 | } |
| 33 | return nil |
| 34 | } |
| 35 | |
| 36 | func (s *Store) GetWebRefreshToken(ctx context.Context, tokenHash string) (*WebRefreshTokenMessage, error) { |
| 37 | q := qb.Q().Space(` |
no test coverage detected