|
|
@ -67,10 +67,12 @@ class MeshListener(MeshArgsParse): |
|
|
try: |
|
|
try: |
|
|
await self.device.start() |
|
|
await self.device.start() |
|
|
self.meshState = WAIT_CONFIG |
|
|
self.meshState = WAIT_CONFIG |
|
|
|
|
|
logger.info("Mesh state: wait config") |
|
|
self.init_data = await _wait_for_config_complete(self.device) |
|
|
self.init_data = await _wait_for_config_complete(self.device) |
|
|
for from_radio in self.init_data: |
|
|
for from_radio in self.init_data: |
|
|
await queue.put(from_radio) |
|
|
await queue.put(from_radio) |
|
|
|
|
|
|
|
|
|
|
|
logger.info("Mesh state: available") |
|
|
self.meshState = AVAILABLE |
|
|
self.meshState = AVAILABLE |
|
|
while True: |
|
|
while True: |
|
|
from_radio, _ = await self.device.recv() |
|
|
from_radio, _ = await self.device.recv() |
|
|
@ -80,9 +82,11 @@ class MeshListener(MeshArgsParse): |
|
|
logger.info("Kill mesh device") |
|
|
logger.info("Kill mesh device") |
|
|
run = False |
|
|
run = False |
|
|
except: |
|
|
except: |
|
|
|
|
|
logger.error("Mesh state: error") |
|
|
self.meshState = ERR |
|
|
self.meshState = ERR |
|
|
traceback.print_exc() |
|
|
traceback.print_exc() |
|
|
await asyncio.sleep(1) |
|
|
await asyncio.sleep(1) |
|
|
|
|
|
logger.info("Mesh state: reconnect") |
|
|
self.meshState = RECONNECT |
|
|
self.meshState = RECONNECT |
|
|
finally: |
|
|
finally: |
|
|
await self.device.close() |
|
|
await self.device.close() |
|
|
@ -235,7 +239,7 @@ if __name__ == "__main__": |
|
|
parser = argparse.ArgumentParser() |
|
|
parser = argparse.ArgumentParser() |
|
|
#mesh |
|
|
#mesh |
|
|
parser.add_argument("--transport", default="tcp") |
|
|
parser.add_argument("--transport", default="tcp") |
|
|
parser.add_argument("--disable-mesh", action="store_true", default=False) |
|
|
parser.add_argument("--disable-mesh", action="store_true", default=True) |
|
|
#serial transport |
|
|
#serial transport |
|
|
parser.add_argument("--serial-port", default="/dev/tty.usbmodemD0CF1309DC141") |
|
|
parser.add_argument("--serial-port", default="/dev/tty.usbmodemD0CF1309DC141") |
|
|
parser.add_argument("--serial-baudrate", default=115200) |
|
|
parser.add_argument("--serial-baudrate", default=115200) |
|
|
@ -249,7 +253,7 @@ if __name__ == "__main__": |
|
|
parser.add_argument("--web-port", default=8680) |
|
|
parser.add_argument("--web-port", default=8680) |
|
|
#mongodb |
|
|
#mongodb |
|
|
parser.add_argument("--mongo-url") |
|
|
parser.add_argument("--mongo-url") |
|
|
parser.add_argument("--mongo-host", default="127.0.0.1") |
|
|
parser.add_argument("--mongo-host", default="192.168.3.2") |
|
|
parser.add_argument("--mongo-port", default=27017) |
|
|
parser.add_argument("--mongo-port", default=27017) |
|
|
parser.add_argument("--mongo-db", default="meshtastic") |
|
|
parser.add_argument("--mongo-db", default="meshtastic") |
|
|
|
|
|
|
|
|
|