firma

funciones

@@ -18,7 +18,6 @@ funcion_datos_simulados() {
 
 funcion_datos_sensores() {
 
-	#local arduino_id=$1
 	peticiones=1
 	arduinos=( 0x01 0x02 )
 	for arduino_id in ${arduinos[@]};do
@@ -36,9 +35,7 @@ funcion_datos_sensores() {
 		lecturas="$lecturas tp:${lectura_arduino[$indice]} vl:${lectura_arduino[$(expr $indice + 1 )]} un:${lectura_arduino[$(expr $indice + 2 )]} er:${lectura_arduino[$(expr $indice + 3 )]}"
 
 		if [ $vueltas -lt $bloques ]; then
-
 			lecturas="$lecturas AD_SENSOR"
-
 		fi	
 
 		let "indice = $indice + 4 "

registrador

@@ -1,85 +1,62 @@
 #!/bin/bash
-#set -x
-
 source /etc/nodemecu.conf
-source funciones
+source $funciones 
-
-conteo=$(cat $contador)
-uuid="$(uuidgen)"
-marca_de_tiempo="$(date +%s)"
-
-case $modo in
-	test)
-		funcion_datos_simulados
-		;;
-	sensores)
-		funcion_datos_sensores
-		;;
-esac
 
 
-# ARMADO DE FICHERO JSON
+# Revisando stack
 
-for i in $lecturas;do
+for registro_json in $registros/*;do
-case $i in
+	test  "$registro_json" = "/opt/nodemecu/stack/\*"  || break
-	id*)
+	jsonlint-php $registro_json > /dev/null || mv -v $registro_json $registros_corruptos
-		sensores="$sensores { $(echo \"id\":\"$(echo $i | cut -d ":" -f 2)\", \"sensores\": [ )"
-	;;
-	ts*)
-		#sensores="$sensores { $(echo \"timestamp\": $(echo $i | cut -d ":" -f 2),)"
-		sensores="$sensores { $(echo \"timestamp\": $marca_de_tiempo,)"
-	;;
-	tp*)
-		sensores="$sensores $(echo \"type\": \"$(echo $i | cut -d ":" -f 2)\",)"
-	;;
-	vl*)
-		sensores="$sensores $(echo \"value\": $(echo $i | cut -d ":" -f 2),)"
-	;;
-	un*)
-		sensores="$sensores $(echo \"unit\": \"$(echo $i | cut -d ":" -f 2)\",)"
-	;;
-	er*)
-		sensores="$sensores $(echo \"error\": $(echo $i | cut -d ":" -f 2) })"
-	;;
-	AD_SENSOR)
-		sensores="$sensores,"
-	;;
-	AD_ARDUINO)
-		sensores="$sensores]},"
-	;;
-	END)
-		sensores="$sensores]}"
-	;;
-esac
 done
 
+while :;do
+	# si no hay nada en el directorio registros reinicia el bucle
+	# espera el intervalo definido o 1 minuto.
+	file=$(get_stack)
+	[ -z $file ] && sleep ${intervalo:-1}m && continue
+
+	# si no respone el ping reinica el bucle
+	ping -c 1 fsf.org > /dev/null 2>&1 || continue
+
+	# si el fichero 'lock' existe (se esta creando un nuevo registro) reinicia el bucle
+	[ -f $lock ] && continue
+
+
+	# se testea que el servidor responda
+	#test_url="$(curl -s -X POST -o /dev/null -w "%{http_code}" $servidor)"
+	#if [ $test_url -eq 404 ];then
+	#	echo "$(date +%Y-%m-%d-%H:%M:%S) - $url - $test_url" >> /opt/nodemecu/errors.log && sleep 300 && continue 
+	#fi
+
+
+	sing_file $registros/$file
+	firma="$(cat $registros/$file.sign)"
 	
 
 
-json="{\"transaction_uuid\":\"$uuid\",\"controller_id\":\"$name\",\"timestamp\":\"$marca_de_tiempo\",\"error_code\":\"10\",\"coordinates\":{\"lat\":1,\"lng\":1},\"battery_status\":\"98\",\"sample\":\"0\",\"storage\":\"uso del almacenamiento\",\"arduinos\":[$sensores]}"
+	local_transaction_uuid=$(jq -r '."transaction_uuid"' $registros/$file)
-
+	remote_transaction=$(curl -s --connect-timeout 0,9 --show-error -w "~%{http_code}" -X POST -H "X-Signature: $firma" -H "Content-Type: application/json" -d @$registros/$file $servidor 2> $curl_err)
-touch $lock
+	remote_response="$(echo $remote_transaction | cut -d '~' -f 1)"
-
+	server_error="$(echo $remote_transaction | cut -d '~' -f 2)"
-file=$(date +%Y%m%d%H%M%S -d @$marca_de_tiempo)-$uuid
+	if [ ${#remote_response} -eq 36 ];then
-
-
-
-if echo $json | jsonlint-php 2> /dev/null;then
-	echo $json > $directorio_instalacion/$file && rm $lock && echo $((counter+1)) > $contador 
-else
-	echo "$(date +%Y-%m-%d-%H:%M:%S -d @$marca_de_tiempo) - No se pudo obtener información." >> $log
-fi
 
+		if [ $local_transaction_uuid == $remote_response ]; then
+			mv $registros/$file $historicos
+			echo -e "$remote_response: \e[92mOK\e[0m"
+		fi
+	else
+		echo -e "$local_transaction_uuid: \e[91mFAIL\e[0m"
+		# errores
+		unset srv_msg
+		unset curl_msg
+		err_time=$(date +%Y-%m-%d-%H:%M:%S)
+		[ ! -z "$remote_response" ] && srv_msg="- $( echo $remote_response | grep -o '<body.*>.*</body>')" 
+		[ -s "$curl_err" ] && curl_msg="- $(</tmp/curl_err)"
+		echo $err_time - $local_transaction_uuid - server status: $server_error $srv_msg $curl_msg >> $log
+		rm $curl_err
+	fi
 
+done 
 exit
 
-# habia una razon para esto, ya va a saltar
-
-for ((i=1 ; i <=3 ; i++));do
-	if echo $json | jsonlint-php 2> /dev/null;then
-		echo $json > $registros/$file && rm /opt/nodemecu/lock && echo $((counter+1)) > $contador && break
-	else
-		echo "$(date +%Y-%m-%d-%H:%M:%S) - No se pudo obtener información." >> /opt/nodemecu/errors.log && sleep 1
-	fi
-done
-