summaryrefslogtreecommitdiff
path: root/vendor/github.com/uptrace/bun/dialect/pgdialect/stream_parser.go
diff options
context:
space:
mode:
authorLibravatar tobi <31960611+tsmethurst@users.noreply.github.com>2022-08-15 12:35:05 +0200
committerLibravatar GitHub <noreply@github.com>2022-08-15 11:35:05 +0100
commitac6ed3d939fe9dad81aadbd04541e905c625ca82 (patch)
tree6116baf25675837dc99f69c49b9fec2ff112ce5c /vendor/github.com/uptrace/bun/dialect/pgdialect/stream_parser.go
parent[frontend] Sensitive media spoilers (#752) (diff)
downloadgotosocial-ac6ed3d939fe9dad81aadbd04541e905c625ca82.tar.xz
[chore] Update bun / sqlite versions; update gtsmodels (#754)
* upstep bun and sqlite versions * allow specific columns to be updated in the db * only update necessary columns for user * bit tidier * only update necessary fields of media_attachment * only update relevant instance fields * update tests * update only specific account columns * use bool pointers on gtsmodels includes attachment, status, account, user * update columns more selectively * test all default fields on new account insert * updating remaining bools on gtsmodels * initialize pointer fields when extracting AP emoji * copy bools properly * add copyBoolPtr convenience function + test it * initialize false bool ptrs a bit more neatly
Diffstat (limited to 'vendor/github.com/uptrace/bun/dialect/pgdialect/stream_parser.go')
-rw-r--r--vendor/github.com/uptrace/bun/dialect/pgdialect/stream_parser.go60
1 files changed, 60 insertions, 0 deletions
diff --git a/vendor/github.com/uptrace/bun/dialect/pgdialect/stream_parser.go b/vendor/github.com/uptrace/bun/dialect/pgdialect/stream_parser.go
new file mode 100644
index 000000000..7b9a15f62
--- /dev/null
+++ b/vendor/github.com/uptrace/bun/dialect/pgdialect/stream_parser.go
@@ -0,0 +1,60 @@
+package pgdialect
+
+import (
+ "fmt"
+ "io"
+)
+
+type streamParser struct {
+ b []byte
+ i int
+
+ buf []byte
+}
+
+func newStreamParser(b []byte, start int) *streamParser {
+ return &streamParser{
+ b: b,
+ i: start,
+ }
+}
+
+func (p *streamParser) valid() bool {
+ return p.i < len(p.b)
+}
+
+func (p *streamParser) 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 *streamParser) readByte() (byte, error) {
+ if p.valid() {
+ c := p.b[p.i]
+ p.i++
+ return c, nil
+ }
+ return 0, io.EOF
+}
+
+func (p *streamParser) unreadByte() {
+ p.i--
+}
+
+func (p *streamParser) peek() byte {
+ if p.valid() {
+ return p.b[p.i]
+ }
+ return 0
+}
+
+func (p *streamParser) skipNext() {
+ p.i++
+}