main.go

package biliApi

import (
	"bytes"
	"crypto/md5"
	"encoding/json"
	"errors"
	"fmt"
	"net/http"
	"net/url"
	"slices"
	"strconv"
	"strings"
	"sync"
	"time"

	cmp "github.com/qydysky/part/component2"
	pool "github.com/qydysky/part/pool"
	reqf "github.com/qydysky/part/reqf"
	psync "github.com/qydysky/part/sync"
)

const id = "github.com/qydysky/bili_danmu/F.biliApi"
const UA = `Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.3`

func init() {
	if e := cmp.Register[biliApiInter](id, &biliApi{
		location: time.UTC,
	}); e != nil {
		panic(e)
	}
}

type biliApi struct {
	proxy    string
	location *time.Location
	pool     *pool.Buf[reqf.Req]
	cookies  []*http.Cookie
	cache    psync.MapExceeded[string, *struct {
		IsLogin bool
		WbiImg  struct {
			ImgURL string
			SubURL string
		}
	}]
	lock sync.RWMutex
}

// LikeReport implements biliApiInter.
func (t *biliApi) LikeReport(hitCount, uid, roomid, upUid int) (err error) {
	csrf := ""
	if e, t := t.GetCookie(`bili_jct`); e == nil {
		csrf = t
	}

	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Url:     "https://api.live.bilibili.com/xlive/app-ucenter/v1/like_info_v3/like/likeReportV3",
		PostStr: fmt.Sprintf("click_time=%d&uid=%d&room_id=%d&anchor_id=%d&csrf=%s&csrf_token=%s&visit_id=", hitCount, uid, roomid, upUid, csrf, csrf),
		Retry:   2,
		Timeout: 5 * 1000,
		Proxy:   t.proxy,
		Header: map[string]string{
			`Host`:            `api.live.bilibili.com`,
			`User-Agent`:      UA,
			`Accept`:          `application/json, text/javascript, */*; q=0.01`,
			`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
			`Accept-Encoding`: `gzip, deflate, br`,
			`Content-Type`:    `application/x-www-form-urlencoded`,
			`Origin`:          `https://live.bilibili.com`,
			`Connection`:      `keep-alive`,
			`Pragma`:          `no-cache`,
			`Cache-Control`:   `no-cache`,
			`Referer`:         fmt.Sprintf("https://live.bilibili.com/%d", roomid),
			`Cookie`:          t.GetCookiesS(),
		},
	})
	if err != nil {
		return err
	}

	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}

	t.SetCookies(req.Response.Cookies())
	return
}

// SetLocation implements biliApiInter.
func (t *biliApi) SetLocation(secOfTimeZone int) {
	t.location = time.FixedZone("CUS", secOfTimeZone)
}

// LiveHtml implements biliApiInter.
func (t *biliApi) LiveHtml(Roomid int) (err error, res struct {
	RoomInitRes struct {
		Code    int
		Message string
		TTL     int
		Data    struct {
			RoomID      int
			UID         int
			LiveStatus  int
			LiveTime    int
			PlayurlInfo struct {
				ConfJSON string
				Playurl  struct {
					Stream []struct {
						ProtocolName string
						Format       []struct {
							FormatName string
							Codec      []struct {
								CodecName string
								CurrentQn int
								AcceptQn  []int
								BaseURL   string
								URLInfo   []struct {
									Host      string
									Extra     string
									StreamTTL int
								}
								HdrQn     any
								DolbyType int
								AttrName  string
							}
						}
					}
				}
			}
		}
	}
	RoomInfoRes struct {
		Code    int
		Message string
		TTL     int
		Data    struct {
			RoomInfo struct {
				Title        string
				LockStatus   int
				AreaID       int
				ParentAreaID int
			}
			AnchorInfo      struct{ BaseInfo struct{ Uname string } }
			PopularRankInfo struct {
				Rank     int
				RankName string
			}
			GuardInfo struct{ Count int }
		}
	}
}) {
	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Header: map[string]string{
			`Host`:            `live.bilibili.com`,
			`User-Agent`:      `Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.3`,
			`Accept`:          `application/json, text/plain, */*`,
			`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
			`Accept-Encoding`: `gzip, deflate, br`,
			`Origin`:          `https://live.bilibili.com`,
			`Connection`:      `keep-alive`,
			`Pragma`:          `no-cache`,
			`Cache-Control`:   `no-cache`,
			`Referer`:         fmt.Sprintf("https://live.bilibili.com/%d", Roomid),
		},
		Url:   fmt.Sprintf("https://live.bilibili.com/%d", Roomid),
		Proxy: t.proxy,
	})
	if err != nil {
		return
	}

	var j struct {
		RoomInitRes struct {
			Code    int    `json:"code"`
			Message string `json:"message"`
			TTL     int    `json:"ttl"`
			Data    struct {
				RoomID      int `json:"room_id"`
				UID         int `json:"uid"`
				LiveStatus  int `json:"live_status"`
				LiveTime    int `json:"live_time"`
				PlayurlInfo struct {
					ConfJSON string `json:"conf_json"`
					Playurl  struct {
						Stream []struct {
							ProtocolName string `json:"protocol_name"`
							Format       []struct {
								FormatName string `json:"format_name"`
								Codec      []struct {
									CodecName string `json:"codec_name"`
									CurrentQn int    `json:"current_qn"`
									AcceptQn  []int  `json:"accept_qn"`
									BaseURL   string `json:"base_url"`
									URLInfo   []struct {
										Host      string `json:"host"`
										Extra     string `json:"extra"`
										StreamTTL int    `json:"stream_ttl"`
									} `json:"url_info"`
									HdrQn     interface{} `json:"hdr_qn"`
									DolbyType int         `json:"dolby_type"`
									AttrName  string      `json:"attr_name"`
								} `json:"codec"`
							} `json:"format"`
						} `json:"stream"`
					} `json:"playurl"`
				} `json:"playurl_info"`
			} `json:"data"`
		} `json:"roomInitRes"`
		RoomInfoRes struct {
			Code    int    `json:"code"`
			Message string `json:"message"`
			TTL     int    `json:"ttl"`
			Data    struct {
				RoomInfo struct {
					Title        string `json:"title"`
					LockStatus   int    `json:"lock_status"`
					AreaID       int    `json:"area_id"`
					ParentAreaID int    `json:"parent_area_id"`
				} `json:"room_info"`
				AnchorInfo struct {
					BaseInfo struct {
						Uname string `json:"uname"`
					} `json:"base_info"`
				} `json:"anchor_info"`
				PopularRankInfo struct {
					Rank     int    `json:"rank"`
					RankName string `json:"rank_name"`
				} `json:"popular_rank_info"`
				GuardInfo struct {
					Count int `json:"count"`
				} `json:"guard_info"`
			} `json:"data"`
		} `json:"roomInfoRes"`
	}

	if bs := bytes.Split(req.Respon, []byte("<script>window.__NEPTUNE_IS_MY_WAIFU__=")); len(bs) < 2 {
		err = errors.New("不存在__NEPTUNE_IS_MY_WAIFU__")
		return
	} else if bs = bytes.Split(bs[1], []byte("</script>")); len(bs) < 1 {
		err = errors.New("不存在__NEPTUNE_IS_MY_WAIFU__")
		return
	} else {
		err = json.Unmarshal(bs[0], &j)
		if err != nil {
			return
		} else if j.RoomInitRes.Code != 0 {
			err = errors.New(j.RoomInitRes.Message)
			return
		}

		res = struct {
			RoomInitRes struct {
				Code    int
				Message string
				TTL     int
				Data    struct {
					RoomID      int
					UID         int
					LiveStatus  int
					LiveTime    int
					PlayurlInfo struct {
						ConfJSON string
						Playurl  struct {
							Stream []struct {
								ProtocolName string
								Format       []struct {
									FormatName string
									Codec      []struct {
										CodecName string
										CurrentQn int
										AcceptQn  []int
										BaseURL   string
										URLInfo   []struct {
											Host      string
											Extra     string
											StreamTTL int
										}
										HdrQn     any
										DolbyType int
										AttrName  string
									}
								}
							}
						}
					}
				}
			}
			RoomInfoRes struct {
				Code    int
				Message string
				TTL     int
				Data    struct {
					RoomInfo struct {
						Title        string
						LockStatus   int
						AreaID       int
						ParentAreaID int
					}
					AnchorInfo      struct{ BaseInfo struct{ Uname string } }
					PopularRankInfo struct {
						Rank     int
						RankName string
					}
					GuardInfo struct{ Count int }
				}
			}
		}(j)

		t.SetCookies(req.Response.Cookies())
		return
	}
}

