From ab57b30883a49060d8f7ca4ec056c8f7ed007805 Mon Sep 17 00:00:00 2001
From: Devon Hudson <devonhudson@librem.one>
Date: Thu, 15 Dec 2022 10:41:06 -0700
Subject: [PATCH] Delete relay json along with queue entry

---
 relayapi/storage/shared/storage.go | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/relayapi/storage/shared/storage.go b/relayapi/storage/shared/storage.go
index 04045ae92..468c3b861 100644
--- a/relayapi/storage/shared/storage.go
+++ b/relayapi/storage/shared/storage.go
@@ -88,6 +88,7 @@ func (d *Database) CleanAsyncTransactions(
 	for i, receipt := range receipts {
 		nids[i] = receipt.GetNID()
 	}
+
 	err := d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error {
 		err := d.RelayQueue.DeleteQueueEntries(ctx, txn, userID.Domain(), nids)
 		return err
@@ -96,6 +97,14 @@ func (d *Database) CleanAsyncTransactions(
 		return fmt.Errorf("d.deleteQueueEntries: %w", err)
 	}
 
+	err = d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error {
+		err := d.RelayQueueJSON.DeleteQueueJSON(ctx, txn, nids)
+		return err
+	})
+	if err != nil {
+		return fmt.Errorf("d.deleteQueueJSON: %w", err)
+	}
+
 	return nil
 }