changing test-server seqnum to uint64

SNORRIS721 · SNORRIS721 · commit a2a469d4a02c · 2025-05-15T13:06:49.000-05:00
Updating uint64 conversions

Updating uint64 conversions
diff --git a/_sql/mssql/quickfix_database.sql b/_sql/mssql/quickfix_database.sql
@@ -12,8 +12,8 @@ CREATE TABLE sessions (
   targetlocid VARCHAR(64) NOT NULL,
   session_qualifier VARCHAR(64) NOT NULL,
   creation_time DATETIME NOT NULL,
-  incoming_seqnum INT NOT NULL,
-  outgoing_seqnum INT NOT NULL,
+  incoming_seqnum BIGINT NOT NULL,
+  outgoing_seqnum BIGINT NOT NULL,
   PRIMARY KEY (beginstring, sendercompid, sendersubid, senderlocid, 
   				targetcompid, targetsubid, targetlocid, session_qualifier)
 );
@@ -27,7 +27,7 @@ CREATE TABLE messages (
   targetsubid VARCHAR(64) NOT NULL,
   targetlocid VARCHAR(64) NOT NULL,
   session_qualifier VARCHAR(64) NOT NULL,
-  msgseqnum INT NOT NULL,
+  msgseqnum BIGINT NOT NULL,
   message TEXT NOT NULL,
   PRIMARY KEY (beginstring, sendercompid, sendersubid, senderlocid, 
   				targetcompid, targetsubid, targetlocid, session_qualifier,
diff --git a/_sql/mysql/messages_table.sql b/_sql/mysql/messages_table.sql
@@ -11,7 +11,7 @@ CREATE TABLE messages (
   targetsubid VARCHAR(64) NOT NULL,
   targetlocid VARCHAR(64) NOT NULL,
   session_qualifier VARCHAR(64) NOT NULL,
-  msgseqnum INT NOT NULL, 
+  msgseqnum BIGINT NOT NULL, 
   message TEXT NOT NULL,
   PRIMARY KEY (beginstring, sendercompid, sendersubid, senderlocid, 
   				targetcompid, targetsubid, targetlocid, session_qualifier,
diff --git a/_sql/mysql/sessions_table.sql b/_sql/mysql/sessions_table.sql
@@ -12,8 +12,8 @@ CREATE TABLE sessions (
   targetlocid VARCHAR(64) NOT NULL,
   session_qualifier VARCHAR(64) NOT NULL,
   creation_time DATETIME NOT NULL,
-  incoming_seqnum INT NOT NULL, 
-  outgoing_seqnum INT NOT NULL,
+  incoming_seqnum BIGINT NOT NULL, 
+  outgoing_seqnum BIGINT NOT NULL,
   PRIMARY KEY (beginstring, sendercompid, sendersubid, senderlocid, 
   				targetcompid, targetsubid, targetlocid, session_qualifier)
 );
diff --git a/_sql/oracle/messages_table.sql b/_sql/oracle/messages_table.sql
@@ -7,7 +7,7 @@ CREATE TABLE messages (
   targetsubid VARCHAR2(64) NOT NULL,
   targetlocid VARCHAR2(64) NOT NULL,
   session_qualifier VARCHAR2(64) NOT NULL,
-  msgseqnum INTEGER NOT NULL, 
+  msgseqnum BIGINT NOT NULL, 
   message VARCHAR2(4000) NOT NULL,
   PRIMARY KEY (beginstring, sendercompid, sendersubid, senderlocid, 
   				targetcompid, targetsubid, targetlocid, session_qualifier, msgseqnum)
diff --git a/_sql/oracle/sessions_table.sql b/_sql/oracle/sessions_table.sql
@@ -8,8 +8,8 @@ CREATE TABLE sessions (
   targetlocid VARCHAR2(64) NOT NULL,
   session_qualifier VARCHAR2(64) NOT NULL,
   creation_time TIMESTAMP NOT NULL,
-  incoming_seqnum INTEGER NOT NULL, 
-  outgoing_seqnum INTEGER NOT NULL,
+  incoming_seqnum BIGINT NOT NULL, 
+  outgoing_seqnum BIGINT NOT NULL,
   PRIMARY KEY (beginstring, sendercompid, sendersubid, senderlocid, 
   				targetcompid, targetsubid, targetlocid, session_qualifier)
 );
diff --git a/_sql/postgresql/messages_table.sql b/_sql/postgresql/messages_table.sql
@@ -7,7 +7,7 @@ CREATE TABLE messages (
   targetsubid VARCHAR(64) NOT NULL,
   targetlocid VARCHAR(64) NOT NULL,
   session_qualifier VARCHAR(64) NOT NULL,
-  msgseqnum INTEGER NOT NULL, 
+  msgseqnum BIGINT NOT NULL, 
   message TEXT NOT NULL,
   PRIMARY KEY (beginstring, sendercompid, sendersubid, senderlocid, 
   				targetcompid, targetsubid, targetlocid, session_qualifier,
diff --git a/_sql/postgresql/sessions_table.sql b/_sql/postgresql/sessions_table.sql
@@ -8,8 +8,8 @@ CREATE TABLE sessions (
   targetlocid VARCHAR(64) NOT NULL,
   session_qualifier VARCHAR(64) NOT NULL,
   creation_time TIMESTAMP WITH TIME ZONE NOT NULL,
-  incoming_seqnum INTEGER NOT NULL, 
-  outgoing_seqnum INTEGER NOT NULL,
+  incoming_seqnum BIGINT NOT NULL, 
+  outgoing_seqnum BIGINT NOT NULL,
   PRIMARY KEY (beginstring, sendercompid, sendersubid, senderlocid, 
   				targetcompid, targetsubid, targetlocid, session_qualifier)
 );
diff --git a/_sql/sqlite3/messages_table.sql b/_sql/sqlite3/messages_table.sql
@@ -9,7 +9,7 @@ CREATE TABLE messages (
   targetsubid VARCHAR(64) NOT NULL,
   targetlocid VARCHAR(64) NOT NULL,
   session_qualifier VARCHAR(64) NOT NULL,
-  msgseqnum INT NOT NULL, 
+  msgseqnum BIGINT NOT NULL, 
   message TEXT NOT NULL,
   PRIMARY KEY (beginstring, sendercompid, sendersubid, senderlocid, 
   				targetcompid, targetsubid, targetlocid, session_qualifier,
diff --git a/_sql/sqlite3/sessions_table.sql b/_sql/sqlite3/sessions_table.sql
@@ -10,8 +10,8 @@ CREATE TABLE sessions (
   targetlocid VARCHAR(64) NOT NULL,
   session_qualifier VARCHAR(64) NOT NULL,
   creation_time DATETIME NOT NULL,
-  incoming_seqnum INT NOT NULL, 
-  outgoing_seqnum INT NOT NULL,
+  incoming_seqnum BIGINT NOT NULL, 
+  outgoing_seqnum BIGINT NOT NULL,
   PRIMARY KEY (beginstring, sendercompid, sendersubid, senderlocid, 
   				targetcompid, targetsubid, targetlocid, session_qualifier)
 );
diff --git a/_test/test-server/main.go b/_test/test-server/main.go
@@ -200,7 +200,7 @@ func main() {
 		}
 		num, ok := queryParams["NEXTTARGETSEQNUM"]
 		if ok {
-			seqnumInt, cErr := strconv.Atoi(num[0])
+			seqnumInt, cErr := strconv.ParseUint(num[0], 10, 64)
 			if cErr != nil {
 				fmt.Println("cannot find seqnum")
 				os.Exit(1)
@@ -216,7 +216,7 @@ func main() {
 
 		num, ok = queryParams["NEXTSENDERSEQNUM"]
 		if ok {
-			seqnumInt, cErr := strconv.Atoi(num[0])
+			seqnumInt, cErr := strconv.ParseUint(num[0], 10, 64)
 			if cErr != nil {
 				fmt.Println("cannot find seqnum")
 				os.Exit(1)
diff --git a/fix_uint.go b/fix_uint.go
@@ -20,17 +20,7 @@ import (
 	"strconv"
 )
 
-// atoi is similar to the function in strconv, but is tuned for ints appearing in FIX field types.
-func atou(d []byte) (uint64, error) {
-	// if d[0] == asciiMinus {
-	// 	n, err := parseUInt64(d[1:])
-	// 	return (-1) * n, err
-	// }
-
-	return parseUInt64(d)
-}
-
-// parseUInt is similar to the function in strconv, but is tuned for ints appearing in FIX field types.
+// parseUInt is similar to the function in strconv, but is tuned for uint64s appearing in FIX field types.
 func parseUInt64(d []byte) (n uint64, err error) {
 	if len(d) == 0 {
 		err = errors.New("empty bytes")
@@ -49,14 +39,14 @@ func parseUInt64(d []byte) (n uint64, err error) {
 	return
 }
 
-// FIXInt is a FIX Int Value, implements FieldValue.
+// FIXUInt64 is a FIX Uint64 Value, implements FieldValue.
 type FIXUint64 uint64
 
-// Int converts the FIXInt value to int.
+// Uint64 converts the FIXUint64 value to uint64.
 func (f FIXUint64) Uint64() uint64 { return uint64(f) }
 
 func (f *FIXUint64) Read(bytes []byte) error {
-	i, err := atou(bytes)
+	i, err := parseUInt64(bytes)
 	if err != nil {
 		return err
 	}
diff --git a/store/sql/sql_store.go b/store/sql/sql_store.go
@@ -245,7 +245,7 @@ func (store *sqlStore) Refresh() error {
 func (store *sqlStore) populateCache() error {
 	s := store.sessionID
 	var creationTime time.Time
-	var incomingSeqNum, outgoingSeqNum int
+	var incomingSeqNum, outgoingSeqNum uint64
 	row := store.db.QueryRow(sqlString(store.sqlGetSeqNums, store.placeholder),
 		s.BeginString, s.Qualifier,
 		s.SenderCompID, s.SenderSubID, s.SenderLocationID,
diff --git a/store/sql/sql_store_test.go b/store/sql/sql_store_test.go
@@ -136,9 +136,9 @@ TargetCompID=%s
 
 	// Get and check sequence numbers
 	nextSender := store.NextSenderMsgSeqNum()
-	suite.Equal(3, nextSender)
+	suite.Equal(uint64(3), nextSender)
 	nextTarget := store.NextTargetMsgSeqNum()
-	suite.Equal(2, nextTarget)
+	suite.Equal(uint64(2), nextTarget)
 
 	// IterateMessages
 	count := 0
@@ -154,9 +154,9 @@ TargetCompID=%s
 
 	// After reset, sequence numbers should be 1
 	nextSender = store.NextSenderMsgSeqNum()
-	suite.Equal(1, nextSender)
+	suite.Equal(uint64(1), nextSender)
 	nextTarget = store.NextTargetMsgSeqNum()
-	suite.Equal(1, nextTarget)
+	suite.Equal(uint64(1), nextTarget)
 }
 
 func (suite *SQLStoreTestSuite) TearDownTest() {
