Start splitting pgcon

edb/server/pgcon/pgcon.pxd

@@ -16,6 +16,7 @@
 # limitations under the License.
 #
 
+include "./pgcon_sql.pxd"
 
 cimport cython
 cimport cpython
@@ -57,40 +58,6 @@ cdef enum PGAuthenticationState:
     PGAUTH_SASL_FINAL = 12
 
 
-cdef enum PGAction:
-    START_IMPLICIT_TX = 0
-    PARSE = 1
-    BIND = 2
-    DESCRIBE_STMT = 3
-    DESCRIBE_STMT_ROWS = 4
-    DESCRIBE_PORTAL = 5
-    EXECUTE = 6
-    CLOSE_STMT = 7
-    CLOSE_PORTAL = 8
-    FLUSH = 9
-    SYNC = 10
-
-
-cdef class PGMessage:
-    cdef:
-        PGAction action
-        bytes stmt_name
-        bytes portal_name
-        str orig_portal_name
-        object args
-        object query_unit
-        bint frontend_only
-        bint valid
-        bint injected
-
-        object orig_query
-        object fe_settings
-
-    cdef inline bint is_frontend_only(self)
-    cdef inline bint is_valid(self)
-    cdef inline bint is_injected(self)
-
-
 @cython.final
 cdef class PGConnection:
 
@@ -143,6 +110,8 @@ cdef class PGConnection:
 
         str last_indirect_return
 
+        PGSQLConnection _sql
+
     cdef before_command(self)
 
     cdef write(self, buf)
@@ -188,8 +157,6 @@ cdef class PGConnection:
         dict type_id_map,
     )
 
-    cdef _rewrite_sql_error_response(self, PGMessage action, WriteBuffer buf)
-
     cdef inline str get_tenant_label(self)
     cpdef set_stmt_cache_size(self, int maxsize)