requests/response.go

package requests

import (
	"bufio"
	"bytes"
	"context"
	"errors"
	"io"
	"net/url"
	"strconv"
	"strings"
	"time"

	"net/http"

	"github.com/gospider007/bar"
	"github.com/gospider007/bs4"
	"github.com/gospider007/gson"
	"github.com/gospider007/re"
	"github.com/gospider007/tools"
	"github.com/gospider007/websocket"
)

type Response struct {
	rawConn       *readWriteCloser
	response      *http.Response
	webSocket     *websocket.Conn
	sse           *Sse
	ctx           context.Context
	cnl           context.CancelFunc
	reqCtxData    *reqCtxData
	requestOption *RequestOption

	content  []byte
	encoding string
	// stream    bool
	// disDecode bool
	// disUnzip  bool
	filePath string
	// bar       bool
	// isNewConn bool
	readBody bool
}

type Sse struct {
	reader *bufio.Reader
	raw    io.ReadCloser
}
type Event struct {
	Data    string //data
	Event   string //event
	Id      string //id
	Retry   int    //retry num
	Comment string //comment info
}

func newSse(rd io.ReadCloser) *Sse {
	return &Sse{raw: rd, reader: bufio.NewReader(rd)}
}

// recv sse envent data
func (obj *Sse) Recv() (Event, error) {
	var event Event
	for {
		readStr, err := obj.reader.ReadString('\n')
		if err != nil || readStr == "\n" {
			return event, err
		}
		reResult := re.Search(`data:\s?(.*)`, readStr)
		if reResult != nil {
			event.Data += reResult.Group(1)
			continue
		}
		reResult = re.Search(`event:\s?(.*)`, readStr)

		if reResult != nil {
			event.Event = reResult.Group(1)
			continue
		}
		reResult = re.Search(`id:\s?(.*)`, readStr)
		if reResult != nil {
			event.Id = reResult.Group(1)
			continue
		}
		reResult = re.Search(`retry:\s?(.*)`, readStr)
		if reResult != nil {
			if event.Retry, err = strconv.Atoi(reResult.Group(1)); err != nil {
				return event, err
			}
			continue
		}
		reResult = re.Search(`:\s?(.*)`, readStr)
		if reResult != nil {
			event.Comment = reResult.Group(1)
			continue
		}
		return event, errors.New("content parse error:" + readStr)
	}
}

// close sse
func (obj *Sse) Close() error {
	return obj.raw.Close()
}

// return websocket client
func (obj *Response) WebSocket() *websocket.Conn {
	return obj.webSocket
}

// return sse client
func (obj *Response) Sse() *Sse {
	return obj.sse
}

// return URL redirected address
func (obj *Response) Location() (*url.URL, error) {
	u, err := obj.response.Location()
	if err == http.ErrNoLocation {
		err = nil
	}
	return u, err
}

// return response Proto
func (obj *Response) Proto() string {
	return obj.response.Proto
}

// return response cookies
func (obj *Response) Cookies() Cookies {
	if obj.filePath != "" {
		return nil
	}
	return obj.response.Cookies()
}

// return response status code
func (obj *Response) StatusCode() int {
	if obj.filePath != "" {
		return 200
	}
	return obj.response.StatusCode
}

// return response status
func (obj *Response) Status() string {
	if obj.filePath != "" {
		return "200 OK"
	}
	return obj.response.Status
}

// return response url
func (obj *Response) Url() *url.URL {
	if obj.filePath != "" {
		return nil
	}
	return obj.response.Request.URL
}

// return response headers
func (obj *Response) Headers() http.Header {
	if obj.filePath != "" {
		return http.Header{
			"Content-Type": []string{obj.ContentType()},
		}
	}
	return obj.response.Header
}

// change decoding with content
func (obj *Response) Decode(encoding string) {
	if obj.encoding != encoding {
		obj.encoding = encoding
		obj.SetContent(tools.Decode(obj.Content(), encoding))
	}
}

// return content with map[string]any
func (obj *Response) Map() (data map[string]any, err error) {
	_, err = gson.Decode(obj.Content(), &data)
	return
}

// return content with json and you can parse struct
func (obj *Response) Json(vals ...any) (*gson.Client, error) {
	return gson.Decode(obj.Content(), vals...)
}

// return content with string
func (obj *Response) Text() string {
	return tools.BytesToString(obj.Content())
}

// set response content with []byte
func (obj *Response) SetContent(val []byte) {
	obj.content = val
}