// SearchUP implements biliApiInter.
func (t *biliApi) SearchUP(s string) (err error, res []struct {
	Roomid  int
	Uname   string
	Is_live bool
}) {

	query := "page=1&page_size=10&order=online&platform=pc&search_type=live_user&keyword=" + url.PathEscape(s)

	if e, v := t.GetNav(); e != nil {
		err = e
		return
	} else if e, queryE := t.Wbi(query, v.WbiImg); e != nil {
		err = e
		return
	} else {
		query = queryE
	}

	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Url:   "https://api.bilibili.com/x/web-interface/wbi/search/type?" + query,
		Proxy: t.proxy,
		Header: map[string]string{
			`Cookie`: t.GetCookiesS(),
		},
		Timeout: 10 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}

	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		TTL     int    `json:"ttl"`
		Data    struct {
			Result []struct {
				IsLive bool   `json:"is_live"`
				Uname  string `json:"uname"`
				Roomid int    `json:"roomid"`
			} `json:"result"`
		} `json:"data"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}

	for i := 0; i < len(j.Data.Result); i += 1 {
		uname := strings.ReplaceAll(j.Data.Result[i].Uname, `<em class="keyword">`, ``)
		uname = strings.ReplaceAll(uname, `</em>`, ``)
		res = append(res, struct {
			Roomid  int
			Uname   string
			Is_live bool
		}{
			Roomid:  j.Data.Result[i].Roomid,
			Uname:   uname,
			Is_live: j.Data.Result[i].IsLive,
		})
	}

	t.SetCookies(req.Response.Cookies())
	return
}

// GetHisDanmu implements biliApiInter.
func (t *biliApi) GetHisDanmu(Roomid int) (err error, res []string) {
	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Url: "https://api.live.bilibili.com/xlive/web-room/v1/dM/gethistory?roomid=" + strconv.Itoa(Roomid),
		Header: map[string]string{
			`Referer`: "https://live.bilibili.com/" + strconv.Itoa(Roomid),
		},
		Proxy:   t.proxy,
		Timeout: 10 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}

	var j struct {
		Code int `json:"code"`
		Data struct {
			Room []struct {
				Text string `json:"text"`
			} `json:"room"`
		} `json:"data"`
		Message string `json:"message"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}

	for _, v := range j.Data.Room {
		if v.Text != "" {
			res = append(res, v.Text)
		}
	}

	t.SetCookies(req.Response.Cookies())
	return
}

// IsConnected implements biliApiInter.
func (t *biliApi) IsConnected() (err error) {
	req := t.pool.Get()
	defer t.pool.Put(req)
	return req.Reqf(reqf.Rval{
		Url:              "https://www.bilibili.com",
		Proxy:            t.proxy,
		Timeout:          10 * 1000,
		JustResponseCode: true,
	})
}

// GetFollowing implements biliApiInter.
func (t *biliApi) GetFollowing() (err error, res []struct {
	Roomid     int
	Uname      string
	Title      string
	LiveStatus int
}) {
	req := t.pool.Get()
	defer t.pool.Put(req)
	for pageNum := 1; true; pageNum += 1 {
		err = req.Reqf(reqf.Rval{
			Url: `https://api.live.bilibili.com/xlive/web-ucenter/user/following?page=` + strconv.Itoa(pageNum) + `&page_size=10`,
			Header: map[string]string{
				`Host`:            `api.live.bilibili.com`,
				`User-Agent`:      UA,
				`Accept`:          `application/json, text/plain, */*`,
				`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
				`Accept-Encoding`: `gzip, deflate, br`,
				`Origin`:          `https://t.bilibili.com`,
				`Connection`:      `keep-alive`,
				`Pragma`:          `no-cache`,
				`Cache-Control`:   `no-cache`,
				`Referer`:         `https://t.bilibili.com/pages/nav/index_new`,
				`Cookie`:          t.GetCookiesS(),
			},
			Proxy:   t.proxy,
			Timeout: 3 * 1000,
			Retry:   2,
		})
		if err != nil {
			return
		}
		var j struct {
			Code    int    `json:"code"`
			Message string `json:"message"`
			TTL     int    `json:"ttl"`
			Data    struct {
				TotalPage int `json:"totalPage"`
				List      []struct {
					Roomid     int    `json:"roomid"`
					Uname      string `json:"uname"`
					Title      string `json:"title"`
					LiveStatus int    `json:"live_status"`
				} `json:"list"`
			} `json:"data"`
		}

		err = json.Unmarshal(req.Respon, &j)
		if err != nil {
			return
		} else if j.Code != 0 {
			err = errors.New(j.Message)
			return
		}

		for _, item := range j.Data.List {
			if item.LiveStatus == 0 {
				break
			} else {
				res = append(res, struct {
					Roomid     int
					Uname      string
					Title      string
					LiveStatus int
				}(item))
			}
		}

		if pageNum*10 > j.Data.TotalPage {
			break
		}

		time.Sleep(time.Second)
	}

	t.SetCookies(req.Response.Cookies())
	return
}

// getOnlineGoldRank implements biliApiInter.
func (t *biliApi) GetOnlineGoldRank(upUid int, roomid int) (err error, OnlineNum int) {
	req := t.pool.Get()
	defer t.pool.Put(req)

	// api queryContributionRank
	{
		query := fmt.Sprintf("ruid=%d&room_id=%d&page=1&page_size=100&type=online_rank&switch=contribution_rank&platform=web&web_location=444.8", upUid, roomid)

		if e, v := t.GetNav(); e != nil {
			err = e
			return
		} else if e, queryE := t.Wbi(query, v.WbiImg); e != nil {
			err = e
			return
		} else {
			query = queryE
		}

		err = req.Reqf(reqf.Rval{
			Url: "https://api.live.bilibili.com/xlive/general-interface/v1/rank/queryContributionRank?" + query,
			Header: map[string]string{
				`Host`:            `api.live.bilibili.com`,
				`User-Agent`:      UA,
				`Accept`:          `application/json, text/plain, */*`,
				`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
				`Accept-Encoding`: `gzip, deflate, br`,
				`Origin`:          `https://live.bilibili.com`,
				`Connection`:      `keep-alive`,
				`Pragma`:          `no-cache`,
				`Cache-Control`:   `no-cache`,
				`Cookie`:          t.GetCookiesS(),
			},
			Proxy:   t.proxy,
			Timeout: 3 * 1000,
		})
		if err == nil {
			var j struct {
				Code    int    `json:"code"`
				Message string `json:"message"`
				TTL     int    `json:"ttl"`
				Data    struct {
					Count int `json:"count"`
				} `json:"data"`
			}

			err = json.Unmarshal(req.Respon, &j)
			if err != nil {
				return
			} else if j.Code != 0 {
				err = errors.New(j.Message)
				return
			}

			OnlineNum = j.Data.Count

			t.SetCookies(req.Response.Cookies())
			return
		}
	}

	// api getOnlineGoldRank
	{

		err = req.Reqf(reqf.Rval{
			Url: fmt.Sprintf("https://api.live.bilibili.com/xlive/general-interface/v1/rank/getOnlineGoldRank?ruid=%d&roomId=%d&page=1&pageSize=10", upUid, roomid),
			Header: map[string]string{
				`Host`:            `api.live.bilibili.com`,
				`User-Agent`:      UA,
				`Accept`:          `application/json, text/plain, */*`,
				`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
				`Accept-Encoding`: `gzip, deflate, br`,
				`Origin`:          `https://live.bilibili.com`,
				`Connection`:      `keep-alive`,
				`Pragma`:          `no-cache`,
				`Cache-Control`:   `no-cache`,
				`Cookie`:          t.GetCookiesS(),
			},
			Proxy:   t.proxy,
			Timeout: 3 * 1000,
		})
		if err == nil {
			var j struct {
				Code    int    `json:"code"`
				Message string `json:"message"`
				TTL     int    `json:"ttl"`
				Data    struct {
					OnlineNum int `json:"onlineNum"`
				} `json:"data"`
			}

			err = json.Unmarshal(req.Respon, &j)
			if err != nil {
				return
			} else if j.Code != 0 {
				err = errors.New(j.Message)
				return
			}

			OnlineNum = j.Data.OnlineNum

			t.SetCookies(req.Response.Cookies())
			return
		}
	}

	return
}

