| 33 | ) |
| 34 | |
| 35 | func ParseJSONToQuadList(jsonBody []byte) (out []quad.Quad, _ error) { |
| 36 | var quads []struct { |
| 37 | Subject string `json:"subject"` |
| 38 | Predicate string `json:"predicate"` |
| 39 | Object string `json:"object"` |
| 40 | Label string `json:"label"` |
| 41 | } |
| 42 | err := json.Unmarshal(jsonBody, &quads) |
| 43 | if err != nil { |
| 44 | return nil, err |
| 45 | } |
| 46 | out = make([]quad.Quad, 0, len(quads)) |
| 47 | for i, jq := range quads { |
| 48 | q := quad.Quad{ |
| 49 | Subject: quad.StringToValue(jq.Subject), |
| 50 | Predicate: quad.StringToValue(jq.Predicate), |
| 51 | Object: quad.StringToValue(jq.Object), |
| 52 | Label: quad.StringToValue(jq.Label), |
| 53 | } |
| 54 | if !q.IsValid() { |
| 55 | return nil, fmt.Errorf("invalid quad at index %d. %s", i, q) |
| 56 | } |
| 57 | out = append(out, q) |
| 58 | } |
| 59 | return out, nil |
| 60 | } |
| 61 | |
| 62 | const maxQuerySize = 1024 * 1024 // 1 MB |
| 63 | func readLimit(r io.Reader) ([]byte, error) { |