Meshtastic

For sure. It is quite basic and I am not proud of the hacky method I used to "parse" the message, but it might be useful for someone looking for a simple way to interface with a meshtastic device over TCP (onReceive) and the Lemmy API (createPost).

import json
import re
import meshtastic
import meshtastic.tcp_interface
from pubsub import pub
import time
import os
import requests


INSTANCE_API = "https://mander.xyz/api/v3"
MESHTEST_LEMMY_JWT = 'Cookie retrieved from browser'



def createPost(community_name, subject, body):
    url = f"{INSTANCE_API}/post"
    getCommunity = requests.get(f"{INSTANCE_API}/community?name={community_name}").json()
    communityId = getCommunity['community_view']['community']['id']
    data = {
        "community_id": communityId,
        "name": subject,
        "body": body}
    headers = {
        "Authorization": f"Bearer {MESHTEST_LEMMY_JWT}",
        "Content-Type": "application/json"
    }
    response = requests.post(url, headers=headers, json=data)
    return response


MESHTASTIC_NODE_IP = "Local IP of the base node connected to WiFi"

def sstrip(text):
 return re.sub(r'(?:\s|,)*(sub|SUB|Sub|COM|com|Com|Bod|bod|BOD)(?:\s|,)*$', '', text.strip())

def processMessage(message):
    blocks = message.split(':')    # Splits the message into blocks, but will also split smiley faces ":)", bad method. 
    try:
        for i in range(0,len(blocks)-1):
            if blocks[i][-3:].lower() == 'sub':
                subject = sstrip(blocks[i+1])
            if blocks[i][-3:].lower() == 'com':
                community_name = sstrip(blocks[i+1]).lower()
            if blocks[i][-3:].lower() == 'bod':
                body = sstrip(blocks[i+1])
        return community_name, subject, body
    except:
        return 'ERR','ERR','ERR'

def onReceive(packet, interface):
    if 'decoded' in packet and 'payload' in packet['decoded']:
        try:
            message = packet['decoded']['payload'].decode('utf-8')
            sender = packet['from']
            if 'Ping' in message:
                interface.sendText("Pong!", destinationId=sender)
            if message.split('\n')[0] == 'PST':
              try:
                community_name, subject, body = processMessage(message)
                response = createPost(community_name, subject, body)
                if response.ok:
                  interface.sendText("Post created succesfully!", destinationId=sender)
                else:
                  interface.sendText("Unable to create post!", destinationId=sender)
              except:
               interface.sendText("Exception triggered", destinationId=sender)
        except Exception as e:
            pass

interface = meshtastic.tcp_interface.TCPInterface(hostname=MESHTASTIC_NODE_IP)
pub.subscribe(onReceive, "meshtastic.receive")

while True:
    time.sleep(2)