mirror of
https://github.com/meshcore-dev/meshcore_py.git
synced 2026-04-20 22:13:49 +00:00
123 lines
3.7 KiB
Python
123 lines
3.7 KiB
Python
#!/usr/bin/env python3
|
|
"""
|
|
Example demonstrating the new pub-sub system in MeshCore
|
|
Shows how to subscribe to events and use the event system
|
|
"""
|
|
import asyncio
|
|
import argparse
|
|
|
|
from meshcore import MeshCore
|
|
from meshcore.events import EventType
|
|
|
|
|
|
async def message_callback(event):
|
|
print(f"\nReceived message: {event.payload['text']}")
|
|
print(f"From: {event.payload.get('pubkey_prefix', 'channel')}")
|
|
print(f"Type: {event.payload['type']}")
|
|
print(f"Timestamp: {event.payload['sender_timestamp']}")
|
|
|
|
|
|
async def advertisement_callback(event):
|
|
print("\nDetected advertisement")
|
|
|
|
|
|
async def main():
|
|
parser = argparse.ArgumentParser(description="MeshCore Pub-Sub Example")
|
|
parser.add_argument(
|
|
"--port", "-p", help="Serial port", required=True
|
|
)
|
|
parser.add_argument(
|
|
"--baud", "-b", type=int, help="Baud rate", default=115200
|
|
)
|
|
args = parser.parse_args()
|
|
|
|
print(f"Connecting to {args.port} at {args.baud} baud...")
|
|
|
|
# Create MeshCore instance with serial connection
|
|
meshcore = await MeshCore.create_serial(args.port, args.baud, debug=True)
|
|
|
|
# Connection is already established
|
|
success = True
|
|
if not success:
|
|
print("Failed to connect to MeshCore device")
|
|
return
|
|
|
|
print("Connected to MeshCore device")
|
|
|
|
res = await meshcore.commands.send_device_query()
|
|
|
|
# Get contacts
|
|
result = await meshcore.commands.get_contacts()
|
|
if result.type == EventType.ERROR:
|
|
print(f"Error fetching contacts: {result.payload}")
|
|
return
|
|
contacts = result.payload
|
|
if contacts:
|
|
print(f"\nFound {len(contacts)} contacts:")
|
|
for name, contact in contacts.items():
|
|
print(f"- {name}")
|
|
|
|
|
|
await meshcore.commands.send_advert(flood=True)
|
|
|
|
# Subscribe to private messages
|
|
private_subscription = meshcore.subscribe(EventType.CONTACT_MSG_RECV, message_callback)
|
|
|
|
# Subscribe to channel messages
|
|
channel_subscription = meshcore.subscribe(EventType.CHANNEL_MSG_RECV, message_callback)
|
|
|
|
# Subscribe to advertisements
|
|
advert_subscription = meshcore.subscribe(EventType.ADVERTISEMENT, advertisement_callback)
|
|
|
|
await meshcore.start_auto_message_fetching()
|
|
|
|
print("\nSubscribed to events:")
|
|
print("- Private messages")
|
|
print("- Channel messages")
|
|
print("- Advertisements")
|
|
|
|
print("\nWaiting for events. Press Ctrl+C to exit...\n")
|
|
|
|
# Get device info
|
|
device_info = await meshcore.commands.send_device_query()
|
|
if device_info:
|
|
print(f"Device info: {device_info}")
|
|
|
|
# Get time from the device
|
|
device_time = await meshcore.commands.get_time()
|
|
print(f"Device time: {device_time}")
|
|
|
|
# Access current time through the property
|
|
print(f"Current time (property): {meshcore.time}")
|
|
|
|
try:
|
|
while True:
|
|
# Wait for messages
|
|
await asyncio.sleep(1)
|
|
except KeyboardInterrupt:
|
|
meshcore.stop()
|
|
print("\nExiting...")
|
|
except asyncio.CancelledError:
|
|
# Handle task cancellation from KeyboardInterrupt in asyncio.run()
|
|
print("\nTask cancelled - cleaning up...")
|
|
finally:
|
|
# Clean up subscriptions
|
|
meshcore.unsubscribe(private_subscription)
|
|
meshcore.unsubscribe(channel_subscription)
|
|
meshcore.unsubscribe(advert_subscription)
|
|
|
|
# Stop auto-message fetching
|
|
await meshcore.stop_auto_message_fetching()
|
|
|
|
# Disconnect
|
|
await meshcore.disconnect()
|
|
|
|
|
|
if __name__ == "__main__":
|
|
try:
|
|
asyncio.run(main())
|
|
except KeyboardInterrupt:
|
|
# This prevents the KeyboardInterrupt traceback from being shown
|
|
print("\nExited cleanly")
|
|
except Exception as e:
|
|
print(f"Error: {e}")
|