Adds nextexpectedseqnum test defs and refactors test server to suppor…

…t new syntax

.github/workflows/ci.yaml

@@ -241,32 +241,32 @@ jobs:
           ACCEPTANCE_SET: lastseqnumprocessed
         run: make generate-ci && make build && make $FIX_TEST
 
-  # nextexpectedseqnum:
-  #   name: NextExpectedSeqNum Suite
-  #   runs-on: ubuntu-latest
-  #   strategy:
-  #     matrix:
-  #       go: [1.21]
-  #       fix-version:
-  #         - fix44
-  #         - fix50
-  #         - fix50sp1
-  #         - fix50sp2
-  #   steps:
-  #     - name: Setup
-  #       uses: actions/setup-go@v2
-  #       with:
-  #         go-version: ${{ matrix.go }}
-  #     - name: Check out source
-  #       uses: actions/checkout@v2
-  #     - name: Install ruby
-  #       uses: ruby/setup-ruby@v1
-  #       with:
-  #         ruby-version: '3.0'
-  #     - name: Acceptance test
-  #       env:
-  #         GO111MODULE: on
-  #         FIX_TEST: ${{ matrix.fix-version }}
-  #         STORE_TYPE: memory
-  #         ACCEPTANCE_SET: nextexpectedseqnum
-  #       run: make generate-ci && make build && make $FIX_TEST
+  nextexpectedseqnum:
+    name: NextExpectedSeqNum Suite
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        go: [1.21]
+        fix-version:
+          - fix44
+          - fix50
+          - fix50sp1
+          - fix50sp2
+    steps:
+      - name: Setup
+        uses: actions/setup-go@v2
+        with:
+          go-version: ${{ matrix.go }}
+      - name: Check out source
+        uses: actions/checkout@v2
+      - name: Install ruby
+        uses: ruby/setup-ruby@v1
+        with:
+          ruby-version: '3.0'
+      - name: Acceptance test
+        env:
+          GO111MODULE: on
+          FIX_TEST: ${{ matrix.fix-version }}
+          STORE_TYPE: memory
+          ACCEPTANCE_SET: nextexpectedseqnum
+        run: make generate-ci && make build && make $FIX_TEST

_test/Reflector.rb

@@ -61,6 +61,8 @@ def processLine(lineNum, line, body, cid)
         connectAction(cid)
       elsif body == "DISCONNECT"
         disconnectAction(cid)
+      elsif body.index("SET_SESSION") == 0
+        setSeqnum(body)
       else
         raise "Syntax error: " + body
       end

_test/ReflectorClient.rb

@@ -19,6 +19,8 @@
 require 'Reflector'
 require 'FixParser'
 require "socket"
+require 'uri'
+require 'net/http'
 
 class ReflectorClient
 
@@ -62,6 +64,12 @@ def @reflector.disconnectAction(cid)
       @sockets.delete(cid)
       @parsers.delete(cid)
     end
+
+    def @reflector.setSeqnum(body)
+      left_array = body.split(" ")
+      uri = URI('http://localhost:8095/seqnum?SESSION='+left_array[1]+'&'+left_array[2])
+      Net::HTTP.get_response(uri)
+    end
 
     def @reflector.waitConnectAction(cid)
     end

_test/cfg/nextexpectedseqnum/fix44.cfg

@@ -0,0 +1,10 @@
+[DEFAULT]
+SocketAcceptPort=5005
+SenderCompID=ISLD
+TargetCompID=TW
+FileLogPath=tmp
+
+[SESSION]
+BeginString=FIX.4.4
+DataDictionary=../spec/FIX44.xml
+EnableNextExpectedMsgSeqNum=Y

_test/cfg/nextexpectedseqnum/fix50.cfg

@@ -0,0 +1,12 @@
+[DEFAULT]
+SocketAcceptPort=5006
+SenderCompID=ISLD
+TargetCompID=TW
+FileLogPath=tmp
+
+[SESSION]
+BeginString=FIXT.1.1
+DefaultApplVerID=FIX.5.0
+TransportDataDictionary=../spec/FIXT11.xml
+AppDataDictionary=../spec/FIX50.xml
+EnableNextExpectedMsgSeqNum=Y

_test/cfg/nextexpectedseqnum/fix50sp1.cfg

