Implementato controllo meteo su servizio online tramite driver, implementato driver per interfacciarsi con le api di openweathermap e wunderground

CHANGELOG.md

@@ -1,3 +1,9 @@
+# 0.5.8 - xx/07/2018
+- Added "openweathermap" driver for impement check weather condition from openweatermap api
+
+# 0.5.7 - 01/06/2018
+- Added "sonoff_tasmota_http" driver for interfacin with Sonoff module with Tasmota firmware over http protocol
+
 # 0.5.6 - 04/05/2018
 - Added events ev_not_open_for_rain, ev_not_open_for_rain_sensor, ev_not_open_for_rain_online
 - Added script rpinotify.sh for notificate events to telegram

conf/piGarden.conf.example

@@ -90,6 +90,7 @@ EV_TOTAL=6
 EV1_ALIAS="1" #
 EV1_GPIO=17   #		Physical 11 - wPi 0
 #EV1_NORAIN=1 # 	Non interrompe l'irrigazione di questa zona in caso di pioggia
+#EV1_MONOSTAVLE=1 #	L'elettrovalvola è monostabile
 
 EV2_ALIAS="2" #
 EV2_GPIO=27   #		Physical 13 - wPi 2
@@ -106,9 +107,19 @@ EV5_GPIO=23   #		Physical 16 - wPi 4
 EV6_ALIAS="6" #
 EV6_GPIO=24   #		Physical 18 - wPi 5
 
-# Definisce l'api key e il luogo per recuperare lo stato meteo online
+
+# Definisci il servizio online da utilizzare per il controllo delle condizioni meteo, puoi scegliere openweathermap oppure wunderground
+WEATHER_SERVICE="openweathermap"
+
+# Parametri di openweathermap, definisce l'api key e il luogo per recuperare lo stato meteo online
+OPENWEATHERMAP_KEY=""
+OPENWEATHERMAP_LOCATION="q=Pieve%20a%20Nievole,it" # https://openweathermap.org/current
+OPENWEATHERMAP_TZ="Europe/Rome"	# Time zone
+
+# Parametri di wunderground, definisce l'api key e il luogo per recuperare lo stato meteo online
 WUNDERGROUND_KEY=""
-WUNDERGROUND_LOCATION="IY/Monsummano"	# http://www.wunderground.com/weather/api/d/docs?d=resources/country-to-iso-matching&MR=1
+WUNDERGROUND_LOCATION="IT/Pieve%20a%20Nievole"	# http://www.wunderground.com/weather/api/d/docs?d=resources/country-to-iso-matching&MR=1
+
 
 # Blocca l'irrigazione se l'ultima pioggia rilevata online è avvenuta nell'ultima quantità di tempo inserita.
 # Il tempo è espresso in secondi. Quindi inserendo 86400, se nelle ultime 24 ore ha piovuto viene bloccata l'irrigazione. Inserendo il valore zero non viene eseguito nessun controllo.

conf/piGarden.conf.remote.example

@@ -100,11 +100,19 @@ EV4_ALIAS="Giardino_Posteriore_GPIO" #
 EV4_GPIO="18"
 
 
+# Definisci il servizio online da utilizzare per il controllo delle condizioni meteo, puoi scegliere openweathermap oppure wunderground
+WEATHER_SERVICE="openweathermap"
 
-# Definisce l'api key e il luogo per recuperare lo stato meteo online
+# Parametri di openweathermap, definisce l'api key e il luogo per recuperare lo stato meteo online
+OPENWEATHERMAP_KEY=""
+OPENWEATHERMAP_LOCATION="q=Pieve%20a%20Nievole,it" # https://openweathermap.org/current
+OPENWEATHERMAP_TZ="Europe/Rome"	# Time zone
+
+# Parametri di wunderground, definisce l'api key e il luogo per recuperare lo stato meteo online
 WUNDERGROUND_KEY=""
 WUNDERGROUND_LOCATION="IT/Pieve%20a%20Nievole"	# http://www.wunderground.com/weather/api/d/docs?d=resources/country-to-iso-matching&MR=1
 
+
 # Blocca l'irrigazione se l'ultima pioggia rilevata online è avvenuta nell'ultima quantità di tempo inserita.
 # Il tempo è espresso in secondi. Quindi inserendo 86400, se nelle ultime 24 ore ha piovuto viene bloccata l'irrigazione. Inserendo il valore zero non viene eseguito nessun controllo.
 NOT_IRRIGATE_IF_RAIN_ONLINE=86400

conf/piGarden.conf.sonoff_tasmota_http.example

