Skip to content

Commit 7ab3139

Browse files
Added Pending and Active seperate transactions
1 parent ffb2b55 commit 7ab3139

File tree

1 file changed

+9
-4
lines changed

1 file changed

+9
-4
lines changed

internal/session/socket.go

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -50,10 +50,15 @@ func (m *Manager) handleWebSocketCommands(conn *websocket.Conn, username, sessio
5050
if err := m.sendCurrentSession(conn, sessionID); err != nil {
5151
m.errCh <- fmt.Errorf("failed to send current session on command: %w", err)
5252
}
53-
case CtxStreamUserTransactions:
54-
/* push user transactions */
55-
if err := m.sendCurrentUserTransactions(conn, sessionID, 100); err != nil {
56-
m.errCh <- fmt.Errorf("failed to send current list of transactions on command: %w", err)
53+
case CtxStreamUserTransactionsResults:
54+
/* push user transactions results */
55+
if err := m.sendCurrentUserTransactionsResults(conn, sessionID, 100); err != nil {
56+
m.errCh <- fmt.Errorf("failed to send current list of results transactions on command: %w", err)
57+
}
58+
case CtxStreamUserTransactionsPending:
59+
/* push user transactions pending */
60+
if err := m.sendCurrentUserTransactionsPending(conn, sessionID, 100); err != nil {
61+
m.errCh <- fmt.Errorf("failed to send current list of results transactions on command: %w", err)
5762
}
5863
case CtxStreamUserArchiveSession:
5964
/* push archived sessions */

0 commit comments

Comments
 (0)