From d06433e0f51fca5ce5c32e1589bb96b987c95dfb Mon Sep 17 00:00:00 2001 From: Ramiro Paz Date: Tue, 19 May 2026 15:15:54 -0300 Subject: [PATCH] add log --- src/client/fix/manager.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/client/fix/manager.go b/src/client/fix/manager.go index 5d1c7b2..3fbaa20 100644 --- a/src/client/fix/manager.go +++ b/src/client/fix/manager.go @@ -8,6 +8,7 @@ import ( "sync" "time" + "github.com/rs/zerolog/log" uuid "github.com/satori/go.uuid" "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. func (m *Manager) GetAllMessages(inSeq, outSeq int) []domain.Message { m.messagesMu.RLock() + log.Info().Msgf("request received, inSeq: %d, outSeq: %d", inSeq, outSeq) + filtered := make([]domain.Message, 0, len(m.messages)) for _, msg := range m.messages { switch msg.JMessage.Direction { @@ -616,10 +619,13 @@ func (m *Manager) GetAllMessages(inSeq, outSeq int) []domain.Message { } } } + m.messagesMu.RUnlock() 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 }