mirror of
https://github.com/chatmail/core.git
synced 2026-04-17 21:46:35 +03:00
af5a3235fd
Otherwise the task may be garbage collected and cancelled. See <https://docs.python.org/3/library/asyncio-task.html#asyncio.create_task> for reference.
75 lines
2.2 KiB
Python
75 lines
2.2 KiB
Python
#!/usr/bin/env python3
|
|
"""Advanced echo bot example.
|
|
|
|
it will echo back any message that has non-empty text and also supports the /help command.
|
|
"""
|
|
import asyncio
|
|
import logging
|
|
import sys
|
|
|
|
from deltachat_rpc_client import Bot, DeltaChat, EventType, Rpc, events
|
|
|
|
hooks = events.HookCollection()
|
|
|
|
|
|
@hooks.on(events.RawEvent)
|
|
async def log_event(event):
|
|
if event.type == EventType.INFO:
|
|
logging.info(event.msg)
|
|
elif event.type == EventType.WARNING:
|
|
logging.warning(event.msg)
|
|
|
|
|
|
@hooks.on(events.RawEvent(EventType.ERROR))
|
|
async def log_error(event):
|
|
logging.error(event.msg)
|
|
|
|
|
|
@hooks.on(events.MemberListChanged)
|
|
async def on_memberlist_changed(event):
|
|
logging.info("member %s was %s", event.member, "added" if event.member_added else "removed")
|
|
|
|
|
|
@hooks.on(events.GroupImageChanged)
|
|
async def on_group_image_changed(event):
|
|
logging.info("group image %s", "deleted" if event.image_deleted else "changed")
|
|
|
|
|
|
@hooks.on(events.GroupNameChanged)
|
|
async def on_group_name_changed(event):
|
|
logging.info("group name changed, old name: %s", event.old_name)
|
|
|
|
|
|
@hooks.on(events.NewMessage(func=lambda e: not e.command))
|
|
async def echo(event):
|
|
snapshot = event.message_snapshot
|
|
if snapshot.text or snapshot.file:
|
|
await snapshot.chat.send_message(text=snapshot.text, file=snapshot.file)
|
|
|
|
|
|
@hooks.on(events.NewMessage(command="/help"))
|
|
async def help_command(event):
|
|
snapshot = event.message_snapshot
|
|
await snapshot.chat.send_text("Send me any message and I will echo it back")
|
|
|
|
|
|
async def main():
|
|
async with Rpc() as rpc:
|
|
deltachat = DeltaChat(rpc)
|
|
system_info = await deltachat.get_system_info()
|
|
logging.info("Running deltachat core %s", system_info.deltachat_core_version)
|
|
|
|
accounts = await deltachat.get_all_accounts()
|
|
account = accounts[0] if accounts else await deltachat.add_account()
|
|
|
|
bot = Bot(account, hooks)
|
|
if not await bot.is_configured():
|
|
# Save a reference to avoid garbage collection of the task.
|
|
_configure_task = asyncio.create_task(bot.configure(email=sys.argv[1], password=sys.argv[2]))
|
|
await bot.run_forever()
|
|
|
|
|
|
if __name__ == "__main__":
|
|
logging.basicConfig(level=logging.INFO)
|
|
asyncio.run(main())
|