http.go

package rpc

import (
	"bytes"
	"context"
	"encoding/json"
	"fmt"
	"net/http"
	"strings"
	"time"
)

// createRequest
func (p *Provider) createRequest(ctx context.Context, rp RequestPayload) (*http.Request, error) {
	var data []byte
	if rj := p.Opts.Experimental.CustomRequestPayload; rj != nil && p.Opts.Experimental.DotPath != "" {
		d, err := rp.embedPayload(rj, p.Opts.Experimental.DotPath)
		if err != nil {
			return nil, err
		}
		data = d
	} else {
		d, err := json.Marshal(rp)
		if err != nil {
			return nil, err
		}
		data = d
	}

	req, err := http.NewRequestWithContext(ctx, p.Opts.Request.HTTPMethod, p.listenerURL.String(), bytes.NewReader(data))
	if err != nil {
		return nil, err
	}
	for k, v := range p.Opts.Request.StaticHeaders {
		req.Header.Add(k, strings.Join(v, ","))
	}
	if p.Opts.Request.HTTPContentType != "" {
		req.Header.Set("Content-Type", p.Opts.Request.HTTPContentType)
	}
	if p.Opts.Request.TimestampHeader != "" {
		req.Header.Add(p.Opts.Request.TimestampHeader, time.Now().Format(p.Opts.Request.TimestampFormat))
	}

	return req, nil
}

func (p *Provider) handleResponse(statusCode int, headers http.Header, body *bytes.Buffer, reqKeysAndValues []any) (ResponsePayload, error) {
	kvs := reqKeysAndValues
	defer func() {
		if !p.LogNotificationsDisabled {
			kvs = append(kvs, responseKVS(statusCode, headers, body)...)
			p.Logger.Info("rpc notification details", kvs...)
		}
	}()

	res := ResponsePayload{}
	if err := json.Unmarshal(body.Bytes(), &res); err != nil {
		if statusCode != http.StatusOK {
			return ResponsePayload{}, fmt.Errorf("unexpected status code: %d, response error(optional): %v", statusCode, res.Error)
		}
		return ResponsePayload{}, fmt.Errorf("failed to parse response: %w", err)
	}
	if statusCode != http.StatusOK {
		return ResponsePayload{}, fmt.Errorf("unexpected status code: %d, response error(optional): %v", statusCode, res.Error)
	}

	return res, nil
}