public
/
bilibili-go-common
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
1 Commit
1 Branch
0 Tags
34 MiB
 
 
 
Branch: master
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from 'master'
${ noResults }
bilibili-go-common/app/interface/main/dm2/http/http_test.go

306 lines
8.1 KiB
Raw Permalink Blame History

package http
import (
"crypto/md5"
"encoding/hex"
"encoding/json"
"errors"
"fmt"
"io/ioutil"
"net/http"
"net/url"
"strconv"
"strings"
"testing"
"time"
"go-common/app/interface/main/dm2/model"
)
const (
_host = "http://127.0.0.1:6701"
_host2 = "http://api.bilibili.com"
_host3 = "http://uat-api.bilibili.co"
)
var (
cookie = `sid=88dol9eo; fts=1508407962; LIVE_BUVID=AUTO4115084079913953; UM_distinctid=15f3436b684ab-08804fe751374a-31657c00-1fa400-15f3436b685298; pgv_pvi=3618563072; rpdid=kmilkmximpdoswqploqxw; biliMzIsnew=1; biliMzTs=null; buvid3=CBB97852-6CF6-4D3A-B97F-5A9AD1D5827F26561infoc; finger=14bc3c4e; pgv_si=s6534896640; purl_token=bilibili_1511162275; DedeUserID=3078992; DedeUserID__ckMd5=55845496fd6119b5; SESSDATA=7bf20cf0%2C1513762568%2C258e3d17; bili_jct=160db0def61324719de104b7bfe1e3ef; _cnt_pm=0; _cnt_notify=0; _dfcaptcha=b5463dc96d22c22164a8c0e5a1ba9e96; member_v2=1`
dmLikeActURL = _host2 + "/x/v2/dm/thumbup/add"
dmLikeListURL = _host2 + "/x/v2/dm/thumbup/stats"
dmEditURL = _host + "/x/internal/v2/dm/edit/state"
dmPoolURL = _host + "/x/internal/v2/dm/edit/pool"
dmUpSearchURL = _host3 + "/x/v2/dm/search"
dmRecentURL = _host + "/x/internal/v2/dm/recent"
updateMaskURL = _host3 + "/x/internal/v2/dm/mask/update"
editUpFiltersURL = _host + "/x/v2/dm/filter/up/edit"
)
func TestEditUpFilter(t *testing.T) {
fliters := model.UpFilter{
Filter: "zzzzzz",
Comment: "",
}
p := url.Values{}
p.Set("active", "1")
p.Set("type", "0")
filter, err := json.Marshal(fliters)
if err != nil {
return
}
fmt.Print(string(filter))
p.Set("filters", string(filter))
mh := md5.Sum([]byte(p.Encode() + "3cf6bd1b0ff671021da5f424fea4b04a"))
p.Set("sign", hex.EncodeToString(mh[:]))
reqURL := editUpFiltersURL + "?" + p.Encode()
fmt.Println(reqURL)
body, err := opost(reqURL)
if err != nil {
t.Errorf("url(%s) error(%s)", reqURL, err)
t.FailNow()
}
if err = ccode(body); err != nil {
t.Fatal(err, string(body))
t.FailNow()
}
fmt.Println(string(body))
}
func TestRecent(t *testing.T) {
params := url.Values{}
params.Set("uid", "27515256")
params.Set("page", "5")
//params.Set("mid", "27515313")
params.Set("order", "ctime")
params.Set("size", "1")
params.Set("appkey", "53e2fa226f5ad348")
params.Set("ts", strconv.FormatInt(time.Now().Unix(), 10))
mh := md5.Sum([]byte(params.Encode() + "3cf6bd1b0ff671021da5f424fea4b04a"))
params.Set("sign", hex.EncodeToString(mh[:]))
s := dmRecentURL + "?" + params.Encode()
body, err := oget(s)
if err != nil {
t.Errorf("url(%s) error(%s)", s, err)
t.FailNow()
}
if err = ccode(body); err != nil {
t.Fatal(err, string(body))
t.FailNow()
}
fmt.Println(string(body))
}
func TestDMEdit(t *testing.T) {
params := url.Values{}
params.Set("oid", "5")
params.Set("type", "1")
params.Set("mid", "27515313")
params.Set("dmids", "719149463")
params.Set("state", "0")
params.Set("appkey", "53e2fa226f5ad348")
params.Set("ts", strconv.FormatInt(time.Now().Unix(), 10))
mh := md5.Sum([]byte(params.Encode() + "3cf6bd1b0ff671021da5f424fea4b04a"))
params.Set("sign", hex.EncodeToString(mh[:]))
s := dmEditURL + "?" + params.Encode()
body, err := opost(s)
if err != nil {
t.Errorf("url(%s) error(%s)", s, err)
t.FailNow()
}
if err = ccode(body); err != nil {
t.Fatal(err, string(body))
t.FailNow()
}
fmt.Println(string(body))
}
func TestDMPool(t *testing.T) {
params := url.Values{}
params.Set("cid", "5")
params.Set("mid", "27515313")
params.Set("dmids", "719149463")
params.Set("pool", "2")
params.Set("appkey", "53e2fa226f5ad348")
params.Set("ts", strconv.FormatInt(time.Now().Unix(), 10))
mh := md5.Sum([]byte(params.Encode() + "3cf6bd1b0ff671021da5f424fea4b04a"))
params.Set("sign", hex.EncodeToString(mh[:]))
s := dmPoolURL + "?" + params.Encode()
body, err := opost(s)
if err != nil {
t.Errorf("url(%s) error(%s)", s, err)
t.FailNow()
}
if err = ccode(body); err != nil {
t.Fatal(err, string(body))
t.FailNow()
}
fmt.Println(string(body))
}
func TestLikeDM(t *testing.T) {
params := url.Values{}
params.Set("oid", "5")
params.Set("dmid", "719149462")
params.Set("op", "1")
reqURL := dmLikeActURL + "?" + params.Encode()
body, err := cpost(reqURL)
if err != nil {
t.Errorf("url(%s) error(%s)", reqURL, err)
t.FailNow()
}
if err = ccode(body); err != nil {
t.Fatal(err, string(body))
t.FailNow()
}
fmt.Println(string(body))
}
func TestUpdateMask(t *testing.T) {
params := url.Values{}
params.Set("cid", "10109227")
params.Set("time", "30")
params.Set("fps", "20")
params.Set("plat", "1")
params.Set("count", "20")
params.Set("list", "26777486_s0_0_1499")
params.Set("appkey", "8f62754d8d594e90")
params.Set("ts", strconv.FormatInt(1527564095, 10))
data := params.Encode()
if strings.IndexByte(data, '+') > -1 {
data = strings.Replace(data, "+", "%20", -1)
}
mh := md5.Sum([]byte(data + "test"))
params.Set("sign", hex.EncodeToString(mh[:]))
s := updateMaskURL + "?" + params.Encode()
body, err := opost(s)
if err != nil {
t.Errorf("url(%s) error(%s)", s, err)
t.FailNow()
}
if err = ccode(body); err != nil {
t.Fatal(err, string(body))
t.FailNow()
}
fmt.Println(string(body))
}
func TestLikeList(t *testing.T) {
params := url.Values{}
params.Set("oid", "27139273")
params.Set("ids", "719149462,719149463")
reqURL := dmLikeListURL + "?" + params.Encode()
fmt.Println(reqURL)
body, err := cget(reqURL)
if err != nil {
t.Errorf("url(%s) error(%s)", reqURL, err)
t.FailNow()
}
if err = ccode(body); err != nil {
t.Fatal(err, string(body))
t.FailNow()
}
fmt.Println(string(body))
}
func TestDMUpSearch(t *testing.T) {
params := url.Values{}
params.Set("oid", "10131156")
params.Set("type", "1")
params.Set("appkey", "53e2fa226f5ad348")
params.Set("ts", strconv.FormatInt(time.Now().Unix(), 10))
mh := md5.Sum([]byte(params.Encode() + "3cf6bd1b0ff671021da5f424fea4b04a"))
params.Set("sign", hex.EncodeToString(mh[:]))
reqURL := dmUpSearchURL + "?" + params.Encode()
fmt.Println(reqURL)
body, err := oget(reqURL)
if err != nil {
t.Errorf("url(%s) error(%s)", reqURL, err)
t.FailNow()
}
if err = ccode(body); err != nil {
t.Fatal(err, string(body))
t.FailNow()
}
t.Logf("======%+v", body)
fmt.Println(string(body))
}
// oget http get request
func oget(url string) (body []byte, err error) {
resp, err := http.Get(url)
if err != nil {
return
}
defer resp.Body.Close()
body, err = ioutil.ReadAll(resp.Body)
return
}
// ccode check code == 0
func ccode(body []byte) (err error) {
var d interface{}
err = json.Unmarshal(body, d)
if err != nil {
return
}
ma, ok := d.(map[string]interface{})
if !ok {
return
}
code := ma["code"].(int)
if code != 0 {
err = errors.New("code != 0")
return
}
return
}
// opost http post request
func opost(url string) (body []byte, err error) {
resp, err := http.Post(url, "", nil)
if err != nil {
return
}
defer resp.Body.Close()
body, err = ioutil.ReadAll(resp.Body)
return
}
func cpost(url string) (body []byte, err error) {
client := &http.Client{}
req, err := http.NewRequest("POST", url, nil)
if err != nil {
return
}
req.Header.Add("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8")
req.Header.Add("Accept-Language", "ja,zh-CN;q=0.8,zh;q=0.6")
req.Header.Add("Connection", "keep-alive")
req.Header.Add("Cookie", cookie)
req.Header.Add("User-Agent", "Mozilla/5.0 (Windows NT 6.1; WOW64; rv:12.0) Gecko/20100101 Firefox/12.0")
resp, err := client.Do(req)
if err != nil {
return
}
defer resp.Body.Close()
body, err = ioutil.ReadAll(resp.Body)
return
}
func cget(url string) (body []byte, err error) {
client := &http.Client{}
req, err := http.NewRequest("GET", url, nil)
if err != nil {
return
}
req.Header.Add("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8")
req.Header.Add("Accept-Language", "ja,zh-CN;q=0.8,zh;q=0.6")
req.Header.Add("Connection", "keep-alive")
req.Header.Add("Cookie", cookie)
req.Header.Add("User-Agent", "Mozilla/5.0 (Windows NT 6.1; WOW64; rv:12.0) Gecko/20100101 Firefox/12.0")
resp, err := client.Do(req)
if err != nil {
return
}
defer resp.Body.Close()
body, err = ioutil.ReadAll(resp.Body)
return
}