@@ -0,0 +1,12 @@
+[DEFAULT]
+SocketAcceptPort=5007
+SenderCompID=ISLD
+TargetCompID=TW
+FileLogPath=tmp
+
+[SESSION]
+BeginString=FIXT.1.1
+DefaultApplVerID=FIX.5.0SP1
+TransportDataDictionary=../spec/FIXT11.xml
+AppDataDictionary=../spec/FIX50SP1.xml
+EnableNextExpectedMsgSeqNum=Y

_test/cfg/nextexpectedseqnum/fix50sp2.cfg

@@ -0,0 +1,12 @@
+[DEFAULT]
+SocketAcceptPort=5008
+SenderCompID=ISLD
+TargetCompID=TW
+FileLogPath=tmp
+
+[SESSION]
+BeginString=FIXT.1.1
+DefaultApplVerID=FIX.5.0SP2
+TransportDataDictionary=../spec/FIXT11.xml
+AppDataDictionary=../spec/FIX50SP2.xml
+EnableNextExpectedMsgSeqNum=Y

_test/definitions/nextexpectedseqnum/fix44/2a_NextExpectedMsgSeqNumCorrect.def

@@ -0,0 +1,16 @@
+iCONNECT
+
+#------------------------
+# logon message and response
+# send logon with sequence number equals to 1
+# expect for a logon response with NextExpectedMsgSeqNum field equals to 2 
+#------------------------
+
+I8=FIX.4.4
35=A
34=1
49=TW
52=<TIME>
56=ISLD
98=0
789=1
108=2

+E8=FIX.4.4
9=66
35=A
34=1
49=ISLD
52=00000000-00:00:00.000
56=TW
98=0
108=2
789=2
10=0

+
+# logout message and response
+I8=FIX.4.4
35=5
34=2
49=TW
52=<TIME>
56=ISLD

+E8=FIX.4.4
9=49
35=5
34=2
49=ISLD
52=00000000-00:00:00.000
56=TW
10=0

+
+eDISCONNECT

_test/definitions/nextexpectedseqnum/fix44/2b_NextExpectedMsgSeqNumTooHigh.def

@@ -0,0 +1,10 @@
+# If message NextExpectedMsgSeqNum field is too high, we must disconnect
+
+iCONNECT
+iSET_SESSION FIX.4.4:ISLD->TW NEXTSENDERSEQNUM=1
+iSET_SESSION FIX.4.4:ISLD->TW NEXTTARGETSEQNUM=1
+
+I8=FIX.4.4
35=A
34=1000
49=TW
52=<TIME>
56=ISLD
98=0
789=1200
108=30

+
+E8=FIX.4.4
9=135
35=5
34=1
49=ISLD
52=00000000-00:00:00.000
56=TW
58=Tag 789 (NextExpectedMsgSeqNum) is higher than expected. Expected 1, Received 1200
10=0

+eDISCONNECT

_test/definitions/nextexpectedseqnum/fix44/2c_NextExpectedMsgSeqNumTooLow.def

@@ -0,0 +1,14 @@
+iCONNECT
+iSET_SESSION FIX.4.4:ISLD->TW NEXTSENDERSEQNUM=2000
+iSET_SESSION FIX.4.4:ISLD->TW NEXTTARGETSEQNUM=1
+
+I8=FIX.4.4
35=A
34=1
49=TW
52=<TIME>
56=ISLD
98=0
789=1
108=30

+
+E8=FIX.4.4
9=70
35=A
34=2000
49=ISLD
52=00000000-00:00:00.000
56=TW
98=0
108=30
789=2
10=0

+E8=FIX.4.4
9=94
35=4
34=1
43=Y
49=ISLD
52=<TIME>
56=TW
122=<TIME>
36=2001
123=Y

+
+# logout message and response
+I8=FIX.4.4
35=5
34=2
49=TW
52=<TIME>
56=ISLD

+E8=FIX.4.4
9=52
35=5
34=2001
49=ISLD
52=00000000-00:00:00.000
56=TW
10=0

+
+eDISCONNECT

_test/definitions/nextexpectedseqnum/fix44/ResetSeqNumFlagAndNextExpectedMsgSeqNum.def

