diff --git a/test/main.go b/test/main.go index c1b1655..131ffda 100644 --- a/test/main.go +++ b/test/main.go @@ -22,12 +22,12 @@ func main() { server := os.Args[2] proxy := os.Args[3] - u, token, id := getToken(room) + u, id := getToken(room) - startRoom(room, server, proxy, u, token, id) + startRoom(room, server, proxy, u, id) } -func getToken(room string) (*url.URL, string, string) { +func getToken(room string) (*url.URL, string) { req, err := http.NewRequestWithContext(context.TODO(), http.MethodGet, "https://ru.stripchat.com/"+room, nil) if err != nil { panic(err) @@ -61,17 +61,11 @@ func getToken(room string) (*url.URL, string, string) { panic(err) } - re = regexp.MustCompile(`"token":"*(.*?)\s*"`) - m = re.FindSubmatch(buf) - if len(m) != 2 { - panic("not match") - } - re = regexp.MustCompile(`img.strpst.com/thumbs/*(.*?)\s*"`) id := re.FindSubmatch(buf) if len(id) != 2 { panic("not match") } xid := string(id[1]) - return u, string(m[1]), xid[strings.Index(xid, "/")+1:] + return u, xid[strings.Index(xid, "/")+1:] } diff --git a/test/worker.go b/test/worker.go index d21f575..48100e5 100644 --- a/test/worker.go +++ b/test/worker.go @@ -58,9 +58,9 @@ type ServerResponse struct { } `json:"params,omitempty"` } -func startRoom(room, server, proxy string, u *url.URL, token string, id string) { +func startRoom(room, server, proxy string, u *url.URL, id string) { // curl -vvv -X POST -H "Content-Type: application/x-www-form-urlencoded; charset=UTF-8" -H "X-Requested-With: XMLHttpRequest" -d "method=getRoomData" -d "args[]=Icehotangel" "https://rt.bongocams.com/tools/amf.php?res=771840&t=1654437233142" - fmt.Printf("token %s id %s\n", token, id) + fmt.Println("Start", room, "server", server, "proxy", proxy) Dialer := *websocket.DefaultDialer @@ -88,12 +88,6 @@ func startRoom(room, server, proxy string, u *url.URL, token string, id string) defer c.Close() - ws, _, err := Dialer.Dial("wss://websocket.stripchat.com/connection/websocket", nil) - if err != nil { - panic(err) - } - defer ws.Close() - for { _, message, err := c.ReadMessage() if err != nil { @@ -120,17 +114,13 @@ func startRoom(room, server, proxy string, u *url.URL, token string, id string) return } } - if err = ws.WriteMessage(websocket.TextMessage, []byte(fmt.Sprintf(`{"params":{"token":"%s","name":"js"},"id":1}`, token))); err != nil { - panic(err) - } + } if !strings.Contains(m.SubscriptionKey, "newChatMessage") { continue } - fmt.Println("proper msg") - if m.Params.Message.Type == "lovense" { fmt.Println("donate") fmt.Println(m.Params.Message.Details.LovenseDetails.Detail.Name, " send ", m.Params.Message.Details.LovenseDetails.Detail.Amount, "tokens")