From bf8b47b328ac05443480d48f794cf84a23e5d3a2 Mon Sep 17 00:00:00 2001
From: Christoph John <christoph.john@macd.com>
Date: Fri, 12 Jan 2024 15:32:34 +0100
Subject: [PATCH 01/10] typos and doc comments

---
 quickfixj-base/src/main/java/quickfix/FixVersions.java    | 2 +-
 quickfixj-base/src/main/java/quickfix/InvalidMessage.java | 4 ++--
 quickfixj-base/src/main/java/quickfix/MessageUtils.java   | 8 ++++----
 3 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/quickfixj-base/src/main/java/quickfix/FixVersions.java b/quickfixj-base/src/main/java/quickfix/FixVersions.java
index 209d65baf8..1f71f3432d 100644
--- a/quickfixj-base/src/main/java/quickfix/FixVersions.java
+++ b/quickfixj-base/src/main/java/quickfix/FixVersions.java
@@ -30,7 +30,7 @@ public interface FixVersions {
     String BEGINSTRING_FIX44 = "FIX.4.4";
 
     /*
-     * FIX 5.0+ does not have a begin string.
+     * FIX 5.0+ does not have a BeginString.
      */
     String FIX50 = "FIX.5.0";
     String FIX50SP1 = "FIX.5.0SP1";
diff --git a/quickfixj-base/src/main/java/quickfix/InvalidMessage.java b/quickfixj-base/src/main/java/quickfix/InvalidMessage.java
index c15ee2440a..2476c28928 100644
--- a/quickfixj-base/src/main/java/quickfix/InvalidMessage.java
+++ b/quickfixj-base/src/main/java/quickfix/InvalidMessage.java
@@ -19,8 +19,8 @@
 
 package quickfix;
 
-/*
- * An exception when a message is not valid according to the
+/**
+ * Thrown when a message is not valid according to the
  * basic message validation or the data dictionary.
  */
 public class InvalidMessage extends Exception {
diff --git a/quickfixj-base/src/main/java/quickfix/MessageUtils.java b/quickfixj-base/src/main/java/quickfix/MessageUtils.java
index fe7a51b038..2c73ac40c9 100644
--- a/quickfixj-base/src/main/java/quickfix/MessageUtils.java
+++ b/quickfixj-base/src/main/java/quickfix/MessageUtils.java
@@ -208,10 +208,10 @@ public static String getStringField(String messageString, int tag) {
     };
 
     /**
-     * Convert an ApplVerID to a "begin string"
+     * Convert an ApplVerID to a BeginString.
      *
      * @param applVerID
-     * @return the begin string for the specified ApplVerID.
+     * @return the BeginString for the specified ApplVerID.
      * @throws QFJException if conversion fails.
      * @see ApplVerID
      */
@@ -239,10 +239,10 @@ public static String toBeginString(ApplVerID applVerID) throws QFJException {
     };
 
     /**
-     * Convert a begin string to an ApplVerID
+     * Convert a BeginString to an ApplVerID.
      *
      * @param beginString
-     * @return the ApplVerID for the specified begin string.
+     * @return the ApplVerID for the specified BeginString.
      * @throws QFJException if conversion fails.
      * @see FixVersions
      */

From 93610daa2def81203b03a90ef9edf65d7115a226 Mon Sep 17 00:00:00 2001
From: Christoph John <christoph.john@macd.com>
Date: Wed, 7 Feb 2024 11:04:23 +0100
Subject: [PATCH 02/10] added convenience method isLogonMsgType()

---
 quickfixj-base/src/main/java/quickfix/MessageUtils.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/quickfixj-base/src/main/java/quickfix/MessageUtils.java b/quickfixj-base/src/main/java/quickfix/MessageUtils.java
index 2c73ac40c9..75e7e09d85 100644
--- a/quickfixj-base/src/main/java/quickfix/MessageUtils.java
+++ b/quickfixj-base/src/main/java/quickfix/MessageUtils.java
@@ -101,6 +101,7 @@ public static Message parse(MessageFactory messageFactory, DataDictionary dataDi
      * @param messageFactory
      * @param dataDictionary
      * @param messageString
+     * @param validateChecksum
      * @return the parsed message
      * @throws InvalidMessage
      */
@@ -129,6 +130,10 @@ public static boolean isLogon(String message) {
         return isMessageType(message, MsgType.LOGON);
     }
 
+    public static boolean isLogonMsgType(String msgType) {
+        return MsgType.LOGON.equals(msgType);
+    }
+
     private static boolean isMessageType(String message, String msgType) {
         try {
             return msgType.equals(getMessageType(message));

From 26935dba100ef4f30dc7f6815ac622c5684d5995 Mon Sep 17 00:00:00 2001
From: Christoph John <christoph.john@macd.com>
Date: Wed, 7 Feb 2024 11:43:38 +0100
Subject: [PATCH 03/10] changed to use session dictionary on Logon message

 - lookup of application dictionary and throwing of QFJException is prevented this way
---
 .../java/quickfix/MessageSessionUtils.java    | 22 +++++++++++--------
 1 file changed, 13 insertions(+), 9 deletions(-)

diff --git a/quickfixj-core/src/main/java/quickfix/MessageSessionUtils.java b/quickfixj-core/src/main/java/quickfix/MessageSessionUtils.java
index a6eec9e3a6..0bdbafdb8a 100644
--- a/quickfixj-core/src/main/java/quickfix/MessageSessionUtils.java
+++ b/quickfixj-core/src/main/java/quickfix/MessageSessionUtils.java
@@ -36,6 +36,7 @@ public class MessageSessionUtils {
     public static Message parse(Session session, String messageString) throws InvalidMessage {
         final String beginString = MessageUtils.getStringField(messageString, BeginString.FIELD);
         final String msgType = MessageUtils.getMessageType(messageString);
+        final boolean isLogon = MessageUtils.isLogonMsgType(msgType);
         final MessageFactory messageFactory = session.getMessageFactory();
         final DataDictionaryProvider ddProvider = session.getDataDictionaryProvider();
         final ApplVerID applVerID;
@@ -44,17 +45,20 @@ public static Message parse(Session session, String messageString) throws Invali
         final quickfix.Message message;
         final DataDictionary payloadDictionary;
 
-        if (!MessageUtils.isAdminMessage(msgType) || MessageUtils.isLogon(messageString)) {
+        if (!MessageUtils.isAdminMessage(msgType) || isLogon) {
             if (FixVersions.BEGINSTRING_FIXT11.equals(beginString)) {
-                applVerID = getApplVerID(session, messageString);
+                applVerID = getApplVerID(session, messageString, isLogon);
             } else {
                 applVerID = MessageUtils.toApplVerID(beginString);
             }
-            final DataDictionary applicationDataDictionary = ddProvider == null ? null : ddProvider
-                    .getApplicationDataDictionary(applVerID);
-            payloadDictionary = MessageUtils.isAdminMessage(msgType)
-                    ? sessionDataDictionary
-                    : applicationDataDictionary;
+            
+            if (isLogon) {
+                payloadDictionary = sessionDataDictionary;
+            } else {    // we got an app message
+                final DataDictionary applicationDataDictionary = ddProvider == null ? null : ddProvider
+                        .getApplicationDataDictionary(applVerID);
+                payloadDictionary = applicationDataDictionary;
+            }
         } else {
             applVerID = null;
             payloadDictionary = sessionDataDictionary;
@@ -70,7 +74,7 @@ public static Message parse(Session session, String messageString) throws Invali
         return message;
     }
 
-    private static ApplVerID getApplVerID(Session session, String messageString)
+    private static ApplVerID getApplVerID(Session session, String messageString, boolean isLogon)
             throws InvalidMessage {
         ApplVerID applVerID = null;
 
@@ -83,7 +87,7 @@ private static ApplVerID getApplVerID(Session session, String messageString)
             applVerID = session.getTargetDefaultApplicationVersionID();
         }
 
-        if (applVerID == null && MessageUtils.isLogon(messageString)) {
+        if (applVerID == null && isLogon) {
             final String defaultApplVerIdString = MessageUtils.getStringField(messageString,
                     DefaultApplVerID.FIELD);
             if (defaultApplVerIdString != null) {

From cb3d31e038a12519acda1090c0271effdeac518a Mon Sep 17 00:00:00 2001
From: Christoph John <christoph.john@macd.com>
Date: Wed, 7 Feb 2024 11:44:29 +0100
Subject: [PATCH 04/10] added acceptance test

---
 .../server/fixLatest/LogonUnknownDefaultApplVerID.def      | 7 +++++++
 1 file changed, 7 insertions(+)
 create mode 100644 quickfixj-core/src/test/resources/quickfix/test/acceptance/definitions/server/fixLatest/LogonUnknownDefaultApplVerID.def

diff --git a/quickfixj-core/src/test/resources/quickfix/test/acceptance/definitions/server/fixLatest/LogonUnknownDefaultApplVerID.def b/quickfixj-core/src/test/resources/quickfix/test/acceptance/definitions/server/fixLatest/LogonUnknownDefaultApplVerID.def
new file mode 100644
index 0000000000..2079acb12d
--- /dev/null
+++ b/quickfixj-core/src/test/resources/quickfix/test/acceptance/definitions/server/fixLatest/LogonUnknownDefaultApplVerID.def
@@ -0,0 +1,7 @@
+# Send Logout on unknown DefaultApplVerID
+
+iCONNECT
+I8=FIXT.1.1
35=A
34=1
49=TW
52=<TIME>
56=ISLD
98=0
108=30
1137=33

+# we expect Logout due to 1137=33
+E8=FIXT.1.1
9=49
35=5
34=1
49=ISLD
52=00000000-00:00:00.000
56=TW
58=Invalid DefaultApplVerID=33
10=0

+eDISCONNECT

From 49f3957fb2ea1ce4e8b47a983bc0da76667a9640 Mon Sep 17 00:00:00 2001
From: Christoph John <christoph.john@macd.com>
Date: Thu, 8 Feb 2024 14:28:34 +0100
Subject: [PATCH 05/10]  - Changed Session.nextLogon() to validate
 DefaultApplVerID from Logon.  - Added unit test.

---
 .../src/main/java/quickfix/Session.java       | 14 +++++++
 .../mina/acceptor/AcceptorIoHandlerTest.java  | 40 +++++++++++++++++++
 2 files changed, 54 insertions(+)

diff --git a/quickfixj-core/src/main/java/quickfix/Session.java b/quickfixj-core/src/main/java/quickfix/Session.java
index 77a918e85e..d75c25bf51 100644
--- a/quickfixj-core/src/main/java/quickfix/Session.java
+++ b/quickfixj-core/src/main/java/quickfix/Session.java
@@ -64,6 +64,7 @@
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
+import java.util.Optional;
 import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
@@ -2162,6 +2163,19 @@ private void nextLogon(Message logon) throws FieldNotFound, RejectLogon, Incorre
             throw new RejectLogon("Logon attempt not within session time");
         }
 
+        if (sessionID.isFIXT()) {
+            final DataDictionary dictionary = dataDictionaryProvider
+                    .getSessionDataDictionary(sessionID.getBeginString());
+            if (dictionary != null) {
+                Optional<String> defaultApplVerID = logon.getOptionalString(DefaultApplVerID.FIELD);
+                if (defaultApplVerID.isPresent()) {
+                    if (!dictionary.isFieldValue(ApplVerID.FIELD, defaultApplVerID.get())) {
+                        throw new RejectLogon("Invalid DefaultApplVerID=" + defaultApplVerID.get());
+                    }
+                }
+            }
+        }
+
         // QFJ-926 - reset session before accepting Logon
         resetIfSessionNotCurrent(sessionID, SystemTime.currentTimeMillis());
 
diff --git a/quickfixj-core/src/test/java/quickfix/mina/acceptor/AcceptorIoHandlerTest.java b/quickfixj-core/src/test/java/quickfix/mina/acceptor/AcceptorIoHandlerTest.java
index 15405da74c..dd12d23069 100644
--- a/quickfixj-core/src/test/java/quickfix/mina/acceptor/AcceptorIoHandlerTest.java
+++ b/quickfixj-core/src/test/java/quickfix/mina/acceptor/AcceptorIoHandlerTest.java
@@ -23,6 +23,7 @@
 import org.junit.Test;
 import quickfix.FixVersions;
 import quickfix.Message;
+import quickfix.MessageUtils;
 import quickfix.Responder;
 import quickfix.Session;
 import quickfix.SessionFactoryTestSupport;
@@ -33,6 +34,7 @@
 import quickfix.field.ApplVerID;
 import quickfix.field.DefaultApplVerID;
 import quickfix.field.EncryptMethod;
+import quickfix.field.Headline;
 import quickfix.field.HeartBtInt;
 import quickfix.field.MsgSeqNum;
 import quickfix.field.MsgType;
@@ -42,6 +44,7 @@
 import quickfix.field.Text;
 import quickfix.fix44.Logout;
 import quickfix.fixt11.Logon;
+import quickfix.fix50.News;
 import quickfix.mina.EventHandlingStrategy;
 import quickfix.mina.NetworkingOptions;
 import quickfix.mina.SessionConnector;
@@ -56,6 +59,7 @@
 
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertTrue;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.verifyNoMoreInteractions;
@@ -101,6 +105,42 @@ public void testFIXTLogonAndApplVerID() throws Exception {
         }
     }
 
+    @Test
+    public void testFIXTLogonAndUnknownApplVerID() throws Exception {
+        EventHandlingStrategy mockEventHandlingStrategy = mock(EventHandlingStrategy.class);
+        IoSession mockIoSession = mock(IoSession.class);
+        SessionSettings settings = mock(SessionSettings.class);
+
+        final SessionID sessionID = new SessionID(FixVersions.BEGINSTRING_FIXT11, "SENDER",
+                "TARGET");
+        final UnitTestApplication unitTestApplication = new UnitTestApplication();
+        try (Session session = SessionFactoryTestSupport.createSession(sessionID, unitTestApplication, false, false, true, true, new DefaultApplVerID(DefaultApplVerID.FIX50SP2))) {
+            when(mockIoSession.getAttribute("QF_SESSION")).thenReturn(null);    // to create a new Session
+
+            final HashMap<SessionID, Session> acceptorSessions = new HashMap<>();
+            acceptorSessions.put(sessionID, session);
+            final StaticAcceptorSessionProvider sessionProvider = createSessionProvider(acceptorSessions);
+
+            final AcceptorIoHandler handler = new AcceptorIoHandler(sessionProvider,
+                    settings, new NetworkingOptions(new Properties()), mockEventHandlingStrategy);
+
+            final DefaultApplVerID defaultApplVerID = new DefaultApplVerID("33");
+            final Logon message = new Logon(new EncryptMethod(EncryptMethod.NONE_OTHER),
+                    new HeartBtInt(30), defaultApplVerID);
+            message.getHeader().setString(TargetCompID.FIELD, sessionID.getSenderCompID());
+            message.getHeader().setString(SenderCompID.FIELD, sessionID.getTargetCompID());
+            message.getHeader().setField(new SendingTime(LocalDateTime.now()));
+            message.getHeader().setInt(MsgSeqNum.FIELD, 1);
+
+            handler.messageReceived(mockIoSession, message.toString());
+            session.next(message);
+
+            Message lastToAdminMessage = unitTestApplication.lastToAdminMessage();
+            assertEquals(MsgType.LOGOUT, MessageUtils.getMessageType(lastToAdminMessage.toString()));
+            assertTrue(lastToAdminMessage.getString(Text.FIELD).contains("Invalid DefaultApplVerID=33"));
+        }
+    }
+
     @Test
     public void testMessageBeforeLogon() throws Exception {
         IoSession mockIoSession = mock(IoSession.class);

From 68971aea34f44b04941490bdeacfa86bfff690c8 Mon Sep 17 00:00:00 2001
From: Christoph John <christoph.john@macd.com>
Date: Thu, 8 Feb 2024 17:25:26 +0100
Subject: [PATCH 06/10] corrected location of logging.properties

---
 .github/workflows/maven.yml | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/.github/workflows/maven.yml b/.github/workflows/maven.yml
index 7fc23a3830..544078d6a3 100644
--- a/.github/workflows/maven.yml
+++ b/.github/workflows/maven.yml
@@ -28,7 +28,7 @@ jobs:
           java-version: ${{ matrix.java }}
           cache: 'maven'
       - name: Test with Maven
-        run: ./mvnw install -B -V -Pminimal-fix-latest -D"java.util.logging.config.file"="logging.properties" -D"http.keepAlive"="false" -D"maven.wagon.http.pool"="false" -D"maven.wagon.httpconnectionManager.ttlSeconds"="120"
+        run: ./mvnw install -B -V -Pminimal-fix-latest -D"java.util.logging.config.file"="./quickfixj-core/src/test/resources/logging.properties" -D"http.keepAlive"="false" -D"maven.wagon.http.pool"="false" -D"maven.wagon.httpconnectionManager.ttlSeconds"="120"
 
   test-windows:
     runs-on: ${{ matrix.os }}
@@ -55,4 +55,4 @@ jobs:
           java-version: ${{ matrix.java }}
           cache: 'maven'
       - name: Test with Maven on Windows
-        run: ./mvnw.cmd install -B -V  -D"maven.javadoc.skip"="true" -P"skipBundlePlugin,minimal-fix-latest" -D"java.util.logging.config.file"="logging.properties"  -D"http.keepAlive"="false" -D"maven.wagon.http.pool"="false" -D"maven.wagon.httpconnectionManager.ttlSeconds"="120"
+        run: ./mvnw.cmd install -B -V  -D"maven.javadoc.skip"="true" -P"skipBundlePlugin,minimal-fix-latest" -D"java.util.logging.config.file"="./quickfixj-core/src/test/resources/logging.properties"  -D"http.keepAlive"="false" -D"maven.wagon.http.pool"="false" -D"maven.wagon.httpconnectionManager.ttlSeconds"="120"

From 59f5e115ee8ca6686d9c8b344f2dd3ff20e55ede Mon Sep 17 00:00:00 2001
From: Christoph John <christoph.john@macd.com>
Date: Thu, 8 Feb 2024 17:38:29 +0100
Subject: [PATCH 07/10] decreased log level in logging.properties

---
 quickfixj-core/src/test/resources/logging.properties | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/quickfixj-core/src/test/resources/logging.properties b/quickfixj-core/src/test/resources/logging.properties
index 353d97cee2..543346a5b1 100644
--- a/quickfixj-core/src/test/resources/logging.properties
+++ b/quickfixj-core/src/test/resources/logging.properties
@@ -1,5 +1,5 @@
 handlers=java.util.logging.ConsoleHandler
-java.util.logging.ConsoleHandler.level=ALL
+java.util.logging.ConsoleHandler.level=INFO
 java.util.logging.ConsoleHandler.formatter=java.util.logging.SimpleFormatter
 
-.level=ALL
+.level=INFO

From 7dbb1e104a38532c1fae9ae88fe73053e59c7609 Mon Sep 17 00:00:00 2001
From: Christoph John <christoph.john@macd.com>
Date: Fri, 9 Feb 2024 11:55:49 +0100
Subject: [PATCH 08/10] Update logging.properties to make acceptance test
 output visible

---
 quickfixj-core/src/test/resources/logging.properties | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/quickfixj-core/src/test/resources/logging.properties b/quickfixj-core/src/test/resources/logging.properties
index 543346a5b1..ee2d95efbd 100644
--- a/quickfixj-core/src/test/resources/logging.properties
+++ b/quickfixj-core/src/test/resources/logging.properties
@@ -1,5 +1,5 @@
 handlers=java.util.logging.ConsoleHandler
-java.util.logging.ConsoleHandler.level=INFO
+java.util.logging.ConsoleHandler.level=FINER
 java.util.logging.ConsoleHandler.formatter=java.util.logging.SimpleFormatter
 
-.level=INFO
+.level=FINER

From cb87fe563f86d7cec207b86fe209e3e077caede3 Mon Sep 17 00:00:00 2001
From: Christoph John <christoph.john@macd.com>
Date: Fri, 9 Feb 2024 12:32:25 +0100
Subject: [PATCH 09/10] Update logging.properties, AGAIN

---
 quickfixj-core/src/test/resources/logging.properties | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/quickfixj-core/src/test/resources/logging.properties b/quickfixj-core/src/test/resources/logging.properties
index ee2d95efbd..c4b09a664b 100644
--- a/quickfixj-core/src/test/resources/logging.properties
+++ b/quickfixj-core/src/test/resources/logging.properties
@@ -1,5 +1,5 @@
 handlers=java.util.logging.ConsoleHandler
-java.util.logging.ConsoleHandler.level=FINER
+java.util.logging.ConsoleHandler.level=FINE
 java.util.logging.ConsoleHandler.formatter=java.util.logging.SimpleFormatter
 
-.level=FINER
+.level=FINE

From 9d4768fa04e2278519d9ab6588208954e27cd34d Mon Sep 17 00:00:00 2001
From: Christoph John <christoph.john@macd.com>
Date: Fri, 9 Feb 2024 12:42:23 +0100
Subject: [PATCH 10/10] added FIXLatest ApplVerID to FIXT11.xml

---
 .../quickfixj-messages-fixt11/src/main/resources/FIXT11.xml      | 1 +
 1 file changed, 1 insertion(+)

diff --git a/quickfixj-messages/quickfixj-messages-fixt11/src/main/resources/FIXT11.xml b/quickfixj-messages/quickfixj-messages-fixt11/src/main/resources/FIXT11.xml
index d763b29641..2d119a42e4 100644
--- a/quickfixj-messages/quickfixj-messages-fixt11/src/main/resources/FIXT11.xml
+++ b/quickfixj-messages/quickfixj-messages-fixt11/src/main/resources/FIXT11.xml
@@ -353,6 +353,7 @@
       <value enum="7" description="FIX50"/>
       <value enum="8" description="FIX50SP1"/>
       <value enum="9" description="FIX50SP2"/>
+      <value enum="10" description="FIXLatest"/>
     </field>
     <field number="1129" name="CstmApplVerID" type="STRING"/>
     <field number="1130" name="RefApplVerID" type="STRING"/>