@@ -0,0 +1,150 @@
+# Log file
+LOG_FILE="/home/pi/piGarden/log/piGarden.log"
+LOG_FILE_MAX_SIZE=1048576 # 1MB
+
+# Log file for driver output
+#LOG_OUTPUT_DRV_FILE="/tmp/piGarden.drv.log"
+
+# Status directory
+STATUS_DIR="/home/pi/piGarden/state"
+
+# Event directory
+EVENT_DIR="/home/pi/piGarden/events"
+
+# Posizione gpio
+GPIO="/usr/local/bin/gpio"
+
+# Posizione js
+JQ="/usr/local/bin/jq"
+
+# Percorso curl
+CURL="/usr/bin/curl"
+
+# Percorso wc
+WC="/usr/bin/wc"
+
+# Percorso gzip
+GZIP="/bin/gzip"
+
+# Percorso mv
+MV="/bin/mv"
+
+# Percorso di tr
+TR="/usr/bin/tr"
+
+# Percorso di cut
+CUT="/usr/bin/cut"
+
+# Percorso tcpserver
+TCPSERVER="/usr/bin/tcpserver"
+
+# Percorso cron
+CRONTAB="/usr/bin/crontab"
+
+# Percorso grep
+GREP="/bin/grep"
+
+# Percorsp sed
+SED="/bin/sed"
+
+# Percorso readlink
+READLINK="/bin/readlink"
+
+# Percorso stat
+STAT="/usr/bin/stat"
+
+# Se impostato con il valore 1, indica che il sistema gestisce elettrovalvole monostabili, 
+# se impostato a 0 il sistema gestirà elettrovalvole bisstabili
+EV_MONOSTABLE=0
+
+# Id gpio usati per simulare il doppio deviatore con cui eseguire l'alimentazione alle elettrovalvole
+SUPPLY_GPIO_1=2
+SUPPLY_GPIO_2=3
+
+# Stato dei due gpio per impartire l'alimentazione positiva alle elettrovalvole (aperta)
+SUPPLY_GPIO_POS=0
+
+# Stato dei due gpio per impartire l'alimentazione negativa alle elettrovalvole (chiusa)
+SUPPLY_GPIO_NEG=1
+
+# Stato di ingresso da assegnare al gpio per chiudere il rele
+RELE_GPIO_CLOSE=0
+
+# Stato di ingresso da assegnare al gpio per aprire il rele
+RELE_GPIO_OPEN=1
+
+# Id del gpio usato per collegare il sensore di rilevamento pioggia
+RAIN_GPIO=25		# Physical 22 - wPi 6
+
+# Valore in ingresso sul gpio definito in RAIN_GPIO che indica lo stato di pioggia
+RAIN_GPIO_STATE=0
+
+
+
+
+# Numero totale di elettrovalvole
+EV_TOTAL=4
+
+# Definizione delle elettrovalvole
+EV1_ALIAS="Giardino_Posteriore_DX"
+EV1_GPIO="drv:sonoff_tasmota_http:SONOFF1:Power1"
+EV1_MONOSTABLE=1
+
+EV2_ALIAS="Giardino_Posteriore_CN"
+EV2_GPIO="drv:sonoff_tasmota_http:SONOFF1:Power2"
+EV2_MONOSTABLE=1
+
+EV3_ALIAS="Giardino_Posteriore_SX"
+EV3_GPIO="drv:sonoff_tasmota_http:SONOFF1:Power3"
+EV3_MONOSTABLE=1
+
+EV4_ALIAS="Giardino_Anteriore"
+EV4_GPIO="drv:sonoff_tasmota_http:SONOFF2:Power1"
+
+
+# Definisci il servizio online da utilizzare per il controllo delle condizioni meteo, puoi scegliere openweathermap oppure wunderground
+WEATHER_SERVICE="openweathermap"
+
+# Parametri di openweathermap, definisce l'api key e il luogo per recuperare lo stato meteo online
+OPENWEATHERMAP_KEY=""
+OPENWEATHERMAP_LOCATION="q=Pieve%20a%20Nievole,it" # https://openweathermap.org/current
+OPENWEATHERMAP_TZ="Europe/Rome"	# Time zone
+
+# Parametri di wunderground, definisce l'api key e il luogo per recuperare lo stato meteo online
+WUNDERGROUND_KEY=""
+WUNDERGROUND_LOCATION="IT/Pieve%20a%20Nievole"	# http://www.wunderground.com/weather/api/d/docs?d=resources/country-to-iso-matching&MR=1
+
+
+# Blocca l'irrigazione se l'ultima pioggia rilevata online è avvenuta nell'ultima quantità di tempo inserita.
+# Il tempo è espresso in secondi. Quindi inserendo 86400, se nelle ultime 24 ore ha piovuto viene bloccata l'irrigazione. Inserendo il valore zero non viene eseguito nessun controllo.
+NOT_IRRIGATE_IF_RAIN_ONLINE=86400
+
+# Il parametro è simile a quello precedente, il controllo però anziché essere fatto attingendo a wunderground, viene eseguito direttamente sul sensore se installato. Inserendo il valore zero non viene eseguito nessun controllo.
+NOT_IRRIGATE_IF_RAIN_SENSOR=86400
+
+# Indirizzo ip e porta di ascolto del socket server
+TCPSERVER_IP="127.0.0.1"
+TCPSERVER_PORT="8084"
+
+# Utente e password che i clients devono utilizzare per stabilire una connessione tramite socket server
+TCPSERVER_USER=""
+TCPSERVER_PWD=""
+
+# Con impostato il valore 1 non invia l'identificativi per statistiche di utilizzo
+NO_SEND_IDENTIFIER=0
+
+
+#
+# Configurazione moduli sonoff
+#
+SONOFF1_IP="192.168.1.1"
+SONOFF1_USER="user"
+SONOFF1_PWD="pwd"
+
+SONOFF2_IP="192.168.1.21"
+SONOFF2_USER=""
+SONOFF2_PWD=""
+
+
+
+

conf/piGarden.conf.spb16ch.example

@@ -472,9 +472,18 @@ EV128_ALIAS="Zona_128" #
 EV128_GPIO="drv:spb16ch:128"
 
 