// return content with []byte
func (obj *Response) Content() []byte {
	if !obj.IsWebSocket() && !obj.IsSse() {
		obj.ReadBody()
		// err := obj.ReadBody()
		// if err != nil {
		// 	// log.Panic(err, " Response Content read body error")
		// 	// log.Print(err, " Response Content read body error")
		// 	// return nil
		// }
	}
	// log.Print(len(obj.content))
	return obj.content
}

// return content with parse html
func (obj *Response) Html() *bs4.Client {
	return bs4.NewClient(obj.Text(), obj.Url().String())
}

// return content type
func (obj *Response) ContentType() string {
	if obj.filePath != "" {
		return http.DetectContentType(obj.content)
	}
	contentType := obj.response.Header.Get("Content-Type")
	if contentType == "" {
		contentType = http.DetectContentType(obj.content)
	}
	return contentType
}

// return content encoding
func (obj *Response) ContentEncoding() string {
	if obj.filePath != "" {
		return ""
	}
	return obj.response.Header.Get("Content-Encoding")
}

// return content length
func (obj *Response) ContentLength() int64 {
	if obj.filePath != "" {
		return int64(len(obj.content))
	}
	if obj.response.ContentLength >= 0 {
		return obj.response.ContentLength
	}
	return int64(len(obj.content))
}

type barBody struct {
	body *bytes.Buffer
	bar  *bar.Client
}

func (obj *barBody) Write(con []byte) (int, error) {
	l, err := obj.body.Write(con)
	obj.bar.Add(int64(l))
	return l, err
}
func (obj *Response) defaultDecode() bool {
	return strings.Contains(obj.ContentType(), "html")
}

// must stream=true
func (obj *Response) Conn() *connecotr {
	if obj.IsWebSocket() || obj.IsSse() || obj.IsStream() {
		return obj.rawConn.Conn()
	}
	return nil
}

func (obj *Response) Body() io.ReadCloser {
	return obj.response.Body
}

// return true if response is stream
func (obj *Response) IsStream() bool {
	return obj.requestOption.Stream
}

// return true if response is other stream
func (obj *Response) IsWebSocket() bool {
	return obj.webSocket != nil
}
func (obj *Response) IsSse() bool {
	return obj.sse != nil
}

// read body
func (obj *Response) ReadBody() (err error) {
	if obj.readBody {
		return errors.New("already read body")
	}
	if obj.IsWebSocket() && obj.IsSse() {
		return errors.New("can not read stream")
	}
	obj.readBody = true
	bBody := bytes.NewBuffer(nil)
	if obj.requestOption.Bar && obj.ContentLength() > 0 {
		_, err = io.Copy(&barBody{
			bar:  bar.NewClient(obj.response.ContentLength),
			body: bBody,
		}, obj.Body())
	} else {
		_, err = io.Copy(bBody, obj.Body())
	}
	if obj.reqCtxData.logger != nil {
		obj.reqCtxData.logger(Log{
			Id:   obj.reqCtxData.requestId,
			Time: time.Now(),
			Type: LogType_ResponseBody,
			Msg:  "response body",
		})
	}
	if err != nil {
		obj.ForceCloseConn()
		return errors.New("response read content error: " + err.Error())
	}
	if !obj.requestOption.DisDecode && obj.defaultDecode() {
		obj.content, obj.encoding, _ = tools.Charset(bBody.Bytes(), obj.ContentType())
	} else {
		obj.content = bBody.Bytes()
	}
	obj.CloseBody()
	return
}

// conn is new conn
func (obj *Response) IsNewConn() bool {
	return obj.reqCtxData.isNewConn
}

// conn proxy
func (obj *Response) Proxys() []*url.URL {
	if obj.rawConn != nil {
		return obj.rawConn.Proxys()
	}
	return nil
}

// conn is in pool ?
func (obj *Response) InPool() bool {
	if obj.rawConn != nil {
		return obj.rawConn.InPool()
	}
	return false
}

// close body
func (obj *Response) CloseBody() {
	obj.close(false)
}

// safe close conn
func (obj *Response) CloseConn() {
	obj.close(true)
}

// close
func (obj *Response) close(closeConn bool) {
	if obj.webSocket != nil {
		obj.webSocket.Close()
	}
	if obj.sse != nil {
		obj.sse.Close()
	}
	if obj.IsWebSocket() || obj.IsSse() || !obj.readBody {
		obj.ForceCloseConn()
	} else if obj.rawConn != nil {
		if closeConn {
			obj.rawConn.CloseConn()
		} else {
			obj.rawConn.Close()
		}
	}
	obj.cnl() //must later
}

// force close conn
func (obj *Response) ForceCloseConn() {
	if obj.rawConn != nil {
		obj.rawConn.ForceCloseConn()
	}
}