Adding config option for ResetSeqTime

Author: SNORRIS721

.devcontainer/Dockerfile.dev

@@ -1 +1 @@
-FROM mcr.microsoft.com/devcontainers/go:1.21
+FROM mcr.microsoft.com/devcontainers/go:1.23

config/configuration.go

@@ -317,6 +317,17 @@ const (
 	//  - Y
 	//  - N
 	ResetOnDisconnect string = "ResetOnDisconnect"
+
+	// ResetSeqTime determines a time which a logon with a seqnum reset will be sent while keeping the session connected.
+	//
+	// Required: No
+	//
+	// Default: N/A
+	//
+	// Valid Values:
+	//	- 00:00:00
+	//  - A time in the format of HH:MM:SS, time is represented in time zone configured by TimeZone
+	ResetSeqTime string = "ResetSeqTime"
 )
 
 const (

internal/session_settings.go

@@ -18,6 +18,8 @@ type SessionSettings struct {
 	SkipCheckLatency             bool
 	MaxLatency                   time.Duration
 	DisableMessagePersist        bool
+	ResetSeqTime                 TimeOfDay
+	EnableResetSeqTime           bool
 
 	// Required on logon for FIX.T.1 messages.
 	DefaultApplVerID string

session.go

@@ -919,6 +919,7 @@ func (s *session) run() {
 
 		case now := <-ticker.C:
 			s.CheckSessionTime(s, now)
+			s.CheckResetTime(s, now)
 		}
 	}
 }

session_factory.go

@@ -344,6 +344,26 @@ func (f sessionFactory) newSession(
 		}
 	}
 
+	if settings.HasSetting(config.ResetSeqTime) {
+		var seqTimeStr string
+		if seqTimeStr, err = settings.Setting(config.ResetSeqTime); err != nil {
+			return
+		}
+
+		var seqTime internal.TimeOfDay
+		if seqTime, err = internal.ParseTimeOfDay(seqTimeStr); err != nil {
+			err = errors.Wrapf(
+				err, "problem parsing time of day '%v' for setting '%v",
+				settings.settings[config.StartTime], config.StartTime,
+			)
+			return
+		}
+		s.EnableResetSeqTime = true
+		s.ResetSeqTime = seqTime
+	} else {
+		s.EnableResetSeqTime = false
+	}
+
 	if settings.HasSetting(config.TimeStampPrecision) {
 		var precisionStr string
 		if precisionStr, err = settings.Setting(config.TimeStampPrecision); err != nil {

session_state.go

@@ -155,6 +155,15 @@ func (sm *stateMachine) CheckSessionTime(session *session, now time.Time) {
 	}
 }
 
+func (sm *stateMachine) CheckResetTime(session *session, now time.Time) {
+	if session.EnableResetSeqTime {
+		ts := internal.NewTimeOfDay(now.Clock())
+		if session.ResetSeqTime == ts {
+			session.sendLogonInReplyTo(true, nil)
+		}
+	}
+}
+
 func (sm *stateMachine) setState(session *session, nextState sessionState) {
 	if !nextState.IsConnected() {
 		if sm.IsConnected() {

session_test.go

@@ -1001,3 +1001,28 @@ func (suite *SessionSendTestSuite) TestDropAndSendDropsQueueWithReset() {
 	suite.LastToAdminMessageSent()
 	suite.NoMessageSent()
 }
+
+func (s *SessionSuite) TestSeqNumResetTime() {
+	s.MockApp.On("ToAdmin")
+	s.SetupTest()
+
+	now := time.Now().UTC()
+	s.session.ResetSeqTime = internal.NewTimeOfDay(now.Clock())
+	s.session.EnableResetSeqTime = true
+
+	s.IncrNextSenderMsgSeqNum()
+	s.IncrNextTargetMsgSeqNum()
+
+	s.MockApp.On("ToAdmin")
+
+	s.IncrNextSenderMsgSeqNum()
+	s.IncrNextTargetMsgSeqNum()
+
+	s.MockApp.On("ToAdmin")
+
+	s.session.CheckResetTime(s.session, now)
+
+	s.NextSenderMsgSeqNum(2)
+	s.NextSenderMsgSeqNum(2)
+
+}