@@ -0,0 +1,14 @@
+# FIX Logon using tag 141/ResetSeqNumFlag and tag 789/NextExpectedSeqMsgNum
+
+iCONNECT
+iSET_SESSION FIX.4.4:ISLD->TW NEXTSENDERSEQNUM=2000
+iSET_SESSION FIX.4.4:ISLD->TW NEXTTARGETSEQNUM=2000
+
+I8=FIX.4.4
35=A
34=1
49=TW
52=<TIME>
56=ISLD
98=0
789=1
141=Y
108=30

+E8=FIX.4.4
9=73
35=A
34=1
49=ISLD
52=00000000-00:00:00.000
56=TW
98=0
108=30
141=Y
789=2
10=0

+
+# logout message and response
+I8=FIX.4.4
35=5
34=2
49=TW
52=<TIME>
56=ISLD

+E8=FIX.4.4
9=49
35=5
34=2
49=ISLD
52=00000000-00:00:00
56=TW
10=0

+
+eDISCONNECT

_test/definitions/nextexpectedseqnum/fix50/2a_NextExpectedMsgSeqNumCorrect.def

@@ -0,0 +1,16 @@
+iCONNECT
+
+#------------------------
+# logon message and response
+# send logon with sequence number equals to 1
+# expect for a logon response with NextExpectedMsgSeqNum field equals to 2 
+#------------------------
+
+I8=FIXT.1.1
35=A
34=1
49=TW
52=<TIME>
56=ISLD
98=0
789=1
1137=7
108=2

+E8=FIXT.1.1
9=73
35=A
34=1
49=ISLD
52=00000000-00:00:00.000
56=TW
98=0
108=2
789=2
1137=7
10=0

+
+# logout message and response
+I8=FIXT.1.1
35=5
34=2
49=TW
52=<TIME>
56=ISLD

+E8=FIXT.1.1
9=49
35=5
34=2
49=ISLD
52=00000000-00:00:00.000
56=TW
10=0

+
+eDISCONNECT

_test/definitions/nextexpectedseqnum/fix50/2b_NextExpectedMsgSeqNumTooHigh.def

@@ -0,0 +1,9 @@
+# If message NextExpectedMsgSeqNum field is too high, we must disconnect
+
+iCONNECT
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTSENDERSEQNUM=1
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTTARGETSEQNUM=1
+I8=FIXT.1.1
35=A
34=1000
49=TW
52=<TIME>
56=ISLD
98=0
789=1200
1137=7
108=30

+
+E8=FIXT.1.1
9=135
35=5
34=1
49=ISLD
52=00000000-00:00:00.000
56=TW
58=Tag 789 (NextExpectedMsgSeqNum) is higher than expected. Expected 1, Received 1200
10=0

+eDISCONNECT

_test/definitions/nextexpectedseqnum/fix50/2c_NextExpectedMsgSeqNumTooLow.def

@@ -0,0 +1,14 @@
+iCONNECT
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTSENDERSEQNUM=2000
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTTARGETSEQNUM=1
+
+I8=FIXT.1.1
35=A
34=1
49=TW
52=<TIME>
56=ISLD
98=0
789=1
1137=7
108=30

+
+E8=FIXT.1.1
9=77
35=A
34=2000
49=ISLD
52=00000000-00:00:00.000
56=TW
98=0
108=30
789=2
1137=7
10=0

+E8=FIXT.1.1
9=94
35=4
34=1
43=Y
49=ISLD
52=<TIME>
56=TW
122=<TIME>
36=2001
123=Y

+
+# logout message and response
+I8=FIXT.1.1
35=5
34=2
49=TW
52=<TIME>
56=ISLD

+E8=FIXT.1.1
9=52
35=5
34=2001
49=ISLD
52=00000000-00:00:00.000
56=TW
10=0

+
+eDISCONNECT

_test/definitions/nextexpectedseqnum/fix50/ResetSeqNumFlagAndNextExpectedMsgSeqNum.def

@@ -0,0 +1,14 @@
+# FIX Logon using tag 141/ResetSeqNumFlag and tag 789/NextExpectedSeqMsgNum
+
+iCONNECT
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTSENDERSEQNUM=2000
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTTARGETSEQNUM=2000
+
+I8=FIXT.1.1
35=A
34=1
49=TW
52=<TIME>
56=ISLD
98=0
789=1
141=Y
1137=7
108=30