-# Definisce l'api key e il luogo per recuperare lo stato meteo online
+# Definisci il servizio online da utilizzare per il controllo delle condizioni meteo, puoi scegliere openweathermap oppure wunderground
+WEATHER_SERVICE="openweathermap"
+
+# Parametri di openweathermap, definisce l'api key e il luogo per recuperare lo stato meteo online
+OPENWEATHERMAP_KEY=""
+OPENWEATHERMAP_LOCATION="q=Pieve%20a%20Nievole,it" # https://openweathermap.org/current
+OPENWEATHERMAP_TZ="Europe/Rome"	# Time zone
+
+# Parametri di wunderground, definisce l'api key e il luogo per recuperare lo stato meteo online
 WUNDERGROUND_KEY=""
-WUNDERGROUND_LOCATION="IY/Monsummano"	# http://www.wunderground.com/weather/api/d/docs?d=resources/country-to-iso-matching&MR=1
+WUNDERGROUND_LOCATION="IT/Pieve%20a%20Nievole"	# http://www.wunderground.com/weather/api/d/docs?d=resources/country-to-iso-matching&MR=1
+
 
 # Blocca l'irrigazione se l'ultima pioggia rilevata online è avvenuta nell'ultima quantità di tempo inserita.
 # Il tempo è espresso in secondi. Quindi inserendo 86400, se nelle ultime 24 ore ha piovuto viene bloccata l'irrigazione. Inserendo il valore zero non viene eseguito nessun controllo.

drv/openweathermap/README.md

@@ -0,0 +1,13 @@
+# Driver for check wather condition with openweathermap online service
+
+# Example of configuration in piGarden.conf
+
+```bash
+WEATHER_SERVICE="openweathermap"
+
+OPENWEATHERMAP_KEY="d4d22ea805788420267971135563b4cc" # Set with your api key of openweathermap
+OPENWEATHERMAP_LOCATION="q=Pieve%20a%20Nievole,it"    # Set with location identify, see https://openweathermap.org/current
+OPENWEATHERMAP_TZ="Europe/Rome"			      # Set with your time zone
+```
+
+

drv/openweathermap/common.include.sh

@@ -0,0 +1,123 @@
+#
+# Funzioni comuni utilizzate dal driver
+#
+
+#
+# Recupera la descrizione della condizione meteo
+#
+# $1 condizione meteo recuperata dalle api
+#
+function drv_openweathermap_get_wather {
+
+	declare -A w
+
+	w["thunderstorm with light rain"]="Thunderstorms and Rain"
+	w["thunderstorm with rain"]="Thunderstorms and Rain"
+	w["thunderstorm with heavy rain"]="Thunderstorms and Rain"
+	w["light thunderstorm"]="Thunderstorm"
+	w["thunderstorm"]="Thunderstorm"
+	w["heavy thunderstorm"]="Thunderstorm"
+	w["ragged thunderstorm"]="Thunderstorm"
+	w["thunderstorm with light drizzle"]="Thunderstorms and Rain"
+	w["thunderstorm with drizzle"]="Thunderstorms and Rain"
+	w["thunderstorm with heavy drizzle"]="Thunderstorms and Rain"
+
+	w["light intensity drizzle"]="Drizzle"
+	w["drizzle"]="Drizzle"
+	w["heavy intensity drizzle"]="Drizzle"
+	w["light intensity drizzle rain"]="Drizzle"
+	w["drizzle rain"]="Drizzle"
+	w["heavy intensity drizzle rain"]="Drizzle"
+	w["shower rain and drizzle"]="Drizzle"
+	w["heavy shower rain and drizzle"]="Drizzle"
+	w["shower drizzle"]="Drizzle"
+
+	w["light rain"]="Rain Mist"
+	w["moderate rain"]="Rain"
+	w["heavy intensity rain"]="Rain"
+	w["very heavy rain"]="Rain"
+	w["extreme rain"]="Rain"
+	w["freezing rain"]="Freezing Rain"
+	w["light intensity shower rain"]="Rain"
+	w["shower rain"]="Rain"
+	w["heavy intensity shower rain"]="Rain"
+	w["ragged shower rain"]="Rain"
+
+	w["light snow"]="Snow"
+	w["snow"]="Snow"
+	w["heavy snow"]=""
+	w["sleet"]="Snow Grains"
+	w["shower sleet"]="Snow Grains"
+	w["light rain and snow"]="Snow"
+	w["rain and snow"]="Snow"
+	w["light shower snow"]="Snow"
+	w["shower snow"]="Snow"
+	w["heavy shower snow"]="Snow"
+
+	w["mist"]="Mist"
+	w["smoke"]="Smoke"
+	w["haze"]="Haze"
+	w["sand, dust whirls"]="Dust Whirls"
+	w["fog"]="Fog"
+	w["sand"]="Sand"
+	w["dust"]="Widespread Dust"
+	w["volcanic ash"]="Volcanic Ash"
+	w["squalls"]="Squalls"
+	w["tornado"]="Tornado"
+
+	w["clear sky"]="Clear"
+
+	w["few clouds"]="Partly Cloudy"
+	w["scattered clouds"]="Scattered Clouds"
+	w["broken clouds"]="Partly Cloudy"
+	w["overcast clouds"]="Mostly Cloudy"
+
+	local weather=${w[$1]}
+
+	if [ -z "$weather" ]; then
+		weather="$1"
+	fi
+
+	echo $weather
+
+}																												    
+
+#
+# Recupera la l'icona rappresentativa delle condizione meteo
+#
+# $1 nome dell'icona recuperato delle api weather.icon
+#
+function drv_openweathermap_get_ico {
+
+	declare -A w
+
+	w["01d"]="http://icons.wxug.com/i/c/k/clear.gif"
+	w["01n"]="http://icons.wxug.com/i/c/k/nt_clear.gif"
+	w["02d"]="http://icons.wxug.com/i/c/k/partlycloudy.gif"
+	w["02n"]="http://icons.wxug.com/i/c/k/nt_partlycloudy.gif"
+	w["03d"]="http://icons.wxug.com/i/c/k/cloudy.gif"
+	w["03n"]="http://icons.wxug.com/i/c/k/nt_cloudy.gif"
+	w["04d"]="http://icons.wxug.com/i/c/k/cloudy.gif"
+	w["04n"]="http://icons.wxug.com/i/c/k/nt_cloudy.gif"
+	w["09d"]="http://icons.wxug.com/i/c/k/sleet.gif"
+	w["09n"]="http://icons.wxug.com/i/c/k/nt_sleet.gif"
+	w["10d"]="http://icons.wxug.com/i/c/k/rain.gif"
+	w["10n"]="http://icons.wxug.com/i/c/k/nt_rain.gif"
+	w["11d"]="http://icons.wxug.com/i/c/k/tstorms.gif"
+	w["11n"]="http://icons.wxug.com/i/c/k/nt_tstorms.gif"
+	w["13d"]="http://icons.wxug.com/i/c/k/snow.gif"
+	w["13n"]="http://icons.wxug.com/i/c/k/nt_snow.gif"
+	w["50d"]="http://icons.wxug.com/i/c/k/fog.gif"
+	w["50n"]="http://icons.wxug.com/i/c/k/nt_fog.gif"
+
+	local ico=${w[$1]}
+
+	if [ -z "$ico" ]; then
+		ico="$1"
+	fi
+
+	echo $ico
+
+}																												    
+
+

