Update webhook_handler.py

webhook_handler.py

@@ -40,11 +40,20 @@ def handle_webhook(data, key_callback_vk, db_name):
         group_id = data['group_id']
         print(f"User {user_id} unsubscribed from the mailing list of group {group_id}")
 
-        # Удаляем информацию о подписке из базы данных
+        # Записываем информацию об отписке в базу данных
         conn = sqlite3.connect(db_name)
         cursor = conn.cursor()
 
-        cursor.execute("UPDATE contacts SET canal = NULL WHERE vk_id = ?", (user_id,))
+        # Проверяем, существует ли запись для данного пользователя
+        cursor.execute("SELECT * FROM contacts WHERE vk_id = ?", (user_id,))
+        result = cursor.fetchone()
+
+        if result:
+            # Обновляем запись, если пользователь уже существует
+            cursor.execute("UPDATE contacts SET canal = 0 WHERE vk_id = ?", (user_id,))
+        else:
+            # Создаем новую запись, если пользователь не существует
+            cursor.execute("INSERT INTO contacts (vk_id, canal) VALUES (?, 0)", (user_id,))
 
         conn.commit()
         conn.close()