akulij/sinkbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

process updates using goroutines

Browse Source
This commit is contained in:
akulij 2024-08-13 01:26:08 +03:00
parent 3b7d3ed3b8
commit 5e23b05631
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
cmd/app/main.go
View File

@ -95,6 +95,12 @@ func main() {
var bc = GetBotController() var bc = GetBotController()
for update := range bc.updates { for update := range bc.updates {
go ProcessUpdate(bc, update)
}
}
func ProcessUpdate(bc BotController, update tgbotapi.Update) {
if update.Message != nil { if update.Message != nil {
var UserID = update.Message.From.ID var UserID = update.Message.From.ID
@ -241,7 +247,7 @@ func main() {
if err != nil { if err != nil {
msg := tgbotapi.NewMessage(update.Message.Chat.ID, "Something went wrong, try again...") msg := tgbotapi.NewMessage(update.Message.Chat.ID, "Something went wrong, try again...")
bc.bot.Send(msg) bc.bot.Send(msg)
continue return
} }
bc.db.Model(&user).Update("state", "start") bc.db.Model(&user).Update("state", "start")
@ -330,7 +336,6 @@ func main() {
} }
} }
} }
}
} }
func DownloadFile(filepath string, url string) error { func DownloadFile(filepath string, url string) error {