Method handlePayloadLine

src/go/plugin/framework/functions/parser.go:115–159

(line string)

}

func (p *inputParser) handlePayloadLine(line string) (inputEvent, error) {
	if line == lineFunctionPayloadEnd {
		p.readingPayload = false
		p.currentFn.Payload = []byte(p.payloadBuf.String())
		fn := p.currentFn
		p.currentFn = nil
		p.payloadBuf.Reset()
		return inputEvent{kind: inputEventCall, fn: fn}, nil
	}

	if hasLinePrefix(line, lineFunctionCancel) {
		event, err := parseCancelEvent(line)
		if err != nil {
			// Malformed cancel must not affect payload parser state.
			return inputEvent{}, err
		}

		if p.currentFn != nil && event.uid == p.currentFn.UID {
			p.resetPayloadState()
			event.preAdmission = true
		}
		return event, nil
	}

	if hasLinePrefix(line, lineFunctionProgress) {
		return parseProgressEvent(line), nil
	}

	if line == lineQuit {
		p.resetPayloadState()
		return inputEvent{kind: inputEventQuit}, nil
	}

	if hasLinePrefix(line, lineFunction) || strings.HasPrefix(line, lineFunction+"_") {
		p.resetPayloadState()
		return p.parseEvent(line)
	}

	if p.payloadBuf.Len() > 0 {
		p.payloadBuf.WriteByte('\n')
	}
	p.payloadBuf.WriteString(line)

	return inputEvent{}, nil
}

func (p *inputParser) resetPayloadState() {
	p.readingPayload = false