will it work

lib/middleware/middlewares/eqp/consumer.go

 package eqp
 
 import (
-	"errors"
-
 	"pggat2/lib/pnet"
 	"pggat2/lib/pnet/packet"
 	packets "pggat2/lib/pnet/packet/packets/v3.0"
@@ -45,7 +43,12 @@ func (T Consumer) Send(typ packet.Type, bytes []byte) error {
 	case packet.Parse:
 		destination, query, parameterDataTypes, ok := packets.ReadParse(in)
 		if !ok {
-			return errors.New("bad packet format")
+			return ErrBadPacketFormat
+		}
+		if destination != "" {
+			if _, ok = T.preparedStatements[destination]; ok {
+				return ErrPreparedStatementExists
+			}
 		}
 		T.preparedStatements[destination] = PreparedStatement{
 			Query:              query,
@@ -54,7 +57,12 @@ func (T Consumer) Send(typ packet.Type, bytes []byte) error {
 	case packet.Bind:
 		destination, source, parameterFormatCodes, parameterValues, resultFormatCodes, ok := packets.ReadBind(in)
 		if !ok {
-			return errors.New("bad packet format")
+			return ErrBadPacketFormat
+		}
+		if destination != "" {
+			if _, ok = T.portals[destination]; ok {
+				return ErrPortalExists
+			}
 		}
 		T.portals[destination] = Portal{
 			Source:               source,
@@ -65,7 +73,7 @@ func (T Consumer) Send(typ packet.Type, bytes []byte) error {
 	case packet.Close:
 		which, target, ok := packets.ReadClose(in)
 		if !ok {
-			return errors.New("bad packet format")
+			return ErrBadPacketFormat
 		}
 		switch which {
 		case 'S':
@@ -73,7 +81,7 @@ func (T Consumer) Send(typ packet.Type, bytes []byte) error {
 		case 'P':
 			delete(T.portals, target)
 		default:
-			return errors.New("unknown close target")
+			return ErrUnknownCloseTarget
 		}
 	}
 	return T.inner.Send(typ, bytes)

lib/middleware/middlewares/eqp/creator.go

 package eqp
 
 import (
-	"errors"
-
 	"pggat2/lib/pnet"
 	"pggat2/lib/pnet/packet"
 	packets "pggat2/lib/pnet/packet/packets/v3.0"
@@ -37,16 +35,24 @@ func (T Creator) Read() (packet.In, error) {
 		case packet.Parse:
 			destination, query, parameterDataTypes, ok := packets.ReadParse(in)
 			if !ok {
-				return packet.In{}, errors.New("bad packet format")
+				return packet.In{}, ErrBadPacketFormat
 			}
 			T.preparedStatements[destination] = PreparedStatement{
 				Query:              query,
 				ParameterDataTypes: parameterDataTypes,
 			}
+
+			// send parse complete
+			out := T.inner.Write()
+			out.Type(packet.ParseComplete)
+			err = out.Send()
+			if err != nil {
+				return packet.In{}, err
+			}
 		case packet.Bind:
 			destination, source, parameterFormatCodes, parameterValues, resultFormatCodes, ok := packets.ReadBind(in)
 			if !ok {
-				return packet.In{}, errors.New("bad packet format")
+				return packet.In{}, ErrBadPacketFormat
 			}
 			T.portals[destination] = Portal{
 				Source:               source,
@@ -54,10 +60,18 @@ func (T Creator) Read() (packet.In, error) {
 				ParameterValues:      parameterValues,
 				ResultFormatCodes:    resultFormatCodes,
 			}
+
+			// send bind complete
+			out := T.inner.Write()
+			out.Type(packet.BindComplete)
+			err = out.Send()
+			if err != nil {
+				return packet.In{}, err
+			}
 		case packet.Close:
 			which, target, ok := packets.ReadClose(in)
 			if !ok {
-				return packet.In{}, errors.New("bad packet format")
+				return packet.In{}, ErrBadPacketFormat
 			}
 			switch which {
 			case 'S':
@@ -65,7 +79,7 @@ func (T Creator) Read() (packet.In, error) {
 			case 'P':
 				delete(T.portals, target)
 			default:
-				return packet.In{}, errors.New("unknown close target")
+				return packet.In{}, ErrBadPacketFormat
 			}
 		default:
 			return in, nil

lib/middleware/middlewares/eqp/errors.go

+package eqp
+
+import "errors"
+
+var (
+	ErrBadPacketFormat         = errors.New("bad packet format")
+	ErrPreparedStatementExists = errors.New("prepared statement already exists")
+	ErrPortalExists            = errors.New("portal already exists")
+	ErrUnknownCloseTarget      = errors.New("unknown close target")
+)