Function readFunctionPayload

src/go/cmd/godplugin/main.go:246–275

(raw string)

}

func readFunctionPayload(raw string) ([]byte, time.Duration, error) {
	if raw == "" {
		return nil, 0, nil
	}

	var data []byte
	var err error
	if after, ok := strings.CutPrefix(raw, "@"); ok {
		data, err = os.ReadFile(after)
	} else {
		data = []byte(raw)
	}
	if err != nil {
		return nil, 0, fmt.Errorf("read payload: %w", err)
	}

	var payload map[string]any
	if err := json.Unmarshal(data, &payload); err != nil {
		return nil, 0, fmt.Errorf("parse payload JSON: %w", err)
	}

	timeoutMs, ok, err := parsePayloadTimeout(payload)
	if err != nil {
		return nil, 0, err
	}
	if ok {
		return data, time.Duration(timeoutMs) * time.Millisecond, nil
	}
	return data, 0, nil
}

func parsePayloadTimeout(payload map[string]any) (int64, bool, error) {
	if payload == nil {