test
This commit is contained in:
parent
1d5a4bcac9
commit
4d5e7608eb
10
client.go
10
client.go
@ -14,6 +14,16 @@ func clientSendCWMsg(userID64 int64, s string) {
|
|||||||
MQTGCmdQueue <- c
|
MQTGCmdQueue <- c
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func clientRefreshCWMsg(chatID64 int64, msgID64 int64) {
|
||||||
|
c := TGCommand{
|
||||||
|
Type: commandRefreshMsg,
|
||||||
|
FromChatID64: chatID64,
|
||||||
|
FromMsgID64: msgID64,
|
||||||
|
}
|
||||||
|
|
||||||
|
MQTGCmdQueue <- c
|
||||||
|
}
|
||||||
|
|
||||||
func clientMsgMeAck(m *ChatWarsMessageMeAck) {
|
func clientMsgMeAck(m *ChatWarsMessageMeAck) {
|
||||||
if _, ok := clientsQueue[m.Msg.UserID64]; ok {
|
if _, ok := clientsQueue[m.Msg.UserID64]; ok {
|
||||||
if v, ok := clientsCW.Load(m.Msg.UserID64); ok {
|
if v, ok := clientsCW.Load(m.Msg.UserID64); ok {
|
||||||
|
7
job.go
7
job.go
@ -377,12 +377,7 @@ func jobMsgRefresh(j Job) {
|
|||||||
|
|
||||||
log.Printf("Refreshing message :\n%s\n", m.Text)
|
log.Printf("Refreshing message :\n%s\n", m.Text)
|
||||||
|
|
||||||
c := TGCommand{
|
clientRefreshCWMsg(m.ChatID64, m.ID64)
|
||||||
Type: commandRefreshMsg,
|
|
||||||
FromChatID64: m.ChatID64,
|
|
||||||
FromMsgID64: m.ID64,
|
|
||||||
}
|
|
||||||
MQTGCmdQueue <- c
|
|
||||||
|
|
||||||
err = setJobDone(j.ID64)
|
err = setJobDone(j.ID64)
|
||||||
logOnError(err, "joMsgClient : setJobDone")
|
logOnError(err, "joMsgClient : setJobDone")
|
||||||
|
Loading…
Reference in New Issue
Block a user