diff --git a/mqttconnector/.gitignore b/mqttconnector/.gitignore deleted file mode 100644 index c167fb8..0000000 --- a/mqttconnector/.gitignore +++ /dev/null @@ -1 +0,0 @@ -piGardenMqttconnector.ini diff --git a/mqttconnector/exec_command.sh b/mqttconnector/exec_command.sh deleted file mode 100755 index c969855..0000000 --- a/mqttconnector/exec_command.sh +++ /dev/null @@ -1,2 +0,0 @@ -#!/bin/bash -echo -e "$1" | ../piGarden.sh socket_server_command diff --git a/mqttconnector/mqttconnector.py b/mqttconnector/mqttconnector.py deleted file mode 100644 index 89ddc99..0000000 --- a/mqttconnector/mqttconnector.py +++ /dev/null @@ -1,88 +0,0 @@ -# -# Installare libreria paho-mqtt, configparser: -# sudo pip install paho-mqtt configparser -# - -import paho.mqtt.client as mqttClient -import time -import subprocess -import configparser - -def on_connect(client, userdata, flags, rc): - - if rc == 0: - - print("Connected to broker") - - global Connected # Use global variable - Connected = True # Signal connection - - else: - - print("Connection failed") - -def on_message(client, userdata, message): - print "Topic : " + message.topic - print "Message received: " + message.payload - if message.topic.startswith("pigarden/command/"): - print "pigarden command: " + message.payload - cmd = "" - cmd = message.payload - if pigarden_user != "" and pigarden_pwd != "": - cmd = pigarden_user + '\n' + pigarden_pwd + '\n' + cmd - - p = subprocess.Popen([ pigarden_path + "mqttconnector/exec_command.sh", cmd ], stdout=subprocess.PIPE) - (output, err) = p.communicate() - - ## Wait for date to terminate. Get return returncode ## - p_status = p.wait() - print "Command : '" + cmd + "'" - print "Command output : ", output - print "Command exit status/return code : ", p_status - - - - -config = configparser.ConfigParser() -config.read('/etc/piGardenMqttconnector.ini') - - -Connected = False # global variable for the state of the connection - -broker_address = config['mqtt']['broker_address'] -port = int(config['mqtt']['port']) -user = config['mqtt']['user'] -password = config['mqtt']['password'] -client_id = config['mqtt']['client_id'] - -pigarden_path = config['pigarden']['path'] -pigarden_user = config['pigarden']['user'] -pigarden_pwd = config['pigarden']['pwd'] - -client = mqttClient.Client(client_id) # create new instance -client.username_pw_set(user, password=password) # set username and password -client.on_connect = on_connect # attach function to callback -client.on_message = on_message # attach function to callback - -print broker_address, port, user, password - -client.connect(broker_address, port=port) # connect to broker - -client.loop_start() #start the loop - -while Connected != True: #Wait for connection - time.sleep(0.1) - -client.subscribe("pigarden/command/+") - -try: - while True: - time.sleep(1) - -except KeyboardInterrupt: - print "exiting" - client.disconnect() - client.loop_stop() - - - diff --git a/mqttconnector/piGardenMqttconnector.ini.example b/mqttconnector/piGardenMqttconnector.ini.example deleted file mode 100644 index 54ccd26..0000000 --- a/mqttconnector/piGardenMqttconnector.ini.example +++ /dev/null @@ -1,12 +0,0 @@ -[mqtt] -broker_address= -port= -user= -password= -client_id=mqttconnector - -[pigarden] -path=/home/pi/piGarden/ -user=a -pwd=b -