// Copyright 2020 PingCAP, Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// See the License for the specific language governing permissions and
// limitations under the License.

package utils

import (
	"context"
	"crypto/tls"
	"fmt"
	"io"
	"net"
	"net/http"
	"net/url"
	"os"
	"path/filepath"
	"time"
)

// HTTPClient is a wrap of http.Client
type HTTPClient struct {
	client *http.Client
	header http.Header
}

// NewHTTPClient returns a new HTTP client with timeout and HTTPS support
func NewHTTPClient(timeout time.Duration, tlsConfig *tls.Config) *HTTPClient {
	if timeout < time.Second {
		timeout = 10 * time.Second // default timeout is 10s
	}
	tr := &http.Transport{
		TLSClientConfig: tlsConfig,
		Dial:            (&net.Dialer{Timeout: 3 * time.Second}).Dial,
	}
	// prefer to use the inner http proxy
	httpProxy := os.Getenv("TIUP_INNER_HTTP_PROXY")
	if len(httpProxy) == 0 {
		httpProxy = os.Getenv("HTTP_PROXY")
	}
	if len(httpProxy) > 0 {
		if proxyURL, err := url.Parse(httpProxy); err == nil {
			tr.Proxy = http.ProxyURL(proxyURL)
		}
	}
	return &HTTPClient{
		client: &http.Client{
			Timeout:   timeout,
			Transport: tr,
		},
	}
}

// SetRequestHeader set http request header
func (c *HTTPClient) SetRequestHeader(key, value string) {
	if c.header == nil {
		c.header = http.Header{}
	}
	c.header.Add(key, value)
}

// Get fetch an URL with GET method and returns the response
func (c *HTTPClient) Get(ctx context.Context, url string) ([]byte, error) {
	data, _, err := c.GetWithStatusCode(ctx, url)
	return data, err
}

// GetWithStatusCode fetch a URL with GET method and returns the response, also the status code.
func (c *HTTPClient) GetWithStatusCode(ctx context.Context, url string) ([]byte, int, error) {
	var statusCode int
	req, err := http.NewRequest("GET", url, nil)
	if err != nil {
		return nil, statusCode, err
	}

	req.Header = c.header

	if ctx != nil {
		req = req.WithContext(ctx)
	}
	res, err := c.client.Do(req)
	if err != nil {
		return nil, statusCode, err
	}
	defer res.Body.Close()

	data, err := checkHTTPResponse(res)
	return data, res.StatusCode, err
}

// Download fetch an URL with GET method and Download the response to filePath
func (c *HTTPClient) Download(ctx context.Context, url, filePath string) error {
	//  IsExist
	if IsExist(filePath) {
		return fmt.Errorf("target file %s already exists", filePath)
	}

	if err := MkdirAll(filepath.Dir(filePath), 0755); err != nil {
		return err
	}

	// create target file
	f, err := os.Create(filePath)
	if err != nil {
		return err
	}
	defer f.Close()

	req, err := http.NewRequest("GET", url, nil)
	if err != nil {
		return err
	}

	req.Header = c.header

	if ctx != nil {
		req = req.WithContext(ctx)
	}
	res, err := c.client.Do(req)
	if err != nil {
		return err
	}
	defer res.Body.Close()

	_, err = io.Copy(f, res.Body)
	if err != nil {
		return err
	}

	return nil
}

// Post send a POST request to the url and returns the response
func (c *HTTPClient) Post(ctx context.Context, url string, body io.Reader) ([]byte, error) {
	data, _, err := c.PostWithStatusCode(ctx, url, body)
	return data, err
}

// PostWithStatusCode send a POST request to the url and returns the response, also the http status code.
func (c *HTTPClient) PostWithStatusCode(ctx context.Context, url string, body io.Reader) ([]byte, int, error) {
	var statusCode int
	req, err := http.NewRequest("POST", url, body)
	if err != nil {
		return nil, statusCode, err
	}

	if c.header == nil {
		req.Header.Set("Content-Type", "application/json")
	} else {
		req.Header = c.header
	}

	if ctx != nil {
		req = req.WithContext(ctx)
	}
	res, err := c.client.Do(req)
	if err != nil {
		return nil, statusCode, err
	}
	defer res.Body.Close()

	data, err := checkHTTPResponse(res)
	return data, res.StatusCode, err
}

// Put send a PUT request to the url and returns the response, also the status code
func (c *HTTPClient) Put(ctx context.Context, url string, body io.Reader) ([]byte, int, error) {
	var statusCode int
	req, err := http.NewRequest("PUT", url, body)
	if err != nil {
		return nil, statusCode, err
	}
	if c.header == nil {
		req.Header.Set("Content-Type", "application/json")
	} else {
		req.Header = c.header
	}
	if ctx != nil {
		req = req.WithContext(ctx)
	}

	resp, err := c.client.Do(req)
	if err != nil {
		return nil, statusCode, err
	}
	defer resp.Body.Close()
	b, err := checkHTTPResponse(resp)
	statusCode = resp.StatusCode
	return b, statusCode, err
}

// Delete send a DELETE request to the url and returns the response and status code.
func (c *HTTPClient) Delete(ctx context.Context, url string, body io.Reader) ([]byte, int, error) {
	var statusCode int
	req, err := http.NewRequest("DELETE", url, body)
	if err != nil {
		return nil, statusCode, err
	}

	if ctx != nil {
		req = req.WithContext(ctx)
	}
	res, err := c.client.Do(req)
	if err != nil {
		return nil, statusCode, err
	}
	defer res.Body.Close()
	b, err := checkHTTPResponse(res)
	statusCode = res.StatusCode
	return b, statusCode, err
}

// Client returns the http.Client
func (c *HTTPClient) Client() *http.Client {
	return c.client
}

// WithClient uses the specified HTTP client
func (c *HTTPClient) WithClient(client *http.Client) *HTTPClient {
	c.client = client
	return c
}

// checkHTTPResponse checks if an HTTP response is with normal status codes
func checkHTTPResponse(res *http.Response) ([]byte, error) {
	body, err := io.ReadAll(res.Body)
	if err != nil {
		return nil, err
	}
	if res.StatusCode < 200 || res.StatusCode >= 400 {
		return body, fmt.Errorf("error requesting %s, response: %s, code %d",
			res.Request.URL, string(body), res.StatusCode)
	}
	return body, nil
}