Function rawRequest

cmd/api.go:482–586

(method, uri string, requestTarget string, headers []header, body string, timeout int)

}

func rawRequest(method, uri string, requestTarget string, headers []header, body string, timeout int) (ResponseInfo, error) {
	parsedURL, err := url.Parse(uri)
	if err != nil || parsedURL == nil || parsedURL.Scheme == "" || parsedURL.Host == "" {
		parsedURL, err = parseRawURL(uri)
		if err != nil {
			return ResponseInfo{}, err
		}
	}

	addr := parsedURL.Host
	if parsedURL.Port() == "" {
		port := "80"
		if parsedURL.Scheme == "https" {
			port = "443"
		}
		addr = net.JoinHostPort(parsedURL.Hostname(), port)
	}

	dialer := &net.Dialer{Timeout: time.Duration(timeout) * time.Millisecond}
	var conn net.Conn
	if parsedURL.Scheme == "https" {
		conn, err = tls.DialWithDialer(dialer, "tcp", addr, &tls.Config{
			InsecureSkipVerify: true,
			ServerName:         parsedURL.Hostname(),
		})
	} else {
		conn, err = dialer.Dial("tcp", addr)
	}
	if err != nil {
		return ResponseInfo{}, err
	}
	defer func() {
		_ = conn.Close()
	}()
	_ = conn.SetDeadline(time.Now().Add(time.Duration(timeout) * time.Millisecond))

	if requestTarget == "" {
		requestTarget = rawRequestTarget(uri)
	}

	hasHost := false
	hasConnection := false
	hasContentLength := false
	var builder strings.Builder
	builder.WriteString(method)
	builder.WriteString(" ")
	builder.WriteString(requestTarget)
	builder.WriteString(" HTTP/1.1\r\n")
	for _, h := range headers {
		if strings.EqualFold(h.key, "Host") {
			hasHost = true
		}
		if strings.EqualFold(h.key, "Connection") {
			hasConnection = true
		}
		if strings.EqualFold(h.key, "Content-Length") {
			hasContentLength = true
		}