drv/openweathermap/rainonline.include.sh

@@ -0,0 +1,74 @@
+#
+# Ritorna lo stato delle condizioni meteo interrogando il servizio online 
+#
+# $i 	identificativo gpio del sensore di pioggia
+#
+# return output:	0  - errore durante il recupero delle condizioni meteo 
+#			>0 - rilevato pioggia, timestamp del rilevamento
+#			<0 - rilevato nessuna pioggia, timestamp del rilevamento
+function drv_openweathermap_rain_online_get {
+
+	# http://www.wunderground.com/weather/api/d/docs?d=resources/phrase-glossary&MR=1
+	$CURL "http://api.openweathermap.org/data/2.5/weather?$OPENWEATHERMAP_LOCATION&units=metric&appid=$OPENWEATHERMAP_KEY" > $TMP_PATH/check_rain_online.openweathermap.json
+	local weather=`cat $TMP_PATH/check_rain_online.openweathermap.json | $JQ -M ".weather[0].main"`
+
+	local wind_deg=$(cat $TMP_PATH/check_rain_online.openweathermap.json | $JQ -r -M ".wind.deg")
+	local wind_speed=$(cat $TMP_PATH/check_rain_online.openweathermap.json | $JQ -r -M ".wind.speed")
+	if [ "$wind_speed" == "null" ]; then
+		#wind_speed=$($JQ -n $wind_speed*3600/1000)
+		wind_speed=0
+	fi
+
+
+	local weather="$(cat $TMP_PATH/check_rain_online.openweathermap.json | $JQ -r -M ".weather[0].description")"
+	local ico=$(cat $TMP_PATH/check_rain_online.openweathermap.json | $JQ -r -M ".weather[0].icon")
+	weather=$(drv_openweathermap_get_wather "$weather")
+	ico=$(drv_openweathermap_get_ico "$ico")
+
+	local current_observation=$(cat <<EOF
+{
+  "display_location": {
+    "city": "$(cat $TMP_PATH/check_rain_online.openweathermap.json | $JQ -r -M ".name")"
+  },
+  "observation_epoch": "$(cat $TMP_PATH/check_rain_online.openweathermap.json | $JQ -r -M ".dt")",
+  "local_epoch": "$(cat $TMP_PATH/check_rain_online.openweathermap.json | $JQ -r -M ".dt")",
+  "local_tz_long": "$OPENWEATHERMAP_TZ",
+  "weather": "$weather",
+  "temp_c": $(cat $TMP_PATH/check_rain_online.openweathermap.json | $JQ -r -M ".main.temp"),
+  "relative_humidity": "$(cat $TMP_PATH/check_rain_online.openweathermap.json | $JQ -r -M ".main.humidity")%",
+  "wind_dir": "$(deg2dir $wind_deg)",
+  "wind_degrees": $wind_deg,
+  "wind_kph": $wind_speed,
+  "wind_gust_kph": "--",
+  "pressure_mb": "$(cat $TMP_PATH/check_rain_online.openweathermap.json | $JQ -r -M ".main.pressure")",
+  "dewpoint_c": "--",
+  "feelslike_c": "--",
+  "icon_url": "$ico"
+}
+EOF
+)
+#  "icon_url": "http://openweathermap.org/img/w/$(cat $TMP_PATH/check_rain_online.openweathermap.json | $JQ -r -M ".weather[0].icon").png"
+
+	#local current_observation=`cat $TMP_PATH/check_rain_online.json | $JQ -M ".current_observation"`
+
+	if [ "$weather" = "null" ]; then
+		echo "0"
+	else
+		echo "$current_observation" > "$STATUS_DIR/last_weather_online"
+		local local_epoch=`cat $STATUS_DIR/last_weather_online | $JQ -M -r ".local_epoch"`
+		if 	[[ "$weather" == *"Rain"* ]] || 
+		 	[[ "$weather" == *"Snow"* ]] || 
+	 		[[ "$weather" == *"Hail"* ]] || 
+			[[ "$weather" == *"Ice"* ]] || 
+			[[ "$weather" == *"Thunderstorm"* ]] || 
+			[[ "$weather" == *"Drizzle"* ]]; 
+		then
+			echo $local_epoch
+		else
+			echo "-$local_epoch"
+		fi
+	fi
+
+}
+
+

drv/remote/README.md

@@ -1,4 +1,13 @@
-# Driver per controllare pigarden remoti in rete da un'installazione pigarden master
+# Driver for controlling remote pigarden on the network from a pigarden master installation
 
-Per maggiori informazioni consulta https://www.lejubila.net/2018/03/pigardent-0-5-5-driver-master-per-implementare-un-architettura-master-slave/
+For more information see https://www.lejubila.net/2018/03/pigardent-0-5-5-driver-master-per-implementare-un-architettura-master-slave/
 
+# Example of zone configuration in piGarden.conf
+
+EV1_ALIAS="Giarino_Posteriore_DX" #
+EV1_GPIO="drv:remote:PIREMOTE1:Giardino_Posteriore_DX"
+
+PIREMOTE1_IP="192.168.1.51"
+PIREMOTE1_PORT="8084"
+PIREMOTE1_USER=""
+PIREMOTE1_PWD=""

drv/remote/rele.include.sh

@@ -68,8 +68,8 @@ function drv_remote_rele_close {
 		error="${error%\"}"
 		error="${error#\"}"
 		echo "error=$error"
-	        log_write "Remote rele open error: $error"
+	        log_write "Remote rele close error: $error"
-        	message_write "warning" "Remote rele open error: $error"
+        	message_write "warning" "Remote rele close error: $error"
 		return 1
 	fi
 }

drv/remote/setup.include.sh

@@ -1,6 +1,6 @@
 #
 # Questa funzione viene invocata dalla funzione "setup_drv" di piGarden ad ogni avvio dello script