// RoomEntryAction implements biliApiInter.
func (t *biliApi) RoomEntryAction(Roomid int) (err error) {
	csrf := ""
	if e, t := t.GetCookie(`bili_jct`); e == nil {
		csrf = t
	}

	req := t.pool.Get()
	defer t.pool.Put(req)

	err = req.Reqf(reqf.Rval{
		Url:     `https://api.live.bilibili.com/xlive/web-room/v1/index/roomEntryAction`,
		PostStr: fmt.Sprintf("room_id=%d&platform=pc&csrf_token=%s&csrf=%s&visit_id=", Roomid, csrf, csrf),
		Header: map[string]string{
			`Host`:            `api.live.bilibili.com`,
			`User-Agent`:      UA,
			`Accept`:          `application/json, text/plain, */*`,
			`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
			`Accept-Encoding`: `gzip, deflate, br`,
			`Origin`:          `https://live.bilibili.com`,
			`Connection`:      `keep-alive`,
			`Pragma`:          `no-cache`,
			`Cache-Control`:   `no-cache`,
			`Referer`:         fmt.Sprintf("https://live.bilibili.com/%d", Roomid),
			`Cookie`:          t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 3 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}
	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}

	t.SetCookies(req.Response.Cookies())
	return
}

// GetHisStream implements biliApiInter.
func (t *biliApi) GetHisStream() (err error, res []struct {
	Uname      string
	Title      string
	Roomid     int
	LiveStatus int
}) {
	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Url: `https://api.bilibili.com/x/web-interface/history/cursor?type=live&ps=10`,
		Header: map[string]string{
			`Host`:            `api.live.bilibili.com`,
			`User-Agent`:      UA,
			`Accept`:          `application/json, text/plain, */*`,
			`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
			`Accept-Encoding`: `gzip, deflate, br`,
			`Origin`:          `https://t.bilibili.com`,
			`Connection`:      `keep-alive`,
			`Pragma`:          `no-cache`,
			`Cache-Control`:   `no-cache`,
			`Referer`:         `https://t.bilibili.com/pages/nav/index_new`,
			`Cookie`:          t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 3 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}
	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		TTL     int    `json:"ttl"`
		Data    struct {
			List []struct {
				Title      string `json:"title"`
				AuthorName string `json:"author_name"`
				Kid        int    `json:"kid"`
				LiveStatus int    `json:"live_status"`
			} `json:"list"`
		} `json:"data"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}

	for _, item := range j.Data.List {
		res = append(res, struct {
			Uname      string
			Title      string
			Roomid     int
			LiveStatus int
		}{
			Uname:      item.AuthorName,
			Title:      item.Title,
			Roomid:     item.Kid,
			LiveStatus: item.LiveStatus,
		})
	}

	t.SetCookies(req.Response.Cookies())
	return
}

// GetCookies implements biliApiInter.
func (t *biliApi) GetCookies() (cookies []*http.Cookie) {
	t.lock.RLock()
	defer t.lock.RUnlock()
	return append(cookies, t.cookies...)
}

func (t *biliApi) GetCookiesS() (cookies string) {
	t.lock.RLock()
	defer t.lock.RUnlock()
	return reqf.Cookies_List_2_String(t.cookies)
}

// Silver2coin implements biliApiInter.
func (t *biliApi) Silver2coin() (err error, Message string) {
	e, csrf := t.GetCookie(`bili_jct`)
	if e != nil {
		return err, ""
	}
	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Url:     `https://api.live.bilibili.com/xlive/revenue/v1/wallet/silver2coin`,
		PostStr: url.PathEscape(fmt.Sprintf("csrf_token=%s&csrf=%s", csrf, csrf)),
		Header: map[string]string{
			`Host`:            `api.live.bilibili.com`,
			`User-Agent`:      UA,
			`Accept`:          `application/json, text/plain, */*`,
			`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
			`Accept-Encoding`: `gzip, deflate, br`,
			`Origin`:          `https://link.bilibili.com`,
			`Connection`:      `keep-alive`,
			`Pragma`:          `no-cache`,
			`Cache-Control`:   `no-cache`,
			`Content-Type`:    `application/x-www-form-urlencoded`,
			`Referer`:         `https://link.bilibili.com/p/center/index`,
			`Cookie`:          t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 3 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}
	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}
	Message = j.Message
	t.SetCookies(req.Response.Cookies())
	return
}

// GetWalletRule implements biliApiInter.
func (t *biliApi) GetWalletRule() (err error, Silver2CoinPrice int) {
	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Url: `https://api.live.bilibili.com/xlive/revenue/v1/wallet/getRule`,
		Header: map[string]string{
			`Host`:            `api.live.bilibili.com`,
			`User-Agent`:      UA,
			`Accept`:          `application/json, text/plain, */*`,
			`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
			`Accept-Encoding`: `gzip, deflate, br`,
			`Origin`:          `https://link.bilibili.com`,
			`Connection`:      `keep-alive`,
			`Pragma`:          `no-cache`,
			`Cache-Control`:   `no-cache`,
			`Referer`:         `https://link.bilibili.com/p/center/index`,
			`Cookie`:          t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 3 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}
	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		TTL     int    `json:"ttl"`
		Data    struct {
			Silver2CoinPrice int `json:"silver_2_coin_price"`
		} `json:"data"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}

	Silver2CoinPrice = j.Data.Silver2CoinPrice
	t.SetCookies(req.Response.Cookies())
	return
}

// GetWalletStatus implements biliApiInter.
func (t *biliApi) GetWalletStatus() (err error, res struct {
	Silver          int
	Silver2CoinLeft int
}) {
	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Url: `https://api.live.bilibili.com/xlive/revenue/v1/wallet/getStatus`,
		Header: map[string]string{
			`Host`:            `api.live.bilibili.com`,
			`User-Agent`:      UA,
			`Accept`:          `application/json, text/plain, */*`,
			`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
			`Accept-Encoding`: `gzip, deflate, br`,
			`Origin`:          `https://link.bilibili.com`,
			`Connection`:      `keep-alive`,
			`Pragma`:          `no-cache`,
			`Cache-Control`:   `no-cache`,
			`Referer`:         `https://link.bilibili.com/p/center/index`,
			`Cookie`:          t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 3 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}
	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		TTL     int    `json:"ttl"`
		Data    struct {
			Silver          int `json:"silver"`
			Silver2CoinLeft int `json:"silver_2_coin_left"`
		} `json:"data"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}

	res = struct {
		Silver          int
		Silver2CoinLeft int
	}(j.Data)

	t.SetCookies(req.Response.Cookies())
	return
}

// GetBagList implements biliApiInter.
func (t *biliApi) GetBagList(Roomid int) (err error, res []struct {
	Bag_id    int
	Gift_id   int
	Gift_name string
	Gift_num  int
	Expire_at int
}) {
	req := t.pool.Get()
	defer t.pool.Put(req)

	err = req.Reqf(reqf.Rval{
		Url: `https://api.live.bilibili.com/xlive/web-room/v1/gift/bag_list?t=` + strconv.Itoa(int(time.Now().UnixNano()/int64(time.Millisecond))) + `&room_id=` + strconv.Itoa(Roomid),
		Header: map[string]string{
			`Host`:            `api.live.bilibili.com`,
			`User-Agent`:      UA,
			`Accept`:          `application/json, text/plain, */*`,
			`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
			`Accept-Encoding`: `gzip, deflate, br`,
			`Origin`:          `https://live.bilibili.com`,
			`Connection`:      `keep-alive`,
			`Pragma`:          `no-cache`,
			`Cache-Control`:   `no-cache`,
			`Referer`:         "https://live.bilibili.com/" + strconv.Itoa(Roomid),
			`Cookie`:          t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 3 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}

	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		Data    struct {
			List []struct {
				Bag_id    int    `json:"bag_id"`
				Gift_id   int    `json:"gift_id"`
				Gift_name string `json:"gift_name"`
				Gift_num  int    `json:"gift_num"`
				Expire_at int    `json:"expire_at"`
			} `json:"list"`
		} `json:"data"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}
	res = []struct {
		Bag_id    int
		Gift_id   int
		Gift_name string
		Gift_num  int
		Expire_at int
	}(j.Data.List)
	t.SetCookies(req.Response.Cookies())
	return
}

// GetLiveBuvid implements biliApiInter.
func (t *biliApi) GetLiveBuvid(Roomid int) (err error) {
	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Url: fmt.Sprintf("https://api.live.bilibili.com/live/getRoomKanBanModel?roomid=%d", Roomid),
		Header: map[string]string{
			`Host`:                      `live.bilibili.com`,
			`User-Agent`:                UA,
			`Accept`:                    `text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8`,
			`Accept-Language`:           `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
			`Accept-Encoding`:           `gzip, deflate, br`,
			`Connection`:                `keep-alive`,
			`Cache-Control`:             `no-cache`,
			`Referer`:                   "https://live.bilibili.com",
			`DNT`:                       `1`,
			`Upgrade-Insecure-Requests`: `1`,
		},
		Proxy:   t.proxy,
		Timeout: 3 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}
	t.SetCookies(req.Response.Cookies())
	return
}

// GetOtherCookies implements biliApiInter.
func (t *biliApi) GetOtherCookies() (err error) {
	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Url: `https://www.bilibili.com/`,
		Header: map[string]string{
			`Cookie`: t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 10 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}
	t.SetCookies(req.Response.Cookies())
	return
}

// DoSign implements biliApiInter.
func (t *biliApi) DoSign() (err error, HadSignDays int) {
	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Url: `https://api.live.bilibili.com/xlive/web-ucenter/v1/sign/DoSign`,
		Header: map[string]string{
			`Host`:            `api.live.bilibili.com`,
			`User-Agent`:      UA,
			`Accept`:          `application/json, text/plain, */*`,
			`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
			`Accept-Encoding`: `gzip, deflate, br`,
			`Origin`:          `https://live.bilibili.com`,
			`Connection`:      `keep-alive`,
			`Pragma`:          `no-cache`,
			`Cache-Control`:   `no-cache`,
			`Referer`:         "https://live.bilibili.com/all",
			`Cookie`:          t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 3 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}

	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		Data    struct {
			HadSignDays int `json:"hadSignDays"`
		} `json:"data"`
	}
	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}

	HadSignDays = j.Data.HadSignDays
	t.SetCookies(req.Response.Cookies())
	return
}

