mirror of
https://github.com/getAlby/hub.git
synced 2026-08-13 12:33:39 +02:00
fix: delete all request and response events rather than trying to delete orphans (#1476)
fix: delete request and response events rather than trying to delete orphans
This commit is contained in:
parent
b1484228ad
commit
7dc8ff130f
1 changed files with 5 additions and 5 deletions
|
|
@ -20,18 +20,18 @@ var _202508041712_delete_non_cascade_deleted_records = &gormigrate.Migration{
|
|||
|
||||
if err := db.Transaction(func(tx *gorm.DB) error {
|
||||
|
||||
// delete orphaned app permissions
|
||||
if err := tx.Exec(`DELETE FROM app_permissions
|
||||
WHERE app_id NOT IN (SELECT id FROM apps);`).Error; err != nil {
|
||||
WHERE app_id NOT IN (SELECT id FROM apps)`).Error; err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if err := tx.Exec(`DELETE FROM request_events
|
||||
WHERE app_id NOT IN (SELECT id FROM apps);`).Error; err != nil {
|
||||
// delete request and response events, later we will setup a task to delete excess events
|
||||
if err := tx.Exec(`DELETE FROM request_events`).Error; err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if err := tx.Exec(`DELETE FROM response_events
|
||||
WHERE request_id NOT IN (SELECT id FROM request_events);`).Error; err != nil {
|
||||
if err := tx.Exec(`DELETE FROM response_events`).Error; err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue