Skip to content

Commit 8b1282e

Browse files
Modified to store pending transactions in txpending
1 parent f88643a commit 8b1282e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

internal/session/interact.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -170,15 +170,15 @@ func (m *Manager) ExpireSession(username string) error {
170170
}
171171

172172
/* add transaction to a session - assumes caller holds necessary locks */
173-
func (m *Manager) AddTransaction(session *Session, txn types.Transaction) error {
173+
func (m *Manager) AddTransaction(session *Session, txn *types.Transaction) error {
174174
/* push transaction into the queue from back */
175175
session.TransactionQueue.PushBack(txn)
176176

177177
/* convert transaction to correct type and save to Redis */
178178
// if tx, ok := txn.(*types.Transaction); ok {
179179

180180
// *tx was used here
181-
if err := m.saveTransactionResultsRedis(session, txn); err != nil {
181+
if err := m.SaveTransactionResultsRedis(session, txn, "txpending"); err != nil {
182182
return fmt.Errorf("failed to save transaction to Redis: %w", err)
183183
}
184184

0 commit comments

Comments
 (0)