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),