From dacf07b53b3d68adda48f8feb1f49ed5fe720df1 Mon Sep 17 00:00:00 2001 From: shoopea Date: Thu, 21 Jan 2021 15:15:50 +0100 Subject: [PATCH] test --- bot.go | 11 +++++++++++ rules.go | 1 + 2 files changed, 12 insertions(+) diff --git a/bot.go b/bot.go index 8f9a01e..a2599d5 100644 --- a/bot.go +++ b/bot.go @@ -833,6 +833,17 @@ func botShops(m *ChatWarsMessage) { } func botBrewItem(m *ChatWarsMessage, r *regexp.Regexp) { + if hasUnfinishedJob(cacheObjSubType[`job_brew_item`]) { + c := TGCommand{ + Type: commandReplyMsg, + Text: "Brew Item is already running", + FromMsgID64: m.ID64, + FromChatID64: m.ChatID64, + } + TGCmdQueue <- c + return + } + clt, err := getLockedIdleClient() if err != nil { c := TGCommand{ diff --git a/rules.go b/rules.go index 5daecaf..cfde0e1 100644 --- a/rules.go +++ b/rules.go @@ -221,6 +221,7 @@ func resetMsgParsingRules() error { muxObjItem.RLock() for _, o := range objItems { if o.Craft != nil && o.ItemTypeID == cacheObjSubType[`item_misc`] && len(o.Craft.Command) > 6 && o.Craft.Command[0:5] == "/brew_" { + fmt.Printf("Inserting %s\n", o.Code) r = MessageParsingRule{ Priority: 9998, Description: fmt.Sprintf("Specific item brew %s", o.Code),