From 5d45b5baad2ad2d2fff685e8eccb102c32dcabd6 Mon Sep 17 00:00:00 2001 From: Devon Hudson Date: Tue, 6 Dec 2022 13:56:04 -0700 Subject: [PATCH] Fix panic in database GetAsyncTransaction --- federationapi/storage/shared/storage.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/federationapi/storage/shared/storage.go b/federationapi/storage/shared/storage.go index d2924aaa2..289a71f50 100644 --- a/federationapi/storage/shared/storage.go +++ b/federationapi/storage/shared/storage.go @@ -384,7 +384,11 @@ func (d *Database) GetAsyncTransaction( return nil, nil, nil } - txns, err := d.FederationTransactionJSON.SelectTransactionJSON(ctx, nil, nids) + txns := map[int64][]byte{} + err = d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error { + txns, err = d.FederationTransactionJSON.SelectTransactionJSON(ctx, txn, nids) + return err + }) if err != nil { return nil, nil, fmt.Errorf("d.SelectTransactionJSON: %w", err) }