115 lines
4.1 KiB
GDScript
115 lines
4.1 KiB
GDScript
extends Control
|
|
|
|
var receivedmessagecount = 0
|
|
|
|
func _ready():
|
|
connectedactionsactive(false)
|
|
|
|
func _on_brokerprotocol_item_selected(index):
|
|
# port defaults for [tcp, ssl, ws, wss] used at https://test.mosquitto.org/
|
|
$VBox/HBoxBroker/brokerport.text = "%d" % ([ 1883, 8886, 8080, 8081 ][index])
|
|
|
|
func _on_button_connect_toggled(button_pressed):
|
|
if button_pressed:
|
|
randomize()
|
|
$MQTT.client_id = "s%d" % randi()
|
|
|
|
if $VBox/HBoxLastwill/lastwilltopic.text:
|
|
$MQTT.set_last_will($VBox/HBoxLastwill/lastwilltopic.text,
|
|
$VBox/HBoxLastwill/lastwillmessage.text,
|
|
$VBox/HBoxLastwill/lastwillretain.button_pressed)
|
|
else:
|
|
$MQTT.set_last_will("", "", false)
|
|
|
|
if $VBox/HBoxBroker/brokeruser.text:
|
|
$MQTT.set_user_pass($VBox/HBoxBroker/brokeruser.text,
|
|
$VBox/HBoxBroker/brokerpswd.text)
|
|
else:
|
|
$MQTT.set_user_pass(null, null)
|
|
|
|
$VBox/HBoxBrokerControl/status.text = "connecting..."
|
|
var brokerurl = $VBox/HBoxBroker/brokeraddress.text
|
|
var protocol = $VBox/HBoxBroker/brokerprotocol.get_item_text($VBox/HBoxBroker/brokerprotocol.selected)
|
|
$MQTT.connect_to_broker("%s%s:%s" % [protocol, brokerurl, $VBox/HBoxBroker/brokerport.text])
|
|
|
|
else:
|
|
#$VBox/HBoxBrokerControl/status.text = "disconnecting..."
|
|
$MQTT.disconnect_from_server()
|
|
|
|
|
|
func brokersettingsactive(active):
|
|
$VBox/HBoxBroker/brokeraddress.editable = active
|
|
$VBox/HBoxBroker/brokerport.editable = active
|
|
$VBox/HBoxBroker/brokerprotocol.disabled = not active
|
|
$VBox/HBoxLastwill/lastwilltopic.editable = active
|
|
$VBox/HBoxLastwill/lastwillmessage.editable = active
|
|
$VBox/HBoxLastwill/lastwillretain.disabled = not active
|
|
$VBox/HBoxBrokerControl/ButtonConnect.button_pressed = not active
|
|
|
|
func connectedactionsactive(active):
|
|
$VBox/HBoxSubscriptions/subscribetopic.editable = active
|
|
$VBox/HBoxSubscriptions/subscribe.disabled = not active
|
|
$VBox/HBoxPublish/publishtopic.editable = active
|
|
$VBox/HBoxPublish/publishmessage.editable = active
|
|
$VBox/HBoxPublish/publishretain.disabled = not active
|
|
$VBox/HBoxPublish/publish.disabled = not active
|
|
if not active:
|
|
$VBox/HBoxSubscriptions/subscriptions.clear()
|
|
$VBox/HBoxSubscriptions/subscriptions.disabled = true
|
|
$VBox/HBoxSubscriptions/unsubscribe.disabled = true
|
|
|
|
func _on_mqtt_broker_connected():
|
|
$VBox/HBoxBrokerControl/status.text = "connected."
|
|
brokersettingsactive(false)
|
|
connectedactionsactive(true)
|
|
receivedmessagecount = 0
|
|
|
|
func _on_mqtt_broker_disconnected():
|
|
$VBox/HBoxBrokerControl/status.text = "disconnected."
|
|
brokersettingsactive(true)
|
|
connectedactionsactive(false)
|
|
|
|
func _on_mqtt_broker_connection_failed():
|
|
$VBox/HBoxBrokerControl/status.text = "failed."
|
|
brokersettingsactive(true)
|
|
connectedactionsactive(false)
|
|
|
|
|
|
func _on_mqtt_received_message(topic, message):
|
|
if receivedmessagecount == 0:
|
|
$VBox/subscribedmessages.clear()
|
|
receivedmessagecount += 1
|
|
$VBox/subscribedmessages.append_text("[b]%s[/b] %s\n" % [topic, message])
|
|
|
|
func _on_publish_pressed():
|
|
var qos = 0
|
|
$MQTT.publish($VBox/HBoxPublish/publishtopic.text,
|
|
$VBox/HBoxPublish/publishmessage.text,
|
|
$VBox/HBoxPublish/publishretain.button_pressed,
|
|
qos)
|
|
|
|
func _on_subscribe_pressed():
|
|
var qos = 0
|
|
var topic = $VBox/HBoxSubscriptions/subscribetopic.text.strip_edges()
|
|
$MQTT.subscribe(topic, qos)
|
|
for i in range($VBox/HBoxSubscriptions/subscriptions.item_count):
|
|
if topic == $VBox/HBoxSubscriptions/subscriptions.get_item_text(i):
|
|
return
|
|
$VBox/HBoxSubscriptions/subscriptions.add_item(topic)
|
|
$VBox/HBoxSubscriptions/subscriptions.select($VBox/HBoxSubscriptions/subscriptions.item_count - 1)
|
|
$VBox/HBoxSubscriptions/subscriptions.disabled = false
|
|
$VBox/HBoxSubscriptions/unsubscribe.disabled = false
|
|
|
|
func _on_unsubscribe_pressed():
|
|
var seloptbutt = $VBox/HBoxSubscriptions/subscriptions
|
|
var sel = seloptbutt.selected
|
|
var topic = seloptbutt.get_item_text(sel)
|
|
$MQTT.unsubscribe(topic)
|
|
seloptbutt.remove_item(seloptbutt.selected)
|
|
$VBox/HBoxSubscriptions/subscriptions.disabled = (seloptbutt.item_count == 0)
|
|
$VBox/HBoxSubscriptions/unsubscribe.disabled = (seloptbutt.item_count == 0)
|
|
if seloptbutt.item_count != 0:
|
|
seloptbutt.select(min(sel, seloptbutt.item_count - 1))
|
|
|
|
|