mirror of
https://github.com/meshtastic/python.git
synced 2026-08-02 10:07:06 -04:00
add sanity prerelease tests
This commit is contained in:
@@ -575,7 +575,8 @@ class StreamInterface(MeshInterface):
|
||||
self._rxBuf = bytes() # empty
|
||||
self._wantExit = False
|
||||
|
||||
self._rxThread = threading.Thread(target=self.__reader, args=(), daemon=True)
|
||||
# FIXME, figure out why daemon=True causes reader thread to exit too early
|
||||
self._rxThread = threading.Thread(target=self.__reader, args=())
|
||||
|
||||
MeshInterface.__init__(self, debugOut=debugOut, noProto=noProto)
|
||||
|
||||
@@ -595,6 +596,7 @@ class StreamInterface(MeshInterface):
|
||||
time.sleep(0.1) # wait 100ms to give device time to start running
|
||||
|
||||
self._rxThread.start()
|
||||
self._waitConnected()
|
||||
|
||||
def _disconnected(self):
|
||||
"""We override the superclass implementation to close our port"""
|
||||
|
||||
@@ -129,15 +129,18 @@ def onConnected(interface):
|
||||
closeNow = False # Should we drop the connection after we finish?
|
||||
try:
|
||||
if args.settime:
|
||||
closeNow = True
|
||||
print("Setting device RTC time")
|
||||
# can include lat/long/alt etc: latitude = 37.5, longitude = -122.1
|
||||
interface.sendPosition()
|
||||
|
||||
if args.setowner:
|
||||
closeNow = True
|
||||
print(f"Setting device owner to {args.setowner}")
|
||||
interface.setOwner(args.setowner)
|
||||
|
||||
if args.sendtext:
|
||||
closeNow = True
|
||||
print(f"Sending text message {args.sendtext} to {args.destOrAll}")
|
||||
interface.sendText(args.sendtext, args.destOrAll,
|
||||
wantAck=True, wantResponse=True)
|
||||
|
||||
Reference in New Issue
Block a user