// GetWebGetSignInfo implements biliApiInter.
func (t *biliApi) GetWebGetSignInfo() (err error, Status int) {

	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Url: `https://api.live.bilibili.com/xlive/web-ucenter/v1/sign/WebGetSignInfo`,
		Header: map[string]string{
			`Host`:            `api.live.bilibili.com`,
			`User-Agent`:      UA,
			`Accept`:          `application/json, text/plain, */*`,
			`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
			`Accept-Encoding`: `gzip, deflate, br`,
			`Origin`:          `https://live.bilibili.com`,
			`Connection`:      `keep-alive`,
			`Pragma`:          `no-cache`,
			`Cache-Control`:   `no-cache`,
			`Referer`:         "https://live.bilibili.com/all",
			`Cookie`:          t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 3 * 1000,
		Retry:   2,
	})

	if err != nil {
		return
	}

	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		Data    struct {
			Status int `json:"status"`
		} `json:"data"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}
	Status = j.Data.Status
	t.SetCookies(req.Response.Cookies())
	return
}

// GetCookies implements biliApiInter.
func (t *biliApi) GetCookie(name string) (error, string) {
	t.lock.RLock()
	defer t.lock.RUnlock()
	for i := 0; i < len(t.cookies); i++ {
		if t.cookies[i].Name == name {
			return nil, t.cookies[i].Value
		}
	}
	return errors.New("cookie not found: " + name), ""
}

// SetFansMedal implements biliApiInter.
func (t *biliApi) SetFansMedal(medalId int) (err error) {
	post_url := `https://api.live.bilibili.com/xlive/web-room/v1/fansMedal/take_off` //无牌，不佩戴牌子
	post_str := ""

	if medalId != 0 {
		e, csrf := t.GetCookie(`bili_jct`)
		if e != nil {
			return e
		}
		post_url = `https://api.live.bilibili.com/xlive/web-room/v1/fansMedal/wear`
		post_str = fmt.Sprintf("medal_id=%d&csrf_token=%s&csrf=%s", medalId, csrf, csrf)
	}

	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Url:     post_url,
		PostStr: post_str,
		Header: map[string]string{
			`Cookie`:       t.GetCookiesS(),
			`Content-Type`: `application/x-www-form-urlencoded; charset=UTF-8`,
			`Referer`:      `https://passport.bilibili.com/login`,
		},
		Proxy:   t.proxy,
		Timeout: 10 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}

	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		TTL     int    `json:"ttl"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}

	t.SetCookies(req.Response.Cookies())
	return
}

// GetFansMedal implements biliApiInter.
func (t *biliApi) GetFansMedal(RoomID, TargetID int) (err error, res []struct {
	TodayFeed    int
	TargetID     int
	IsLighted    int
	MedalID      int
	RoomID       int
	LivingStatus int
}) {
	//获取牌子列表
	r := t.pool.Get()
	defer t.pool.Put(r)

	for pageNum := 1; true; pageNum += 1 {
		url := fmt.Sprintf("https://api.live.bilibili.com/xlive/app-ucenter/v1/fansMedal/panel?page=%d&page_size=10", pageNum)
		if RoomID != 0 {
			url += fmt.Sprintf("&room_id=%d", RoomID)
		}
		if TargetID != 0 {
			url += fmt.Sprintf("&target_id=%d", TargetID)
		}

		err = r.Reqf(reqf.Rval{
			Url: url,
			Header: map[string]string{
				`Cookie`:  t.GetCookiesS(),
				`Referer`: fmt.Sprintf("https://live.bilibili.com/%d", RoomID),
			},
			Proxy:   t.proxy,
			Timeout: 10 * 1000,
			Retry:   2,
		})
		if err != nil {
			return
		}

		var j struct {
			Code    int    `json:"code"`
			Message string `json:"message"`
			TTL     int    `json:"ttl"`
			Data    struct {
				List []struct {
					Medal struct {
						TodayFeed int `json:"today_feed"`
						TargetID  int `json:"target_id"`
						MedalID   int `json:"medal_id"`
						IsLighted int `json:"is_lighted"`
					} `json:"medal"`
					AnchorInfo struct {
						NickName string `json:"nick_name"`
					} `json:"anchor_info"`
					RoomInfo struct {
						RoomID       int `json:"room_id"`
						LivingStatus int `json:"living_status"`
					} `json:"room_info"`
				} `json:"list"`
				SpecialList []struct {
					Medal struct {
						TodayFeed int `json:"today_feed"`
						TargetID  int `json:"target_id"`
						MedalID   int `json:"medal_id"`
						IsLighted int `json:"is_lighted"`
					} `json:"medal"`
					AnchorInfo struct {
						NickName string `json:"nick_name"`
					} `json:"anchor_info"`
					RoomInfo struct {
						RoomID       int `json:"room_id"`
						LivingStatus int `json:"living_status"`
					} `json:"room_info"`
				} `json:"special_list"`
				PageInfo struct {
					CurrentPage int `json:"current_page"`
					TotalPage   int `json:"total_page"`
				} `json:"page_info"`
			} `json:"data"`
		}

		err = json.Unmarshal(r.Respon, &j)
		if err != nil {
			return
		} else if j.Code != 0 {
			err = errors.New(j.Message)
			return
		}

		t.SetCookies(r.Response.Cookies())
		for i := 0; i < len(j.Data.SpecialList); i++ {
			li := j.Data.SpecialList[i]
			if RoomID != 0 && li.RoomInfo.RoomID != RoomID {
				continue
			}
			if TargetID != 0 && TargetID != li.Medal.TargetID {
				continue
			}
			res = append(res, struct {
				TodayFeed    int
				TargetID     int
				IsLighted    int
				MedalID      int
				RoomID       int
				LivingStatus int
			}{
				TodayFeed:    li.Medal.TodayFeed,
				TargetID:     li.Medal.TargetID,
				IsLighted:    li.Medal.IsLighted,
				MedalID:      li.Medal.MedalID,
				RoomID:       li.RoomInfo.RoomID,
				LivingStatus: li.RoomInfo.LivingStatus,
			})
		}

		for i := 0; i < len(j.Data.List); i++ {
			li := j.Data.List[i]
			if RoomID != 0 && li.RoomInfo.RoomID != RoomID {
				continue
			}
			if TargetID != 0 && TargetID != li.Medal.TargetID {
				continue
			}
			res = append(res, struct {
				TodayFeed    int
				TargetID     int
				IsLighted    int
				MedalID      int
				RoomID       int
				LivingStatus int
			}{
				TodayFeed:    li.Medal.TodayFeed,
				TargetID:     li.Medal.TargetID,
				IsLighted:    li.Medal.IsLighted,
				MedalID:      li.Medal.MedalID,
				RoomID:       li.RoomInfo.RoomID,
				LivingStatus: li.RoomInfo.LivingStatus,
			})
		}

		if j.Data.PageInfo.CurrentPage == j.Data.PageInfo.TotalPage {
			break
		}

		time.Sleep(time.Second)
	}

	return
}

// GetWearedMedal implements biliApiInter.
func (t *biliApi) GetWearedMedal(uid, upUid int) (err error, res struct {
	TodayIntimacy int
	RoomID        int
	TargetID      int
}) {
	csrf := ""
	if e, t := t.GetCookie(`bili_jct`); e == nil {
		csrf = t
	}

	r := t.pool.Get()
	defer t.pool.Put(r)
	err = r.Reqf(reqf.Rval{
		Url:     `https://api.live.bilibili.com/live_user/v1/UserInfo/get_weared_medal`,
		PostStr: fmt.Sprintf("source=1&uid=%d&target_id=%d&csrf_token=%s&csrf=%s&visit_id=", uid, upUid, csrf, csrf),
		Header: map[string]string{
			`Cookie`: t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 10 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}

	var j struct {
		Code    int    `json:"code"`
		Msg     string `json:"msg"`
		Message string `json:"message"`
		Data    any    `json:"data"`
	}
	var jd struct {
		TodayIntimacy int `json:"today_intimacy"`
		TargetID      int `json:"target_id"`
		Roominfo      struct {
			RoomID int `json:"room_id"`
		} `json:"roominfo"`
	}

	err = json.Unmarshal(r.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}

	t.SetCookies(r.Response.Cookies())
	switch j.Data.(type) {
	case any:
		return
	default:
		if data, e := json.Marshal(j.Data); e != nil {
			err = e
			return
		} else if e = json.Unmarshal(data, &jd); e != nil {
			err = e
			return
		} else {
			res.TodayIntimacy = jd.TodayIntimacy
			res.TargetID = jd.TargetID
			res.RoomID = jd.Roominfo.RoomID
			return
		}
	}
}

// Wbi implements biliApiInter.
func (t *biliApi) Wbi(query string, WbiImg struct {
	ImgURL string
	SubURL string
}) (err error, queryEnc string) {
	if query != "" {
		wrid, wts := getWridWts(query, WbiImg.ImgURL, WbiImg.SubURL)
		queryEnc = query + "&w_rid=" + wrid + "&wts=" + wts
	}
	return
}

