extern/zrok
1
1
Fork 0
mirror of https://github.com/openziti/zrok.git synced 2024-11-26 01:54:09 +01:00
Code Issues Packages Projects Releases Wiki Activity

soft deletes for password_reset_request (#262)

Browse Source
This commit is contained in:
Michael Quigley 2023-03-10 11:14:01 -05:00
parent d900043fa3
commit 01dd77ca3b
No known key found for this signature in database
GPG Key ID: 9B60314A9DD20A62
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
controller/store/password_reset_request.go
View File

@ -30,7 +30,7 @@ func (self *Store) CreatePasswordResetRequest(prr *PasswordResetRequest, tx *sql
func (self *Store) FindPasswordResetRequestWithToken(token string, tx *sqlx.Tx) (*PasswordResetRequest, error) { func (self *Store) FindPasswordResetRequestWithToken(token string, tx *sqlx.Tx) (*PasswordResetRequest, error) {
prr := &PasswordResetRequest{} prr := &PasswordResetRequest{}
if err := tx.QueryRowx("select * from password_reset_requests where token = $1", token).StructScan(prr); err != nil { if err := tx.QueryRowx("select * from password_reset_requests where token = $1 and not deleted", token).StructScan(prr); err != nil {
return nil, errors.Wrap(err, "error selecting password_reset_requests by token") return nil, errors.Wrap(err, "error selecting password_reset_requests by token")
} }
return prr, nil return prr, nil
@ -40,10 +40,10 @@ func (self *Store) FindExpiredPasswordResetRequests(before time.Time, limit int,
var sql string var sql string
switch self.cfg.Type { switch self.cfg.Type {
case "postgres": case "postgres":
sql = "select * from password_reset_requests where created_at < $1 limit %d for update" sql = "select * from password_reset_requests where created_at < $1 and not deleted limit %d for update"
case "sqlite3": case "sqlite3":
sql = "select * from password_reset_requests where created_at < $1 limit %d" sql = "select * from password_reset_requests where created_at < $1 and not deleted limit %d"
default: default:
return nil, errors.Errorf("unknown database type '%v'", self.cfg.Type) return nil, errors.Errorf("unknown database type '%v'", self.cfg.Type)
} }
@ -64,7 +64,7 @@ func (self *Store) FindExpiredPasswordResetRequests(before time.Time, limit int,
} }
func (self *Store) DeletePasswordResetRequest(id int, tx *sqlx.Tx) error { func (self *Store) DeletePasswordResetRequest(id int, tx *sqlx.Tx) error {
stmt, err := tx.Prepare("delete from password_reset_requests where id = $1") stmt, err := tx.Prepare("update password_reset_requests set updated_at = current_timestamp, deleted = true where id = $1")
if err != nil { if err != nil {
return errors.Wrap(err, "error preparing password_reset_requests delete statement") return errors.Wrap(err, "error preparing password_reset_requests delete statement")
} }
@ -88,7 +88,7 @@ func (self *Store) DeleteMultiplePasswordResetRequests(ids []int, tx *sqlx.Tx) e
indexes[i] = fmt.Sprintf("$%d", i+1) indexes[i] = fmt.Sprintf("$%d", i+1)
} }
stmt, err := tx.Prepare(fmt.Sprintf("delete from password_reset_requests where id in (%s)", strings.Join(indexes, ","))) stmt, err := tx.Prepare(fmt.Sprintf("update password_reset_requests set updated_at = current_timestamp, deleted = true where id in (%s)", strings.Join(indexes, ",")))
if err != nil { if err != nil {
return errors.Wrap(err, "error preparing password_reset_requests delete multiple statement") return errors.Wrap(err, "error preparing password_reset_requests delete multiple statement")
} }