Function forwardStream

core/services/cloudproxy/proxy.go:66–88

forwardStream relays the upstream SSE response to the client, flushing per read so events arrive in real time. Response/output PII redaction is out of scope for now, so the stream is forwarded unmodified.

(c echo.Context, body io.Reader)

// redaction is out of scope for now, so the stream is forwarded
// unmodified.
func forwardStream(c echo.Context, body io.Reader) error {
	c.Response().Header().Set("Content-Type", "text/event-stream")
	c.Response().Header().Set("Cache-Control", "no-cache")
	c.Response().Header().Set("Connection", "keep-alive")
	c.Response().WriteHeader(http.StatusOK)

	buf := make([]byte, 32*1024)
	for {
		n, rErr := body.Read(buf)
		if n > 0 {
			if _, wErr := c.Response().Writer.Write(buf[:n]); wErr != nil {
				return nil
			}
			c.Response().Flush()
		}
		if rErr != nil {
			if rErr != io.EOF {
				xlog.Debug("cloudproxy: stream read error", "error", rErr)
			}
			return nil
		}
	}
}