From c136d3e1040faf5e702c9c527af5b78eb5ad10dd Mon Sep 17 00:00:00 2001 From: Plakhotnikov Vladimir Date: Fri, 1 Sep 2023 23:16:41 +0500 Subject: [PATCH] Update frame validation error to current version --- internal/receive.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/internal/receive.go b/internal/receive.go index 1efc8ee..d734b56 100644 --- a/internal/receive.go +++ b/internal/receive.go @@ -13,6 +13,8 @@ import ( // shortland for the Could not open input file: ../roadrunner/tests/psr-wfsdorker.php var res = []byte("Could not op") //nolint:gochecknoglobals +const validationError = "validation failed on the message sent to STDOUT, see: https://roadrunner.dev/docs/known-issues-stdout-crc/current/en, invalid message: %s" + func ReceiveFrame(relay io.Reader, fr *frame.Frame) error { const op = errors.Op("goridge_frame_receive") @@ -58,17 +60,17 @@ func ReceiveFrame(relay io.Reader, fr *frame.Frame) error { if d, ok := relay.(deadliner); ok { err = d.SetReadDeadline(time.Now().Add(time.Second * 2)) if err != nil { - return errors.E(op, errors.Errorf("validation failed on the message sent to STDOUT, see: https://roadrunner.dev/docs/known-issues-stdout-crc/2.x/en, invalid message: %s", fr.Header())) + return errors.E(op, errors.Errorf(validationError, fr.Header())) } // we don't care about error here resp, _ := io.ReadAll(relay) - return errors.E(op, errors.Errorf("validation failed on the message sent to STDOUT, see: https://roadrunner.dev/docs/known-issues-stdout-crc/2.x/en, invalid message: %s", string(fr.Header())+string(resp))) + return errors.E(op, errors.Errorf(validationError, string(fr.Header())+string(resp))) } // no deadline, so, only 14 bytes - return errors.E(op, errors.Errorf("validation failed on the message sent to STDOUT, see: https://roadrunner.dev/docs/known-issues-stdout-crc/2.x/en, invalid message: %s", fr.Header())) + return errors.E(op, errors.Errorf(validationError, fr.Header())) } // read the read payload