From bd72c0969acdfc52a2672f6e8f41c55847822410 Mon Sep 17 00:00:00 2001
From: Tejas Mehta <tejas@cloudflare.com>
Date: Wed, 22 Nov 2023 10:22:27 -0500
Subject: [PATCH] Remove FLUSH from CF integration

---
 cf/src/connection.js | 16 +++++++---------
 1 file changed, 7 insertions(+), 9 deletions(-)

diff --git a/cf/src/connection.js b/cf/src/connection.js
index c09b2720..93e47732 100644
--- a/cf/src/connection.js
+++ b/cf/src/connection.js
@@ -185,13 +185,11 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
 
     return q.options.simple
       ? b().Q().str(q.statement.string + b.N).end()
-      : q.describeFirst
-        ? Buffer.concat([describe(q), Flush])
-        : q.prepare
-          ? q.prepared
-            ? prepared(q)
-            : Buffer.concat([describe(q), prepared(q)])
-          : unnamed(q)
+      : q.prepare 
+        ? q.prepared 
+          ? prepared(q) 
+          : Buffer.concat([describe(q), prepared(q)]) 
+        : unnamed(q)
   }
 
   function describe(q) {
@@ -604,7 +602,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
       !query.statement.types[i] && (query.statement.types[i] = x.readUInt32BE(7 + i * 4))
 
     query.prepare && (statements[query.signature] = query.statement)
-    query.describeFirst && !query.onlyDescribe && (write(prepared(query)), query.describeFirst = false)
+    query.describeFirst && !query.onlyDescribe && (query.describeFirst = false)
   }
 
   function RowDescription(x) {
@@ -953,7 +951,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
   function Execute(portal = '', rows = 0) {
     return Buffer.concat([
       b().E().str(portal + b.N).i32(rows).end(),
-      Flush
+      Sync
     ])
   }