Method JQ

script.go:725–760

JQ executes query on the pipe's contents (presumed to be valid JSON or [JSONLines] data), applying the query to each newline-delimited input value and producing results until the first error is encountered. An invalid query or value will set the appropriate error on the pipe. The exact dialect of J

(query string)

//
// [JSONLines]: https://jsonlines.org/
func (p *Pipe) JQ(query string) *Pipe {
	parsedQuery, err := gojq.Parse(query)
	if err != nil {
		return p.WithError(err)
	}
	code, err := gojq.Compile(parsedQuery)
	if err != nil {
		return p.WithError(err)
	}
	return p.Filter(func(r io.Reader, w io.Writer) error {
		dec := json.NewDecoder(r)
		for dec.More() {
			var input any
			err := dec.Decode(&input)
			if err != nil {
				return err
			}
			iter := code.Run(input)
			for {
				v, ok := iter.Next()
				if !ok {
					break
				}
				if err, ok := v.(error); ok {
					return err
				}
				result, err := gojq.Marshal(v)
				if err != nil {
					return err
				}
				fmt.Fprintln(w, string(result))
			}
		}
		return nil
	})
}

// Last produces only the last n lines of the pipe's contents, or all the lines
// if there are less than n. If n is zero or negative, there is no output at