Commit 74e8e323 authored by 王明明's avatar 王明明

nk 修改

parent 6b944b62
......@@ -132,7 +132,7 @@ func (akm *AkmClient) postSensor(times int) error {
abck, bmsz := akm.GetCookie()
t1 := time.Now()
res, ua := sensor.GenData(times, abck, bmsz, akm.ua, akm.postUrl)
res, ua := sensor.GenData(times, abck, bmsz, akm.postUrl)
akm.ua = ua
t2 := time.Now()
sensor_data := "{\"sensor_data\":\"" + res + "\"}"
......
package sensor
import (
"crypto/rand"
"fmt"
"math"
"math/rand"
"math/big"
"strconv"
)
func Float64() float64 {
return float64(RandRandom(1000)) / float64(1000)
}
func GetRandomTime() int64 {
f := rand.Float64()*100 + 30
f := Float64()*100 + 30
return int64(int(math.Floor(f)))
}
......@@ -26,21 +30,81 @@ func ItoS(s int) string {
return strconv.Itoa(s)
}
type AkmEvent struct {
x int
y int
startTs int64
// 总耗时
ta int64
// keyevent-108
ke_cnt int
kact string
ke_vel int
ke_cnt_lmt int
ke_ts int64
// mouseevent-110
me_vel int
me_cnt int
mact string
me_ts int64
// devicemotionevent -109
dmact string
dme_vel int
dme_cnt int
dme_ts int64
// pointerevent -114
pe_cnt int
pe_vel int
pact string
pduce_cnt int
pme_cnt int
pe_ts int64
// deviceorientation -111
doact string
doe_vel int
doe_cnt int
do_ts int64
// -117
te_ts int64
te_vel int
tact string
tme_cnt int
te_cnt int
tduce_cnt int
}
func (akm *AkmEvent) event108(keyType int, delay int64, e *KeyEventInfo) {
if akm.ke_cnt >= akm.ke_cnt_lmt {
return
}
s := now() - akm.startTs + delay
akm.ke_ts = akm.ke_ts + delay
n := -2
l := 0
d := 0
k := 0
u := fmt.Sprintf("%d,%d,%d,%d,%d,%d,%d;", akm.ke_cnt, keyType, s, n, l, d, k)
k := 1974
u := fmt.Sprintf("%d,%d,%d,%d,%d,%d,%d;", akm.ke_cnt, keyType, akm.ke_ts, n, l, d, k)
akm.kact = akm.kact + u
akm.ke_vel = akm.ke_vel + akm.ke_cnt + keyType + int(s) + n + d + k
akm.ta += s
akm.ke_vel = akm.ke_vel + akm.ke_cnt + keyType + int(akm.ke_ts) + n + d + k
akm.ta += akm.ke_ts
akm.ke_cnt++
}
func (akm *AkmEvent) event117(keyType int, delay int64) {
x := -1
y := -1
if akm.ke_cnt >= akm.ke_cnt_lmt {
return
}
akm.te_ts = akm.te_ts + delay
akm.tact = akm.tact + fmt.Sprintf("%d,%d,%d,%d,%d;", akm.te_cnt, keyType, akm.te_ts, x, y)
akm.ta += akm.te_ts
akm.te_vel = akm.te_vel + akm.te_cnt + keyType + int(akm.te_ts) + x + y
if keyType == 1 {
akm.tme_cnt++
} else {
akm.tduce_cnt++
akm.te_cnt++
}
}
func (akm *AkmEvent) ActivateKeyEvent(keycode string) {
keyEventInfo := &KeyEventInfo{altKey: false, shiftKey: false, metaKey: false, ctrlKey: false, charCode: 0, keyCode: keycode}
t := GetRandomTime()
......@@ -64,9 +128,14 @@ func (akm *AkmEvent) ActivateDeviceMotionEvent() {
akm.event109(t)
}
func (akm *AkmEvent) ActivateTouchEvent() {
t := GetRandomTime()
akm.event117(2, t)
akm.event117(3, t)
}
func (akm *AkmEvent) event109(delay int64) {
s := now() - akm.startTs + delay
akm.dme_ts = akm.dme_ts + delay
e := -1
n := -1
o := -1
......@@ -79,15 +148,15 @@ func (akm *AkmEvent) event109(delay int64) {
d := -1
// m = t["accelerationIncludingGravity"]["x"], r = t["accelerationIncludingGravity"]["y"], i = t["accelerationIncludingGravity"]["z"];
// c = t["rotationRate"]["alpha"], b = t["rotationRate"]["beta"] ,d = t["rotationRate"]["gamma"];
akm.dmact = akm.dmact + fmt.Sprintf("%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d;", akm.dme_cnt, s, e, n, o, m, r, i, c, b, d)
akm.dme_vel = akm.dme_vel + akm.dme_cnt + int(s)
akm.ta += s
akm.dmact = akm.dmact + fmt.Sprintf("%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d;", akm.dme_cnt, akm.dme_ts, e, n, o, m, r, i, c, b, d)
akm.dme_vel = akm.dme_vel + akm.dme_cnt + int(akm.dme_ts)
akm.ta += akm.dme_ts
akm.dme_cnt++
}
func (akm *AkmEvent) event114(pointerType, x, y int, delay int64) {
s := now() - akm.startTs + delay
i := fmt.Sprintf("%d,%d,%d,%d,%d;", akm.pe_cnt, pointerType, s, x, y)
akm.pe_vel = akm.pe_vel + akm.pe_cnt + pointerType + int(s) + x + y
akm.pe_ts = akm.pe_ts + delay
i := fmt.Sprintf("%d,%d,%d,%d,%d;", akm.pe_cnt, pointerType, akm.pe_ts, x, y)
akm.pe_vel = akm.pe_vel + akm.pe_cnt + pointerType + int(akm.pe_ts) + x + y
akm.pact = akm.pact + i
if pointerType == 1 {
akm.pme_cnt++
......@@ -95,15 +164,15 @@ func (akm *AkmEvent) event114(pointerType, x, y int, delay int64) {
akm.pduce_cnt++
}
akm.pe_cnt++
akm.ta += s
akm.ta += akm.pe_ts
}
func Random() {
}
func (akm *AkmEvent) ActivatePointerEvent() {
t := math.Floor(rand.Float64()*100 + 30)
x := math.Floor(rand.Float64()*229 + (229 / 2))
y := math.Floor(rand.Float64()*691 + (691 / 2))
t := math.Floor(Float64()*100 + 30)
x := math.Floor(Float64()*float64(akm.x) + float64(akm.x/2))
y := math.Floor(Float64()*float64(akm.y) + float64(akm.y/2))
akm.event114(3, int(x), int(y), int64(t))
akm.event114(4, int(x), int(y), int64(t))
......@@ -114,80 +183,66 @@ func (akm *AkmEvent) ActivateOrientationEvent() {
}
func (akm *AkmEvent) event111(delay int64) {
s := now() - akm.startTs + delay
akm.do_ts = akm.do_ts + delay
e := -1
n := -1
o := -1
akm.doact = akm.doact + fmt.Sprintf("%d,%d,%d,%d,%d;", akm.doe_cnt, s, e, n, o)
akm.ta += s
akm.doe_vel = akm.doe_vel + akm.doe_cnt + int(s)
akm.doact = akm.doact + fmt.Sprintf("%d,%d,%d,%d,%d;", akm.doe_cnt, akm.do_ts, e, n, o)
akm.ta += akm.do_ts
akm.doe_vel = akm.doe_vel + akm.doe_cnt + int(akm.do_ts)
akm.doe_cnt++
}
type AkmEvent struct {
startTs int64
// 总耗时
ta int64
// keyevent-108
ke_cnt int
kact string
ke_vel int
ke_cnt_lmt int
// mouseevent-110
me_vel int
me_cnt int
mact string
// devicemotionevent -109
dmact string
dme_vel int
dme_cnt int
// pointerevent -114
pe_cnt int
pe_vel int
pact string
pduce_cnt int
pme_cnt int
// deviceorientation -111
doact string
doe_vel int
doe_cnt int
// -117
te_vel int
tact string
tme_cnt int
te_cnt int
tduce_cnt int
}
func (akm *AkmEvent) ActivateRandomEvent() {
if rand.Float64() > 0.1 {
for i := 0; i < int(math.Floor(rand.Float64()*10+rand.Float64()*10)); i++ {
if Float64() > 0 {
s := int(math.Floor(Float64()*10 + Float64()*10))
for i := 0; i < s; i++ {
akm.ActivateKeyEvent("a")
}
}
if rand.Float64() > 0.2 {
if Float64() > 0 {
for i := 0; i < int(math.Floor(rand.Float64()*5+rand.Float64()*10)); i++ {
for i := 0; i < int(math.Floor(Float64()*5+Float64()*10)); i++ {
akm.ActivateDeviceMotionEvent()
}
}
if rand.Float64() > 0.1 {
if Float64() > 0 {
for i := 0; i < int(math.Floor(rand.Float64()*5+rand.Float64()*10)); i++ {
for i := 0; i < int(math.Floor(Float64()*5+Float64()*10)); i++ {
akm.ActivateTouchEvent()
}
}
if Float64() > 0 {
for i := 0; i < int(math.Floor(Float64()*5+Float64()*10)); i++ {
akm.ActivateOrientationEvent()
}
}
if rand.Float64() > 0.1 {
if Float64() > 0 {
for i := 0; i < int(math.Floor(rand.Float64()*5+rand.Float64()*10)); i++ {
for i := 0; i < int(math.Floor(Float64()*5+Float64()*10)); i++ {
akm.ActivatePointerEvent()
}
}
}
func NewAkmEvent(startTs int64) *AkmEvent {
return &AkmEvent{startTs: startTs, ke_cnt_lmt: 150}
func RandRandom(a int64) int64 {
res, _ := rand.Int(rand.Reader, big.NewInt(a))
return res.Int64()
}
func NewAkmEvent(x, y int, startTs int64) *AkmEvent {
return &AkmEvent{
x: x,
y: y,
startTs: startTs,
ke_cnt_lmt: 150,
te_ts: now() - startTs + RandRandom(1000),
me_ts: now() - startTs + RandRandom(1000),
dme_ts: now() - startTs + RandRandom(1000),
do_ts: now() - startTs + RandRandom(1000),
pe_ts: now() - startTs + RandRandom(1000),
ke_ts: now() - startTs + RandRandom(1000),
}
}
This diff is collapsed.
......@@ -83,8 +83,8 @@ func actU2() {
func actVY() {
px := "http://user-unifflcc-region-us:q39CEBTs5A5YQXor@pr.roxlabs.cn:4600"
t1 := time.Now()
//resp, err := http.Post("http://lcc.unififi.com/akamai/gen",
resp, err := http.Post("http://127.0.0.1:59001/akamai/gen",
resp, err := http.Post("http://lcc.unififi.com/akamai/gen",
//resp, err := http.Post("http://127.0.0.1:59001/akamai/gen",
"application/json", strings.NewReader("{\"type\": \"VY\", \"proxy\": \""+px+"\"}"))
//"application/json", strings.NewReader("{\"type\": \"VY\", \"proxy\": \"http://127.0.0.1:8890\"}"))
//resp, err := http.Post("http://127.0.0.1:59001/akamai/gen", "application/json", strings.NewReader("{\"type\": \"u2\", \"proxy\": \"http://user-unifflcc-region-us:q39CEBTs5A5YQXor@pr.roxlabs.cn:4600\"}"))
......
package main
import (
"fmt"
"github.com/imroc/biu"
"test/sensor"
)
......@@ -14,24 +12,23 @@ func main() {
url1 := "https://www.easyjet.com/en"
abck := "B9E0C674552DB391815F82C0647FADC9~-1~YAAQBGUzuBl9/72GAQAAyb94wAm4ydH5I2znFxoyfaPIvHOHSyqXZHzgQ7m2RkagTpBzztNa5LmNFcqg4DNXEm/tZ+r1JxOWYfLY1EA5bzEvauFo6puMeVBuo4HdbMVfmxlwKaZpIQRNtUq0Z1wEmw2rrWetb3RktDypg1QT1tuF/hnXMQseB7YMYUY2Gku1MCLDlJF3wgsm6+tXjbhbqG0RR5IKiv3My4Q5kx2JEGDFV+X/RgB5wQz1ggUsipMSyDhrqlBsYhuMxyOzZNUQX29HuKZZjKTF3omqkyGJIrMhWz7yQ3fwlKrTYjswHxIX/GP4rZqWUL3m0Zhnhu/SrZipSJOLtKbgTwTuQS+iAXNP5DsSVGL0s8+nMrQNuIVyCNUZg3nxRRjgDx/+AvYppn2xiwW/tkuOAYIbtFRkirM5J9U=~-1~||1-EAjzIUtDUl-2250-10-1000-2||~-"
bmsz := "F7BF54E40B51C55E0818DC07CD173D3D~YAAQtto4fZOUjTaGAQAAu2TuXRLag7FMMOcGVWfM6R1TuxY9u8Z+UDLtA8qE03/kyE1u1gycaSyEWy9GEbaHoyc2CT7Gqokpc8mxNY8qoEITjbsXZlhLE9Zm2K7ekUb1wAsxocavW2rsJTBvlEfYAcPs6/04ASA1QueCbMErtMm5Jqg7MnPVmCym75ewsP6qihOts07wgEWNkbSsdaHzQf4cm3uHxirh3o91GojyUSGrxRcFRn4NJlQtxIX/PrOsUr4HyxcYTAX+WUh6QyBCzGQ4pNgiszuc4R9OdAy3XGc6LzUP7PBIl5fz6OpZUj2gTJT2j5WPOn2I469jdYrZCAMoajftNJ9nrdy36vkz9S+Xp3z7dh9btp+Q+bpRYd1M9zhtmlmHxTTSv7rs6sOBHE/tmvEHXtc=~3748403~3683895"
ua := "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/110.0.0.0 Safari/537.36 Edg/110.0.1587.50"
abck = "B9E0C674552DB391815F82C0647FADC9~-1~YAAQBGUzuBl9/72GAQAAyb94wAm4ydH5I2znFxoyfaPIvHOHSyqXZHzgQ7m2RkagTpBzztNa5LmNFcqg4DNXEm/tZ+r1JxOWYfLY1EA5bzEvauFo6puMeVBuo4HdbMVfmxlwKaZpIQRNtUq0Z1wEmw2rrWetb3RktDypg1QT1tuF/hnXMQseB7YMYUY2Gku1MCLDlJF3wgsm6+tXjbhbqG0RR5IKiv3My4Q5kx2JEGDFV+X/RgB5wQz1ggUsipMSyDhrqlBsYhuMxyOzZNUQX29HuKZZjKTF3omqkyGJIrMhWz7yQ3fwlKrTYjswHxIX/GP4rZqWUL3m0Zhnhu/SrZipSJOLtKbgTwTuQS+iAXNP5DsSVGL0s8+nMrQNuIVyCNUZg3nxRRjgDx/+AvYppn2xiwW/tkuOAYIbtFRkirM5J9U=~-1~||1-EAjzIUtDUl-2250-10-1000-2||~-1"
println(sensor.GenData(3, abck, bmsz, ua, url1))
fmt.Println("sss ", string(byte(128)))
fmt.Println("sss ", "aaa"+string(rune(128)), "ssss")
for _, char := range []rune("\u0080") {
fmt.Println(string(char))
}
fmt.Println(-32033727, biu.ToBinaryString(int64(-32033727)))
fmt.Println(2634309123, biu.ToBinaryString(int64(2634309123)))
fmt.Println(-1677454335, biu.ToBinaryString(int64(-1677454335)))
var res int64
biu.ReadBinaryString("11111111 11111111 11111111 11111111 10011100 00000100 00010100 00000001", &res)
fmt.Println("res", res)
t := sensor.Iq("Mozilla/5.0 (iPhone; CPU iPhone OS 13_2_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/13.0.3 Mobile/15E148 Safari/604.1")
println(t) ////uri := "https://tls.peet.ws/api/all"
println(sensor.GenData(3, abck, bmsz, url1))
//fmt.Println("sss ", string(byte(128)))
//fmt.Println("sss ", "aaa"+string(rune(128)), "ssss")
//for _, char := range []rune("\u0080") {
// fmt.Println(string(char))
//}
//fmt.Println(-32033727, biu.ToBinaryString(int64(-32033727)))
//fmt.Println(2634309123, biu.ToBinaryString(int64(2634309123)))
//fmt.Println(-1677454335, biu.ToBinaryString(int64(-1677454335)))
//var res int64
//biu.ReadBinaryString("11111111 11111111 11111111 11111111 10011100 00000100 00010100 00000001", &res)
//fmt.Println("res", res)
//t := sensor.Iq("Mozilla/5.0 (iPhone; CPU iPhone OS 13_2_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/13.0.3 Mobile/15E148 Safari/604.1")
//
//println(t) ////uri := "https://tls.peet.ws/api/all"
//jar := tls_client.NewCookieJar()
//options := []tls_client.HttpClientOption{
// tls_client.WithTimeoutSeconds(30),
......
......@@ -20,29 +20,32 @@ func getCookie(client tls_client.HttpClient) (string, string) {
bm_sz := ""
uri, _ := url.Parse("https://www.spirit.com/")
for _, cookie := range client.GetCookies(uri) {
if cookie.Name == "_abck" {
abck = cookie.Value
}
if cookie.Name == "bm_sz" {
abck = cookie.Value
bm_sz = cookie.Value
}
}
return abck, bm_sz
}
func abckSensor(client tls_client.HttpClient, sensorurl string) string {
ua := ""
for i := 0; i < 5; i++ {
var UA string
func abckSensor(client tls_client.HttpClient, sensorurl string) {
for i := 0; i < 4; i++ {
abck, bm_sz := getCookie(client)
datas := fmt.Sprintf("times=%d&abck=%s&bm_sz=%s&url=%s", i, abck, bm_sz, "https://www.spirit.com/")
r, _ := http.Post("http://127.0.0.1:3033/akm2t", "application/x-www-form-urlencoded", strings.NewReader(datas))
rs, _ := io.ReadAll(r.Body)
rsss := strings.Split(string(rs), "|||||")
sensorData := rsss[0]
ua = rsss[1]
//sensorData, ua := sensor.GenData(i, abck, bm_sz, "Mozilla/5.0 (Linux; Android 9; SM-N9500) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/111.0.0.0 Mobile Safari/537.36", "https://www.spirit.com/")
//fmt.Println("ua", ua)
UA = rsss[1]
//if i == 2 {
// sensorData, UA = sensor.GenData(i, abck, bm_sz, "https://www.spirit.com/")
//}
fmt.Println("ua", UA)
sensor := "{\"sensor_data\":\"" + sensorData + "\"}"
req, _ := http.NewRequest("POST", "https://www.spirit.com"+sensorurl, strings.NewReader(sensor))
req.Header.Set("authority", "www.spirit.com")
......@@ -53,11 +56,10 @@ func abckSensor(client tls_client.HttpClient, sensorurl string) string {
req.Header.Set("origin", "https://www.spirit.com")
req.Header.Set("pragma", "no-cache")
req.Header.Set("referer", "https://www.spirit.com/")
req.Header.Set("user-agent", ua)
req.Header.Set("user-agent", UA)
resp, err := client.Do(req)
if err != nil {
log.Println("网络出错")
return ""
}
defer resp.Body.Close()
//readBytes, _ := io.ReadAll(resp.Body)
......@@ -66,25 +68,14 @@ func abckSensor(client tls_client.HttpClient, sensorurl string) string {
fmt.Println(cookie.Name, len(cookie.Value))
}
}
return ua
}
func main() {
wg := &sync.WaitGroup{}
for i := 0; i < 10; i++ {
for i := 0; i < 1; i++ {
wg.Add(1)
go func() {
jar := tls_client.NewCookieJar()
//uri, _ := url.Parse("https://www.spirit.com/")
//var cookies []*http.Cookie
//for key, value := range v.Cookies {
// cookies = append(cookies, &http.Cookie{
// Name: key,
// Value: value,
// })
//}
//jar.SetCookies(uri, cookies)
i, _ := rand.Int(rand.Reader, big.NewInt(149))
number := i.String() //转成string
num, err := strconv.Atoi(number)
......@@ -96,9 +87,9 @@ func main() {
tls_client.WithClientProfile(tls_client.Chrome_108),
tls_client.WithNotFollowRedirects(),
tls_client.WithCookieJar(jar), // create cookieJar instance and pass it as argument
//tls_client.WithProxyUrl("http://127.0.0.1:8890"),
tls_client.WithProxyUrl("http://127.0.0.1:8890"),
//tls_client.WithProxyUrl("http://user-unifflcc-region-us:q39CEBTs5A5YQXor@pr.roxlabs.cn:4600"),
tls_client.WithProxyUrl(px),
//tls_client.WithProxyUrl(px),
//tls_client.WithInsecureSkipVerify(),
}
client, err := tls_client.NewHttpClient(tls_client.NewNoopLogger(), options...)
......@@ -128,8 +119,8 @@ func main() {
panic(err)
}
fmt.Println(sensorurl)
ua := abckSensor(client, sensorurl)
nk(client, ua)
abckSensor(client, sensorurl)
nk(client)
wg.Done()
}()
......@@ -137,8 +128,7 @@ func main() {
wg.Wait()
}
func nk(client tls_client.HttpClient, ua string) {
fmt.Println("UA", ua)
func nk(client tls_client.HttpClient) {
//t1 := time.Now()
////resp, err := http.Post("http://lcc.unififi.com/akamai/gen",
//resp, err := http.Post("http://127.0.0.1:59001/akamai/gen",
......@@ -169,7 +159,7 @@ func nk(client tls_client.HttpClient, ua string) {
req.Header.Set("sec-ch-ua-mobile", "?0")
req.Header.Set("ocp-apim-subscription-key", "dc6844776fe84b1c8b68affe7deb7916")
//req.Header.Set("user-agent", "Mozilla/5.0 (Linux; Android 9; SM-N9500) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/111.0.0.0 Mobile Safari/537.36")
req.Header.Set("user-agent", ua)
req.Header.Set("user-agent", UA)
resp, err := client.Do(req)
if err != nil {
panic(err)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment