mirror of
https://github.com/chatmail/core.git
synced 2026-04-17 21:46:35 +03:00
fa87d2e225
This patch adds new C APIs dc_get_next_msgs() and dc_wait_next_msgs(), and their JSON-RPC counterparts get_next_msgs() and wait_next_msgs(). New configuration "last_msg_id" tracks the last message ID processed by the bot. get_next_msgs() returns message IDs above the "last_msg_id". wait_next_msgs() waits for new message notification and calls get_next_msgs(). wait_next_msgs() can be used to build a separate message processing loop independent of the event loop. Async Python API get_fresh_messages_in_arrival_order() is deprecated in favor of get_next_messages(). Introduced Python APIs: - Account.wait_next_incoming_message() - Message.is_from_self() - Message.is_from_device() Introduced Rust APIs: - Context.set_config_u32() - Context.get_config_u32()
58 lines
2.0 KiB
Python
58 lines
2.0 KiB
Python
#!/usr/bin/env python3
|
|
"""
|
|
Example echo bot without using hooks
|
|
"""
|
|
import asyncio
|
|
import logging
|
|
import sys
|
|
|
|
from deltachat_rpc_client import DeltaChat, EventType, Rpc, SpecialContactId
|
|
|
|
|
|
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()
|
|
|
|
await account.set_config("bot", "1")
|
|
if not await account.is_configured():
|
|
logging.info("Account is not configured, configuring")
|
|
await account.set_config("addr", sys.argv[1])
|
|
await account.set_config("mail_pw", sys.argv[2])
|
|
await account.configure()
|
|
logging.info("Configured")
|
|
else:
|
|
logging.info("Account is already configured")
|
|
await deltachat.start_io()
|
|
|
|
async def process_messages():
|
|
for message in await account.get_next_messages():
|
|
snapshot = await message.get_snapshot()
|
|
if snapshot.from_id != SpecialContactId.SELF and not snapshot.is_bot and not snapshot.is_info:
|
|
await snapshot.chat.send_text(snapshot.text)
|
|
await snapshot.message.mark_seen()
|
|
|
|
# Process old messages.
|
|
await process_messages()
|
|
|
|
while True:
|
|
event = await account.wait_for_event()
|
|
if event["type"] == EventType.INFO:
|
|
logging.info("%s", event["msg"])
|
|
elif event["type"] == EventType.WARNING:
|
|
logging.warning("%s", event["msg"])
|
|
elif event["type"] == EventType.ERROR:
|
|
logging.error("%s", event["msg"])
|
|
elif event["type"] == EventType.INCOMING_MSG:
|
|
logging.info("Got an incoming message")
|
|
await process_messages()
|
|
|
|
|
|
if __name__ == "__main__":
|
|
logging.basicConfig(level=logging.INFO)
|
|
asyncio.run(main())
|