nefrace/KickerBot
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Migration to Tongo, new logic for user storage #3

Merged
nefrace merged 19 commits from tongo into master 2023-09-10 13:10:33 +03:00
Conversation 0 Commits 19 Files Changed 9 +344 -184
9 changed files with 344 additions and 184 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit b631b4423a - Show all commits

12
kicker/handlers.go
View File

@ -55,10 +55,7 @@ func userJoined(b *bot, update *echotron.Update) error {
log.Printf("Error creating captcha bytes: %v", bytes) log.Printf("Error creating captcha bytes: %v", bytes)
b.SendMessage("Не могу создать капчу, @nefrace, проверь логи.", update.Message.Chat.ID, &echotron.MessageOptions{MessageThreadID: int64(update.Message.ThreadID)}) b.SendMessage("Не могу создать капчу, @nefrace, проверь логи.", update.Message.Chat.ID, &echotron.MessageOptions{MessageThreadID: int64(update.Message.ThreadID)})
} }
msg := fmt.Sprintf("Приветствую тебя, *%s*\\!\nДля подтверждения, что ты человек, выбери логотип движка, которому посвящен данный чат, и отправь его номер сюда\\.\n*_Я дам тебе десять минут на это\\._*", UserMention(usr))
// user.CorrectAnswer = int8(captcha.CorrectAnswer)
log.Print(user)
msg := fmt.Sprintf("Приветствую тебя, *[%s](tg://user?id=%d)*\\!\nДля подтверждения, что ты человек, выбери логотип движка, которому посвящен данный чат, и отправь его номер сюда\\.\n*_Я дам тебе десять минут на это\\._*", EscapeText(echotron.MarkdownV2, user.FirstName), user.UserId)
options := echotron.PhotoOptions{ options := echotron.PhotoOptions{
Caption: msg, Caption: msg,
ParseMode: echotron.MarkdownV2, ParseMode: echotron.MarkdownV2,
@ -110,7 +107,12 @@ func checkCaptcha(b *bot, update *echotron.Update) error {
// d := db.GetDatabase() // d := db.GetDatabase()
ctx, cancel := context.WithTimeout(context.Background(), 15*time.Second) ctx, cancel := context.WithTimeout(context.Background(), 15*time.Second)
defer cancel() defer cancel()
if user, err := store.GetOne(ctx, tongo.E("user_id", sender.ID), tongo.E("chat_id", message.Chat.ID), tongo.E("is_joined", false)); err == nil { //d.GetUser(ctx, db.User{UserId: sender.ID, ChatId: message.Chat.ID}); err == nil {
if user, err := store.GetOne(ctx,
tongo.E("user_id", sender.ID),
tongo.E("chat_id", message.Chat.ID),
tongo.E("is_joined", false),
); err == nil { //d.GetUser(ctx, db.User{UserId: sender.ID, ChatId: message.Chat.ID}); err == nil {
chat, err := chatStore.GetOne(ctx, tongo.E("chat_id", message.Chat.ID)) chat, err := chatStore.GetOne(ctx, tongo.E("chat_id", message.Chat.ID))
if err != nil { if err != nil {
return err return err