From 98263a7de64269898a2f81207e38943b5c8e8653 Mon Sep 17 00:00:00 2001
From: Tobi Smethurst <31960611+tsmethurst@users.noreply.github.com>
Date: Thu, 12 Aug 2021 21:03:24 +0200
Subject: Grand test fixup (#138)

* start fixing up tests

* fix up tests + automate with drone

* fiddle with linting

* messing about with drone.yml

* some more fiddling

* hmmm

* add cache

* add vendor directory

* verbose

* ci updates

* update some little things

* update sig
---
 .../pg/v10/internal/parser/streaming_parser.go     | 65 ++++++++++++++++++++++
 1 file changed, 65 insertions(+)
 create mode 100644 vendor/github.com/go-pg/pg/v10/internal/parser/streaming_parser.go

(limited to 'vendor/github.com/go-pg/pg/v10/internal/parser/streaming_parser.go')

diff --git a/vendor/github.com/go-pg/pg/v10/internal/parser/streaming_parser.go b/vendor/github.com/go-pg/pg/v10/internal/parser/streaming_parser.go
new file mode 100644
index 000000000..723c12b16
--- /dev/null
+++ b/vendor/github.com/go-pg/pg/v10/internal/parser/streaming_parser.go
@@ -0,0 +1,65 @@
+package parser
+
+import (
+	"fmt"
+
+	"github.com/go-pg/pg/v10/internal/pool"
+)
+
+type StreamingParser struct {
+	pool.Reader
+}
+
+func NewStreamingParser(rd pool.Reader) StreamingParser {
+	return StreamingParser{
+		Reader: rd,
+	}
+}
+
+func (p StreamingParser) SkipByte(skip byte) error {
+	c, err := p.ReadByte()
+	if err != nil {
+		return err
+	}
+	if c == skip {
+		return nil
+	}
+	_ = p.UnreadByte()
+	return fmt.Errorf("got %q, wanted %q", c, skip)
+}
+
+func (p StreamingParser) ReadSubstring(b []byte) ([]byte, error) {
+	c, err := p.ReadByte()
+	if err != nil {
+		return b, err
+	}
+
+	for {
+		if c == '"' {
+			return b, nil
+		}
+
+		next, err := p.ReadByte()
+		if err != nil {
+			return b, err
+		}
+
+		if c == '\\' {
+			switch next {
+			case '\\', '"':
+				b = append(b, next)
+				c, err = p.ReadByte()
+				if err != nil {
+					return nil, err
+				}
+			default:
+				b = append(b, '\\')
+				c = next
+			}
+			continue
+		}
+
+		b = append(b, c)
+		c = next
+	}
+}
-- 
cgit v1.2.3