From ec371734fc9fa232bb1ca24f4e2160c590244fdc Mon Sep 17 00:00:00 2001 From: poiuty Date: Mon, 22 May 2023 16:56:38 +0300 Subject: [PATCH] update --- app/worker.go | 21 +++++++++++---------- 1 file changed, 11 insertions(+), 10 deletions(-) diff --git a/app/worker.go b/app/worker.go index 1f771b3..4955226 100644 --- a/app/worker.go +++ b/app/worker.go @@ -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) + } } } }