// GetNav implements biliApiInter.
func (t *biliApi) GetNav() (err error, res struct {
	IsLogin bool
	WbiImg  struct {
		ImgURL string
		SubURL string
	}
}) {
	vr, loaded, f := t.cache.LoadOrStore(`webImg`)
	if loaded {
		res = *vr
		return
	}

	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Url: `https://api.bilibili.com/x/web-interface/nav`,
		Header: map[string]string{
			`Host`:            `api.bilibili.com`,
			`User-Agent`:      UA,
			`Accept`:          `application/json, text/plain, */*`,
			`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
			`Accept-Encoding`: `gzip, deflate, br`,
			`Origin`:          `https://t.bilibili.com`,
			`Connection`:      `keep-alive`,
			`Pragma`:          `no-cache`,
			`Cache-Control`:   `no-cache`,
			`Referer`:         `https://t.bilibili.com/pages/nav/index_new`,
			`Cookie`:          t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 3 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}

	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		TTL     int    `json:"ttl"`
		Data    struct {
			IsLogin bool `json:"isLogin"`
			WbiImg  struct {
				ImgURL string `json:"img_url"`
				SubURL string `json:"sub_url"`
			} `json:"wbi_img"`
		} `json:"data"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else {
		res.IsLogin = j.Data.IsLogin
		res.WbiImg.ImgURL = j.Data.WbiImg.ImgURL
		res.WbiImg.SubURL = j.Data.WbiImg.SubURL
	}

	f(&res, time.Hour)

	t.SetCookies(req.Response.Cookies())
	return
}

// GetGuardNum implements biliApiInter.
func (t *biliApi) GetGuardNum(upUid int, roomid int) (err error, GuardNum int) {
	req := t.pool.Get()
	defer t.pool.Put(req)

	err = req.Reqf(reqf.Rval{
		Url: fmt.Sprintf(`https://api.live.bilibili.com/xlive/app-room/v2/guardTab/topList?roomid=%d&page=1&ruid=%d&page_size=29`, roomid, upUid),
		Header: map[string]string{
			`Host`:            `api.live.bilibili.com`,
			`User-Agent`:      UA,
			`Accept`:          `application/json, text/plain, */*`,
			`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
			`Accept-Encoding`: `gzip, deflate, br`,
			`Origin`:          `https://live.bilibili.com`,
			`Connection`:      `keep-alive`,
			`Pragma`:          `no-cache`,
			`Cache-Control`:   `no-cache`,
			`Referer`:         fmt.Sprintf("https://live.bilibili.com/%d", roomid),
			`Cookie`:          t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 3 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}

	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		TTL     int    `json:"ttl"`
		Data    struct {
			Info struct {
				Num int `json:"num"`
			} `json:"info"`
		} `json:"data"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}

	//获取舰长数
	GuardNum = j.Data.Info.Num

	t.SetCookies(req.Response.Cookies())
	return
}

// GetPopularAnchorRank implements biliApiInter.
func (t *biliApi) GetPopularAnchorRank(uid int, upUid int, roomid int) (err error, note string) {
	req := t.pool.Get()
	defer t.pool.Put(req)

	err = req.Reqf(reqf.Rval{
		Url: fmt.Sprintf(`https://api.live.bilibili.com/xlive/general-interface/v1/rank/getPopularAnchorRank?uid=%d&ruid=%d&clientType=2`, uid, upUid),
		Header: map[string]string{
			`Host`:            `api.live.bilibili.com`,
			`User-Agent`:      UA,
			`Accept`:          `application/json, text/plain, */*`,
			`Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`,
			`Accept-Encoding`: `gzip, deflate, br`,
			`Origin`:          `https://live.bilibili.com`,
			`Connection`:      `keep-alive`,
			`Pragma`:          `no-cache`,
			`Cache-Control`:   `no-cache`,
			`Referer`:         fmt.Sprintf("https://live.bilibili.com/%d", roomid),
			`Cookie`:          t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 3 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}

	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		TTL     int    `json:"ttl"`
		Data    struct {
			Anchor struct {
				Rank int `json:"rank"`
			} `json:"anchor"`
		} `json:"data"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}

	//获取排名
	note = "人气榜 "
	if j.Data.Anchor.Rank == 0 {
		note += "100+"
	} else {
		note += strconv.Itoa(j.Data.Anchor.Rank)
	}

	t.SetCookies(req.Response.Cookies())
	return
}

// getDanmuMedalAnchorInfo implements biliApiInter.
func (t *biliApi) GetDanmuMedalAnchorInfo(Uid string, Roomid int) (err error, rface string) {
	req := t.pool.Get()
	defer t.pool.Put(req)

	err = req.Reqf(reqf.Rval{
		Url: "https://api.live.bilibili.com/xlive/web-room/v1/index/getDanmuMedalAnchorInfo?ruid=" + Uid,
		Header: map[string]string{
			`Referer`: fmt.Sprintf("https://live.bilibili.com/%d", Roomid),
			`Cookie`:  t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 10 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}

	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		Data    struct {
			Rface string `json:"rface"`
		} `json:"data"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}

	rface = j.Data.Rface + `@58w_58h`

	t.SetCookies(req.Response.Cookies())
	return
}