-# e serve per eseguire l'evenutale setup del driver se necessario
+# e serve per eseguire l'eventuale setup del driver se necessario
 #
 function drv_remote_setup {
 

drv/sample/rainonline.include.sh

@@ -0,0 +1,13 @@
+#
+# Ritorna lo stato delle condizioni meteo interrogando il servizio online 
+#
+# return output:	0  - errore durante il recupero delle condizioni meteo 
+#			>0 - rilevato pioggia, timestamp del rilevamento
+#			<0 - rilevato nessuna pioggia, timestamp del rilevamento
+function drv_sample_rain_online_get {
+
+	local FOO="bar"
+
+}
+
+

drv/sample/setup.include.sh

@@ -1,6 +1,6 @@
 #
 # Questa funzione viene invocata dalla funzione "setup_drv" di piGarden ad ogni avvio dello script
-# e serve per eseguire l'evenutale setup del driver se necessario
+# e serve per eseguire l'eventuale setup del driver se necessario
 #
 function drv_sample_setup {
 

drv/sonoff_tasmota_http/README.md

@@ -0,0 +1,21 @@
+# Driver for controlling Sonoff remote relays with Tasmota firmware via http protocol
+
+More information on Sonoff Tasmota firmware: https://github.com/arendst/Sonoff-Tasmota
+
+
+# Example of zone configuration in piGarden.conf
+
+EV1_ALIAS="Giardino_Posteriore_DX"
+EV1_GPIO="drv:sonoff_tasmota_http:SONOFF1:Power1"
+EV1_MONOSTABLE=1
+
+EV2_ALIAS="Giardino_Posteriore_CN"
+EV2_GPIO="drv:sonoff_tasmota_http:SONOFF1:Power2"
+EV2_MONOSTABLE=1
+
+SONOFF1_IP="192.168.1.1"
+SONOFF1_USER="user"
+SONOFF1_PWD="pwd"
+
+More information for configuration: https://www.lejubila.net/2018/06/pigarden-0-5-7-gestisci-le-tue-elettrovalvole-con-i-moduli-sonoff-grazie-al-nuovo-driver-sonoff_tasmota_http
+

drv/sonoff_tasmota_http/common.include.sh

@@ -0,0 +1,50 @@
+#
+# Funzioni comuni utilizzate dal driver
+#
+
+#
+# Invia un comando al modulo sonoff tramite http
+#
+# $1	identificativo modulo sonoff
+# $2	comando da eseguire
+#
+function drv_sonoff_tasmota_http_command {
+
+	local remote="$1"
+	local command="$2"
+
+	local remote_ip_var=$remote"_IP"
+	local remote_user_var=$remote"_USER"
+	local remote_pwd_var=$remote"_PWD"
+
+	local remote_ip="${!remote_ip_var}"
+	local remote_user="${!remote_user_var}"
+	local remote_pwd="${!remote_pwd_var}"
+
+	local url="http://$remote_ip/cm"
+	local credentials=""
+	local response=""
+
+	if [[ ! -z $remote_user ]] && [[ ! -z $remote_pwd ]]; then
+		credentials="user=$remote_user&password=$remote_pwd&"
+	fi
+
+	url="$url?$credentials$command"
+
+	echo "url api sonoff: $url" >> "$LOG_OUTPUT_DRV_FILE"
+
+	$CURL --connect-timeout 5 -sb -H "$url"
+
+	local res=$?
+
+	echo "curl code response: $res" >> "$LOG_OUTPUT_DRV_FILE"
+
+	if [ "$res" != "0" ]; then
+		echo "The curl command failed with: $res - url: $url"
+	fi
+
+	#echo "{\"POWER1\":\"ON\"}"
+
+}
+
+

drv/sonoff_tasmota_http/config.include.sh

@@ -0,0 +1,7 @@
+#
+# File di configurazione del driver
+# 
+
+# Dichiarazione variabile di esempio
+#declare -g SAMPLE_FOO
+#SAMPLE_FOO="bar"

drv/sonoff_tasmota_http/init.include.sh

@@ -0,0 +1,9 @@
+#
+# Questa funzione viene inviocata dalla funzione "init" di piGarden se sono presenti elettrovalvole o sensori che utilizzano questo driver
+#
+function drv_sonoff_tasmota_http_init {
+
+	local FOO=bar
+
+}
+

drv/sonoff_tasmota_http/rainsensor.include.sh

@@ -0,0 +1,23 @@
+#
+# Inizializza il sensore di rilevamento pioggia 
+#
+# $i 	identificativo gpio del sensore di pioggia
+#
+function drv_sonoff_tasmota_http_rain_sensor_init {
+
+	local FOO="bar"
+
+}
+
+#
+# Ritorna lo stato del sensore di rilevamento pioggia 
+#
+# $i 	identificativo gpio del sensore di pioggia
+#
+function drv_sonoff_tasmota_http_rain_sensor_get {
+
+	local FOO="bar"
+
+}
+
+

drv/sonoff_tasmota_http/rele.include.sh

@@ -0,0 +1,78 @@
+#
+# Inizializzazione rele 
+#
+# $1 identificativo relè da inizializzare
+#
+function drv_sonoff_tasmota_http_rele_init {
+	drv_sonoff_tasmota_http_rele_open "$1"
+}
+
+#
+# Apertura rele 
+#
+# $1 identificativo relè da aprire (chiude l'elettrovalvola)
+#
+function drv_sonoff_tasmota_http_rele_open {
+
+	local remote=`echo $1 | $CUT -d':' -f3,3`
+	local remote_alias=`echo $1 | $CUT -d':' -f4,4`
+
+	local command="cmnd=$remote_alias%20Off"
+
+	echo "remote=$remote"
+	echo "remote_alias=$remote_alias"
+	echo "command=$command"
+
+	local response=$(drv_sonoff_tasmota_http_command "$remote" "$command")
+
+	echo "response=$response"
+	local jskey=${remote_alias^^}
+
+	local result=$(echo $response|$JQ -M ".$jskey")
+	echo "result=$result"
+	if [[ "$result" != "\"OFF\"" ]]; then
+		local error="Command error: $response"
+		error="${error%\"}"
+		error="${error#\"}"
+		echo "error=$error"
+	        log_write "Remote rele open error: $error"
+        	message_write "warning" "Remote rele open error: $error"
+		return 1
+	fi
+}
+
+#
+# Chiusura rele 
+#
+# $1 identificativo relè da chiudere (apre l'elettrovalvola)
+#
+function drv_sonoff_tasmota_http_rele_close {
+
+	local remote=`echo $1 | $CUT -d':' -f3,3`
+	local remote_alias=`echo $1 | $CUT -d':' -f4,4`
+
+	local command="cmnd=$remote_alias%20On"
+
+	echo "remote=$remote"
+	echo "remote_alias=$remote_alias"
+	echo "command=$command"
+
+	local response=$(drv_sonoff_tasmota_http_command "$remote" "$command")
+
+	echo "response=$response"
+	local jskey=${remote_alias^^}
+
+	local result=$(echo $response|$JQ -M ".$jskey")
+	echo "result=$result"
+	if [[ "$result" != "\"ON\"" ]]; then
+		local error="Command error: $response"
+		error="${error%\"}"
+		error="${error#\"}"
+		echo "error=$error"
+	        log_write "Remote rele close error: $error"
+        	message_write "warning" "Remote rele close error: $error"
+		return 1
+	fi
+
+}
+

drv/sonoff_tasmota_http/setup.include.sh

@@ -0,0 +1,10 @@
+#
+# Questa funzione viene invocata dalla funzione "setup_drv" di piGarden ad ogni avvio dello script
+# e serve per eseguire l'eventuale setup del driver se necessario
+#
+function drv_sonoff_tasmota_http_setup {
+
+	local FOO="bar"
+
+}
+

drv/sonoff_tasmota_http/supply.include.sh

@@ -0,0 +1,34 @@
+#
+# Inizializza i rele che gestiscono l'alimentazione per le valvole bistabili
+#
+# $1    identificativo relè 
+#
+function drv_sonoff_tasmota_http_supply_bistable_init {
+
+	drv_sonoff_tasmota_http_supply_negative "$1"
+
+}
+
+#
+# Imposta l'alimentazione delle elettrovalvole con voltaggio positivo 
+#
+# $1    identificativo relè 
+#
+function drv_sonoff_tasmota_http_supply_positive {
+
+	drv_sonoff_tasmota_http_rele_open "$1"
+
+}
+
+#
+# Imposta l'alimentazione delle elettrovalvole con voltaggio negativo
+#
+# $1    identificativo relè 
+#
+function drv_sonoff_tasmota_http_supply_negative {
+
+	drv_sonoff_tasmota_http_rele_close "$1"
+
+}
+
+

drv/wunderground/README.md

@@ -0,0 +1,12 @@
+# Driver for check wather condition with wunderground online service
+
+# Example of configuration in piGarden.conf
+
+```bash
+WEATHER_SERVICE="wunderground"
+
+WUNDERGROUND_KEY=""			# Set with your api key of wunderground
+WUNDERGROUND_LOCATION="IY/Monsummano"	# Set with your location indentify, see http://www.wunderground.com/weather/api/d/docs?d=resources/country-to-iso-matching&MR=1 
+```
+
+

drv/wunderground/common.include.sh

@@ -0,0 +1,12 @@
+#
+# Funzioni comuni utilizzate dal driver
+#
+
+#
+# Funzione di esempio
+#
+function sample_foo {
+
+	echo "bar"
+
+}

drv/wunderground/rainonline.include.sh

@@ -0,0 +1,36 @@
+#
+# Ritorna lo stato delle condizioni meteo interrogando il servizio online 
+#
+# $i 	identificativo gpio del sensore di pioggia
+#
+# return output:	0  - errore durante il recupero delle condizioni meteo 
+#			>0 - rilevato pioggia, timestamp del rilevamento
+#			<0 - rilevato nessuna pioggia, timestamp del rilevamento
+function drv_wunderground_rain_online_get {
+
+	# http://www.wunderground.com/weather/api/d/docs?d=resources/phrase-glossary&MR=1
+	$CURL http://api.wunderground.com/api/$WUNDERGROUND_KEY/conditions/q/$WUNDERGROUND_LOCATION.json > $TMP_PATH/check_rain_online.json
+	local weather=`cat $TMP_PATH/check_rain_online.json | $JQ -M ".current_observation.weather"`
+	local current_observation=`cat $TMP_PATH/check_rain_online.json | $JQ -M ".current_observation"`
+	local local_epoch=`cat $TMP_PATH/check_rain_online.json | $JQ -M -r ".current_observation.local_epoch"`
+
+	if [ "$weather" = "null" ]; then
+		echo "0"
+	else
+		if 	[[ "$weather" == *"Rain"* ]] || 
+		 	[[ "$weather" == *"Snow"* ]] || 
+	 		[[ "$weather" == *"Hail"* ]] || 
+			[[ "$weather" == *"Ice"* ]] || 
+			[[ "$weather" == *"Thunderstorm"* ]] || 
+			[[ "$weather" == *"Drizzle"* ]]; 
+		then
+			echo $local_epoch
+		else
+			echo "-$local_epoch"
+		fi
+		echo "$current_observation" > "$STATUS_DIR/last_weather_online"
+	fi
+
+}
+
+

include/drv.include.sh

@@ -19,7 +19,7 @@ function setup_drv {
         done
 
 	# Inizializza i driver per gli altri gpio
-	for gpio in "$SUPPLY_GPIO_1" "$SUPPLY_GPIO_2" "$RAIN_GPIO"
+	for gpio in "$SUPPLY_GPIO_1" "$SUPPLY_GPIO_2" "$RAIN_GPIO" "$WEATHER_SERVICE"
 	do
 		if [[ "$gpio" == drv:* ]]; then
 			local drv=`echo $gpio | $CUT -d':' -f2,2`
@@ -32,7 +32,7 @@ function setup_drv {
 	local file_drv
 	for drv in "${list_drv[@]}"
 	do
-		for callback in config common init rele supply rainsensor setup
+		for callback in config common init rele supply rainsensor rainonline setup
 		do
 			file_drv="$DIR_SCRIPT/drv/$drv/$callback.include.sh"
 			if [ -f "$file_drv" ]; then
@@ -315,3 +315,30 @@ function drv_rain_sensor_get {
 	echo "$vret"
 
 }
+
+#
+# Legge lo stato le condizioni meteo dal servizio online
+#
+# $1	identificativo gpio sensore pioggia
+#
+function drv_rain_online_get {
+	local idx="$1"
+	local fnc=`get_driver_callback "rain_online_get" "$idx"`
+	local vret=""
+
+	# Nessun driver definito, esegue la lettura del sensore tramite gpio del raspberry
+	if [ -z "$fnc" ]; then
+	        log_write "Driver not found: $idx"
+        	message_write "warning" "Driver not found: $idx"
+	# Il driver definito non è stato trovato
+	elif [ "$fnc" == "drvnotfound" ]; then
+	        log_write "Driver not found: $idx"
+        	message_write "warning" "Driver not found: $idx"
+	else
+		echo "$(date) $fnc arg:$idx" >> "$LOG_OUTPUT_DRV_FILE"
+		vret=`$fnc "$idx"`
+	fi
+
+	echo "$vret"
+
+}

include/rain.include.sh

@@ -1,7 +1,7 @@
 #
 # Controlla se se piove tramite http://api.wunderground.com/
 #
-function check_rain_online {
+function check_rain_online_old {
 
 	trigger_event "check_rain_online_before" ""
 
@@ -42,6 +42,55 @@ function check_rain_online {
 	trigger_event "check_rain_online_after" "$current_state_rain_online" "$weather"
 }
 
+
+
+
+
+
+
+
+
+
+#
+# Controlla se se piove tramite http://api.wunderground.com/
+#
+function check_rain_online {
+
+	trigger_event "check_rain_online_before" ""
+
+	local local_epoch=`drv_rain_online_get $WEATHER_SERVICE`
+	local current_state_rain_online=""
+	local last_state_rain_online=`cat "$STATUS_DIR/last_state_rain_online" 2> /dev/null`
+	local weather="null"
+
+	if [[ $local_epoch =~ ^-?[0-9]+$ ]]; then
+		if [ $local_epoch -eq 0 ]; then
+			log_write "check_rain_online - failed read online data"
+		else
+			if [ $local_epoch -gt 0 ]; then
+				current_state_rain_online='rain'
+				echo $local_epoch > "$STATUS_DIR/last_rain_online"
+			else
+				current_state_rain_online='norain'
+			fi
+			weather=$(cat "$STATUS_DIR/last_weather_online" | $JQ -M ".weather")
+			
+			log_write "check_rain_online - weather=$weather, local_epoch=$local_epoch"
+			if [ "$current_state_rain_online" != "$last_state_rain_online" ]; then
+				echo "$current_state_rain_online" > "$STATUS_DIR/last_state_rain_online"
+				trigger_event "check_rain_online_change" "$current_state_rain_online" "$weather"
+			fi
+		fi
+	else
+		log_write "check_rain_online - failed read online data"
+	fi
+
+	trigger_event "check_rain_online_after" "$current_state_rain_online" "$weather"
+}
+
+
+
+
 #
 # Controlla se se piove tramite sensore
 #

piGarden.sh

@@ -85,6 +85,8 @@ function ev_open {
 	local EVNORAIN=`ev_number2norain $EVNUM`
 	local EV_IS_REMOTE_VAR=EV"$EVNUM"_REMOTE
 	local EV_IS_REMOTE=${!EV_IS_REMOTE_VAR}
+	local EV_IS_MONOSTAVLE_VAR=EV"$EVNUM"_MONOSTABLE
+	local EV_IS_MONOSTAVLE=${!EV_IS_MONOSTAVLE_VAR}
 
 	if [ ! "$2" = "force" ] && [ "$EVNORAIN" != "1" ]; then
 		if [[ "$NOT_IRRIGATE_IF_RAIN_ONLINE" -gt 0 && -f $STATUS_DIR/last_rain_online ]]; then
@@ -132,7 +134,7 @@ function ev_open {
 	lock
 
 	# Gestisce l'apertura dell'elettrovalvola in base alla tipologia (monostabile / bistabile) 
-	if [ "$EV_MONOSTABLE" == "1" ] || [ "$EV_IS_REMOTE" == "1" ]; then
+	if [ "$EV_MONOSTABLE" == "1" ] || [ "$EV_IS_REMOTE" == "1" ] || [ "$EV_IS_MONOSTABLE" == "1" ]; then
 		drv_rele_close "$g"
 		if [ $? -eq 1 ]; then
 			unlock
@@ -780,6 +782,94 @@ function exec_reboot {
 	trigger_event "exec_reboot_after" 
 }
 
+
+#
+# Converte da gradi a direzione
+#
+# $1 gradi
+#
+function deg2dir {
+	local deg=$(echo $1 | $SED 's/\..*$//')
+	local dir=""
+
+	if [ "$deg" == "null" ]; then
+		echo ""
+		return
+	fi
+
+	# N	348.75 - 11.25
+	if [ $deg -le 11 ]; then
+		dir="North"
+
+	# NNE	11.25 - 33.75
+	elif [ $deg -le 33 ]; then
+		dir="NNE"
+
+	# NE	33.75 - 56.25
+	elif [ $deg -le 56 ]; then
+		dir="NE"
+
+	# ENE	56.25 - 78.75
+	elif [ $deg -le 78 ]; then
+		dir="ENE"
+
+	# E	78.75 - 101.25
+	elif [ $deg -le 101 ]; then
+		dir="East"
+
+	# ESE	101.25 - 123.75
+	elif [ $deg -le 123 ]; then
+		dir="ESE"
+
+	# SE	123.75 - 146.25
+	elif [ $deg -le 146 ]; then
+		dir="SE"
+
+	# SSE	146.25 - 168.75
+	elif [ $deg -le 168 ]; then
+		dir="SSE"
+
+	# S	168.75 - 191.25
+	elif [ $deg -le 191 ]; then
+		dir="South"
+
+	# SSW	191.25 - 213.75
+	elif [ $deg -le 213 ]; then
+		dir="SSW"
+
+	# SW	213.75 - 236.25
+	elif [ $deg -le 236 ]; then
+		dir="SW"
+
+	# WSW	236.25 - 258.75
+	elif [ $deg -le 258 ]; then
+		dir="WSW"
+
+	# W	258.75 - 281.25
+	elif [ $deg -le 281 ]; then
+		dir="West"
+
+	# WNW	281.25 - 303.75
+	elif [ $deg -le 303 ]; then
+		dir="WNW"
+
+	# NW	303.75 - 326.25
+	elif [ $deg -le 326 ]; then
+		dir="NW"
+
+	# NNW	326.25 - 348.75
+	elif [ $deg -le 348 ]; then
+		dir="NNW"
+
+	# N	348.75 - 11.25
+	else
+		dir="North"
+	fi
+
+	echo $dir
+
+}
+
 function debug1 {
 	. "$DIR_SCRIPT/debug/debug1.sh"	
 }
@@ -790,7 +880,7 @@ function debug2 {
 
 VERSION=0
 SUB_VERSION=5
-RELEASE_VERSION=6
+RELEASE_VERSION=8
 
 DIR_SCRIPT=`dirname $0`
 NAME_SCRIPT=${0##*/}
@@ -830,6 +920,11 @@ if [ -z "$EVENT_DIR" ]; then
 	EVENT_DIR="$DIR_SCRIPT/events"
 fi
 
+if [ -z $WEATHER_SERVICE ]; then
+	WEATHER_SERVICE="drv:wunderground"
+else
+	WEATHER_SERVICE="drv:$WEATHER_SERVICE"
+fi
 
 # Elimina il file di lock se più vecchio di 11 secondi
 if [ -f "$LOCK_FILE" ]; then