Method chunkedRequest

pkg/agent/proxy/integrations/http/chunk.go:185–227

Handled chunked requests when transfer-encoding is given.

(ctx context.Context, finalReq *[]byte, clientConn, destConn net.Conn, _ string)

// Handled chunked requests when transfer-encoding is given.
func (h *HTTP) chunkedRequest(ctx context.Context, finalReq *[]byte, clientConn, destConn net.Conn, _ string) error {

	for {
		select {
		case <-ctx.Done():
			return ctx.Err()
		default:
			//TODO: we have to implement a way to read the buffer chunk wise according to the chunk size (chunk size comes in hexadecimal)
			// because it can happen that some chunks come after 5 seconds.
			err := clientConn.SetReadDeadline(time.Now().Add(5 * time.Second))
			if err != nil {
				utils.LogError(h.Logger, err, "failed to set the read deadline for the client conn")
				return err
			}
			requestChunked, err := pUtil.ReadBytes(ctx, h.Logger, clientConn)
			if err != nil {
				if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
					break
				}
				utils.LogError(h.Logger, nil, "failed to read the response message from the destination server")
				return err
			}

			*finalReq = append(*finalReq, requestChunked...)
			// destConn is nil in case of test mode.
			if destConn != nil {
				_, err = destConn.Write(requestChunked)
				if err != nil {
					if ctx.Err() != nil {
						return ctx.Err()
					}
					utils.LogError(h.Logger, nil, "failed to write request message to the destination server")
					return err
				}
			}

			//check if the initial request is completed
			if strings.HasSuffix(string(requestChunked), "0\r\n\r\n") {
				return nil
			}
		}
	}
}

func (h *HTTP) handleChunkedResponses(ctx context.Context, finalResp *[]byte, clientConn, destConn net.Conn, resp []byte) error {