Quantex/qfixdpl
9
0
Fork 0
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

add log

Browse Source
This commit is contained in:
Ramiro Paz
2026-05-19 15:15:54 -03:00
parent 0f3ac0dd8d
commit d06433e0f5
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/client/fix/manager.go
View File

@ -8,6 +8,7 @@ import (
"sync" "sync"
"time" "time"
"github.com/rs/zerolog/log"
uuid "github.com/satori/go.uuid" uuid "github.com/satori/go.uuid"
"github.com/shopspring/decimal" "github.com/shopspring/decimal"
@ -603,6 +604,8 @@ func (m *Manager) handleRawMessage(direction string, msg *quickfix.Message) {
// ascending by CreatedAt. Passing 0 for either cursor returns all messages on that side. // ascending by CreatedAt. Passing 0 for either cursor returns all messages on that side.
func (m *Manager) GetAllMessages(inSeq, outSeq int) []domain.Message { func (m *Manager) GetAllMessages(inSeq, outSeq int) []domain.Message {
m.messagesMu.RLock() m.messagesMu.RLock()
log.Info().Msgf("request received, inSeq: %d, outSeq: %d", inSeq, outSeq)
filtered := make([]domain.Message, 0, len(m.messages)) filtered := make([]domain.Message, 0, len(m.messages))
for _, msg := range m.messages { for _, msg := range m.messages {
switch msg.JMessage.Direction { switch msg.JMessage.Direction {
@ -616,10 +619,13 @@ func (m *Manager) GetAllMessages(inSeq, outSeq int) []domain.Message {
} }
} }
} }
m.messagesMu.RUnlock() m.messagesMu.RUnlock()
sort.Slice(filtered, func(i, j int) bool { return filtered[i].CreatedAt.Before(filtered[j].CreatedAt) }) sort.Slice(filtered, func(i, j int) bool { return filtered[i].CreatedAt.Before(filtered[j].CreatedAt) })
log.Info().Msgf("messages sent: %d", len(filtered))
return filtered return filtered
} }