statbate/special-pancake
1
0
Fork 0
mirror of https://github.com/statbate/special-pancake.git synced 2026-08-11 03:12:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

update

Browse source
This commit is contained in:
poiuty 2023-05-22 16:56:38 +03:00
parent b0ed58805a
commit ec371734fc
1 changed files with 11 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

21
app/worker.go
View file

@ -236,7 +236,7 @@ func xWorker(workerData Info, u url.URL) {
fmt.Println(err.Error(), workerData.room)
continue
}
for _, msg := range topmsg.Messages {
for _, msg := range topmsg {
inmsg := &Data{}
if err := json.Unmarshal([]byte(msg.Data), inmsg); err != nil {
@ -244,16 +244,17 @@ func xWorker(workerData Info, u url.URL) {
continue
}
// inmsg.User.Username, inmsg.User.Gender, inmsg.User.IsBroadcast, inmsg.Action
fmt.Println(inmsg.User.Username, inmsg.User.Gender, inmsg.User.IsBroadcast, inmsg.Action, workerData.room)
if inmsg.User.Username == workerData.room && inmsg.User.IsBroadcast && inmsg.Action == "leave" {
fmt.Println("leave, start ticker", workerData.room)
leave.Reset(60 * 5 * time.Second)
}
if inmsg.User.Username == workerData.room && inmsg.User.IsBroadcast && inmsg.Action == "enter" {
fmt.Println("enter, stop ticker", workerData.room)
leave.Reset(60 * 60 * 8 * time.Second)
if inmsg.User.Username == workerData.room && inmsg.User.IsBroadcast {
if inmsg.Action == "leave" {
fmt.Println("leave, start ticker", workerData.room)
leave.Reset(60 * 5 * time.Second)
}
if inmsg.Action == "enter" {
fmt.Println("enter, stop ticker", workerData.room)
leave.Reset(60 * 60 * 8 * time.Second)
}
}
}
}