mirror of
https://github.com/hanzoai/graph.git
synced 2026-10-30 18:35:37 +00:00
zeekay
f5aaeb712e
Derived from Dgraph (github.com/dgraph-io/dgraph) at commit 64804bd2, Apache-2.0. See NOTICE. WHAT THIS IS. The graph engine as a Go library: posting lists, the DQL parser, the type and tokenizer system, the index and schema layers, and the wire types. 39,170 lines of the upstream's 166,337. THE STORE is github.com/luxfi/zapdb, a Badger fork that kept the package name, the subpackages (options, pb, y) and the API — Open, OpenManaged, DB, Options — so the 74 import sites are aliased rather than rewritten. THE CODEC is ZAP. zapdb serializes with ZAP, not protobuf: its pb package builds the ZAP types by default and the protobuf ones only under `-tags grpc`, a path that does not compile (table/builder.go calls pb.Marshal, which that tag removes). One call site in posting needed converting; every other type here is Hanzo's own protobuf and is untouched. NO TRANSPORT. An embedded engine dials nothing, so nothing here imports google.golang.org/grpc. Removed: 20 transport functions in x, the generated service stubs for Raft, Zero and Worker (1,657 lines), and the JWT helper — identity belongs to IAM. The core called none of them. NOT KEPT: worker, conn, raftwal, the cluster commands, the GraphQL layer and the test harnesses. `query`, the DQL execution engine, went with them because it depends on worker; parsing DQL is available here, executing it is not. The history of the upstream project lives at github.com/dgraph-io/dgraph. This repository begins at the derivation because three quarters of that history describes code this fork does not carry.
74 lines
1.4 KiB
Go
74 lines
1.4 KiB
Go
/*
|
|
* SPDX-FileCopyrightText: © 2017-2026 Istari Digital, Inc.
|
|
* SPDX-License-Identifier: Apache-2.0
|
|
*/
|
|
|
|
package dql
|
|
|
|
import (
|
|
"archive/tar"
|
|
"bytes"
|
|
"compress/gzip"
|
|
"io"
|
|
"os"
|
|
"testing"
|
|
)
|
|
|
|
const (
|
|
corpusTarFile = "fuzz-data/corpus.tar.gz"
|
|
)
|
|
|
|
func FuzzTestParser(f *testing.F) {
|
|
// add the corpus data to the test
|
|
fd, err := os.Open(corpusTarFile)
|
|
if err != nil {
|
|
f.Fatalf("error opening corpus tar file: %v", err)
|
|
}
|
|
defer func() {
|
|
if err := fd.Close(); err != nil {
|
|
f.Logf("error closing corpus tar file: %v", err)
|
|
}
|
|
}()
|
|
|
|
gzr, err := gzip.NewReader(fd)
|
|
if err != nil {
|
|
f.Fatalf("error reading corpus tar file: %v", err)
|
|
}
|
|
defer func() {
|
|
if err := gzr.Close(); err != nil {
|
|
f.Logf("error closing corpus tar file: %v", err)
|
|
}
|
|
}()
|
|
tr := tar.NewReader(gzr)
|
|
|
|
for {
|
|
header, err := tr.Next()
|
|
if err == io.EOF {
|
|
break
|
|
}
|
|
if err != nil {
|
|
f.Fatalf("error while reading corpus tar file: %v", err)
|
|
}
|
|
|
|
switch header.Typeflag {
|
|
case tar.TypeReg:
|
|
buf := new(bytes.Buffer)
|
|
if _, err := io.Copy(buf, tr); err != nil {
|
|
f.Fatalf("error while copying file [%v]: %v", header.Name, err)
|
|
}
|
|
f.Add(buf.Bytes())
|
|
f.Logf("adding input: %v", buf.String())
|
|
}
|
|
}
|
|
|
|
f.Fuzz(func(t *testing.T, in []byte) {
|
|
defer func() {
|
|
if err := recover(); err != nil {
|
|
t.Errorf("DQL parsing failed for input [%x] with error: [%v]", in, err)
|
|
}
|
|
}()
|
|
|
|
_, _ = Parse(Request{Str: string(in)})
|
|
})
|
|
}
|