fix: forbidden user error

Author: escalopa

serverless/reminder/internal/handler/handler.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"slices"
 	"strconv"
+	"strings"
 	"sync"
 	"time"
 
@@ -22,6 +23,7 @@ type (
 		GetSubscribersByOffset(ctx context.Context, botID int64, offset int32) (chatIDs []int64, _ error)
 		GetPrayerDay(ctx context.Context, botID int64, date time.Time) (prayerDay *domain.PrayerDay, _ error)
 		SetReminderMessageID(ctx context.Context, botID int64, chatID int64, reminderMessageID int32) error
+		DeleteChat(ctx context.Context, botID int64, chatID int64) error
 	}
 
 	Handler struct {
@@ -215,6 +217,17 @@ func (h *Handler) remindUser(
 		ParseMode: models.ParseModeMarkdown,
 	})
 	if err != nil {
+		if strings.HasPrefix(err.Error(), bot.ErrorForbidden.Error()) {
+			// bot was blocked or user is deactivated so delete chat
+			err = h.db.DeleteChat(ctx, chat.BotID, chat.ChatID)
+			if err != nil {
+				log.Error("remindUser: delete chat", log.Err(err), log.BotID(chat.BotID), log.ChatID(chat.ChatID))
+				return fmt.Errorf("remindUser: delete chat: %v", err)
+			}
+			log.Warn("remindUser: delete chat", log.BotID(chat.BotID), log.ChatID(chat.ChatID))
+			return nil
+		}
+
 		log.Error("remindUser: send message", log.Err(err), log.BotID(chat.BotID), log.ChatID(chat.ChatID))
 		return fmt.Errorf("remindUser: send message: %v", err)
 	}

serverless/reminder/internal/service/db.go

@@ -253,3 +253,25 @@ func (db *DB) SetReminderMessageID(ctx context.Context, botID int64, chatID int6
 
 	return err
 }
+
+func (db *DB) DeleteChat(ctx context.Context, botID int64, chatID int64) error {
+	query := `
+		DECLARE $bot_id AS Int64;
+		DECLARE $chat_id AS Int64;
+
+		DELETE FROM chats
+		WHERE bot_id = $bot_id AND chat_id = $chat_id;
+	`
+
+	params := table.NewQueryParameters(
+		table.ValueParam("$bot_id", types.Int64Value(botID)),
+		table.ValueParam("$chat_id", types.Int64Value(chatID)),
+	)
+
+	err := db.client.Do(ctx, func(ctx context.Context, s table.Session) error {
+		_, _, err := s.Execute(ctx, writeTx, query, params)
+		return err
+	})
+
+	return err
+}