// Copyright (c) 2015-present Jeevanandam M (jeeva@myjeeva.com), All rights reserved.
// resty source code and usage is governed by a MIT style
// license that can be found in the LICENSE file.
// SPDX-License-Identifier: MIT

// Package resty provides a simple HTTP, REST, and SSE client library for Go.
package resty // import "resty.dev/v3"

import (
	"math"
	"net"
	"net/http"
	"net/http/cookiejar"
	"net/url"
	"runtime"
	"sync"
	"time"

	"golang.org/x/net/publicsuffix"
)

// Version is the current Resty library version string.
const Version = "3.0.0-rc.2+devrc3"

// New creates a new Resty client.
func New() *Client {
	return NewWithTransportSettings(nil)
}

// NewWithTransportSettings creates a new Resty client with the provided
// [TransportSettings].
func NewWithTransportSettings(transportSettings *TransportSettings) *Client {
	return NewWithDialerAndTransportSettings(nil, transportSettings)
}

// NewWithClient creates a new Resty client with the given [http.Client].
func NewWithClient(hc *http.Client) *Client {
	return createClient(hc)
}

// NewWithDialer creates a new Resty client with the given [net.Dialer].
func NewWithDialer(dialer *net.Dialer) *Client {
	return NewWithDialerAndTransportSettings(dialer, nil)
}

// NewWithLocalAddr creates a new Resty client with the given local address.
func NewWithLocalAddr(localAddr net.Addr) *Client {
	return NewWithDialerAndTransportSettings(
		&net.Dialer{LocalAddr: localAddr},
		nil,
	)
}

// NewWithDialerAndTransportSettings creates a new Resty client with the given
// [net.Dialer] and [TransportSettings].
func NewWithDialerAndTransportSettings(dialer *net.Dialer, transportSettings *TransportSettings) *Client {
	return createClient(&http.Client{
		Jar:       createCookieJar(),
		Transport: createTransport(dialer, transportSettings),
	})
}

//‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾‾
// Unexported methods
//_______________________________________________________________________

func createTransport(dialer *net.Dialer, transportSettings *TransportSettings) *http.Transport {
	if transportSettings == nil {
		transportSettings = &TransportSettings{}
	}

	// Dialer

	if dialer == nil {
		dialer = &net.Dialer{}
	}

	if transportSettings.DialerTimeout > 0 {
		dialer.Timeout = transportSettings.DialerTimeout
	} else {
		dialer.Timeout = 30 * time.Second
	}

	if transportSettings.DialerKeepAlive > 0 {
		dialer.KeepAlive = transportSettings.DialerKeepAlive
	} else {
		dialer.KeepAlive = 30 * time.Second
	}

	// Transport
	t := &http.Transport{
		Proxy:              http.ProxyFromEnvironment,
		DialContext:        transportDialContext(dialer),
		DisableKeepAlives:  transportSettings.DisableKeepAlives,
		DisableCompression: true, // Resty handles it, see [Client.AddContentDecoder]
		ForceAttemptHTTP2:  true,
	}

	if transportSettings.IdleConnTimeout > 0 {
		t.IdleConnTimeout = transportSettings.IdleConnTimeout
	} else {
		t.IdleConnTimeout = 90 * time.Second
	}

	if transportSettings.TLSHandshakeTimeout > 0 {
		t.TLSHandshakeTimeout = transportSettings.TLSHandshakeTimeout
	} else {
		t.TLSHandshakeTimeout = 10 * time.Second
	}

	if transportSettings.ExpectContinueTimeout > 0 {
		t.ExpectContinueTimeout = transportSettings.ExpectContinueTimeout
	} else {
		t.ExpectContinueTimeout = 1 * time.Second
	}

	if transportSettings.MaxIdleConns > 0 {
		t.MaxIdleConns = transportSettings.MaxIdleConns
	} else {
		t.MaxIdleConns = 100
	}

	if transportSettings.MaxIdleConnsPerHost > 0 {
		t.MaxIdleConnsPerHost = transportSettings.MaxIdleConnsPerHost
	} else {
		t.MaxIdleConnsPerHost = runtime.GOMAXPROCS(0) + 1
	}

	if transportSettings.MaxConnsPerHost > 0 {
		t.MaxConnsPerHost = transportSettings.MaxConnsPerHost
	}

	//
	// No default value in Resty for following settings, added to
	// provide ability to set value otherwise the Go HTTP client
	// default value applies.
	//

	if transportSettings.ResponseHeaderTimeout > 0 {
		t.ResponseHeaderTimeout = transportSettings.ResponseHeaderTimeout
	}

	if transportSettings.MaxResponseHeaderBytes > 0 {
		t.MaxResponseHeaderBytes = transportSettings.MaxResponseHeaderBytes
	}

	if transportSettings.WriteBufferSize > 0 {
		t.WriteBufferSize = transportSettings.WriteBufferSize
	}

	if transportSettings.ReadBufferSize > 0 {
		t.ReadBufferSize = transportSettings.ReadBufferSize
	}

	return t
}

func createCookieJar() *cookiejar.Jar {
	cookieJar, _ := cookiejar.New(&cookiejar.Options{PublicSuffixList: publicsuffix.List})
	return cookieJar
}

func createClient(hc *http.Client) *Client {
	c := &Client{ // not setting language default values
		lock:                     &sync.RWMutex{},
		queryParams:              url.Values{},
		formData:                 url.Values{},
		header:                   http.Header{},
		authScheme:               defaultAuthScheme,
		cookies:                  make([]*http.Cookie, 0),
		retryWaitTime:            defaultWaitTime,
		retryMaxWaitTime:         defaultMaxWaitTime,
		isRetryDefaultConditions: true,
		pathParams:               make(map[string]string),
		headerAuthorizationKey:   hdrAuthorizationKey,
		jsonEscapeHTML:           true,
		httpClient:               hc,
		debugBodyLimit:           math.MaxInt32,
		contentTypeEncoders:      make(map[string]ContentTypeEncoder),
		contentTypeDecoders:      make(map[string]ContentTypeDecoder),
		contentDecompresserKeys:  make([]string, 0),
		contentDecompressers:     make(map[string]ContentDecompresser),
		certWatcherStopChan:      make(chan bool),
	}

	// Logger
	c.SetLogger(createLogger())
	c.SetDebugLogFormatter(DebugLogFormatter)

	c.AddContentTypeEncoder(jsonKey, encodeJSON)
	c.AddContentTypeEncoder(xmlKey, encodeXML)

	c.AddContentTypeDecoder(jsonKey, decodeJSON)
	c.AddContentTypeDecoder(xmlKey, decodeXML)

	// Order matter, giving priority to gzip
	c.AddContentDecompresser("deflate", decompressDeflate)
	c.AddContentDecompresser("gzip", decompressGzip)

	// request middlewares
	c.SetRequestMiddlewares(
		MiddlewareRequestCreate,
	)

	// response middlewares
	c.SetResponseMiddlewares(
		MiddlewareResponseAutoParse,
		MiddlewareResponseSaveToFile,
	)

	return c
}