chtwrs/chirpnest
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
shoopea 2020-06-27 14:06:21 +02:00
parent 87a8b05129
commit f2f7354ad1
2 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
job.go
View File

@ -692,10 +692,6 @@ func jobMsgRefresh(j Job) {
err = setJobDone(j.ID64) err = setJobDone(j.ID64)
logOnError(err, "joMsgClient : setJobDone") logOnError(err, "joMsgClient : setJobDone")
return return
} else {
err = setJobDone(j.ID64)
logOnError(err, "joMsgClient : setJobDone")
return
} }
err = delObj(p.ObjID64) err = delObj(p.ObjID64)

9
workers.go
View File

@ -500,6 +500,15 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
cwm, err := parseSubTypeMessageTimeAck(m, rule.re) cwm, err := parseSubTypeMessageTimeAck(m, rule.re)
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_time_ack`]") logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_time_ack`]")
err = insertMsgTimeAck(cwm) err = insertMsgTimeAck(cwm)
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : insertMsgTimeAck")
if cwm.RealTime.After(m.Date.Add(5*time.Minute)) || cwm.RealTime.Before(m.Date.Add(5*time.Minute)) {
w := TGCommand{
Type: commandSendMsg,
Text: fmt.Sprintf("Date drifting %v => %v\n", m.Date, cwm.RealTime-m.Date),
ToUserID64: cfg.Bot.Admin,
}
TGCmdQueue <- w
}
case cacheObjSubType[`msg_orderbook_acl`]: case cacheObjSubType[`msg_orderbook_acl`]:
_, err := parseSubTypeMessageOrderbookAck(m, rule.re) _, err := parseSubTypeMessageOrderbookAck(m, rule.re)
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_orderbook_acl`]") logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_orderbook_acl`]")