// GetDanmuInfo implements biliApiInter.
func (t *biliApi) GetDanmuInfo(Roomid int) (err error, res struct {
	Token string
	WSURL []string
}) {
	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Url: fmt.Sprintf("https://api.live.bilibili.com/xlive/web-room/v1/index/getDanmuInfo?type=0&id=%d", Roomid),
		Header: map[string]string{
			`Referer`: fmt.Sprintf("https://live.bilibili.com/%d", Roomid),
			`Cookie`:  t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 10 * 1000,
	})
	if err != nil {
		return
	}

	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		TTL     int    `json:"ttl"`
		Data    struct {
			Group            string  `json:"group"`
			BusinessID       int     `json:"business_id"`
			RefreshRowFactor float64 `json:"refresh_row_factor"`
			RefreshRate      int     `json:"refresh_rate"`
			MaxDelay         int     `json:"max_delay"`
			Token            string  `json:"token"`
			HostList         []struct {
				Host    string `json:"host"`
				Port    int    `json:"port"`
				WssPort int    `json:"wss_port"`
				WsPort  int    `json:"ws_port"`
			} `json:"host_list"`
		} `json:"data"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}

	//弹幕钥
	res.Token = j.Data.Token
	//弹幕链接
	var tmp []string
	for _, v := range j.Data.HostList {
		if v.WssPort != 443 {
			tmp = append(tmp, "wss://"+v.Host+":"+strconv.Itoa(v.WssPort)+"/sub")
		} else {
			tmp = append(tmp, "wss://"+v.Host+"/sub")
		}
	}
	res.WSURL = tmp
	t.SetCookies(req.Response.Cookies())
	return
}

// GetRoomPlayInfo implements biliApiInter.
func (t *biliApi) GetRoomPlayInfo(Roomid int, Qn int) (err error, res struct {
	UpUid         int
	RoomID        int
	LiveStartTime time.Time
	Liveing       bool
	Streams       []struct {
		ProtocolName string
		Format       []struct {
			FormatName string
			Codec      []struct {
				CodecName string
				CurrentQn int
				AcceptQn  []int
				BaseURL   string
				URLInfo   []struct {
					Host      string
					Extra     string
					StreamTTL int
				}
				HdrQn     any
				DolbyType int
				AttrName  string
			}
		}
	}
}) {
	req := t.pool.Get()
	defer t.pool.Put(req)
	err = req.Reqf(reqf.Rval{
		Url: fmt.Sprintf("https://api.live.bilibili.com/xlive/web-room/v2/index/getRoomPlayInfo?protocol=0,1&format=0,1,2&codec=0,1,2&qn=%d&platform=web&ptype=8&dolby=5&panorama=1&room_id=%d", Qn, Roomid),
		Header: map[string]string{
			`Referer`: fmt.Sprintf("https://live.bilibili.com/%d", Roomid),
			`Cookie`:  t.GetCookiesS(),
		},
		Proxy:   t.proxy,
		Timeout: 10 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}

	var j struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		TTL     int    `json:"ttl"`
		Data    struct {
			RoomID          int   `json:"room_id"`
			ShortID         int   `json:"short_id"`
			UID             int   `json:"uid"`
			IsHidden        bool  `json:"is_hidden"`
			IsLocked        bool  `json:"is_locked"`
			IsPortrait      bool  `json:"is_portrait"`
			LiveStatus      int   `json:"live_status"`
			HiddenTill      int   `json:"hidden_till"`
			LockTill        int   `json:"lock_till"`
			Encrypted       bool  `json:"encrypted"`
			PwdVerified     bool  `json:"pwd_verified"`
			LiveTime        int   `json:"live_time"`
			RoomShield      int   `json:"room_shield"`
			AllSpecialTypes []int `json:"all_special_types"`
			PlayurlInfo     struct {
				ConfJSON string `json:"conf_json"`
				Playurl  struct {
					Cid     int `json:"cid"`
					GQnDesc []struct {
						Qn       int         `json:"qn"`
						Desc     string      `json:"desc"`
						HdrDesc  string      `json:"hdr_desc"`
						AttrDesc interface{} `json:"attr_desc"`
					} `json:"g_qn_desc"`
					Stream []struct {
						ProtocolName string `json:"protocol_name"`
						Format       []struct {
							FormatName string `json:"format_name"`
							Codec      []struct {
								CodecName string `json:"codec_name"`
								CurrentQn int    `json:"current_qn"`
								AcceptQn  []int  `json:"accept_qn"`
								BaseURL   string `json:"base_url"`
								URLInfo   []struct {
									Host      string `json:"host"`
									Extra     string `json:"extra"`
									StreamTTL int    `json:"stream_ttl"`
								} `json:"url_info"`
								HdrQn     interface{} `json:"hdr_qn"`
								DolbyType int         `json:"dolby_type"`
								AttrName  string      `json:"attr_name"`
							} `json:"codec"`
						} `json:"format"`
					} `json:"stream"`
					P2PData struct {
						P2P      bool        `json:"p2p"`
						P2PType  int         `json:"p2p_type"`
						MP2P     bool        `json:"m_p2p"`
						MServers interface{} `json:"m_servers"`
					} `json:"p2p_data"`
					DolbyQn interface{} `json:"dolby_qn"`
				} `json:"playurl"`
			} `json:"playurl_info"`
		} `json:"data"`
	}

	err = json.Unmarshal(req.Respon, &j)
	if err != nil {
		return
	} else if j.Code != 0 {
		err = errors.New(j.Message)
		return
	}

	//主播uid
	res.UpUid = j.Data.UID
	//房间号（完整）
	res.RoomID = j.Data.RoomID
	//直播开始时间
	if j.Data.LiveTime != 0 {
		res.LiveStartTime = time.Unix(int64(j.Data.LiveTime), 0)
	}
	//是否在直播
	res.Liveing = j.Data.LiveStatus == 1

	//当前直播流
	res.Streams = []struct {
		ProtocolName string
		Format       []struct {
			FormatName string
			Codec      []struct {
				CodecName string
				CurrentQn int
				AcceptQn  []int
				BaseURL   string
				URLInfo   []struct {
					Host      string
					Extra     string
					StreamTTL int
				}
				HdrQn     any
				DolbyType int
				AttrName  string
			}
		}
	}(j.Data.PlayurlInfo.Playurl.Stream)
	t.SetCookies(req.Response.Cookies())
	return
}

// SetCookies implements biliApiInter.
func (t *biliApi) SetCookies(cookies []*http.Cookie) {
	t.lock.Lock()
	defer t.lock.Unlock()
	for i := 0; i < len(cookies); i++ {
		found := false
		for k := 0; k < len(t.cookies); k++ {
			if t.cookies[k].Name == cookies[i].Name {
				t.cookies[k].Value = cookies[i].Value
				found = true
				break
			}
		}
		if !found {
			t.cookies = append(t.cookies, cookies[i])
		}
	}
}

// GetInfoByRoom implements biliApiInter.
// test
func (t *biliApi) GetInfoByRoom(Roomid int) (err error, res struct {
	UpUid         int
	Uname         string
	ParentAreaID  int
	AreaID        int
	Title         string
	LiveStartTime time.Time
	Liveing       bool
	RoomID        int
	GuardNum      int
	Note          string
	Locked        bool
}) {
	req := t.pool.Get()
	defer t.pool.Put(req)

	query := fmt.Sprintf("room_id=%d&web_location=444.8", Roomid)

	if e, v := t.GetNav(); e != nil {
		err = e
		return
	} else if e, queryE := t.Wbi(query, v.WbiImg); e != nil {
		err = e
		return
	} else {
		query = queryE
	}

	err = req.Reqf(reqf.Rval{
		Url: "https://api.live.bilibili.com/xlive/web-room/v1/index/getInfoByRoom?" + query,
		Header: map[string]string{
			`Referer`: fmt.Sprintf("https://live.bilibili.com/%d", Roomid),
		},
		Proxy:   t.proxy,
		Timeout: 10 * 1000,
		Retry:   2,
	})
	if err != nil {
		return
	}

	//Roominfores
	{
		var j struct {
			Code    int    `json:"code"`
			Message string `json:"message"`
			TTL     int    `json:"ttl"`
			Data    struct {
				RoomInfo struct {
					UID            int    `json:"uid"`
					RoomID         int    `json:"room_id"`
					ShortID        int    `json:"short_id"`
					Title          string `json:"title"`
					Cover          string `json:"cover"`
					Tags           string `json:"tags"`
					Background     string `json:"background"`
					Description    string `json:"description"`
					LiveStatus     int    `json:"live_status"`
					LiveStartTime  int    `json:"live_start_time"`
					LiveScreenType int    `json:"live_screen_type"`
					LockStatus     int    `json:"lock_status"`
					LockTime       int    `json:"lock_time"`
					HiddenStatus   int    `json:"hidden_status"`
					HiddenTime     int    `json:"hidden_time"`
					AreaID         int    `json:"area_id"`
					AreaName       string `json:"area_name"`
					ParentAreaID   int    `json:"parent_area_id"`
					ParentAreaName string `json:"parent_area_name"`
					Keyframe       string `json:"keyframe"`
					SpecialType    int    `json:"special_type"`
					UpSession      string `json:"up_session"`
					PkStatus       int    `json:"pk_status"`
					IsStudio       bool   `json:"is_studio"`
					Pendants       struct {
						Frame struct {
							Name  string `json:"name"`
							Value string `json:"value"`
							Desc  string `json:"desc"`
						} `json:"frame"`
					} `json:"pendants"`
					OnVoiceJoin int `json:"on_voice_join"`
					Online      int `json:"online"`
					RoomType    struct {
						Two3    int `json:"2-3"`
						Three21 int `json:"3-21"`
					} `json:"room_type"`
				} `json:"room_info"`
				AnchorInfo struct {
					BaseInfo struct {
						Uname        string `json:"uname"`
						Face         string `json:"face"`
						Gender       string `json:"gender"`
						OfficialInfo struct {
							Role     int    `json:"role"`
							Title    string `json:"title"`
							Desc     string `json:"desc"`
							IsNft    int    `json:"is_nft"`
							NftDmark string `json:"nft_dmark"`
						} `json:"official_info"`
					} `json:"base_info"`
					LiveInfo struct {
						Level        int           `json:"level"`
						LevelColor   int           `json:"level_color"`
						Score        int           `json:"score"`
						UpgradeScore int           `json:"upgrade_score"`
						Current      []int         `json:"current"`
						Next         []interface{} `json:"next"`
						Rank         string        `json:"rank"`
					} `json:"live_info"`
					RelationInfo struct {
						Attention int `json:"attention"`
					} `json:"relation_info"`
					MedalInfo struct {
						MedalName string `json:"medal_name"`
						MedalID   int    `json:"medal_id"`
						Fansclub  int    `json:"fansclub"`
					} `json:"medal_info"`
					GiftInfo interface{} `json:"gift_info"`
				} `json:"anchor_info"`
				NewsInfo struct {
					UID     int    `json:"uid"`
					Ctime   string `json:"ctime"`
					Content string `json:"content"`
				} `json:"news_info"`
				RankdbInfo struct {
					Roomid    int    `json:"roomid"`
					RankDesc  string `json:"rank_desc"`
					Color     string `json:"color"`
					H5URL     string `json:"h5_url"`
					WebURL    string `json:"web_url"`
					Timestamp int    `json:"timestamp"`
				} `json:"rankdb_info"`
				AreaRankInfo struct {
					AreaRank struct {
						Index int    `json:"index"`
						Rank  string `json:"rank"`
					} `json:"areaRank"`
					LiveRank struct {
						Rank string `json:"rank"`
					} `json:"liveRank"`
				} `json:"area_rank_info"`
				BattleRankEntryInfo interface{} `json:"battle_rank_entry_info"`
				TabInfo             struct {
					List []struct {
						Type      string `json:"type"`
						Desc      string `json:"desc"`
						IsFirst   int    `json:"isFirst"`
						IsEvent   int    `json:"isEvent"`
						EventType string `json:"eventType"`
						ListType  string `json:"listType"`
						APIPrefix string `json:"apiPrefix"`
						RankName  string `json:"rank_name"`
					} `json:"list"`
				} `json:"tab_info"`
				ActivityInitInfo struct {
					EventList []interface{} `json:"eventList"`
					WeekInfo  struct {
						BannerInfo interface{} `json:"bannerInfo"`
						GiftName   interface{} `json:"giftName"`
					} `json:"weekInfo"`
					GiftName interface{} `json:"giftName"`
					Lego     struct {
						Timestamp int    `json:"timestamp"`
						Config    string `json:"config"`
					} `json:"lego"`
				} `json:"activity_init_info"`
				VoiceJoinInfo struct {
					Status struct {
						Open        int    `json:"open"`
						AnchorOpen  int    `json:"anchor_open"`
						Status      int    `json:"status"`
						UID         int    `json:"uid"`
						UserName    string `json:"user_name"`
						HeadPic     string `json:"head_pic"`
						Guard       int    `json:"guard"`
						StartAt     int    `json:"start_at"`
						CurrentTime int    `json:"current_time"`
					} `json:"status"`
					Icons struct {
						IconClose    string `json:"icon_close"`
						IconOpen     string `json:"icon_open"`
						IconWait     string `json:"icon_wait"`
						IconStarting string `json:"icon_starting"`
					} `json:"icons"`
					WebShareLink string `json:"web_share_link"`
				} `json:"voice_join_info"`
				AdBannerInfo struct {
					Data []struct {
						ID                   int         `json:"id"`
						Title                string      `json:"title"`
						Location             string      `json:"location"`
						Position             int         `json:"position"`
						Pic                  string      `json:"pic"`
						Link                 string      `json:"link"`
						Weight               int         `json:"weight"`
						RoomID               int         `json:"room_id"`
						UpID                 int         `json:"up_id"`
						ParentAreaID         int         `json:"parent_area_id"`
						AreaID               int         `json:"area_id"`
						LiveStatus           int         `json:"live_status"`
						AvID                 int         `json:"av_id"`
						IsAd                 bool        `json:"is_ad"`
						AdTransparentContent interface{} `json:"ad_transparent_content"`
						ShowAdIcon           bool        `json:"show_ad_icon"`
					} `json:"data"`
				} `json:"ad_banner_info"`
				SkinInfo struct {
					ID          int    `json:"id"`
					SkinName    string `json:"skin_name"`
					SkinConfig  string `json:"skin_config"`
					ShowText    string `json:"show_text"`
					SkinURL     string `json:"skin_url"`
					StartTime   int    `json:"start_time"`
					EndTime     int    `json:"end_time"`
					CurrentTime int    `json:"current_time"`
				} `json:"skin_info"`
				WebBannerInfo struct {
					ID               int    `json:"id"`
					Title            string `json:"title"`
					Left             string `json:"left"`
					Right            string `json:"right"`
					JumpURL          string `json:"jump_url"`
					BgColor          string `json:"bg_color"`
					HoverColor       string `json:"hover_color"`
					TextBgColor      string `json:"text_bg_color"`
					TextHoverColor   string `json:"text_hover_color"`
					LinkText         string `json:"link_text"`
					LinkColor        string `json:"link_color"`
					InputColor       string `json:"input_color"`
					InputTextColor   string `json:"input_text_color"`
					InputHoverColor  string `json:"input_hover_color"`
					InputBorderColor string `json:"input_border_color"`
					InputSearchColor string `json:"input_search_color"`
				} `json:"web_banner_info"`
				LolInfo        interface{} `json:"lol_info"`
				PkInfo         interface{} `json:"pk_info"`
				BattleInfo     interface{} `json:"battle_info"`
				SilentRoomInfo struct {
					Type       string `json:"type"`
					Level      int    `json:"level"`
					Second     int    `json:"second"`
					ExpireTime int    `json:"expire_time"`
				} `json:"silent_room_info"`
				SwitchInfo struct {
					CloseGuard   bool `json:"close_guard"`
					CloseGift    bool `json:"close_gift"`
					CloseOnline  bool `json:"close_online"`
					CloseDanmaku bool `json:"close_danmaku"`
				} `json:"switch_info"`
				RecordSwitchInfo interface{} `json:"record_switch_info"`
				RoomConfigInfo   struct {
					DmText string `json:"dm_text"`
				} `json:"room_config_info"`
				GiftMemoryInfo struct {
					List interface{} `json:"list"`
				} `json:"gift_memory_info"`
				NewSwitchInfo struct {
					RoomSocket           int `json:"room-socket"`
					RoomPropSend         int `json:"room-prop-send"`
					RoomSailing          int `json:"room-sailing"`
					RoomInfoPopularity   int `json:"room-info-popularity"`
					RoomDanmakuEditor    int `json:"room-danmaku-editor"`
					RoomEffect           int `json:"room-effect"`
					RoomFansMedal        int `json:"room-fans_medal"`
					RoomReport           int `json:"room-report"`
					RoomFeedback         int `json:"room-feedback"`
					RoomPlayerWatermark  int `json:"room-player-watermark"`
					RoomRecommendLiveOff int `json:"room-recommend-live_off"`
					RoomActivity         int `json:"room-activity"`
					RoomWebBanner        int `json:"room-web_banner"`
					RoomSilverSeedsBox   int `json:"room-silver_seeds-box"`
					RoomWishingBottle    int `json:"room-wishing_bottle"`
					RoomBoard            int `json:"room-board"`
					RoomSupplication     int `json:"room-supplication"`
					RoomHourRank         int `json:"room-hour_rank"`
					RoomWeekRank         int `json:"room-week_rank"`
					RoomAnchorRank       int `json:"room-anchor_rank"`
					RoomInfoIntegral     int `json:"room-info-integral"`
					RoomSuperChat        int `json:"room-super-chat"`
					RoomTab              int `json:"room-tab"`
					RoomHotRank          int `json:"room-hot-rank"`
					FansMedalProgress    int `json:"fans-medal-progress"`
					GiftBayScreen        int `json:"gift-bay-screen"`
					RoomEnter            int `json:"room-enter"`
					RoomMyIdol           int `json:"room-my-idol"`
					RoomTopic            int `json:"room-topic"`
					FansClub             int `json:"fans-club"`
					RoomPopularRank      int `json:"room-popular-rank"`
					MicUserGift          int `json:"mic_user_gift"`
					NewRoomAreaRank      int `json:"new-room-area-rank"`
				} `json:"new_switch_info"`
				SuperChatInfo struct {
					Status      int           `json:"status"`
					JumpURL     string        `json:"jump_url"`
					Icon        string        `json:"icon"`
					RankedMark  int           `json:"ranked_mark"`
					MessageList []interface{} `json:"message_list"`
				} `json:"super_chat_info"`
				OnlineGoldRankInfoV2 struct {
					List []struct {
						UID        int64  `json:"uid"`
						Face       string `json:"face"`
						Uname      string `json:"uname"`
						Score      string `json:"score"`
						Rank       int    `json:"rank"`
						GuardLevel int    `json:"guard_level"`
					} `json:"list"`
				} `json:"online_gold_rank_info_v2"`
				DmBrushInfo struct {
					MinTime     int `json:"min_time"`
					BrushCount  int `json:"brush_count"`
					SliceCount  int `json:"slice_count"`
					StorageTime int `json:"storage_time"`
				} `json:"dm_brush_info"`
				DmEmoticonInfo struct {
					IsOpenEmoticon   int `json:"is_open_emoticon"`
					IsShieldEmoticon int `json:"is_shield_emoticon"`
				} `json:"dm_emoticon_info"`
				DmTagInfo struct {
					DmTag           int           `json:"dm_tag"`
					Platform        []interface{} `json:"platform"`
					Extra           string        `json:"extra"`
					DmChronosExtra  string        `json:"dm_chronos_extra"`
					DmMode          []interface{} `json:"dm_mode"`
					DmSettingSwitch int           `json:"dm_setting_switch"`
					MaterialConf    interface{}   `json:"material_conf"`
				} `json:"dm_tag_info"`
				TopicInfo struct {
					TopicID   int    `json:"topic_id"`
					TopicName string `json:"topic_name"`
				} `json:"topic_info"`
				GameInfo struct {
					GameStatus int `json:"game_status"`
				} `json:"game_info"`
				WatchedShow struct {
					Switch       bool   `json:"switch"`
					Num          int    `json:"num"`
					TextSmall    string `json:"text_small"`
					TextLarge    string `json:"text_large"`
					Icon         string `json:"icon"`
					IconLocation int    `json:"icon_location"`
					IconWeb      string `json:"icon_web"`
				} `json:"watched_show"`
				TopicRoomInfo struct {
					InteractiveH5URL string `json:"interactive_h5_url"`
					Watermark        int    `json:"watermark"`
				} `json:"topic_room_info"`
				ShowReserveStatus bool `json:"show_reserve_status"`
				SecondCreateInfo  struct {
					ClickPermission  int    `json:"click_permission"`
					CommonPermission int    `json:"common_permission"`
					IconName         string `json:"icon_name"`
					IconURL          string `json:"icon_url"`
					URL              string `json:"url"`
				} `json:"second_create_info"`
				PlayTogetherInfo struct {
					Switch   int `json:"switch"`
					IconList []struct {
						Icon    string `json:"icon"`
						Title   string `json:"title"`
						JumpURL string `json:"jump_url"`
						Status  int    `json:"status"`
					} `json:"icon_list"`
				} `json:"play_together_info"`
				CloudGameInfo struct {
					IsGaming int `json:"is_gaming"`
				} `json:"cloud_game_info"`
				LikeInfoV3 struct {
					TotalLikes    int      `json:"total_likes"`
					ClickBlock    bool     `json:"click_block"`
					CountBlock    bool     `json:"count_block"`
					GuildEmoText  string   `json:"guild_emo_text"`
					GuildDmText   string   `json:"guild_dm_text"`
					LikeDmText    string   `json:"like_dm_text"`
					HandIcons     []string `json:"hand_icons"`
					DmIcons       []string `json:"dm_icons"`
					EggshellsIcon string   `json:"eggshells_icon"`
					CountShowTime int      `json:"count_show_time"`
					ProcessIcon   string   `json:"process_icon"`
					ProcessColor  string   `json:"process_color"`
				} `json:"like_info_v3"`
				LivePlayInfo struct {
					ShowWidgetBanner bool `json:"show_widget_banner"`
				} `json:"live_play_info"`
				MultiVoice struct {
					SwitchStatus int           `json:"switch_status"`
					Members      []interface{} `json:"members"`
				} `json:"multi_voice"`
				PopularRankInfo struct {
					Rank       int    `json:"rank"`
					Countdown  int    `json:"countdown"`
					Timestamp  int    `json:"timestamp"`
					URL        string `json:"url"`
					OnRankName string `json:"on_rank_name"`
					RankName   string `json:"rank_name"`
				} `json:"popular_rank_info"`
				NewAreaRankInfo struct {
					Items []struct {
						ConfID      int    `json:"conf_id"`
						RankName    string `json:"rank_name"`
						UID         int    `json:"uid"`
						Rank        int    `json:"rank"`
						IconURLBlue string `json:"icon_url_blue"`
						IconURLPink string `json:"icon_url_pink"`
						IconURLGrey string `json:"icon_url_grey"`
						JumpURLLink string `json:"jump_url_link"`
						JumpURLPc   string `json:"jump_url_pc"`
						JumpURLPink string `json:"jump_url_pink"`
						JumpURLWeb  string `json:"jump_url_web"`
					} `json:"items"`
					RotationCycleTimeWeb int `json:"rotation_cycle_time_web"`
				} `json:"new_area_rank_info"`
				GiftStar struct {
					Show bool `json:"show"`
				} `json:"gift_star"`
				VideoConnectionInfo interface{} `json:"video_connection_info"`
				PlayerThrottleInfo  struct {
					Status              int `json:"status"`
					NormalSleepTime     int `json:"normal_sleep_time"`
					FullscreenSleepTime int `json:"fullscreen_sleep_time"`
					TabSleepTime        int `json:"tab_sleep_time"`
					PromptTime          int `json:"prompt_time"`
				} `json:"player_throttle_info"`
				GuardInfo struct {
					Count                   int `json:"count"`
					AnchorGuardAchieveLevel int `json:"anchor_guard_achieve_level"`
				} `json:"guard_info"`
				HotRankInfo interface{} `json:"hot_rank_info"`
			} `json:"data"`
		}

		err = json.Unmarshal(req.Respon, &j)
		if err != nil {
			return
		} else if j.Code != 0 {
			err = errors.New(j.Message)
			return
		}

		//直播开始时间
		if j.Data.RoomInfo.LiveStartTime != 0 {
			res.LiveStartTime = time.Unix(int64(j.Data.RoomInfo.LiveStartTime), 0)
		}
		//是否在直播
		res.Liveing = j.Data.RoomInfo.LiveStatus == 1
		//直播间标题
		res.Title = j.Data.RoomInfo.Title
		//主播名
		res.Uname = j.Data.AnchorInfo.BaseInfo.Uname
		//分区
		res.ParentAreaID = j.Data.RoomInfo.ParentAreaID
		//子分区
		res.AreaID = j.Data.RoomInfo.AreaID
		//主播id
		res.UpUid = j.Data.RoomInfo.UID
		//房间id
		res.RoomID = j.Data.RoomInfo.RoomID
		//舰长数
		res.GuardNum = j.Data.GuardInfo.Count
		//分区排行
		res.Note = j.Data.PopularRankInfo.RankName + " "
		if rank := j.Data.PopularRankInfo.Rank; rank > 50 || rank == 0 {
			res.Note += "100+"
		} else {
			res.Note += strconv.Itoa(rank)
		}
		//直播间是否被封禁
		res.Locked = j.Data.RoomInfo.LockStatus == 1
	}
	t.SetCookies(req.Response.Cookies())
	return
}

func (t *biliApi) SetReqPool(pool *pool.Buf[reqf.Req]) {
	t.pool = pool
}

// GetRoomBaseInfo implements biliApiInter.
// test
func (t *biliApi) GetRoomBaseInfo(Roomid int) (err error, res struct {
	UpUid         int
	Uname         string
	ParentAreaID  int
	AreaID        int
	Title         string
	LiveStartTime time.Time
	Liveing       bool
	RoomID        int
}) {
	req := t.pool.Get()
	defer t.pool.Put(req)

	err = req.Reqf(reqf.Rval{
		Url: fmt.Sprintf("https://api.live.bilibili.com/xlive/web-room/v1/index/getRoomBaseInfo?req_biz=link-center&room_ids=%d", Roomid),
		Header: map[string]string{
			`Referer`: "https://link.bilibili.com/p/center/index",
		},
		Proxy:   t.proxy,
		Timeout: 10 * 1000,
	})
	if err != nil {
		return
	}

	//Roominfores
	{
		var j struct {
			Code    int    `json:"code"`
			Message string `json:"message"`
			TTL     int    `json:"ttl"`
			Data    struct {
				ByRoomIds map[string]struct {
					RoomID     int `json:"room_id"`
					UID        int `json:"uid"`
					AreaID     int `json:"area_id"`
					LiveStatus int `json:"live_status"`
					// LiveURL        string `json:"live_url"`
					ParentAreaID int    `json:"parent_area_id"`
					Title        string `json:"title"`
					// ParentAreaName string `json:"parent_area_name"`
					// AreaName       string `json:"area_name"`
					LiveTime string `json:"live_time"`
					// Description    string `json:"description"`
					// Tags           string `json:"tags"`
					Attention  int    `json:"attention"`
					Online     int    `json:"online"`
					ShortID    int    `json:"short_id"`
					Uname      string `json:"uname"`
					Cover      string `json:"cover"`
					Background string `json:"background"`
					JoinSlide  int    `json:"join_slide"`
					LiveID     int64  `json:"live_id"`
					LiveIDStr  string `json:"live_id_str"`
				} `json:"by_room_ids"`
			} `json:"data"`
		}

		err = json.Unmarshal(req.Respon, &j)
		if err != nil {
			return
		} else if j.Code != 0 {
			err = errors.New(j.Message)
			return
		}

		for _, data := range j.Data.ByRoomIds {
			if Roomid == data.RoomID || Roomid == data.ShortID {
				//主播id
				res.UpUid = data.UID
				//子分区
				res.AreaID = data.AreaID
				//分区
				res.ParentAreaID = data.ParentAreaID
				//直播间标题
				res.Title = data.Title
				//直播开始时间
				if ti, e := time.ParseInLocation(time.DateTime, data.LiveTime, t.location); e == nil && !ti.IsZero() {
					res.LiveStartTime = ti
				}
				//是否在直播
				res.Liveing = data.LiveStatus == 1
				//主播名
				res.Uname = data.Uname
				//房间id
				res.RoomID = data.RoomID
				return
			}
		}
	}
	t.SetCookies(req.Response.Cookies())
	return
}

// LoginQrPoll implements F.BiliApi.
// test
func (t *biliApi) LoginQrPoll(QrcodeKey string) (err error, code int) {
	r := t.pool.Get()
	defer t.pool.Put(r)
	if e := r.Reqf(reqf.Rval{
		Url:     `https://passport.bilibili.com/x/passport-login/web/qrcode/poll?qrcode_key=` + QrcodeKey + `&source=main-fe-header`,
		Proxy:   t.proxy,
		Timeout: 10 * 1000,
		Retry:   2,
	}); e != nil {
		err = e
		return
	}

	var res struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		TTL     int    `json:"ttl"`
		Data    struct {
			URL          string `json:"url"`
			RefreshToken string `json:"refresh_token"`
			Timestamp    int    `json:"timestamp"`
			Code         int    `json:"code"`
			Message      string `json:"message"`
		} `json:"data"`
	}

	if e := json.Unmarshal(r.Respon, &res); e != nil {
		err = e
		return
	}

	if res.Code != 0 {
		err = errors.New(`code != 0`)
		return
	}
	code = res.Data.Code
	t.SetCookies(r.Response.Cookies())
	return
}

