update lsn on Primary Keep Alive Message

porsager · Feb 17, 2024 · a5cd811 · a5cd811
1 parent 5404fbd
commit a5cd811
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/subscribe.js b/src/subscribe.js
@@ -110,8 +110,10 @@ export default function Subscribe(postgres, options) {
     function data(x) {
       if (x[0] === 0x77)
         parse(x.subarray(25), state, sql.options.parsers, handle, options.transform)
-      else if (x[0] === 0x6b && x[17])
+      else if (x[0] === 0x6b && x[17]) {
+        state.lsn = x.subarray(1, 9)
         pong()
+      }
     }
 
     function handle(a, b) {