(ctx context.Context)
| 220 | } |
| 221 | |
| 222 | func (p *SQLite3Store) deleteExpired(ctx context.Context) error { |
| 223 | tx, err := p.db.BeginTx(ctx, nil) |
| 224 | if err != nil { |
| 225 | return err |
| 226 | } |
| 227 | defer tx.Rollback() |
| 228 | |
| 229 | _, err = tx.ExecContext(ctx, "DELETE FROM sessions WHERE expiry < ?", nowJulianDay()) |
| 230 | if err != nil { |
| 231 | return err |
| 232 | } |
| 233 | |
| 234 | if err = tx.Commit(); err != nil { |
| 235 | return err |
| 236 | } |
| 237 | |
| 238 | return nil |
| 239 | } |
| 240 | |
| 241 | func nowJulianDay() float64 { |
| 242 | return toJulianDay(time.Now().UTC()) |
no test coverage detected