+E8=FIXT.1.1
9=80
35=A
34=1
49=ISLD
52=00000000-00:00:00.000
56=TW
98=0
108=30
141=Y
789=2
1137=7
10=0

+
+# logout message and response
+I8=FIXT.1.1
35=5
34=2
49=TW
52=<TIME>
56=ISLD

+E8=FIXT.1.1
9=49
35=5
34=2
49=ISLD
52=00000000-00:00:00.000
56=TW
10=0

+
+eDISCONNECT

_test/definitions/nextexpectedseqnum/fix50sp1/2a_NextExpectedMsgSeqNumCorrect.def

@@ -0,0 +1,16 @@
+iCONNECT
+
+#------------------------
+# logon message and response
+# send logon with sequence number equals to 1
+# expect for a logon response with NextExpectedMsgSeqNum field equals to 2 
+#------------------------
+
+I8=FIXT.1.1
35=A
34=1
49=TW
52=<TIME>
56=ISLD
98=0
789=1
1137=8
108=2

+E8=FIXT.1.1
9=73
35=A
34=1
49=ISLD
52=00000000-00:00:00.000
56=TW
98=0
108=2
789=2
1137=8
10=0

+
+# logout message and response
+I8=FIXT.1.1
35=5
34=2
49=TW
52=<TIME>
56=ISLD

+E8=FIXT.1.1
9=49
35=5
34=2
49=ISLD
52=00000000-00:00:00.000
56=TW
10=0

+
+eDISCONNECT

_test/definitions/nextexpectedseqnum/fix50sp1/2b_NextExpectedMsgSeqNumTooHigh.def

@@ -0,0 +1,9 @@
+# If message NextExpectedMsgSeqNum field is too high, we must disconnect
+
+iCONNECT
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTSENDERSEQNUM=1
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTTARGETSEQNUM=1
+I8=FIXT.1.1
35=A
34=1000
49=TW
52=<TIME>
56=ISLD
98=0
789=1200
1137=8
108=30

+
+E8=FIXT.1.1
9=135
35=5
34=1
49=ISLD
52=00000000-00:00:00.000
56=TW
58=Tag 789 (NextExpectedMsgSeqNum) is higher than expected. Expected 1, Received 1200
10=0

+eDISCONNECT

_test/definitions/nextexpectedseqnum/fix50sp1/2c_NextExpectedMsgSeqNumTooLow.def

@@ -0,0 +1,14 @@
+iCONNECT
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTSENDERSEQNUM=2000
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTTARGETSEQNUM=1
+
+I8=FIXT.1.1
35=A
34=1
49=TW
52=<TIME>
56=ISLD
98=0
789=1
1137=10
108=30

+
+E8=FIXT.1.1
9=77
35=A
34=2000
49=ISLD
52=00000000-00:00:00.000
56=TW
98=0
108=30
789=2
1137=8
10=0

+E8=FIXT.1.1
9=94
35=4
34=1
43=Y
49=ISLD
52=<TIME>
56=TW
122=<TIME>
36=2001
123=Y

+
+# logout message and response
+I8=FIXT.1.1
35=5
34=2
49=TW
52=<TIME>
56=ISLD

+E8=FIXT.1.1
9=52
35=5
34=2001
49=ISLD
52=00000000-00:00:00.000
56=TW
10=0

+
+eDISCONNECT

_test/definitions/nextexpectedseqnum/fix50sp1/ResetSeqNumFlagAndNextExpectedMsgSeqNum.def

@@ -0,0 +1,14 @@
+# FIX Logon using tag 141/ResetSeqNumFlag and tag 789/NextExpectedSeqMsgNum
+
+iCONNECT
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTSENDERSEQNUM=2000
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTTARGETSEQNUM=2000
+
+I8=FIXT.1.1
35=A
34=1
49=TW
52=<TIME>
56=ISLD
98=0
789=1
141=Y
1137=8
108=30

+E8=FIXT.1.1
9=80
35=A
34=1
49=ISLD
52=00000000-00:00:00.000
56=TW
98=0
108=30
141=Y
789=2
1137=8
10=0

