extern/hishtory
1
0
Fork 0
mirror of https://github.com/ddworken/hishtory.git synced 2025-02-16 18:41:03 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix transaction for creating deletion requests so that it actually uses the passed in tx

Browse Source
This commit is contained in:
David Dworken 2023-10-15 11:49:36 -07:00
parent 299617ba7e
commit 67f2ed6de1
No known key found for this signature in database
1 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
backend/server/internal/database/db.go
View File

@ -257,22 +257,26 @@ func (db *DB) DeletionRequestCreate(ctx context.Context, request *shared.Deletio
fmt.Printf("db.DeletionRequestCreate: Found %d devices\n", len(devices))
return db.Transaction(func(tx *gorm.DB) error {
err = db.Transaction(func(tx *gorm.DB) error {
for _, device := range devices {
request.DestinationDeviceId = device.DeviceId
tx := db.WithContext(ctx).Create(&request)
tx := tx.WithContext(ctx).Create(&request)
if tx.Error != nil {
return fmt.Errorf("create: tx.Error: %w", tx.Error)
}
}
numDeleted, err := db.DeleteMessagesFromBackend(ctx, userID, request.Messages.Ids)
if err != nil {
return fmt.Errorf("db.DeleteMessagesFromBackend: %w", err)
}
fmt.Printf("addDeletionRequestHandler: Deleted %d rows in the backend\n", numDeleted)
return nil
})
if err != nil {
return err
}
numDeleted, err := db.DeleteMessagesFromBackend(ctx, userID, request.Messages.Ids)
if err != nil {
return fmt.Errorf("db.DeleteMessagesFromBackend: %w", err)
}
fmt.Printf("addDeletionRequestHandler: Deleted %d rows in the backend\n", numDeleted)
return nil
}
func (db *DB) FeedbackCreate(ctx context.Context, feedback *shared.Feedback) error {