From f2cd19a0532428febde77990a914d7527fb9c904 Mon Sep 17 00:00:00 2001 From: Mow910 Date: Sun, 25 Jan 2026 17:28:38 +0100 Subject: [PATCH] =?UTF-8?q?Ajout=20d'un=20syst=C3=A8me=20de=20notification?= =?UTF-8?q?s=20YouTube=20avec=20une=20nouvelle=20table=20`youtube=5Fnotifi?= =?UTF-8?q?cation`=20dans=20la=20base=20de=20donn=C3=A9es,=20int=C3=A9grat?= =?UTF-8?q?ion=20de=20la=20v=C3=A9rification=20des=20vid=C3=A9os=20YouTube?= =?UTF-8?q?,=20et=20cr=C3=A9ation=20d'une=20interface=20web=20pour=20g?= =?UTF-8?q?=C3=A9rer=20les=20notifications.=20Le=20bot=20Discord=20enverra?= =?UTF-8?q?=20des=20alertes=20pour=20les=20nouvelles=20vid=C3=A9os=20d?= =?UTF-8?q?=C3=A9tect=C3=A9es.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- database/models.py | 10 ++ database/schema.sql | 10 ++ discordbot/__init__.py | 8 ++ discordbot/youtube.py | 180 +++++++++++++++++++++++++++++++++ webapp/__init__.py | 2 +- webapp/templates/template.html | 1 + webapp/templates/youtube.html | 113 +++++++++++++++++++++ webapp/youtube.py | 157 ++++++++++++++++++++++++++++ 8 files changed, 480 insertions(+), 1 deletion(-) create mode 100644 discordbot/youtube.py create mode 100644 webapp/templates/youtube.html create mode 100644 webapp/youtube.py diff --git a/database/models.py b/database/models.py index 9f103d1..e174fce 100644 --- a/database/models.py +++ b/database/models.py @@ -61,3 +61,13 @@ class AntiCheatCache(db.Model): notes = db.Column(db.String(1024)) updated_at = db.Column(db.DateTime) +class YouTubeNotification(db.Model): + __tablename__ = 'youtube_notification' + id = db.Column(db.Integer, primary_key=True) + enable = db.Column(db.Boolean, default=True) + channel_id = db.Column(db.String(128)) # ID de la chaîne YouTube + notify_channel = db.Column(db.Integer) # ID du canal Discord + message = db.Column(db.String(2000)) + video_type = db.Column(db.String(16), default='all') # 'all', 'video', 'short' + last_video_id = db.Column(db.String(128)) # ID de la dernière vidéo notifiée + diff --git a/database/schema.sql b/database/schema.sql index 04cef86..4f36e26 100644 --- a/database/schema.sql +++ b/database/schema.sql @@ -76,3 +76,13 @@ CREATE TABLE IF NOT EXISTS `member_invites` ( `inviter_name` VARCHAR(256), `join_date` DATETIME NOT NULL ); + +CREATE TABLE IF NOT EXISTS `youtube_notification` ( + id INTEGER PRIMARY KEY AUTOINCREMENT, + `enable` BOOLEAN NOT NULL DEFAULT TRUE, + `channel_id` VARCHAR(128) NOT NULL, + `notify_channel` INTEGER NOT NULL, + `message` VARCHAR(2000) NOT NULL, + `video_type` VARCHAR(16) NOT NULL DEFAULT 'all', + `last_video_id` VARCHAR(128) +); diff --git a/discordbot/__init__.py b/discordbot/__init__.py index 2de81dd..9c48341 100644 --- a/discordbot/__init__.py +++ b/discordbot/__init__.py @@ -22,6 +22,7 @@ from discordbot.moderation import ( handle_say_command ) from discordbot.welcome import sendWelcomeMessage, sendLeaveMessage, updateInviteCache +from discordbot.youtube import checkYouTubeVideos from protondb import searhProtonDb class DiscordBot(discord.Client): @@ -35,6 +36,7 @@ class DiscordBot(discord.Client): self.loop.create_task(self.updateStatus()) self.loop.create_task(self.updateHumbleBundle()) + self.loop.create_task(self.updateYouTube()) async def updateStatus(self): while not self.is_closed(): @@ -50,6 +52,12 @@ class DiscordBot(discord.Client): while not self.is_closed(): await checkHumbleBundleAndNotify(self) await asyncio.sleep(30*60) + + async def updateYouTube(self): + while not self.is_closed(): + await checkYouTubeVideos() + # Vérification toutes les 5 minutes (comme pour Twitch) + await asyncio.sleep(5*60) def getAllTextChannel(self) -> list[TextChannel]: channels = [] diff --git a/discordbot/youtube.py b/discordbot/youtube.py new file mode 100644 index 0000000..7211fca --- /dev/null +++ b/discordbot/youtube.py @@ -0,0 +1,180 @@ +import logging +import asyncio +import xml.etree.ElementTree as ET +import requests + +from database import db +from database.models import YouTubeNotification +from webapp import webapp + +logger = logging.getLogger('youtube-notification') +logger.setLevel(logging.INFO) + + +async def checkYouTubeVideos(): + with webapp.app_context(): + try: + notifications: list[YouTubeNotification] = YouTubeNotification.query.filter_by(enable=True).all() + + for notification in notifications: + try: + await _checkChannelVideos(notification) + except Exception as e: + logger.error(f"Erreur lors de la vérification de la chaîne {notification.channel_id}: {e}") + continue + except Exception as e: + logger.error(f"Erreur lors de la vérification YouTube: {e}") + + +async def _checkChannelVideos(notification: YouTubeNotification): + try: + channel_id = notification.channel_id + + rss_url = f"https://www.youtube.com/feeds/videos.xml?channel_id={channel_id}" + + response = await asyncio.to_thread(requests.get, rss_url, timeout=10) + + if response.status_code != 200: + logger.error(f"Erreur HTTP {response.status_code} lors de la récupération du RSS pour {channel_id}") + return + + root = ET.fromstring(response.content) + + ns = {'atom': 'http://www.w3.org/2005/Atom', 'yt': 'http://www.youtube.com/xml/schemas/2015', 'media': 'http://search.yahoo.com/mrss/'} + + entries = root.findall('atom:entry', ns) + + if not entries: + logger.warning(f"Aucune vidéo trouvée dans le RSS pour {channel_id}") + return + + videos = [] + for entry in entries: + video_id = entry.find('yt:videoId', ns) + if video_id is None: + continue + video_id = video_id.text + + title_elem = entry.find('atom:title', ns) + video_title = title_elem.text if title_elem is not None else 'Sans titre' + + link_elem = entry.find('atom:link', ns) + video_url = link_elem.get('href') if link_elem is not None else f"https://www.youtube.com/watch?v={video_id}" + + published_elem = entry.find('atom:published', ns) + published_at = published_elem.text if published_elem is not None else '' + + author_elem = entry.find('atom:author/atom:name', ns) + channel_name = author_elem.text if author_elem is not None else 'Inconnu' + + thumbnail = None + media_thumbnail = entry.find('media:group/media:thumbnail', ns) + if media_thumbnail is not None: + thumbnail = media_thumbnail.get('url') + + is_short = False + if video_title and ('#shorts' in video_title.lower() or '#short' in video_title.lower()): + is_short = True + + if notification.video_type == 'all': + videos.append((video_id, { + 'title': video_title, + 'url': video_url, + 'published': published_at, + 'channel_name': channel_name, + 'thumbnail': thumbnail, + 'is_short': is_short + })) + elif notification.video_type == 'short' and is_short: + videos.append((video_id, { + 'title': video_title, + 'url': video_url, + 'published': published_at, + 'channel_name': channel_name, + 'thumbnail': thumbnail, + 'is_short': is_short + })) + elif notification.video_type == 'video' and not is_short: + videos.append((video_id, { + 'title': video_title, + 'url': video_url, + 'published': published_at, + 'channel_name': channel_name, + 'thumbnail': thumbnail, + 'is_short': is_short + })) + + videos.sort(key=lambda x: x[1]['published'], reverse=True) + + if videos: + latest_video_id, latest_video = videos[0] + + if not notification.last_video_id: + notification.last_video_id = latest_video_id + db.session.commit() + return + + if latest_video_id != notification.last_video_id: + logger.info(f"Nouvelle vidéo détectée: {latest_video_id} pour la chaîne {notification.channel_id}") + await _notifyVideo(notification, latest_video, latest_video_id) + notification.last_video_id = latest_video_id + db.session.commit() + + except Exception as e: + logger.error(f"Erreur lors de la vérification des vidéos: {e}") + + +async def _notifyVideo(notification: YouTubeNotification, video_data: dict, video_id: str): + from discordbot import bot + try: + channel_name = video_data.get('channel_name', 'Inconnu') + video_title = video_data.get('title', 'Sans titre') + video_url = video_data.get('url', f"https://www.youtube.com/watch?v={video_id}") + thumbnail = video_data.get('thumbnail', '') + published_at = video_data.get('published', '') + is_short = video_data.get('is_short', False) + + try: + message = notification.message.format( + channel_name=channel_name or 'Inconnu', + video_title=video_title or 'Sans titre', + video_url=video_url, + video_id=video_id, + thumbnail=thumbnail or '', + published_at=published_at or '', + is_short=is_short + ) + except KeyError as e: + logger.error(f"Variable manquante dans le message de notification: {e}") + message = f"🎥 Nouvelle vidéo de {channel_name}: [{video_title}]({video_url})" + + logger.info(f"Envoi de notification YouTube: {message}") + bot.loop.create_task(_sendMessage(notification.notify_channel, message, video_url, thumbnail, video_title, channel_name)) + + except Exception as e: + logger.error(f"Erreur lors de la notification: {e}") + + +async def _sendMessage(channel_id: int, message: str, video_url: str, thumbnail: str, video_title: str, channel_name: str): + from discordbot import bot + try: + discord_channel = bot.get_channel(channel_id) + if not discord_channel: + logger.error(f"Canal Discord {channel_id} introuvable") + return + + import discord + embed = discord.Embed( + title=video_title, + url=video_url, + color=0xFF0000 + ) + embed.set_author(name=channel_name, icon_url="https://www.youtube.com/img/desktop/yt_1200.png") + if thumbnail: + embed.set_image(url=thumbnail) + + await discord_channel.send(message, embed=embed) + logger.info(f"Notification YouTube envoyée avec succès") + + except Exception as e: + logger.error(f"Erreur lors de l'envoi du message Discord: {e}") diff --git a/webapp/__init__.py b/webapp/__init__.py index 28f6c3c..cdaaa26 100644 --- a/webapp/__init__.py +++ b/webapp/__init__.py @@ -2,4 +2,4 @@ from flask import Flask webapp = Flask(__name__) -from webapp import commandes, configurations, index, humeurs, protondb, live_alert, twitch_auth, moderation +from webapp import commandes, configurations, index, humeurs, protondb, live_alert, twitch_auth, moderation, youtube diff --git a/webapp/templates/template.html b/webapp/templates/template.html index e36f520..1539260 100644 --- a/webapp/templates/template.html +++ b/webapp/templates/template.html @@ -19,6 +19,7 @@