Switch train MQTT broker to local
This commit is contained in:
parent
8d6233c888
commit
5fa12e05a8
12
main.py
12
main.py
|
@ -155,11 +155,9 @@ def mqtt_publish(topic, message):
|
||||||
publish.single(
|
publish.single(
|
||||||
topic,
|
topic,
|
||||||
str(message),
|
str(message),
|
||||||
hostname='webhost.protospace.ca',
|
hostname='172.17.17.181',
|
||||||
port=8883,
|
port=1883,
|
||||||
client_id='protovac',
|
client_id='protovac',
|
||||||
auth=dict(username='writer', password=secrets.MQTT_WRITER_PASSWORD),
|
|
||||||
tls=dict(ca_certs='/etc/ssl/certs/ISRG_Root_X1.pem'),
|
|
||||||
keepalive=5, # timeout
|
keepalive=5, # timeout
|
||||||
)
|
)
|
||||||
except BaseException as e:
|
except BaseException as e:
|
||||||
|
@ -1483,13 +1481,13 @@ I will be terse in my responses.
|
||||||
res = ''
|
res = ''
|
||||||
|
|
||||||
if button == 'r':
|
if button == 'r':
|
||||||
res = mqtt_publish('train/control', -140)
|
res = mqtt_publish('train/control/speed', -140)
|
||||||
logging.info('Setting train speed to: -140')
|
logging.info('Setting train speed to: -140')
|
||||||
elif button == 't':
|
elif button == 't':
|
||||||
res = mqtt_publish('train/control', 0)
|
res = mqtt_publish('train/control/speed', 0)
|
||||||
logging.info('Setting train speed to: 0')
|
logging.info('Setting train speed to: 0')
|
||||||
elif button == 'y':
|
elif button == 'y':
|
||||||
res = mqtt_publish('train/control', 160)
|
res = mqtt_publish('train/control/speed', 160)
|
||||||
logging.info('Setting train speed to: 160')
|
logging.info('Setting train speed to: 160')
|
||||||
|
|
||||||
elif button == 'b' or c == KEY_ESCAPE:
|
elif button == 'b' or c == KEY_ESCAPE:
|
||||||
|
|
Loading…
Reference in New Issue
Block a user