Function extractSSEJSON

internal/toolinjection/inject_stream.go:331–343

--------------------------------------------------------------------------- Common helpers --------------------------------------------------------------------------- extractSSEJSON extracts the JSON payload from an SSE data line within a chunk.

(chunk []byte)

// extractSSEJSON extracts the JSON payload from an SSE data line within a chunk.
func extractSSEJSON(chunk []byte) []byte {
	for _, line := range bytes.Split(chunk, []byte("\n")) {
		line = bytes.TrimSpace(line)
		if bytes.HasPrefix(line, []byte("data:")) {
			data := bytes.TrimPrefix(line, []byte("data:"))
			data = bytes.TrimSpace(data)
			if len(data) > 0 && data[0] == '{' {
				return data
			}
		}
	}
	return nil
}

// sseJSONReplace applies a transform function to the JSON payload inside an SSE
// data line, returning the chunk with the modified JSON.