Function jsonify

tracer/parser.go:154–198

(mime string, buf []byte)

}

func jsonify(mime string, buf []byte) ([]byte, bool) {
	switch mime {
	case "application/grpc":
		switch strings.ToLower(os.Getenv("SUBTRACE_GRPC")) {
		case "0", "n", "no", "f", "false":
		default:
			var arr []map[string]any
			for len(buf) > 0 {
				if len(buf) < 5 {
					return nil, false
				}

				comp := buf[0]
				size := binary.BigEndian.Uint32(buf[1:5])
				if len(buf) < int(size) {
					return nil, false
				}
				buf = buf[5:]

				if int(size) > len(buf) {
					return nil, false
				}
				slice := buf[:size]
				buf = buf[size:]

				if comp != 0 {
					arr = append(arr, map[string]any{"_comp": base64.RawStdEncoding.EncodeToString(slice)})
					continue
				}

				enc := make(map[string]any)
				if err := decodeRawProto(1, enc, slice); err != nil {
					return nil, false
				}
				arr = append(arr, enc)
			}
			b, err := json.Marshal(arr)
			if err != nil {
				return nil, false
			}
			return b, true
		}
	}
	return nil, false
}

func (p *Parser) UseRequest(req *http.Request) {
	sampler := newSampler(req.Body)