Compare commits
3
Commits
main
..
b745d310fd
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
b745d310fd | ||
|
|
bd726024e2 | ||
|
|
e5f12d0ae5 |
+12
-16
@@ -1,18 +1,8 @@
|
|||||||
|
import asyncio
|
||||||
|
import os
|
||||||
from nio import AsyncClient, RoomMessageText
|
from nio import AsyncClient, RoomMessageText
|
||||||
import random
|
|
||||||
|
|
||||||
class BooeehBot:
|
class BooeehBot:
|
||||||
|
|
||||||
def generate_boeh(self):
|
|
||||||
boeh = "b"
|
|
||||||
for _ in range(random.randint(1, 10)):
|
|
||||||
boeh += "o"
|
|
||||||
for _ in range(random.randint(1, 5)):
|
|
||||||
boeh += "e"
|
|
||||||
for _ in range(random.randint(1, 3)):
|
|
||||||
boeh += "e"
|
|
||||||
return boeh
|
|
||||||
|
|
||||||
def __init__(self, url, username, password):
|
def __init__(self, url, username, password):
|
||||||
self.url = url
|
self.url = url
|
||||||
self.username = username
|
self.username = username
|
||||||
@@ -22,23 +12,26 @@ class BooeehBot:
|
|||||||
async def login(self):
|
async def login(self):
|
||||||
try:
|
try:
|
||||||
response = await self.client.login(self.password)
|
response = await self.client.login(self.password)
|
||||||
print(f"Logged in. Serving {self.username}.")
|
print(f"User logged in: {self.username}")
|
||||||
return response
|
return response
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
print(f"Login error: {e}")
|
print(f"Login error: {e}")
|
||||||
return None
|
return None
|
||||||
|
|
||||||
async def handle_message(self, room, event):
|
async def handle_message(self, room, event):
|
||||||
specific_user_id = "@joewilliams007:matrix.org"
|
specific_user_id = '@joewilliams007:matrix.org'
|
||||||
|
|
||||||
if isinstance(event, RoomMessageText):
|
if isinstance(event, RoomMessageText):
|
||||||
if event.sender == specific_user_id:
|
if event.sender == specific_user_id:
|
||||||
response_text = self.generate_boeh()
|
response_text = "booeeeh"
|
||||||
try:
|
try:
|
||||||
await self.client.room_send(
|
await self.client.room_send(
|
||||||
room.room_id,
|
room.room_id,
|
||||||
message_type="m.room.message",
|
message_type="m.room.message",
|
||||||
content={"msgtype": "m.text", "body": response_text},
|
content={
|
||||||
|
"msgtype": "m.text",
|
||||||
|
"body": response_text
|
||||||
|
}
|
||||||
)
|
)
|
||||||
print(f"Response to {event.sender}: " + response_text)
|
print(f"Response to {event.sender}: " + response_text)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
@@ -55,3 +48,6 @@ class BooeehBot:
|
|||||||
|
|
||||||
async def stop(self):
|
async def stop(self):
|
||||||
await self.client.close()
|
await self.client.close()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -1,7 +1,6 @@
|
|||||||
import asyncio
|
import asyncio
|
||||||
|
from boeh import env
|
||||||
from boeh import BooeehBot, env
|
from boeh import BooeehBot
|
||||||
|
|
||||||
|
|
||||||
async def main_async():
|
async def main_async():
|
||||||
url = "https://matrix.org"
|
url = "https://matrix.org"
|
||||||
@@ -14,10 +13,8 @@ async def main_async():
|
|||||||
except KeyboardInterrupt:
|
except KeyboardInterrupt:
|
||||||
await bot.stop()
|
await bot.stop()
|
||||||
|
|
||||||
|
|
||||||
def main():
|
def main():
|
||||||
asyncio.run(main_async())
|
asyncio.run(main_async())
|
||||||
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
if __name__ == "__main__":
|
||||||
main()
|
main()
|
||||||
Reference in New Issue
Block a user