func (t *biliApi) SetProxy(proxy string) {
	t.proxy = proxy
}

// test
func (t *biliApi) LoginQrCode() (err error, imgUrl string, QrcodeKey string) {
	r := t.pool.Get()
	defer t.pool.Put(r)
	if e := r.Reqf(reqf.Rval{
		Url:     `https://passport.bilibili.com/x/passport-login/web/qrcode/generate?source=main-fe-header`,
		Proxy:   t.proxy,
		Timeout: 10 * 1000,
		Retry:   2,
	}); e != nil {
		err = e
		return
	}

	var res struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
		TTL     int    `json:"ttl"`
		Data    struct {
			URL       string `json:"url"`
			QrcodeKey string `json:"qrcode_key"`
		} `json:"data"`
	}

	if e := json.Unmarshal(r.Respon, &res); e != nil {
		err = e
		return
	}
	if res.Code != 0 {
		err = errors.New(`code != 0`)
		return
	}

	if res.Data.URL == `` {
		err = errors.New(`Data.URL == ""`)
		return
	} else {
		imgUrl = res.Data.URL
	}
	if res.Data.QrcodeKey == `` {
		err = errors.New(`Data.QrcodeKey == ""`)
		return
	} else {
		QrcodeKey = res.Data.QrcodeKey
	}
	t.SetCookies(r.Response.Cookies())
	return
}

