discord_bot.py 57 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063
  1. """Le bot Discord : événements, commandes et réactions."""
  2. from __future__ import annotations
  3. import asyncio
  4. import contextlib
  5. import hashlib
  6. import json
  7. import logging
  8. import random
  9. import re
  10. from dataclasses import dataclass
  11. from datetime import datetime, timedelta
  12. import discord
  13. from discord import app_commands
  14. from discord.ext import commands
  15. from . import VERSION
  16. from .claude_client import ClaudeClient, ClaudeError, ImageData
  17. from .config import Settings, memory_warning
  18. from .emojis import discord_emojis, emoji_names, short_emojis, usable_emojis
  19. from .history import ConversationHistory, images_marker, render_line
  20. from .images import ImageError, prepare_image
  21. from .members import MemberRegistry, with_username
  22. from .memory import DATE_FORMAT, MemoryStore
  23. from .memory_views import MemoryCard, member_target, reply_error, see_user, server_target
  24. from .models import display_name, is_known
  25. from .pdf_files import PDF_EXTENSIONS, PDF_MAX_BYTES, PdfError, prepare_pdf
  26. from .presence import PresenceManager, Status
  27. from .text_files import TEXT_EXTENSIONS, TEXT_FILE_MAX_BYTES, TextFileError, decode_text_file
  28. from .text_utils import split_message
  29. logger = logging.getLogger("chatbot.discord")
  30. CUSTOM_EMOJI_ONLY = re.compile(r"^<a?:\w+:\d+>$")
  31. USER_MENTION = re.compile(r"<@!?(\d+)>")
  32. IMAGE_EXTENSIONS = (".jpg", ".jpeg", ".png", ".gif", ".webp", ".bmp", ".tif", ".tiff")
  33. # Couleur du message de démarrage : le vert du statut « en ligne » de Discord.
  34. ONLINE_COLOR = discord.Color(0x23A55A)
  35. # Longueur maximale du texte d'un message cité ou transféré transmis à Claude.
  36. QUOTE_MAX_LENGTH = 500
  37. # Images lues par message : chacune coûte jusqu'à ~1 600 tokens.
  38. MAX_IMAGES = 4
  39. # Messages écrits par quelqu'un ; les autres types sont des messages système
  40. # (arrivée d'un membre, message épinglé, boost, fil créé…).
  41. USER_MESSAGE_TYPES = (discord.MessageType.default, discord.MessageType.reply)
  42. # En passant absent ou en « Ne pas déranger », le bot prévient son salon si on y a parlé depuis moins de :
  43. DEPARTURE_WINDOW = timedelta(minutes=3)
  44. def author_name(user: discord.User | discord.Member) -> str:
  45. """Nom d'un auteur pour Claude, avec son nom d'utilisateur (voir with_username)."""
  46. return with_username(user.display_name, user.name)
  47. def looks_like_image(attachment: discord.Attachment) -> bool:
  48. return (attachment.content_type or "").startswith("image/") or attachment.filename.lower().endswith(IMAGE_EXTENSIONS)
  49. def looks_like_text(attachment: discord.Attachment) -> bool:
  50. return attachment.filename.lower().endswith(TEXT_EXTENSIONS)
  51. def looks_like_pdf(attachment: discord.Attachment) -> bool:
  52. return attachment.content_type == "application/pdf" or attachment.filename.lower().endswith(PDF_EXTENSIONS)
  53. def channel_problem(client: discord.Client, channel_id: int) -> str | None:
  54. """Pourquoi le salon dédié (CHANNEL_ID) est inutilisable, ou None s'il convient."""
  55. channel = client.get_channel(channel_id)
  56. if channel is None:
  57. if client.get_guild(channel_id):
  58. return (f"CHANNEL_ID ({channel_id}) est l'identifiant du serveur, pas du salon : fais un clic droit "
  59. "sur le salon > Copier l'identifiant du salon.")
  60. return (f"Salon {channel_id} introuvable : vérifie CHANNEL_ID (clic droit sur le salon > Copier l'identifiant "
  61. "du salon, avec le mode développeur de Discord) et que le bot est bien invité sur ce serveur.")
  62. guild = getattr(channel, "guild", None)
  63. if guild is None or not isinstance(channel, discord.abc.Messageable):
  64. kind = ("une catégorie" if isinstance(channel, discord.CategoryChannel)
  65. else "un forum" if isinstance(channel, discord.ForumChannel)
  66. else "une conversation privée" if guild is None else "un salon où l'on ne peut pas écrire")
  67. return f"CHANNEL_ID ({channel_id}) désigne {kind} : donne l'identifiant d'un salon textuel."
  68. permissions = channel.permissions_for(guild.me)
  69. in_thread = isinstance(channel, discord.Thread)
  70. needed = (("view_channel", "Voir les salons"),
  71. ("send_messages_in_threads" if in_thread else "send_messages",
  72. "Envoyer des messages dans les fils" if in_thread else "Envoyer des messages"),
  73. ("read_message_history", "Voir les anciens messages"))
  74. if missing := [label for name, label in needed if not getattr(permissions, name)]:
  75. names = ", ".join(f"« {label} »" for label in missing)
  76. plural = "les permissions" if len(missing) > 1 else "la permission"
  77. return (f"Il manque au bot {plural} {names} dans #{channel} : ajoute-{'les' if len(missing) > 1 else 'la'} "
  78. "à son rôle ou dans les permissions du salon.")
  79. return None
  80. @contextlib.asynccontextmanager
  81. async def typing(channel: discord.abc.Messageable):
  82. """« En train d'écrire… » pendant le bloc, sans empêcher la réponse si Discord le refuse."""
  83. indicator = channel.typing()
  84. try:
  85. await indicator.__aenter__() # seul ce premier envoi peut échouer : les suivants sont protégés
  86. except discord.HTTPException as exc:
  87. logger.warning("Indicateur « en train d'écrire » impossible dans #%s : %s", channel, exc)
  88. indicator = None
  89. try:
  90. yield
  91. finally:
  92. if indicator is not None:
  93. await indicator.__aexit__(None, None, None)
  94. def text_file_prompt(name: str, content: str) -> str:
  95. """Contenu d'un fichier .txt tel qu'il est transmis à Claude."""
  96. return f"\n\n[Contenu du fichier joint « {name} » :]\n{content}\n[Fin du fichier « {name} »]"
  97. def text_file_marker(name: str) -> str:
  98. """Remplace un fichier texte dans la mémoire (son contenu n'est pas conservé)."""
  99. return f"[fichier texte joint « {name} » : tu l'as lu à ce moment-là, mais son contenu n'est plus conservé en mémoire]"
  100. def attachments_marker(attachments: list[ImageData]) -> str:
  101. """Remplace les images ou le PDF d'un message dans la mémoire (leur contenu n'est pas conservé)."""
  102. if attachments[0].is_pdf:
  103. return f"[PDF joint « {attachments[0].name} » : tu l'as lu à ce moment-là, mais son contenu n'est plus conservé en mémoire]"
  104. return images_marker(len(attachments))
  105. @dataclass
  106. class PendingMessage:
  107. """Message du salon dédié, prêt à être envoyé à Claude."""
  108. message: discord.Message
  109. line: dict # ligne conservée en mémoire (voir history.render_line)
  110. extra: str # ajouté pour Claude seulement : contenu du fichier texte joint
  111. images: list[ImageData] # images, ou un seul PDF
  112. @property
  113. def user_text(self) -> str:
  114. """Texte envoyé à Claude : les images ou le fichier eux-mêmes remplacent leur repère."""
  115. line = {key: value for key, value in self.line.items() if key != "attachments"}
  116. return render_line(line) + self.extra
  117. class HomeTree(app_commands.CommandTree):
  118. """Commandes slash acceptées seulement sur le serveur du bot (voir ChatBot.home_guild_id) : un
  119. administrateur d'un autre serveur où le bot a été invité ne peut ni lire ni modifier la mémoire."""
  120. async def interaction_check(self, interaction: discord.Interaction) -> bool:
  121. bot: ChatBot = self.client # type: ignore[assignment]
  122. if interaction.guild_id is not None and interaction.guild_id == bot.home_guild_id():
  123. return True
  124. logger.warning("/%s refusée pour %s : serveur %s, hors du serveur du bot",
  125. (interaction.data or {}).get("name", "?"), interaction.user, interaction.guild_id)
  126. if interaction.type is discord.InteractionType.application_command:
  127. await interaction.response.send_message("Ce bot ne fonctionne que sur son propre serveur.",
  128. ephemeral=True)
  129. return False
  130. async def on_error(self, interaction: discord.Interaction, error: app_commands.AppCommandError) -> None:
  131. logger.error("Erreur pendant /%s", (interaction.data or {}).get("name", "?"), exc_info=error)
  132. await reply_error(interaction)
  133. class ChatBot(commands.Bot):
  134. def __init__(self, settings: Settings):
  135. intents = discord.Intents.default()
  136. intents.message_content = True # nécessaire pour lire le texte des messages
  137. super().__init__(
  138. command_prefix=commands.when_mentioned, # aucune commande textuelle utilisée
  139. intents=intents,
  140. help_command=None,
  141. tree_cls=HomeTree,
  142. # Le bot ne peut jamais pinger @everyone, @here, des rôles ou des membres.
  143. allowed_mentions=discord.AllowedMentions.none(),
  144. )
  145. self.settings = settings
  146. self.members = MemberRegistry(settings.memory_dir / "registre.json") if settings.memory else None
  147. if self.members and self.members.broken:
  148. self.members = None # registre illisible : mémoire coupée comme avec MEMORY=off (voir MemberRegistry)
  149. self.memory = MemoryStore(settings.memory_dir, self.members, settings.memory_member_limit,
  150. settings.memory_server_limit, settings.timezone) if self.members else None
  151. self.claude = ClaudeClient(settings, self.memory)
  152. self.history = ConversationHistory(settings.history_file, settings.max_history_length)
  153. self._pending: dict[int, list[PendingMessage]] = {} # messages en attente de réponse, par salon
  154. self._announced = False
  155. self.config_error: str | None = None # salon dédié inutilisable : main.py sort en erreur
  156. self._memory_warning = memory_warning(settings) if self.memory else None
  157. self.presence =PresenceManager(self, self.claude, settings) if settings.presence else None
  158. # Absent ou en « Ne pas déranger » : réponses différées, par salon.
  159. self._waiters: dict[int, asyncio.Task] = {} # attente en cours
  160. self._mentions: dict[int, list[discord.Message]] = {} # mentions en attente (hors salon dédié)
  161. # Messages en attente, gardés sur le disque pour y répondre même après un redémarrage.
  162. self._waiting_file = settings.history_file.with_name("waiting_messages.json")
  163. self._waiting: set[tuple[int, int]] = set() # (salon, message)
  164. self._last_main_message: datetime | None = None # date du dernier message reçu dans le salon dédié
  165. # Empreinte des commandes slash envoyées à Discord (voir sync_commands).
  166. self._commands_file = settings.history_file.with_name("slash_commands.sha256")
  167. # ------------------------------------------------------------ cycle de vie
  168. async def setup_hook(self) -> None:
  169. # Exécuté une seule fois au démarrage (contrairement à on_ready).
  170. if problem := await self.claude.check_access():
  171. # Sinon le bot s'annoncerait « En ligne » puis échouerait sur chaque message.
  172. logger.critical("Erreur de configuration : %s", problem)
  173. self.config_error = problem
  174. await self.close() # connect() voit le bot fermé et rend la main à main.py
  175. return
  176. self.tree.add_command(reset_command)
  177. if self.presence:
  178. self.tree.add_command(skip_command)
  179. # Toujours présentes : avec MEMORY=off, elles indiquent que la mémoire est coupée.
  180. self.tree.add_command(memory_command)
  181. self.tree.add_command(server_memory_command)
  182. await self.sync_commands()
  183. if self.memory:
  184. # Lecture de toutes les fiches, avant la connexion : elle ne bloque aucun message.
  185. await asyncio.to_thread(self.memory.index)
  186. s = self.settings
  187. memory = "off" if not s.memory else f"on ({s.memory_dir})" if self.memory else "coupée (registre illisible)"
  188. logger.info("Modèle %s — réflexion : %s, effort : %s, recherche web : %s, mémoire des membres : %s",
  189. s.model, "on" if s.thinking else "off", s.effort or "par défaut",
  190. "on" if s.web_search else "off", memory)
  191. if not is_known(s.model):
  192. # Un nom mal écrit ne serait sinon découvert qu'au premier message (erreur 404).
  193. prices = ""
  194. if s.price_input_per_mtok is None or s.price_output_per_mtok is None:
  195. prices = (" S'il existe bien, renseigne PRICE_INPUT_PER_MTOK et PRICE_OUTPUT_PER_MTOK "
  196. "pour estimer les coûts.")
  197. logger.warning("Modèle %s inconnu du bot : vérifie CLAUDE_MODEL dans le .env.%s", s.model, prices)
  198. # Une réponse qui remplit MAX_TOKENS s'écrit à environ 80 tokens par seconde au mieux ;
  199. # les recherches web et les pages lues ajoutent leur propre attente.
  200. needed = s.max_tokens // 80 + (40 if s.web_search else 0)
  201. if s.api_timeout < needed:
  202. logger.warning("API_TIMEOUT (%g s) est court pour MAX_TOKENS=%s%s : une longue réponse serait "
  203. "abandonnée (« Je mets trop de temps à répondre »). Mets au moins %s dans le .env.",
  204. s.api_timeout, s.max_tokens, " avec la recherche web" if s.web_search else "", needed)
  205. if self._memory_warning:
  206. logger.warning("%s", self._memory_warning) # rappelé dans le message « En ligne »
  207. if self.presence:
  208. self.presence.start()
  209. async def sync_commands(self) -> None:
  210. """Envoie les commandes slash à Discord, seulement si elles ont changé depuis le dernier envoi
  211. (Discord limite ces envois : inutile de les refaire à chaque démarrage)."""
  212. payload = [command.to_dict(self.tree) for command in self.tree.get_commands()]
  213. signature = json.dumps([self.application_id, payload], sort_keys=True, ensure_ascii=False)
  214. digest = hashlib.sha256(signature.encode("utf-8")).hexdigest()
  215. try:
  216. if self._commands_file.read_text(encoding="utf-8").strip() == digest:
  217. logger.info("Commandes slash inchangées : pas de synchronisation.")
  218. return
  219. except OSError:
  220. pass # premier démarrage, ou fichier illisible : on synchronise
  221. try:
  222. synced = await self.tree.sync()
  223. except discord.HTTPException as exc: # le bot fonctionne quand même ; nouvel essai au prochain démarrage
  224. logger.error("Synchronisation des commandes slash impossible : %s", exc)
  225. return
  226. logger.info("%d commande(s) slash synchronisée(s).", len(synced))
  227. try:
  228. self._commands_file.write_text(digest, encoding="utf-8")
  229. except OSError as exc:
  230. logger.warning("Impossible d'écrire %s : %s", self._commands_file, exc)
  231. async def on_ready(self) -> None:
  232. logger.info("Connecté en tant que %s (version %s)", self.user, VERSION)
  233. if self.presence:
  234. await self.presence.apply() # une reconnexion complète efface le statut
  235. if not self._announced: # simple reconnexion : on ne reposte pas le message de démarrage
  236. await self.announce()
  237. async def on_guild_available(self, guild: discord.Guild) -> None:
  238. # Serveur du salon indisponible au démarrage (panne Discord), revenu depuis : le bot s'annonce enfin.
  239. if self.is_ready() and not self._announced and self.home_guild_id() == guild.id:
  240. await self.announce()
  241. async def announce(self) -> None:
  242. """Vérifie le salon dédié, puis y poste le message de démarrage. Un salon inutilisable arrête le bot."""
  243. if problem := channel_problem(self, self.settings.channel_id):
  244. if self.get_channel(self.settings.channel_id) is None and any(g.unavailable for g in self.guilds):
  245. # Le salon est peut-être sur ce serveur : Discord n'en envoie le contenu qu'à son retour.
  246. logger.warning("Salon %s introuvable pour l'instant : un serveur du bot est indisponible chez "
  247. "Discord. Le bot s'annoncera dès son retour.", self.settings.channel_id)
  248. return
  249. logger.critical("Erreur de configuration : %s", problem)
  250. self.config_error = problem
  251. await self.close()
  252. return
  253. self._announced = True
  254. self._replay_task = asyncio.create_task(self.replay_waiting()) # référence gardée : pas de ramasse-miettes
  255. channel = self.get_channel(self.settings.channel_id)
  256. if others := [guild for guild in self.guilds if guild.id != self.home_guild_id()]:
  257. logger.warning("Le bot est aussi sur %d autre(s) serveur(s), où il ne répond pas : %s. Retire-le de ces "
  258. "serveurs, et décoche Public Bot dans le portail Discord (voir le README).", len(others),
  259. ", ".join(f"{guild.name} ({guild.id})" for guild in others))
  260. me = channel.guild.me if getattr(channel, "guild", None) else self.user
  261. logger.info("%d emoji(s) du serveur utilisable(s) dans les réponses.",
  262. len(usable_emojis(getattr(channel, "guild", None))))
  263. started = discord.utils.utcnow()
  264. embed = discord.Embed(
  265. title="En ligne",
  266. description=f"**{me.display_name}** vient de démarrer et répond de nouveau aux messages.",
  267. color=ONLINE_COLOR,
  268. timestamp=started,
  269. )
  270. embed.set_thumbnail(url=me.display_avatar.url)
  271. embed.add_field(name="Version", value=f"`{VERSION}`")
  272. embed.add_field(name="Modèle", value=display_name(self.settings.model))
  273. embed.add_field(name="Démarrage", value=discord.utils.format_dt(started, "R"))
  274. if self._memory_warning:
  275. # Sur OpenShift, personne ne lit le journal de démarrage.
  276. embed.add_field(name="⚠️ Réglage à revoir", value=self._memory_warning, inline=False)
  277. try:
  278. await channel.send(embed=embed)
  279. except discord.HTTPException as exc:
  280. logger.error("Impossible d'envoyer le message de démarrage : %s", exc)
  281. async def close(self) -> None:
  282. if self.presence:
  283. self.presence.stop()
  284. for task in self._waiters.values():
  285. task.cancel() # les messages en attente restent dans waiting_messages.json
  286. await self.claude.close()
  287. await super().close()
  288. def home_guild_id(self) -> int | None:
  289. """Le serveur du salon dédié (CHANNEL_ID), le seul où le bot répond : la mémoire n'existe qu'en
  290. un exemplaire. None tant que le salon est introuvable (avant la connexion, CHANNEL_ID faux)."""
  291. guild = getattr(self.get_channel(self.settings.channel_id), "guild", None)
  292. return guild.id if guild else None
  293. async def on_guild_join(self, guild: discord.Guild) -> None:
  294. logger.warning("Bot ajouté au serveur %s (%s), où il ne répond pas : retire-le de ce serveur, et "
  295. "décoche Public Bot dans le portail Discord (voir le README).", guild.name, guild.id)
  296. # ------------------------------------------------------------- messages
  297. async def on_message(self, message: discord.Message) -> None:
  298. # Ignore ses propres messages et les webhooks : évite les boucles infinies.
  299. if message.author == self.user or message.webhook_id is not None:
  300. return
  301. # Ni autre serveur ni message privé : réponses payées par le propriétaire, mémoire du serveur.
  302. if message.guild is None or message.guild.id != self.home_guild_id():
  303. return
  304. if message.type not in USER_MESSAGE_TYPES:
  305. return # message système
  306. # Les autres bots ne sont écoutés que lorsqu'ils s'adressent au bot : mention,
  307. # ou réponse à l'un de ses messages. Deux bots peuvent ainsi discuter ensemble.
  308. if message.author.bot and self.user not in message.mentions and not await self.replies_to_me(message):
  309. return
  310. in_main_channel = message.channel.id == self.settings.channel_id
  311. # Mention directe uniquement (@everyone et @here ne comptent pas).
  312. mentioned = self.user is not None and self.user in message.mentions
  313. if (in_main_channel or mentioned) and self.members:
  314. await self.register_members(message)
  315. if in_main_channel:
  316. await self.handle_main_channel(message)
  317. elif mentioned:
  318. await self.handle_mention(message)
  319. async def concerned_members(self, message: discord.Message) -> list[discord.User | discord.Member]:
  320. """Membres concernés par un message, sans les bots : auteur, auteur du message cité, membres
  321. mentionnés (ordre des fiches jointes quand elles sont trop nombreuses)."""
  322. users = [message.author]
  323. if (cited := await self.fetch_cited(message)) is not None:
  324. users.append(cited.author)
  325. users += message.mentions
  326. unique = {user.id: user for user in users if not user.bot}
  327. return list(unique.values())
  328. async def member_notes(self, messages: list[discord.Message]) -> str:
  329. """Fiches des membres concernés par ces messages, à joindre pour Claude (vide sans mémoire)."""
  330. if not self.memory:
  331. return ""
  332. ids = [user.id for message in messages for user in await self.concerned_members(message)]
  333. return self.memory.notes_for(ids, author_ids=[message.author.id for message in messages])
  334. async def register_members(self, message: discord.Message) -> None:
  335. """Ajoute au registre les membres concernés par le message, ou met leurs noms à jour."""
  336. for user in await self.concerned_members(message):
  337. await see_user(self.members, user)
  338. async def on_raw_message_edit(self, payload: discord.RawMessageUpdateEvent) -> None:
  339. """Message modifié : la mémoire, ou le message s'il attend encore sa réponse, prend le nouveau texte."""
  340. message = payload.message
  341. # Aperçu d'un lien qui s'affiche, ou transfert (qui ne se modifie pas) : rien n'a changé.
  342. if message.edited_at is None or message.message_snapshots:
  343. return
  344. content = self.message_body(message)
  345. for pending in self._pending.get(payload.channel_id, []):
  346. if pending.message.id == message.id:
  347. pending.line["content"] = content
  348. if await self.history.edit(payload.channel_id, message.id, content):
  349. logger.info("Message modifié dans le salon %s : mémoire mise à jour.", payload.channel_id)
  350. async def on_raw_message_delete(self, payload: discord.RawMessageDeleteEvent) -> None:
  351. await self.forget_deleted(payload.channel_id, {payload.message_id})
  352. async def on_raw_bulk_message_delete(self, payload: discord.RawBulkMessageDeleteEvent) -> None:
  353. await self.forget_deleted(payload.channel_id, payload.message_ids)
  354. async def forget_deleted(self, channel_id: int, message_ids: set[int]) -> None:
  355. """Messages supprimés : ils sortent de la mémoire et n'attendent plus de réponse."""
  356. # Listes modifiées sur place : une réponse sur le point de partir les lit encore.
  357. if pending := self._pending.get(channel_id):
  358. pending[:] = [p for p in pending if p.message.id not in message_ids]
  359. if mentions := self._mentions.get(channel_id):
  360. mentions[:] = [m for m in mentions if m.id not in message_ids]
  361. keys = {(channel_id, message_id) for message_id in message_ids}
  362. if keys & self._waiting:
  363. self._waiting -= keys
  364. self._save_waiting()
  365. if await self.history.delete(channel_id, message_ids):
  366. logger.info("%s message(s) supprimé(s) dans le salon %s : mémoire mise à jour.", len(message_ids), channel_id)
  367. async def handle_main_channel(self, message: discord.Message) -> None:
  368. if self._last_main_message is None or message.created_at > self._last_main_message:
  369. self._last_main_message = message.created_at
  370. content = message.content.strip()
  371. # Un sticker ou un emoji seul reçoit un sticker ou un emoji du serveur. S'il n'y en a aucun
  372. # d'utilisable, Claude répond avec des mots ; accompagné de texte, le sticker lui est décrit.
  373. if (message.stickers and not content and not message.attachments) or CUSTOM_EMOJI_ONLY.match(content):
  374. if not self.available():
  375. return # absent : pas de réaction aux stickers ni aux emojis
  376. if await self.reply_to_sticker(message) or await self.reply_to_emoji(message):
  377. return
  378. forward, forward_images = await self.read_forward(message)
  379. if not (content or message.attachments or message.stickers or forward):
  380. return # sondage, transfert d'un message vide… : rien à lire
  381. attachments = await self.read_attachments(message)
  382. if attachments is False:
  383. return # pièce jointe refusée, l'utilisateur a été prévenu
  384. images, text_file = attachments
  385. # Les images du message cité ne sont utilisées que si le message n'en contient pas lui-même.
  386. reply, reply_images = await self.read_reply(message, want_images=not (images or forward_images))
  387. images = images or forward_images or reply_images
  388. line: dict = {"id": message.id, "date": self.timestamp(message), "author": author_name(message.author)}
  389. if forward:
  390. line["forward"] = forward
  391. else:
  392. if reply:
  393. line["reply_to"] = message.reference.message_id # citation retirée si ce message est supprimé
  394. line["reply"] = reply
  395. line["content"] = self.message_body(message)
  396. markers = [attachments_marker(images)] if images else []
  397. extra = ""
  398. if text_file:
  399. extra = text_file_prompt(*text_file)
  400. markers.append(text_file_marker(text_file[0]))
  401. if markers:
  402. line["attachments"] = markers
  403. # Un seul appel à la fois par salon : l'historique reste cohérent. Les messages arrivés
  404. # pendant une réponse attendent dans la file, puis partent ensemble dans un seul appel.
  405. self._pending.setdefault(message.channel.id, []).append(PendingMessage(message, line, extra, images))
  406. if not self.available() or message.channel.id in self._waiters:
  407. self.answer_later(message, self.answer_main_channel)
  408. return
  409. await self.answer_main_channel(message.channel)
  410. async def answer_main_channel(self, channel: discord.abc.Messageable, late: Status | None = None) -> None:
  411. """Répond en une fois aux messages en attente du salon dédié."""
  412. pending = self._pending.setdefault(channel.id, [])
  413. async with self.history.lock(channel.id):
  414. if not pending:
  415. return # déjà parti avec un message précédent
  416. batch = sorted(pending, key=lambda p: p.message.id)
  417. pending.clear()
  418. last = batch[-1].message
  419. if len(batch) > 1:
  420. logger.info("%s messages regroupés en une seule réponse dans #%s", len(batch), channel)
  421. # Le statut en cours est aussi gardé en mémoire, comme le reste du message.
  422. parts = [(p.user_text, p.images) for p in batch]
  423. lines = [p.line for p in batch]
  424. notes = [self.presence.late_note(late, several=len(batch) > 1)] if late else []
  425. if note := self.presence_note():
  426. notes.append(note)
  427. for note in reversed(notes):
  428. parts.insert(0, (note, []))
  429. lines.insert(0, {"content": note})
  430. try:
  431. async with typing(channel):
  432. try:
  433. notes = await self.member_notes([p.message for p in batch])
  434. answer = await self.claude.ask(self.history.get(channel.id), parts,
  435. emojis=emoji_names(last.guild), member_notes=notes)
  436. except ClaudeError as exc:
  437. await self.safe_reply(last, exc.user_message)
  438. return
  439. except Exception:
  440. logger.exception("Erreur inattendue pendant le traitement d'un message")
  441. await self.safe_reply(last, "Désolé, une erreur inattendue est survenue.")
  442. return
  443. finally:
  444. self.forget_waiting(*(p.message for p in batch))
  445. await self.history.add_exchange(channel.id, lines, short_emojis(answer.text), answer.web_used)
  446. await self.send_answer(last, answer.text)
  447. async def handle_mention(self, message: discord.Message) -> None:
  448. if not self.available() or message.channel.id in self._waiters:
  449. self._mentions.setdefault(message.channel.id, []).append(message)
  450. self.answer_later(message, self.answer_mentions)
  451. return
  452. await self.answer_mention(message)
  453. async def answer_mentions(self, channel: discord.abc.Messageable, late: Status | None = None) -> None:
  454. """Répond, une par une, aux mentions reçues pendant une absence (avec « Répondre »)."""
  455. for message in sorted(self._mentions.pop(channel.id, []), key=lambda m: m.id):
  456. try:
  457. await self.answer_mention(message, late)
  458. finally:
  459. self.forget_waiting(message)
  460. async def answer_mention(self, message: discord.Message, late: Status | None = None) -> None:
  461. """Hors du salon dédié : répond à une mention en lisant les messages récents."""
  462. lines: list[str] = []
  463. if self.settings.context_message_limit > 0:
  464. try:
  465. async for msg in message.channel.history(limit=self.settings.context_message_limit, before=message):
  466. content = short_emojis(msg.clean_content.strip())
  467. if msg.attachments:
  468. content = (content + " [pièce jointe]").strip()
  469. if msg.stickers:
  470. content = (content + " [sticker]").strip()
  471. if content:
  472. lines.append(f"{author_name(msg.author)} : {content}")
  473. except discord.Forbidden:
  474. logger.warning("Pas la permission de lire l'historique de #%s.", message.channel)
  475. lines.reverse()
  476. # Seuls les MAX_IMAGES premières images (à défaut, le premier PDF) et le premier fichier texte
  477. # de la mention sont lus (les autres pièces jointes sont ignorées). Les images du message cité
  478. # ne servent que s'il n'y a ni image ni PDF.
  479. image_files = [a for a in message.attachments if looks_like_image(a)][:MAX_IMAGES]
  480. pdfs = [a for a in message.attachments if looks_like_pdf(a)] if self.settings.pdf_max_pages else []
  481. try:
  482. if image_files:
  483. images = await self.download_images(image_files)
  484. else:
  485. images = [await self.download_pdf(pdfs[0])] if pdfs else []
  486. except (ImageError, PdfError) as exc:
  487. await self.safe_reply(message, exc.user_message)
  488. return
  489. reply, reply_images = await self.read_reply(message, want_images=not images)
  490. images = images or reply_images
  491. bot_name = f"@{message.guild.me.display_name}" if message.guild else f"@{self.user.name}"
  492. text = short_emojis(message.clean_content.replace(bot_name, "").strip()) or "(simple mention, sans texte)"
  493. channel_name = f"#{message.channel.name}" if hasattr(message.channel, "name") else "un message privé"
  494. parts = []
  495. if late:
  496. parts.append(self.presence.late_note(late, several=False))
  497. if note := self.presence_note():
  498. parts.append(note)
  499. if lines:
  500. parts.append(f"Contexte : derniers messages dans {channel_name}\n" + "\n".join(lines))
  501. reply_part = f" ({reply})" if reply else ""
  502. parts.append(f"{self.timestamp(message)}, {author_name(message.author)} te mentionne{reply_part} et écrit : {text}")
  503. prompt = "\n\n".join(parts)
  504. text_files = [a for a in message.attachments if looks_like_text(a)]
  505. if text_files:
  506. try:
  507. prompt += text_file_prompt(*await self.download_text_file(text_files[0]))
  508. except TextFileError as exc:
  509. await self.safe_reply(message, exc.user_message)
  510. return
  511. async with typing(message.channel):
  512. try:
  513. answer = await self.claude.ask([], [(prompt, images)], emojis=emoji_names(message.guild),
  514. cache_history=False, member_notes=await self.member_notes([message]))
  515. except ClaudeError as exc:
  516. await self.safe_reply(message, exc.user_message)
  517. return
  518. except Exception:
  519. logger.exception("Erreur inattendue pendant le traitement d'une mention")
  520. await self.safe_reply(message, "Désolé, une erreur inattendue est survenue.")
  521. return
  522. # En retard, la réponse cite la mention : on sait à quoi elle répond.
  523. await self.send_answer(message, answer.text, reply=late is not None)
  524. # ------------------------------------------------------ réponses différées
  525. def available(self) -> bool:
  526. return self.presence is None or self.presence.available
  527. def answer_later(self, message: discord.Message, answer) -> None:
  528. """Met le message de côté : answer(salon, late=statut) y répondra quand le bot le pourra."""
  529. self.remember_waiting(message)
  530. channel = message.channel
  531. if channel.id in self._waiters:
  532. return # une attente est déjà en cours dans ce salon : le message en profitera
  533. status = self.presence.status
  534. logger.info("Réponse différée dans #%s : %s.", channel, status.unavailability())
  535. self._waiters[channel.id] = asyncio.create_task(self._answer_when_possible(channel, answer, status))
  536. async def _answer_when_possible(self, channel: discord.abc.Messageable, answer, status: Status) -> None:
  537. try:
  538. await self.presence.wait_turn()
  539. finally:
  540. self._waiters.pop(channel.id, None)
  541. try:
  542. await answer(channel, late=status)
  543. except Exception:
  544. logger.exception("Erreur inattendue pendant une réponse différée")
  545. async def on_status_change(self, before: Status, after: Status) -> None:
  546. """Passe absent ou en « Ne pas déranger » : prévient le salon dédié si une conversation y est en cours."""
  547. if not before.available or after.available or self._last_main_message is None:
  548. return
  549. if discord.utils.utcnow() - self._last_main_message > DEPARTURE_WINDOW:
  550. return
  551. channel = self.get_channel(self.settings.channel_id)
  552. if channel is None:
  553. return
  554. async with self.history.lock(channel.id):
  555. # Attend la fin d'une réponse en cours ; le statut a pu changer encore entre-temps.
  556. if self.presence.status is not after:
  557. return
  558. parts = [(note, []) for note in (self.presence_note(), self.presence.departure_note()) if note]
  559. try:
  560. async with typing(channel):
  561. answer = await self.claude.ask(self.history.get(channel.id), parts,
  562. emojis=emoji_names(channel.guild))
  563. except ClaudeError as exc:
  564. logger.warning("Message d'absence non envoyé : %s", exc.user_message)
  565. return
  566. lines = [{"content": text} for text, _ in parts]
  567. await self.history.add_exchange(channel.id, lines, short_emojis(answer.text), answer.web_used)
  568. logger.info("Conversation en cours dans #%s : le salon est prévenu de l'absence.", channel)
  569. for chunk in split_message(discord_emojis(short_emojis(answer.text), channel.guild)):
  570. try:
  571. await channel.send(chunk)
  572. except discord.HTTPException as exc:
  573. logger.error("Envoi du message d'absence impossible : %s", exc)
  574. return
  575. def remember_waiting(self, message: discord.Message) -> None:
  576. self._waiting.add((message.channel.id, message.id))
  577. self._save_waiting()
  578. def forget_waiting(self, *messages: discord.Message) -> None:
  579. keys = {(m.channel.id, m.id) for m in messages}
  580. if keys & self._waiting:
  581. self._waiting -= keys
  582. self._save_waiting()
  583. def _save_waiting(self) -> None:
  584. try:
  585. self._waiting_file.write_text(json.dumps(sorted(self._waiting)), encoding="utf-8")
  586. except OSError as exc:
  587. logger.warning("Impossible d'écrire %s : %s", self._waiting_file, exc)
  588. async def replay_waiting(self) -> None:
  589. """Au démarrage : reprend les messages restés sans réponse avant le redémarrage."""
  590. try:
  591. saved = json.loads(self._waiting_file.read_text(encoding="utf-8"))
  592. except FileNotFoundError:
  593. return
  594. except (OSError, ValueError) as exc:
  595. logger.warning("%s illisible, ignoré : %s", self._waiting_file, exc)
  596. return
  597. messages = []
  598. for channel_id, message_id in saved:
  599. try:
  600. channel = self.get_channel(channel_id) or await self.fetch_channel(channel_id)
  601. messages.append(await channel.fetch_message(message_id))
  602. except discord.HTTPException:
  603. pass # message supprimé, salon inaccessible…
  604. self._waiting.clear()
  605. self._save_waiting()
  606. if messages:
  607. logger.info("%d message(s) resté(s) sans réponse avant le redémarrage : reprise.", len(messages))
  608. # En parallèle, comme à leur arrivée : ceux du salon dédié sont regroupés.
  609. await asyncio.gather(*(self.on_message(m) for m in sorted(messages, key=lambda m: m.id)),
  610. return_exceptions=True)
  611. # ------------------------------------------------------------- réactions
  612. async def reply_to_sticker(self, message: discord.Message) -> bool:
  613. """Répond à un sticker par un sticker aléatoire du serveur (False si aucun n'est utilisable)."""
  614. if not message.stickers or message.guild is None:
  615. return False
  616. stickers = [s for s in message.guild.stickers if s.available]
  617. random.shuffle(stickers)
  618. for sticker in stickers:
  619. try:
  620. await message.channel.send(stickers=[sticker])
  621. logger.info("Sticker envoyé : %s", sticker.name)
  622. return True
  623. except discord.Forbidden as exc: # pas le droit d'envoyer de sticker : inutile d'insister
  624. logger.warning("Envoi de sticker interdit : %s", exc)
  625. break
  626. except discord.HTTPException as exc:
  627. logger.warning("Sticker %s inutilisable : %s", sticker.name, exc)
  628. return False
  629. async def reply_to_emoji(self, message: discord.Message) -> bool:
  630. """Répond à un message composé d'un seul emoji personnalisé par un emoji aléatoire du serveur
  631. (False si le serveur n'en a aucun)."""
  632. if not CUSTOM_EMOJI_ONLY.match(message.content.strip()):
  633. return False
  634. emojis = usable_emojis(message.guild)
  635. if not emojis:
  636. return False
  637. try:
  638. await message.channel.send(str(random.choice(emojis)))
  639. except discord.HTTPException as exc:
  640. logger.warning("Impossible d'envoyer l'emoji : %s", exc)
  641. return True
  642. # ------------------------------------------------------- pièces jointes
  643. async def read_attachments(
  644. self, message: discord.Message
  645. ) -> tuple[list[ImageData], tuple[str, str] | None] | bool:
  646. """Vérifie les pièces jointes, puis télécharge les images (ou le PDF) et le fichier texte.
  647. Renvoie (images ou PDF, éventuellement aucun ; (nom, contenu) du fichier texte ou None),
  648. ou False si l'envoi est refusé (l'utilisateur est alors prévenu).
  649. """
  650. if not message.attachments:
  651. return [], None
  652. images = [a for a in message.attachments if looks_like_image(a)]
  653. pdfs = [a for a in message.attachments if looks_like_pdf(a)] if self.settings.pdf_max_pages else []
  654. texts = [a for a in message.attachments if looks_like_text(a)]
  655. others = [a.filename for a in message.attachments if a not in images + pdfs + texts]
  656. if others:
  657. kinds = "des images, des PDF" if self.settings.pdf_max_pages else "des images"
  658. await self.safe_reply(message, f"Je ne peux lire que {kinds} et des fichiers texte (.txt, .md, .csv, code…). "
  659. f"Fichier(s) non pris en charge : {', '.join(others)}.")
  660. return False
  661. if len(images) > MAX_IMAGES:
  662. await self.safe_reply(message, f"{MAX_IMAGES} images par message au maximum, s'il te plaît.")
  663. return False
  664. if pdfs and (images or len(pdfs) > 1):
  665. await self.safe_reply(message, "Un seul PDF par message, sans image, s'il te plaît.")
  666. return False
  667. if len(texts) > 1:
  668. await self.safe_reply(message, "Un seul fichier texte par message, s'il te plaît.")
  669. return False
  670. try:
  671. if images:
  672. files = await self.download_images(images)
  673. else:
  674. files = [await self.download_pdf(pdfs[0])] if pdfs else []
  675. text_file = await self.download_text_file(texts[0]) if texts else None
  676. except (ImageError, PdfError, TextFileError) as exc:
  677. await self.safe_reply(message, exc.user_message)
  678. return False
  679. return files, text_file
  680. async def download_text_file(self, attachment: discord.Attachment) -> tuple[str, str]:
  681. """Télécharge un fichier texte et renvoie (nom, contenu) (lève TextFileError en cas de problème)."""
  682. if attachment.size > TEXT_FILE_MAX_BYTES:
  683. raise TextFileError(f"Ce fichier texte est trop long (maximum {TEXT_FILE_MAX_BYTES // 1000} Ko).")
  684. try:
  685. data = await attachment.read()
  686. except discord.HTTPException as exc:
  687. logger.error("Téléchargement du fichier texte impossible : %s", exc)
  688. raise TextFileError("Je n'ai pas réussi à télécharger ton fichier, réessaie.")
  689. return attachment.filename, decode_text_file(data)
  690. async def download_pdf(self, attachment: discord.Attachment) -> ImageData:
  691. """Télécharge et vérifie un PDF (lève PdfError en cas de problème)."""
  692. if attachment.size > PDF_MAX_BYTES:
  693. raise PdfError(f"Ce PDF est trop lourd (maximum {PDF_MAX_BYTES // 1_000_000} Mo).")
  694. try:
  695. data = await attachment.read()
  696. except discord.HTTPException as exc:
  697. logger.error("Téléchargement du PDF impossible : %s", exc)
  698. raise PdfError("Je n'ai pas réussi à télécharger ton PDF, réessaie.")
  699. # Lecture du PDF dans un thread : ne bloque pas le bot.
  700. return await asyncio.to_thread(prepare_pdf, attachment.filename, data, self.settings.pdf_max_pages)
  701. async def download_image(self, attachment: discord.Attachment) -> ImageData:
  702. """Télécharge et prépare une image (lève ImageError en cas de problème)."""
  703. if attachment.size > self.settings.max_image_size:
  704. max_mb = self.settings.max_image_size / 1_000_000
  705. raise ImageError(f"Cette image est trop lourde (maximum {max_mb:.2f} Mo).")
  706. try:
  707. data = await attachment.read()
  708. except discord.HTTPException as exc:
  709. logger.error("Téléchargement de l'image impossible : %s", exc)
  710. raise ImageError("Je n'ai pas réussi à télécharger ton image, réessaie.")
  711. # Réduit / convertit l'image si besoin (dans un thread : ne bloque pas le bot).
  712. return await asyncio.to_thread(prepare_image, data)
  713. async def download_images(self, attachments: list[discord.Attachment]) -> list[ImageData]:
  714. """Télécharge et prépare plusieurs images en parallèle (lève ImageError si l'une pose problème).
  715. Si plusieurs échouent, l'erreur nomme la première dans l'ordre du message, pas la plus rapide.
  716. """
  717. results = await asyncio.gather(*(self.download_image(a) for a in attachments), return_exceptions=True)
  718. for attachment, result in zip(attachments, results):
  719. if isinstance(result, ImageError) and len(attachments) > 1:
  720. # précise laquelle, sinon « cette image » est ambigu
  721. raise ImageError(f"« {attachment.filename} » : {result.user_message}")
  722. if isinstance(result, BaseException):
  723. raise result
  724. return list(results)
  725. # ------------------------------------------- message cité ou transféré
  726. async def fetch_cited(self, message: discord.Message) -> discord.Message | None:
  727. """Renvoie le message auquel ce message répond (bouton « Répondre » de Discord),
  728. ou None s'il ne répond à rien ou si le message cité est inaccessible."""
  729. ref = message.reference
  730. if ref is None or ref.message_id is None or ref.type != discord.MessageReferenceType.reply:
  731. return None
  732. cited = ref.resolved
  733. if cited is None: # Discord ne l'a pas fourni (vieux message) : on le télécharge
  734. try:
  735. cited = await message.channel.fetch_message(ref.message_id)
  736. except discord.HTTPException as exc:
  737. logger.info("Message cité inaccessible : %s", exc)
  738. return None
  739. ref.resolved = cited # évite de le télécharger une seconde fois
  740. return cited if isinstance(cited, discord.Message) else None # None : message cité supprimé
  741. async def replies_to_me(self, message: discord.Message) -> bool:
  742. cited = await self.fetch_cited(message)
  743. return cited is not None and cited.author == self.user
  744. async def read_reply(self, message: discord.Message, want_images: bool) -> tuple[str | None, list[ImageData]]:
  745. """Lit le message auquel l'utilisateur répond.
  746. Renvoie sa description pour Claude, ainsi que ses images si want_images est vrai,
  747. ou (None, []) si le message ne répond à rien ou si le message cité est inaccessible.
  748. """
  749. cited = await self.fetch_cited(message)
  750. if cited is None:
  751. return None, []
  752. images = await self.quoted_images(cited.attachments, "cité") if want_images else []
  753. description = self.describe_quoted(cited.clean_content, images, cited.attachments, cited.stickers)
  754. who = "à ton message" if cited.author == self.user else f"au message de {author_name(cited.author)}"
  755. return f"en réponse {who} du {self.timestamp(cited)} : {description or '(message vide)'}", images
  756. async def read_forward(self, message: discord.Message) -> tuple[str | None, list[ImageData]]:
  757. """Lit le message transféré (bouton « Transférer » de Discord).
  758. Renvoie sa description pour Claude et ses images, ou (None, []) si le message
  759. n'est pas un transfert ou si le message transféré ne contient rien de lisible.
  760. """
  761. if not message.message_snapshots:
  762. return None, []
  763. snapshot = message.message_snapshots[0]
  764. images = await self.quoted_images(snapshot.attachments, "transféré")
  765. # Contrairement à un message normal, le contenu transféré garde ses mentions brutes (<@123>).
  766. content = self.clean_mentions(snapshot.content)
  767. description = self.describe_quoted(content, images, snapshot.attachments, snapshot.stickers)
  768. if not description:
  769. return None, []
  770. return f"du {self.timestamp(snapshot)} : {description}", images
  771. async def quoted_images(self, attachments: list[discord.Attachment], kind: str) -> list[ImageData]:
  772. """Télécharge les MAX_IMAGES premières images d'un message cité ou transféré (les illisibles sont ignorées)."""
  773. images = [a for a in attachments if looks_like_image(a)][:MAX_IMAGES]
  774. results = await asyncio.gather(*(self.download_image(a) for a in images), return_exceptions=True)
  775. for result in results:
  776. if isinstance(result, ImageError):
  777. logger.warning("Image du message %s ignorée : %s", kind, result.user_message)
  778. elif isinstance(result, BaseException):
  779. raise result
  780. return [r for r in results if isinstance(r, ImageData)]
  781. @staticmethod
  782. def describe_quoted(content: str, images: list[ImageData], attachments: list, stickers: list) -> str:
  783. """Description d'un message cité ou transféré (vide s'il n'y a rien de lisible)."""
  784. content = short_emojis(content.strip())
  785. if len(content) > QUOTE_MAX_LENGTH:
  786. content = content[:QUOTE_MAX_LENGTH].rstrip() + "…"
  787. parts = [f"« {content} »"] if content else []
  788. if len(images) > 1:
  789. parts.append(f"[ses {len(images)} images sont jointes à ce message]")
  790. elif images:
  791. parts.append("[son image est jointe à ce message]")
  792. elif attachments:
  793. parts.append("[pièce jointe]")
  794. if stickers:
  795. parts.append("[sticker]")
  796. return " ".join(parts)
  797. def clean_mentions(self, text: str) -> str:
  798. """Remplace les mentions brutes (<@123>) par des pseudos, comme le fait clean_content."""
  799. def name(match: re.Match) -> str:
  800. user = self.get_user(int(match.group(1)))
  801. return f"@{user.display_name}" if user else "@quelqu'un"
  802. return USER_MENTION.sub(name, text)
  803. # ------------------------------------------------------------- envoi
  804. def presence_note(self) -> str | None:
  805. return self.presence.prompt_note() if self.presence else None
  806. @staticmethod
  807. def message_body(message: discord.Message) -> str:
  808. """Texte d'un message du salon dédié, tel qu'il est conservé en mémoire (sans ce qui le précède)."""
  809. text = short_emojis(message.clean_content.strip())
  810. if message.stickers:
  811. text = f"{text} [sticker « {message.stickers[0].name} »]".strip()
  812. return text or "(message sans texte)"
  813. def timestamp(self, message: discord.Message | discord.MessageSnapshot) -> str:
  814. return message.created_at.astimezone(self.settings.timezone).strftime(DATE_FORMAT)
  815. async def send_answer(self, message: discord.Message, answer: str, reply: bool = False) -> None:
  816. # Comme un humain : la réponse est postée à la suite dans le salon, sans « Répondre »
  817. # (sauf reply=True : le premier morceau répond alors au message).
  818. # Les emojis passent par leur nom : un code écrit avec un mauvais identifiant est ainsi corrigé.
  819. answer = discord_emojis(short_emojis(answer), message.guild)
  820. for i, chunk in enumerate(split_message(answer)):
  821. # fail_if_not_exists=False : si le message a été supprimé entre-temps, envoi normal.
  822. reference = message.to_reference(fail_if_not_exists=False) if reply and i == 0 else None
  823. try:
  824. await message.channel.send(chunk, reference=reference, mention_author=False)
  825. except discord.HTTPException as exc:
  826. logger.error("Envoi de la réponse impossible : %s", exc)
  827. return
  828. async def safe_reply(self, message: discord.Message, text: str) -> None:
  829. try:
  830. await message.reply(text, mention_author=False)
  831. except discord.HTTPException:
  832. try:
  833. await message.channel.send(text)
  834. except discord.HTTPException as exc:
  835. logger.error("Impossible d'envoyer un message : %s", exc)
  836. # ------------------------------------------------------------- commandes slash
  837. async def allowed(interaction: discord.Interaction) -> bool:
  838. """Commande réservée aux administrateurs : prévient les autres et renvoie False."""
  839. # Vérification côté bot, au cas où un admin aurait ouvert la commande à tous dans les paramètres du serveur.
  840. if interaction.permissions.administrator:
  841. return True
  842. logger.info("Tentative de /%s refusée pour %s dans le salon %s",
  843. interaction.command.name if interaction.command else "?", interaction.user, interaction.channel_id)
  844. await interaction.response.send_message(
  845. "Seuls les administrateurs du serveur peuvent utiliser cette commande.",
  846. ephemeral=True,
  847. )
  848. return False
  849. @app_commands.command(name="reset", description="Réinitialise la mémoire du bot dans ce salon")
  850. @app_commands.guild_only()
  851. # Masque la commande aux membres qui n'ont pas la permission Administrateur.
  852. @app_commands.default_permissions(administrator=True)
  853. async def reset_command(interaction: discord.Interaction) -> None:
  854. if not await allowed(interaction):
  855. return
  856. bot: ChatBot = interaction.client # type: ignore[assignment]
  857. # Le reset attend la fin d'une éventuelle réponse en cours, ce qui peut dépasser
  858. # les 3 secondes accordées par Discord pour répondre à une commande.
  859. await interaction.response.defer()
  860. await bot.history.reset(interaction.channel_id)
  861. logger.info("Historique réinitialisé dans le salon %s par %s", interaction.channel_id, interaction.user)
  862. await interaction.followup.send("L'historique de conversation a été réinitialisé.")
  863. @app_commands.command(name="skip", description="Passe tout de suite au statut Discord suivant du bot")
  864. @app_commands.guild_only()
  865. @app_commands.default_permissions(administrator=True) # comme /reset
  866. async def skip_command(interaction: discord.Interaction) -> None:
  867. if not await allowed(interaction):
  868. return
  869. bot: ChatBot = interaction.client # type: ignore[assignment]
  870. # Une pensée ou une raison d'absence est écrite par Claude : plus de 3 secondes possibles.
  871. await interaction.response.defer(ephemeral=True)
  872. try:
  873. status = await bot.presence.skip()
  874. except Exception:
  875. logger.exception("Erreur inattendue pendant /skip")
  876. await interaction.followup.send("Le statut n'a pas pu être changé, regarde les logs.", ephemeral=True)
  877. return
  878. if status is None:
  879. await interaction.followup.send("C'est la nuit : le bot dort, il n'y a pas de statut à passer.", ephemeral=True)
  880. return
  881. logger.info("Statut passé par %s", interaction.user)
  882. remaining = bot.presence.remaining()
  883. duration = f", pendant environ {remaining}" if remaining else ""
  884. await interaction.followup.send(f"Nouveau statut : {status.label()}{duration}.", ephemeral=True)
  885. MEMORY_OFF = "La mémoire des membres est désactivée sur ce bot (MEMORY=off)."
  886. MEMORY_BROKEN = ("La mémoire des membres est coupée pour l'instant, à cause d'une erreur du bot. "
  887. "Préviens l'administrateur du bot.")
  888. def memory_off(bot: ChatBot) -> str:
  889. """Pourquoi /memoire est indisponible : MEMORY=off, ou registre des membres illisible."""
  890. return MEMORY_BROKEN if bot.settings.memory else MEMORY_OFF
  891. def bot_name(interaction: discord.Interaction) -> str:
  892. return interaction.guild.me.display_name if interaction.guild else interaction.client.user.name
  893. @app_commands.command(name="memoire", description="Voir, modifier ou effacer ce que le bot a retenu sur toi")
  894. @app_commands.describe(membre="Réservé aux administrateurs : la fiche d'un autre membre, ou son identifiant s'il est parti")
  895. @app_commands.guild_only()
  896. # discord.User plutôt que discord.Member : un membre parti du serveur reste accepté (Discord le résout par
  897. # son identifiant), pour que sa fiche puisse encore être effacée.
  898. async def memory_command(interaction: discord.Interaction, membre: discord.User | None = None) -> None:
  899. bot: ChatBot = interaction.client # type: ignore[assignment]
  900. if bot.memory is None:
  901. await interaction.response.send_message(memory_off(bot), ephemeral=True)
  902. return
  903. target = membre or interaction.user
  904. if target.bot:
  905. await interaction.response.send_message("Les bots n'ont pas de fiche.", ephemeral=True)
  906. return
  907. if target.id != interaction.user.id and not interaction.permissions.administrator:
  908. logger.info("/memoire sur %s refusé pour %s", target, interaction.user)
  909. await interaction.response.send_message(
  910. "Seuls les administrateurs peuvent voir la fiche d'un autre membre.", ephemeral=True)
  911. return
  912. await see_user(bot.members, target) # un membre qui n'a encore jamais écrit peut déjà activer la mémoire
  913. if target.id != interaction.user.id:
  914. # Lecture tracée, sans le contenu : un administrateur ne peut pas lire les fiches sans laisser de trace.
  915. logger.info("/memoire : fiche de %s ouverte par %s", target, interaction.user)
  916. card = MemoryCard(bot.memory, member_target(bot.memory, target, interaction.user.id),
  917. interaction.user.id, bot_name(interaction))
  918. await card.send(interaction)
  919. @app_commands.command(name="memoire-serveur", description="Voir ou modifier le fichier général du bot sur le serveur")
  920. @app_commands.guild_only()
  921. @app_commands.default_permissions(administrator=True) # comme /reset
  922. async def server_memory_command(interaction: discord.Interaction) -> None:
  923. if not await allowed(interaction):
  924. return
  925. bot: ChatBot = interaction.client # type: ignore[assignment]
  926. if bot.memory is None:
  927. await interaction.response.send_message(memory_off(bot), ephemeral=True)
  928. return
  929. await MemoryCard(bot.memory, server_target(), interaction.user.id, bot_name(interaction)).send(interaction)