+
+# logout message and response
+I8=FIXT.1.1
35=5
34=2
49=TW
52=<TIME>
56=ISLD

+E8=FIXT.1.1
9=49
35=5
34=2
49=ISLD
52=00000000-00:00:00.000
56=TW
10=0

+
+eDISCONNECT

_test/definitions/nextexpectedseqnum/fix50sp2/2a_NextExpectedMsgSeqNumCorrect.def

@@ -0,0 +1,16 @@
+iCONNECT
+
+#------------------------
+# logon message and response
+# send logon with sequence number equals to 1
+# expect for a logon response with NextExpectedMsgSeqNum field equals to 2 
+#------------------------
+
+I8=FIXT.1.1
35=A
34=1
49=TW
52=<TIME>
56=ISLD
98=0
789=1
1137=9
108=2

+E8=FIXT.1.1
9=73
35=A
34=1
49=ISLD
52=00000000-00:00:00.000
56=TW
98=0
108=2
789=2
1137=9
10=0

+
+# logout message and response
+I8=FIXT.1.1
35=5
34=2
49=TW
52=<TIME>
56=ISLD

+E8=FIXT.1.1
9=49
35=5
34=2
49=ISLD
52=00000000-00:00:00.000
56=TW
10=0

+
+eDISCONNECT

_test/definitions/nextexpectedseqnum/fix50sp2/2b_NextExpectedMsgSeqNumTooHigh.def

@@ -0,0 +1,9 @@
+# If message NextExpectedMsgSeqNum field is too high, we must disconnect
+
+iCONNECT
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTSENDERSEQNUM=1
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTTARGETSEQNUM=1
+I8=FIXT.1.1
35=A
34=1000
49=TW
52=<TIME>
56=ISLD
98=0
789=1200
1137=9
108=30

+
+E8=FIXT.1.1
9=135
35=5
34=1
49=ISLD
52=00000000-00:00:00.000
56=TW
58=Tag 789 (NextExpectedMsgSeqNum) is higher than expected. Expected 1, Received 1200
10=0

+eDISCONNECT

_test/definitions/nextexpectedseqnum/fix50sp2/2c_NextExpectedMsgSeqNumTooLow.def

@@ -0,0 +1,14 @@
+iCONNECT
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTSENDERSEQNUM=2000
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTTARGETSEQNUM=1
+
+I8=FIXT.1.1
35=A
34=1
49=TW
52=<TIME>
56=ISLD
98=0
789=1
1137=9
108=30

+
+E8=FIXT.1.1
9=77
35=A
34=2000
49=ISLD
52=00000000-00:00:00.000
56=TW
98=0
108=30
789=2
1137=9
10=0

+E8=FIXT.1.1
9=94
35=4
34=1
43=Y
49=ISLD
52=<TIME>
56=TW
122=<TIME>
36=2001
123=Y

+
+# logout message and response
+I8=FIXT.1.1
35=5
34=2
49=TW
52=<TIME>
56=ISLD

+E8=FIXT.1.1
9=52
35=5
34=2001
49=ISLD
52=00000000-00:00:00.000
56=TW
10=0

+
+eDISCONNECT

_test/definitions/nextexpectedseqnum/fix50sp2/ResetSeqNumFlagAndNextExpectedMsgSeqNum.def

@@ -0,0 +1,14 @@
+# FIX Logon using tag 141/ResetSeqNumFlag and tag 789/NextExpectedSeqMsgNum
+
+iCONNECT
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTSENDERSEQNUM=2000
+iSET_SESSION FIXT.1.1:ISLD->TW NEXTTARGETSEQNUM=2000
+
+I8=FIXT.1.1
35=A
34=1
49=TW
52=<TIME>
56=ISLD
98=0
789=1
141=Y
1137=9
108=30

+E8=FIXT.1.1
9=80
35=A
34=1
49=ISLD
52=00000000-00:00:00.000
56=TW
98=0
108=30
141=Y
789=2
1137=9
10=0

+
+# logout message and response
+I8=FIXT.1.1
35=5
34=2
49=TW
52=<TIME>
56=ISLD

+E8=FIXT.1.1
9=49
35=5
34=2
49=ISLD
52=00000000-00:00:00.000
56=TW
10=0

+
+eDISCONNECT