Compare commits
20 Commits
main
...
91129fc073
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
91129fc073 | ||
|
|
69a965824c | ||
|
68d881d830
|
|||
|
6c97838158
|
|||
|
db8cdb0670
|
|||
|
ccba64ed35
|
|||
|
|
b4182cb71f | ||
|
|
173bb371eb | ||
|
|
3712c4ddbd | ||
|
|
dccbaa332a | ||
|
|
75b0fb91b3 | ||
|
|
dc9106b8fd | ||
|
|
df7bd7415c | ||
|
|
835b415bc6 | ||
|
|
1be9fd8a1c | ||
|
|
361f22e014 | ||
|
|
76d0627aa9 | ||
|
|
f7bd4393f2 | ||
|
|
caf04ec659 | ||
|
|
a2c0fece12 |
7
.env
Executable file
7
.env
Executable file
@@ -0,0 +1,7 @@
|
|||||||
|
VERBOSE=True
|
||||||
|
SYSTEMD_LOGGING=True
|
||||||
|
matrix_home_server="https://matrix.agent.dev-durable.tchap.gouv.fr"
|
||||||
|
matrix_bot_username="@chat.beta-developpement-durable.gouv.fr:agent.dev-durable.tchap.gouv.fr"
|
||||||
|
matrix_bot_password="C.5;oTYw+Mksn<,7jtgx/TbWHY2Ugf"
|
||||||
|
salt=b'I\x87>\xe5\x91\xbdw\x99\xb3\xea7\xc2\xa6\xbf\x8f#'
|
||||||
|
https_proxy=http://pfrie-std.proxy.e2.rie.gouv.fr:8080/
|
||||||
@@ -1,9 +0,0 @@
|
|||||||
## Matrix env variables
|
|
||||||
|
|
||||||
VERBOSE=True
|
|
||||||
SYSTEMD_LOGGING=False
|
|
||||||
matrix_home_server="https://matrix.agent.ministere_example.tchap.gouv.fr"
|
|
||||||
matrix_bot_username="jean.quidam@ministere_example.gouv.fr"
|
|
||||||
matrix_bot_password="test"
|
|
||||||
join_on_invite=True
|
|
||||||
#https_proxy=http://adresse.du.proxy:port/
|
|
||||||
@@ -20,7 +20,7 @@ pip install \
|
|||||||
tchap-bot --index-url https://code.peren.fr/api/v4/projects/83/packages/pypi/simple
|
tchap-bot --index-url https://code.peren.fr/api/v4/projects/83/packages/pypi/simple
|
||||||
|
|
||||||
# Renseignez les informations de connexion :
|
# Renseignez les informations de connexion :
|
||||||
$EDITOR .env
|
editor .env
|
||||||
python -c 'import secrets; print("salt=", secrets.token_bytes(16), sep="")' >> .env
|
python -c 'import secrets; print("salt=", secrets.token_bytes(16), sep="")' >> .env
|
||||||
|
|
||||||
# Lancer
|
# Lancer
|
||||||
|
|||||||
0
corpus/fra_wikipedia_2021_10K-sentences.txt
Normal file → Executable file
0
corpus/fra_wikipedia_2021_10K-sentences.txt
Normal file → Executable file
130
tchap-beta.py
130
tchap-beta.py
@@ -1,75 +1,55 @@
|
|||||||
import asyncio
|
import asyncio
|
||||||
|
|
||||||
from nio import MatrixRoom, Event
|
from nio import MatrixRoom, Event
|
||||||
|
from nio.crypto import ENCRYPTION_ENABLED
|
||||||
from matrix_bot.bot import MatrixBot
|
|
||||||
from matrix_bot.client import MatrixClient
|
from matrix_bot.bot import MatrixBot
|
||||||
from matrix_bot.eventparser import MessageEventParser, ignore_when_not_concerned, EventNotConcerned
|
from matrix_bot.client import MatrixClient
|
||||||
|
from matrix_bot.eventparser import MessageEventParser, ignore_when_not_concerned, EventNotConcerned
|
||||||
from config import env_config
|
|
||||||
from callbacks import properly_fail
|
from config import env_config
|
||||||
from markov import parle
|
from callbacks import properly_fail
|
||||||
|
from markov import parle
|
||||||
|
|
||||||
async def non_lus(room_id):
|
|
||||||
room = tchap_bot.matrix_client.rooms[room_id]
|
# le décorateur @properly_fail va permettre à la commande de laisser un message d'erreur si la commande plante et
|
||||||
if room.unread_notifications:
|
# d'envoyer le message que le bot n'est plus en train d'écrire
|
||||||
response = await tchap_bot.matrix_client.room_messages(room_id=room_id, limit=room.unread_notifications, direction="back", start="")
|
# la fonction va être appelée dans tous les cas, le décorateur @ignore_when_not_concerned
|
||||||
for message in response.chunk:
|
# permet de laisser event_parser gérer le cas où la commande n'est pas concernée
|
||||||
await repond(room, message, tchap_bot.matrix_client)
|
@properly_fail("Oups, j'ai buggué 😿")
|
||||||
|
@ignore_when_not_concerned
|
||||||
|
async def repond(room: MatrixRoom, message: Event, matrix_client: MatrixClient):
|
||||||
# le décorateur @properly_fail va permettre à la commande de laisser un message d'erreur si la commande plante et
|
# on initialise un event_parser pour décider à quel message cette commande va répondre
|
||||||
# d'envoyer le message que le bot n'est plus en train d'écrire
|
event_parser = MessageEventParser(room=room, event=message, matrix_client=matrix_client)
|
||||||
# la fonction va être appelée dans tous les cas, le décorateur @ignore_when_not_concerned
|
# il ne va pas répondre à ses propres messages
|
||||||
# permet de laisser event_parser gérer le cas où la commande n'est pas concernée
|
event_parser.do_not_accept_own_message()
|
||||||
@properly_fail("Oups, j'ai buggué 😿")
|
|
||||||
@ignore_when_not_concerned
|
# ne répond qu'en message direct ou dans un salon s'il est interpellé avec @identifiant.du.bot dans le corps du message
|
||||||
async def repond(room: MatrixRoom, message: Event, matrix_client: MatrixClient):
|
if len(room.users) > 2 and not (message.formatted_body and matrix_client.user_id in message.formatted_body):
|
||||||
# on initialise un event_parser pour décider à quel message cette commande va répondre
|
raise EventNotConcerned
|
||||||
event_parser = MessageEventParser(room=room, event=message, matrix_client=matrix_client)
|
|
||||||
# il ne va pas répondre à ses propres messages
|
reponse = parle()
|
||||||
event_parser.do_not_accept_own_message()
|
# il envoie l'information qu'il est en train d'écrire
|
||||||
|
await matrix_client.room_typing(room.room_id)
|
||||||
|
await asyncio.sleep(len(reponse) / 50)
|
||||||
if not hasattr(message, "body") or not hasattr(message, "formatted_body"):
|
# il envoie le message
|
||||||
# message non textuel
|
await matrix_client.room_typing(room.room_id, typing_state=False)
|
||||||
raise EventNotConcerned
|
await matrix_client.send_html_message(room.room_id, reponse, "m.notice")
|
||||||
|
|
||||||
# ne répond qu'en message direct ou dans un salon s'il est interpellé avec @identifiant.du.bot dans le corps du message
|
|
||||||
if len(room.users) > 2 and not (message.formatted_body and matrix_client.user_id in message.formatted_body):
|
tchap_bot = MatrixBot(
|
||||||
raise EventNotConcerned
|
env_config.matrix_home_server,
|
||||||
|
env_config.matrix_bot_username,
|
||||||
# il envoie l'information qu'il est en train d'écrire
|
env_config.matrix_bot_password,
|
||||||
await matrix_client.room_typing(room.room_id)
|
proxy=env_config.https_proxy,
|
||||||
reponse = parle()
|
use_functions=True,
|
||||||
await asyncio.sleep(len(reponse) / 50)
|
ssl=True
|
||||||
# il envoie le message
|
)
|
||||||
await matrix_client.room_typing(room.room_id, typing_state=False)
|
|
||||||
await matrix_client.send_html_message(room.room_id, reponse)
|
tchap_bot.matrix_client.matrix_config.encryption_enabled = True
|
||||||
|
tchap_bot.matrix_client.matrix_config.ignore_unverified_devices = True
|
||||||
|
tchap_bot.matrix_client.matrix_config.join_on_invite = True
|
||||||
@properly_fail("Oups, j'ai buggué 😿")
|
|
||||||
@ignore_when_not_concerned
|
tchap_bot.callbacks.register_on_message_event(repond)
|
||||||
async def dune(room: MatrixRoom, message: Event, matrix_client: MatrixClient):
|
tchap_bot.run()
|
||||||
event_parser = MessageEventParser(room=room, event=message, matrix_client=matrix_client)
|
|
||||||
event_parser.do_not_accept_own_message()
|
|
||||||
|
|
||||||
if ("Adrien" in message.body or "adrien" in message.body):
|
|
||||||
await matrix_client.room_typing(room.room_id)
|
|
||||||
await matrix_client.send_html_message(room.room_id, "<em>Lisan al-Gaib !</em>", "m.notice")
|
|
||||||
|
|
||||||
|
|
||||||
tchap_bot = MatrixBot(
|
|
||||||
env_config.matrix_home_server,
|
|
||||||
env_config.matrix_bot_username,
|
|
||||||
env_config.matrix_bot_password,
|
|
||||||
proxy=env_config.https_proxy,
|
|
||||||
use_functions=True,
|
|
||||||
ssl=True
|
|
||||||
)
|
|
||||||
|
|
||||||
tchap_bot.callbacks.register_on_startup(non_lus)
|
|
||||||
tchap_bot.callbacks.register_on_message_event(dune)
|
|
||||||
tchap_bot.callbacks.register_on_message_event(repond)
|
|
||||||
tchap_bot.run()
|
|
||||||
|
|||||||
Reference in New Issue
Block a user