feat: support STATE_GTIDS session track information

* Support parsing gtids from OK package * Rename variable, added eslint check
sidorares · Jun 19, 2023 · 2b1520f · 2b1520f
1 parent fefe036
commit 2b1520f
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/lib/packets/resultset_header.js b/lib/packets/resultset_header.js
@@ -50,6 +50,7 @@ class ResultSetHeader {
           stateChanges = {
             systemVariables: {},
             schema: null,
+            gtids: [],
             trackStateChange: null
           };
         }
@@ -72,6 +73,12 @@ class ResultSetHeader {
             stateChanges.trackStateChange = packet.readLengthCodedString(
               encoding
             );
+          } else if (type === sessionInfoTypes.STATE_GTIDS) {
+            // TODO: find if the first length coded string means anything. Usually comes as empty
+            // eslint-disable-next-line no-unused-vars
+            const _unknownString = packet.readLengthCodedString(encoding);
+            const gtid = packet.readLengthCodedString(encoding);
+            stateChanges.gtids = gtid.split(',');
           } else {
             // unsupported session track type. For now just ignore
           }