// bilibili wrid wts 计算
func getWridWts(query string, imgURL, subURL string, customWts ...string) (w_rid, wts string) {
	wbi := imgURL[strings.LastIndex(imgURL, "/")+1:strings.LastIndex(imgURL, ".")] +
		subURL[strings.LastIndex(subURL, "/")+1:strings.LastIndex(subURL, ".")]

	code := []int{46, 47, 18, 2, 53, 8, 23, 32, 15, 50, 10, 31, 58, 3, 45, 35, 27, 43, 5,
		49, 33, 9, 42, 19, 29, 28, 14, 39, 12, 38, 41, 13, 37, 48, 7, 16, 24, 55,
		40, 61, 26, 17, 0, 1, 60, 51, 30, 4, 22, 25, 54, 21, 56, 59, 6, 63, 57,
		62, 11, 36, 20, 34, 44, 52}

	s := []byte{}

	for i := 0; i < len(code); i++ {
		if code[i] < len(wbi) {
			s = append(s, wbi[code[i]])
			if len(s) >= 32 {
				break
			}
		}
	}

	object := strings.Split(query, "&")

	if len(customWts) == 0 {
		wts = fmt.Sprintf("%d", time.Now().Unix())
	} else {
		wts = customWts[0]
	}
	object = append(object, "wts="+wts)

	slices.Sort(object)

	for i := 0; i < len(object); i++ {
		object[i] = url.PathEscape(object[i])
	}

	w_rid = fmt.Sprintf("%x", md5.Sum([]byte(strings.Join(object, "&")+string(s))))

	return
}