(raw []byte)
| 44 | type RequestPayload []byte |
| 45 | |
| 46 | func NewRequestPayload(raw []byte) (RequestPayload, error) { |
| 47 | if len(bytes.TrimSpace(raw)) == 0 { |
| 48 | return nil, xerrors.New("empty request body") |
| 49 | } |
| 50 | if !json.Valid(raw) { |
| 51 | return nil, xerrors.New("invalid JSON payload") |
| 52 | } |
| 53 | |
| 54 | return RequestPayload(raw), nil |
| 55 | } |
| 56 | |
| 57 | func (p RequestPayload) Stream() bool { |
| 58 | return gjson.GetBytes(p, reqPathStream).Bool() |