update

Reviewed-on: #11

0x01-temperatura/0x01-temperatura.ino

@@ -0,0 +1,68 @@
+
+#include <OneWire.h>
+#include <DallasTemperature.h>
+
+// Pin donde se conecta el bus 1-Wire
+const int pinDatosDQ = 2;
+
+// Instancia a las clases OneWire y DallasTemperature
+OneWire oneWireObjeto(pinDatosDQ);
+DallasTemperature sensorDS18B20(&oneWireObjeto);
+
+
+// Dispositivo
+const int devID = 1;
+char devIDstr[5];
+int inQuery;
+
+
+
+
+float getData() {
+
+  sensorDS18B20.requestTemperatures();
+  return (sensorDS18B20.getTempCByIndex(0));
+}
+
+
+void setup() {
+  Serial.begin(9600);
+  sensorDS18B20.begin();
+
+
+
+
+}
+void loop() {
+
+
+
+
+
+
+  if ( Serial.available() > 0) {
+    inQuery = Serial.read();
+    if ( inQuery == devID) {
+
+      Serial.write(itoa(devID, devIDstr, 10));
+      Serial.write(" ");
+      Serial.write("T");
+      Serial.write(" ");
+
+      
+      char lecturaStr[6]; // Buffer big enough for 7-character float
+      dtostrf(getData(), 2, 4, lecturaStr); // Leave room for too large numbers!
+
+
+      Serial.write(lecturaStr);
+      Serial.write(" ");
+      Serial.write("C");
+      Serial.write(" ");
+      Serial.write("99");
+
+
+    }
+
+  }
+
+}

0x01-temperatura/arduino_0x01.ino.bak

@@ -0,0 +1,29 @@
+int inData;
+
+void setup() {
+  Serial.begin(14400);
+}
+
+
+
+void loop() {
+
+  if ( Serial.available() > 0) {
+    inData = Serial.read();
+    switch (inData) {
+      case 0x01:
+        Serial.write("id:temperatura");
+        Serial.write(" ");
+        Serial.write("tp:temp");
+        Serial.write(" ");
+        Serial.write("vl:29");
+        Serial.write(" ");
+        Serial.write("un:C");
+        Serial.write(" ");
+        Serial.write("er:99");
+        Serial.write(" ");
+        Serial.write('\n');
+        break;
+    }
+  }
+}

0x01-temperatura/config.ino

@@ -0,0 +1 @@
+

0x02-turbidez/0x02-turbidez.ino

@@ -0,0 +1,50 @@
+
+// Dispositivo
+const int devID = 2;
+char devIDstr[5];
+int inQuery;
+
+
+
+
+int getData() {
+  int sensorValue = analogRead(A7);
+  return (map(sensorValue, 0, 700, 100, 0));
+}
+
+
+void setup() {
+  Serial.begin(9600);
+}
+
+
+void loop() {
+
+  Serial.write("\n");
+  delay(1000);
+
+  if ( Serial.available() > 0) {
+    inQuery = Serial.read();
+
+    if ( inQuery == devID) {
+
+      Serial.write(itoa(devID, devIDstr, 10));
+      Serial.write(" ");
+      Serial.write("Tur");
+      Serial.write(" ");
+
+      //char lecturaStr[6]; // Buffer big enough for 7-character float
+      //dtostrf(getData(), 2, 4, lecturaStr); // Leave room for too large numbers!
+      char lecturaStr[5]; // Buffer big enough for 7-character float
+      dtostrf(getData(), 3, 2, lecturaStr); // Leave room for too large numbers!
+
+      Serial.write(lecturaStr);
+      Serial.write(" ");
+      Serial.write("TSS");
+      Serial.write(" ");
+      Serial.write("99");
+
+    }
+  }
+
+}

README.md

@@ -1,13 +1,19 @@
-# Registrador de datos 'nodemecu'
 
+# Sistema Modular para la Captura de Datos y Muestras Ambientales
 
+**nombre clave: 'nodemecu'**
 
-El registrador de datos 'nodemecu' es un programa que se encarga de:
+El Sistema Modular para la Captura de Datos y Muestras Ambientales ('nodemecu') es un desarrollo conjunto de **Herramientas para el Buen Vivir A.C.** (México), la cooperativa de desarrollo digital **SUTTY** (Argentina), **BarraDev infraestructuras y telemetría** (Argentina) y la **Cooperativa de Producción Tecnológica, Gráfica y Audiovisual LTDA** (Argentina) con el apoyo económico de **Witness** (USA), como parte del acompañamiento realizado al Frente de Pueblos en Defensa de la Tierra y el Agua de Puebla, Morelos y Tlaxcala en el marco del proyecto de fortalecimiento **“Coral”**.
 
-- Tomar datos de los sensores asociados a los arduinos.
-- Enviar los datos a un servidor para su presentación.
+'**nodemecu**' consiste en un sistema electrónico autónomo sumergible con sensores que en tiempo real escanean las condiciones ambientales y envían esa información hacia un servidor web que almacena y despliega los datos de Temperatura, PH, Conductividad y Turbidez. Ante la detección de algún indicador de posible contaminación en el agua captura una muestra líquida de manera automatizada y sin intervención humana.
 
+La intención del proyecto es brindar una herramienta accequible y de bajo costo a las comunidades y organizaciones en defensa del territorio, que necesiten fortalecer su estrategia jurídica con datos y cifras  que comprueben la contaminación del medio ambiente. 
 
+El sistema, tanto en su hardware como software, ha sido diseñado de manera modular, de tal manera que permite la fácil implementación de otros sensores y sistemas de captura o comportamiento a partir de los diseños originales, todos los cuales serán publicados bajo licencias de software y hardware libre y puestos a disposición de las comunidades que lo necesiten.
+
+Durante los últimos 6 meses se ha trabajado intensamente en el desarrollo del software que permite el registro, transmisión, almacenamiento y despliegue de datos, el control de los sensores, el diseño de placa de montaje de los componentes y en los exteriores del sistema. Actualmente estamos iniciando la etapa de prototipado, que consiste en la construcción real del sistema, para en caso de cumplir con las espectativas de diseño, inicie su replicación y masificación.
+
+Para culminar esta etapa final antes de la implementación real en campo, hemos comprometido el apoyo del **Instituto de Desarrollo e Innovación Tecnológica de la Universidad Iberoamericana de Puebla** (IDIT - IBERO), quienes nos brindarán acompañamiento y asesoría.
 
 ## Instalación
 

esquematicos/README.md

@@ -0,0 +1,37 @@
+## Impresión PCB
+
+Fichero `impresion_v1.pdf` se utiliza como referencia para el montaje de componentes.
+
+Fichero `impresion_v1-invertido.pdf` es para imprimir y trasladar a placa PCB.
+
+## Lista de materiales
+
+| Insumo                                                       | Cantidad | Unidad | Total | Tienda                                                       | Imagen                                                       | Costo |
+| ------------------------------------------------------------ | -------- | ------ | ----- | ------------------------------------------------------------ | ------------------------------------------------------------ | ----- |
+| Socket DIP 30 (para Arduino Nano)                            | 4        | 69     | 276   | [enlace](https://articulo.mercadolibre.com.mx/MLM-927042088-10-base-socket-zocalo-28-pines-dip-ancha-dip28-_JM#position=13&search_layout=grid&type=item&tracking_id=50e3fda3-211b-4ca5-a739-4e8d0bc14b13) | ![](https://http2.mlstatic.com/D_NQ_NP_635359-MLA46668173367_072021-O.jpg) |       |
+| Arduino Nano                                                 | 4        | 159    | 636   | [enlace](https://articulo.mercadolibre.com.mx/MLM-603372065-arduino-nano-v30-cable-usb-_JM) | ![](https://www.hwlibre.com/wp-content/uploads/2020/04/arduino-nano.jpg) |       |
+| Raspberry Pi 4 2GB                                           | 1        | 1550   | 1550  | [enlace](https://www.geekfactory.mx/tienda/tarjetas/raspberry-pi/raspberry-pi-4-2-gb-ram-modelo-b/) | ![](https://www.newark.com/productimages/standard/en_US/02AH3161-40.jpg) |       |
+| Resistencia 10k 1%tolerancia                                 | 1        | 1      | 1     | [enlace](https://www.steren.com.mx/resistencia-de-pelicula-de-carbon-de-10-kohms-a-1-2-watt-con-5-de-tolerancia.html) | ![](https://http2.mlstatic.com/D_NQ_NP_930651-MLA43848144650_102020-W.jpg) |       |
+| Resistencia 4k7 1%tolerancia                                 | 1        | 20     | 20    |                                                              | ![](https://http2.mlstatic.com/D_NQ_NP_930651-MLA43848144650_102020-W.jpg) |       |
+| Resistencia 3k 1%tolerancia                                  | 1        | 1      | 1     |                                                              | ![](https://http2.mlstatic.com/D_NQ_NP_930651-MLA43848144650_102020-W.jpg) |       |
+| Resistencia 1k5 1%tolerancia                                 | 1        | 20     | 20    |                                                              | ![](https://http2.mlstatic.com/D_NQ_NP_930651-MLA43848144650_102020-W.jpg) |       |
+| Diodo Schottky 5v o más                                      | 4        | 20     | 80    |                                                              | ![](https://uelectronics.com/wp-content/uploads/AR0195-SCHOTTKY-DIODO-1N5819-2.jpg) |       |
+| Fusible chico                                                | 1        | 4      | 4     | [enlace](https://www.steren.com.mx/fusible-europeo-de-5-a-250-vca.html) |                                                              |       |
+| Porta fusible chico (30mm para placa)                        | 2        | 5      | 10    | [enlace](https://www.steren.com.mx/porta-fusible-abrazadera-europeo.html) | ![](https://http2.mlstatic.com/D_NQ_NP_967294-MLA48427348531_122021-O.webp) |       |
+| Botón pulsador                                               | 2        | 45     | 90    | [enlace](https://articulo.mercadolibre.com.mx/MLM-768086213-20-piezas-de-push-button-4-pines-6x6x43mm-_JM#position=8&search_layout=grid&type=item&tracking_id=e91406ce-8426-460f-a0c3-6a5dd90c3014) | ![](https://www.electronicshub.org/wp-content/uploads/2018/02/Raspberry-Pi-Push-Button-Interface-Push-Button.jpg) |       |
+| Sonda digital de temperatura DS18B20                         | 1        | 110    | 110   | [enlace](https://articulo.mercadolibre.com.mx/MLM-847988031-par-2-pzas-ds18b20-sensor-de-temperatura-sumergible-arduino-_JM#position=3&search_layout=grid&type=item&tracking_id=c8613538-bb28-4918-8ae8-fe46ff44ac58) | ![](https://http2.mlstatic.com/D_NQ_NP_760282-MLA31134211758_062019-O.webp) |       |
+| Sensor de turbidez SEN0189                                   | 1        | 415    | 415   | [enlace](https://www.geekfactory.mx/tienda/sensores/sensor-de-turbidez-analogico-gravity-dfrobot/) | ![](https://http2.mlstatic.com/D_NQ_NP_635928-MLM26497853219_122017-O.webp) |       |
+| Kit sensor de pH                                             | 1        | 5240   | 5240  | [enlace](https://atlas-scientific.com/kits/ph-kit/)          | [enlace](https://atlas-scientific.com/kits/ph-kit/)          |       |
+| Kit sensor de conductividad                                  | 1        | 6120   | 6120  | [enlace](https://atlas-scientific.com/kits/mini-conductivity-k-1-0-kit/) | [enlace](https://atlas-scientific.com/kits/mini-conductivity-k-1-0-kit/) |       |
+| Bomba de agua sumergible para arduino                        | 1        | 62     | 62    | [enlace](https://articulo.mercadolibre.com.mx/MLM-683758574-mini-bomba-de-agua-sumergible-36v-arduino-pic-_JM) |                                                              |       |
+| Conector de dos vías para cable hembra + 'Conector de dos vías para plaqueta macho recto | 6        | 45     | 270   | [enlace](https://articulo.mercadolibre.com.mx/MLM-905787098-2-juegos-conector-hembra-cable-y-macho-jst-125-mm-2-pin-_JM#position=3&search_layout=grid&type=item&tracking_id=c47d066e-77b4-474e-b220-2fee12dc0c5a) |                                                              |       |
+| Conector de tres vías para cable hembra+ 'Conector de tres vías para plaqueta hembra recto | 2        | 50     | 100   | [enlace](https://articulo.mercadolibre.com.mx/MLM-734108508-conector-jst-xh-macho-y-hembra-de-3-pines-_JM#position=14&search_layout=grid&type=item&tracking_id=d3ec06ea-1846-4284-99eb-7a0d8ef6ee26) | ![](https://www.electrogeekshop.com/wp-content/uploads/2020/06/conector-housing-hembra-paso-1-molex-3-vias-pack-x-25-D_NQ_NP_886142-MLA40809868011_022020-Q.jpg) |       |
+| celda de litio 18650 (si viene con la chapita de nickel les va a facilitar mucho al momento de soldar) | 56       | 20     | 1120  | [enlace](https://articulo.mercadolibre.com.mx/MLM-826413561-10-piezas-bateria-recargable-18650-ventilador-linterna-t2218-_JM?matt_tool=54306600&matt_word=&matt_source=google&matt_campaign_id=15697272376&matt_ad_group_id=128898863662&matt_match_type=&matt_network=g&matt_device=c&matt_creative=571860447281&matt_keyword=&matt_ad_position=&matt_ad_type=pla&matt_merchant_id=141916252&matt_product_id=MLM826413561&matt_product_partition_id=1429154252846&matt_target_id=pla-1429154252846&gclid=CjwKCAjwxOCRBhA8EiwA0X8hi6BBz86IZwYvJHgGO2gteos_GSVdfXCAoE5pvF6kMe783gNXFrFNWxoCyjUQAvD_BwE) | ![](https://http2.mlstatic.com/D_NQ_NP_711964-MLA48944801614_012022-O.webp) |       |
+| módulo de carga TP4056 con protección de descarga            | 1        | 14     | 14    | [enlace](https://www.geekfactory.mx/tienda/modulos/cargadores/modulo-tp4056-cargador-bateria/) | ![](https://http2.mlstatic.com/D_NQ_NP_600051-MLA45728093114_042021-O.webp) |       |
+| fuente DC-DC boost (step-up que pueda tomar 3v y subirlo a 5.5v) | 1        | 33     | 33    | [enlace](https://www.geekfactory.mx/tienda/modulos/reguladores/convertidor-dc-dc-step-up-boost/) | ![](https://http2.mlstatic.com/D_NQ_NP_660917-MLA45233216458_032021-O.webp) |       |
+| Placa PCB                                                    | 1        | 32     | 32    | [enlace](https://www.geekfactory.mx/tienda/protoboards/placa-fenolica-una-cara-10-x-15-cm/) |                                                              |       |
+| Cables Protoboard                                            | 1        | 52     | 52    | [enlace](https://articulo.mercadolibre.com.mx/MLM-602661891-cables-dupont-jumpers-para-protoboard-20cm-40piezas-_JM?quantity=1&variation_id=18583022758) |                                                              |       |
+| Tira header macho                                            | 4        | 9      | 36    | [enlace](https://www.geekfactory.mx/tienda/componentes/conectores/header-macho/) |                                                              |       |
+| Tira poste hembra                                            | 4        | 10     | 40    | [enlace](https://www.geekfactory.mx/tienda/componentes/conectores/header-hembra-tira-de-pines-sencilla/) |                                                              |       |
+
+

raspberry/arduinos.py

@@ -6,7 +6,7 @@ import sys
 
 ser = serial.Serial(
         port='/dev/serial0', #Replace ttyS0 with ttyAM0 for Pi1,Pi2,Pi0
-        baudrate = 14400,
+        baudrate = 9600,
         parity=serial.PARITY_NONE,
         stopbits=serial.STOPBITS_ONE,
         bytesize=serial.EIGHTBITS,
@@ -22,7 +22,7 @@ ser.flush()
 while True:
 		if ser.in_waiting > 0:
 			line = ser.readline().decode('utf-8', errors='replace').rstrip()
-			time.sleep(0.5)
+			#time.sleep(0.1)
 			print(line)
 			ser.flush()
 			break

raspberry/bin/nodemecu

@@ -7,7 +7,9 @@ fi
 # LECTURA FICHERO DE CONFIGURACION
 
 config=/etc/nodemecu.conf
+envs=/opt/nodemecu/envs
 source $config
+source $envs
 source $funciones
 
 [ -z $1 ] && exit 
@@ -34,7 +36,8 @@ case $com in
 		echo ""
 		echo "Creando juego de llaves"
 			source $config
-			generate_private_key
+			comentario="$nombre $numero_serie"
+			generate_private_key "$comentario"
 		echo ""
 		echo "El modo de operación por defecto es 'test' y se envían datos simulados, cambie a 'sensores' con el comando 'sudo nodemecu modo sensores'
 		"
@@ -53,10 +56,14 @@ case $com in
 		funcion_configurar $@
 		;;
 	captura)
+
+		test_conf_nombre || exit
+		test_conf_intervalo || exit
+		test_conf_key || exit
 		funcion_captura $2
 		;;
 	monitor)
-		$install_dir/monitor.sh
+		funcion_monitor	
 	  	;;
 	cllave)
 		if  [ -z $nombre ]; then
@@ -67,6 +74,7 @@ case $com in
 		fi
 		;;
 
+
 	*)
 		exit 
 		;;

raspberry/contador

@@ -1 +0,0 @@
-0

raspberry/desinstalar

@@ -1,12 +1,12 @@
 #!/bin/bash
 source /etc/nodemecu.conf
-
+source /opt/nodemecu/envs
 if [ $UID -ne 0 ]; then
 	echo "Ejecute 'sudo $0'"
 	exit
 fi
 
-seguro="Si, Estoy Seguro."
+seguro="Si, se lo que estoy haciendo."
 
 
 echo "Está a punto de desinstalar nodemecu, esta acción eliminará todos los archivos de instalacion y registros que se hayan tomado sin posiblidad de recuperación, haga un backup de:
@@ -18,9 +18,9 @@ echo "Está a punto de desinstalar nodemecu, esta acción eliminará todos los a
 Para continuar escriba la frase '$seguro'.
 "
 
-read -p "frase: " frase
+#read -p "frase: " frase
 
-if [ "$frase" = "$seguro" ];then
+#if [ "$frase" = "$seguro" ];then
 
 
 rm /etc/nodemecu.conf
@@ -32,8 +32,8 @@ systemctl disable nodemecu.service
 rm /lib/systemd/system/nodemecu.service
 systemctl daemon-reload
 
-else
+#else
 	echo "La frase de seguridad no concuerda.
 	"
 
-fi
+#fi

raspberry/envs

@@ -0,0 +1,31 @@
+# NO MODIFICAR ESTE FICHERO !!!!!!!!!!
+
+numero_serie=0000000083a999fd
+curl_err=/tmp/curl_err
+directorio_instalacion=/opt/nodemecu
+registros=$directorio_instalacion/registros
+historicos=$directorio_instalacion/historicos
+log=/var/log/nodemecu_errors.log
+registros_corruptos=$directorio_instalacion/corruptos
+lock=$directorio_instalacion/lock
+funciones=$directorio_instalacion/funciones
+arduinos_py=$directorio_instalacion/arduinos.py
+key_dir=$directorio_instalacion/llaves
+private_key=$key_dir/$numero_serie.key
+public_key=$key_dir/$numero_serie.key.pub
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+

raspberry/funciones

@@ -2,17 +2,13 @@
 #set -x
 get_stack () {
 	if [[ ! -z $1 && $1 == "wc" ]];then
-		ls -I "*.sign" $registros | wc -l 
+		ls -I "*.sig" $registros | wc -l 
 	else
-		ls -I "*.sign" $registros | tail -1
+		ls -I "*.sig" $registros | tail -1
 	fi
 }
 
-
-
 # Generar una llave privada ECDSA si no existe
-# 
-# Uso: generate_private_key "comentario"
 generate_private_key () {
   test -f "$private_key" && return 1
 
@@ -27,13 +23,11 @@ sign_file () {
   local _file="$1"
 
   test ! -f "$_file" && return 1
-  test -f "$_file.sig" || ssh-keygen -Y sign -f "$private_key" -n file "$_file" 2>&1 >/dev/null
-
+  test -f "$_file.sig" || ssh-keygen -Y sign -f "$private_key" -n file "$_file"  >/dev/null 2>&1
   cat "${_file}.sig" | grep -v SIGNATURE | tr -d "\n"
 }
 
 
-
 funcion_datos_simulados() {
 	
 	lecturas="id:dummy_plug-01 tp:temp vl:$(( $RANDOM % 20 + 15 )) un:C er:99 AD_SENSOR tp:hum vl:$(( $RANDOM % 50 + 35 )) un:percent er:99 AD_ARDUINO id:dummy_plug-02 tp:temp vl:$(( $RANDOM % 20 + 15 )) un:C er:99 AD_SENSOR tp:hum vl:$(( $RANDOM % 50 + 35 )) un:percent er:99 AD_ARDUINO id:dummy_plug-03 tp:temp vl:$(( $RANDOM % 20 + 15 )) un:C er:99 AD_SENSOR tp:hum vl:$(( $RANDOM % 50 + 35 )) un:percent er:99 AD_ARDUINO id:dummy_plug-04 tp:temp vl:$(( $RANDOM % 20 + 15 )) un:C er:99 AD_SENSOR tp:hum vl:$(( $RANDOM % 50 + 35 )) un:percent er:99 END"
@@ -43,13 +37,14 @@ funcion_datos_simulados() {
 funcion_datos_sensores() {
 
 	peticiones=1
-	arduinos=( 0x01 0x02 )
+	arduinos=( 1 2 )
 	for arduino_id in ${arduinos[@]};do
 	lectura_arduino=($(timeout 3 $arduinos_py $arduino_id))
 
 	let "bloques = (${#lectura_arduino[@]} - 1) / 4"
 
-	lecturas="$lecturas id:${lectura_arduino[0]}"
+	#lecturas="$lecturas id:${lectura_arduino[0]}"
+	lecturas="$lecturas id:${arduino_id[0]}"
 
 	indice=1
 	vueltas=1
@@ -120,6 +115,9 @@ case $comando in
 			if [[ $parametro -ge 1 && $parametro -le 60 ]]; then
 				sed -i 's/intervalo=[0-9]*/intervalo='$parametro'/' $config
                 		echo "Intervalo seteado en $parametro"
+				echo "Para aplicar los cambios ejecute
+					sudo nodemecu captura dentener
+					sudo nodemecu captura iniciar"
 				break
 	        	else
         	        	echo "Establezca un valor entre 1 y 60."
@@ -145,16 +143,8 @@ esac
 
 funcion_captura() {
 	
-	if [ "$1" = "iniciar" ]; then 
 
-		if [ -z $intervalo ]; then
-			echo "Asegurese de haber establecido 'intervalo' de regitro y envio de datos."
-			exit 1
-		fi
-		if [ -z $nombre ]; then
-			echo "Asegurese de haber establecido el 'nombre' de dispositivo."
-			exit 1
-		fi
+	if [ "$1" = "iniciar" ]; then 
 
 		echo "Iniciando la captura de datos en modo '$modo'"
 		echo ""
@@ -175,3 +165,107 @@ funcion_captura() {
 	fi
 }
 
+
+### Validaciones
+
+test_conf_nombre() {
+
+	if [ -z $nombre ]; then
+		echo "No se establecio un nombre para el dispositivo."
+		return 1
+	fi
+}
+
+
+test_conf_servidor () {
+
+	if [ -z $servidor ];then
+		echo "No se establecio un servidor de entrega."
+		return 1
+	fi
+}
+
+test_conf_intervalo() {
+
+	if [ -z $intervalo ];then
+		echo "No se establecio un intervalo de captura."
+		return 1
+	fi
+}
+
+test_conf_key() {
+
+	if [ ! -f $private_key ];then
+	       	echo "No se creo juego de llaves."
+		return 1
+	fi
+}
+
+
+
+
+funcion_validador_json() {
+	
+	validar="$@"
+
+	echo $validar | jsonlint-php > /dev/null 2>&1 || return 1
+}
+
+funcion_verificar_internet() {
+
+	if host fsf.org > /dev/null 2>&1; then
+		return 0
+	else
+		return 1
+	fi
+
+}
+
+funcion_espera() {
+	sleep 1m
+	#sleep ${intervalo:-1}m
+
+}
+
+
+funcion_envio_registro() {
+
+		curl -s --show-error -w "~%{http_code}" \
+			-X POST -H "X-Signature: $(sign_file $registros/$file)" \
+			-H "Content-Type: application/json" -d @$registros/$file \
+			$servidor 2> $curl_err
+
+}
+
+
+funcion_monitor() {
+	local sb="\x1b["
+	local eb="\x1b[K\x1b[0m"
+	local st="\e["
+	local et="\e[0m"
+
+	while :;do
+		clear
+		echo -e "${sb}1;44;97m Nodemecu Monitor${eb}"
+		echo ""
+		echo -e "${st}1;94mNombre:${et} $nombre ${st}1;94mServidor:${et} $servidor ${st}1;94mIntervalo:${et} $intervalo"
+		echo ""
+		echo -e "${sb}1;44;97m Registros${eb}"
+		echo ""
+		echo -e "En cola: $(ls -I *.sig $registros| wc -l)"
+		echo -e "Enviados: $(ls -I *.sig $historicos | wc -l)"
+		echo -e "Registros corrupts: $(ls -I *.sig $registros_corruptos | wc -l)"
+		echo ""
+		echo -e "${sb}1;44;97m Ultimos mensajes${eb}"
+		echo ""
+		echo -e ${st}1m"Systemd unit 'nodemecu.service'${et}"
+		journalctl -n 3 -u nodemecu
+		echo ""
+		echo -e ${st}1m"Fichero '$log'${et}"
+		cat /var/log/nodemecu_errors.log | grep -v "Salida de curl" | grep -v '[*<>{}]' | tail -3
+
+		sleep 2 
+	done
+
+}
+

raspberry/generador_json

@@ -1,10 +1,13 @@
 #!/bin/bash
 
 source /etc/nodemecu.conf
+source /opt/nodemecu/envs 
 source $funciones 
 
-conteo=$(cat $contador)
-uuid="$(uuidgen)"
+test -z $nombre && exit
+test -f $public_key || exit
+
+uuid="$(uuid)"
 marca_de_tiempo="$(date +%s)"
 
 
@@ -49,32 +52,19 @@ case $i in
 esac
 done
 
+sensores=$(echo $sensores | tr -d '[:blank:]')
 
-
-
-json="{\"transaction_uuid\":\"$uuid\",\"serial_number\":\"$(cat $numero_serie)\",\"controller_id\":\"$nombre\",\"timestamp\":\"$marca_de_tiempo\",\"error_code\":\"10\",\"coordinates\":{\"lat\":1,\"lng\":1},\"battery_status\":\"98\",\"sample\":\"0\",\"storage\":\"uso del almacenamiento\",\"arduinos\":[$sensores]}"
+json="{\"transaction_uuid\":\"$uuid\",\"serial_number\":\"$numero_serie\",\"public_key\":\"$(cat $public_key)\",\"controller_id\":\"$nombre\",\"timestamp\":\"$marca_de_tiempo\",\"error_code\":\"10\",\"coordinates\":{\"lat\":1,\"lng\":1},\"battery_status\":\"98\",\"sample\":\"0\",\"storage\":\"uso del almacenamiento\",\"arduinos\":[$sensores]}"
 
 touch $lock
 file=$(date +%Y%m%d%H%M%S -d @$marca_de_tiempo)-$uuid
 
-
-
-if echo $json | jsonlint-php 2> /dev/null;then
-	echo $json > $registros/$file && rm $lock && echo $((conteo+1)) > $contador 
+if funcion_validador_json $json ;then
+	echo $json > $registros/$file && rm $lock 
 else
-	echo "$(date +%Y-%m-%d-%H:%M:%S -d @$marca_de_tiempo) - No se pudo obtener información." >> $log
+	echo "$(date +%Y-%m-%d-%H:%M:%S -d @$marca_de_tiempo) - No se pudo generar fichero json:" >> $log
+	echo $json >> $log
 	rm $lock
 fi
 
 
-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 > /opt/nodemecu/stack/$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

raspberry/instalador

@@ -1,21 +1,26 @@
 #!/bin/bash
 #set -x
-configuracion=nodemecu.conf.ejemplo
-source $configuracion
 
 if [ $UID -ne 0 ]; then
 	echo "Ejecute 'sudo $0'"
 	exit	
 fi
 
+basedir=$( cd -- "$( dirname -- "${BASH_SOURCE[0]}" )" &> /dev/null && pwd )
+
+configuracion=$basedir/nodemecu.conf.ejemplo
+envs=$basedir/envs
+
+source $configuracion
+source $envs
+
 if [ -d $directorio_instalacion ] ; then
 	echo "nodemecu ya se encuentra instalado"
 	exit
 
 fi
 
-ficheros="bin arduinos.py contador generador_json funciones monitor monitor_web nodemecu.service registrador desinstalar"
-
+ficheros="bin envs arduinos.py generador_json funciones registrador desinstalar"
 
 # Dependencias
 
@@ -32,13 +37,10 @@ echo "2. Creando directorios y copiando archivos"
 echo "
 Creación de directorios
 "
-mkdir -vp $directorio_instalacion/archives/historical
-mkdir -v $directorio_instalacion/archives/logs 
-mkdir -v $registros_corruptos
-mkdir -v $envios_fallidos
+mkdir -vp $registros_corruptos
 mkdir -v $historicos
 mkdir -v $registros
-mkdir -v $private_key_dir
+mkdir -v $key_dir
 echo "
 Copiado de archivos
 "
@@ -59,7 +61,7 @@ ls $log
 echo "3. Configurando systemd
 "
 
-cp nodemecu.service /lib/systemd/system/
+cp -v nodemecu.service /lib/systemd/system/
 systemctl daemon-reload
 
 echo "
@@ -67,7 +69,8 @@ echo "
 "
 
 sn=$(cat /proc/cpuinfo | grep Serial | cut -d ' ' -f 2)
-echo $sn > $numero_serie
+
+sed -i 's/numero_serie=/numero_serie='$sn'/' $directorio_instalacion/envs
 
 echo "Número de serie: $sn"
 

raspberry/monitor

@@ -1,16 +0,0 @@
-#!/bin/bash
-
-source /etc/nodemecu.conf
-while :;do 
-	clear
-	echo "$(date)"
-	echo "Stack: $(ls $stack | wc -l) ficheros"
-	echo "Historicos: $(ls $historical | wc -l) ficheros"
-	echo "Testigo: $(cat $install_dir/counter)"
-	echo "Errores: $(wc -l $log) registros"
-	echo "Ultimo error registrado:"
-	tail -1 $log 
-	echo ""
-	echo "'ctrl-c' para salir."
-	sleep 100
-done

raspberry/monitor_web

@@ -1,11 +0,0 @@
-#!/bin/bash
-
-source /etc/nodemecu.conf
-	echo "<p>$(date)<br>"
-	echo "Stack: $(ls $stack | wc -l) ficheros<br>"
-	echo "Historicos: $(ls $historical | wc -l) ficheros<br>"
-	echo "Testigo: $(cat $install_dir/counter)<br>"
-	echo "Errores: $(wc -l $log) registros<br>"
-	echo "Ultimos errores registrados<br>" 
-	tail -1 $log 
-	echo "<br></p>"

raspberry/nodemecu

@@ -1,76 +0,0 @@
-#!/bin/bash
-if [ $UID -ne 0 ]; then
-	echo "Ejecute 'sudo $0'"
-	exit	
-fi
-
-# LECTURA FICHERO DE CONFIGURACION
-
-config=/etc/nodemecu.conf
-source $config
-source $funciones
-
-[ -z $1 ] && exit 
-
-
-com=$1
-
-case $com in
-
-	configurar)
-		echo "Complete los cambios a continuación: 
-		"
-		echo "Nombre del dispositivo."
-		read -p "nombre: " -a entrada_usuario
-		funcion_configurar nombre ${entrada_usuario[@]}
-		echo ""
-		echo "Servidor de entrega de datos."
-		read -p "servidor (ej. https://url.del/servidor): " entrada_usuario
-		funcion_configurar servidor $entrada_usuario
-		echo ""
-		echo "Intervalo de toma de muestras, entre 1 y 60 minutos."
-		read -p "intervalo: " entrada_usuario
-		funcion_configurar intervalo $entrada_usuario
-		echo ""
-		echo "Creando juego de llaves"
-			source $config
-			generate_private_key
-		echo ""
-		echo "El modo de operación por defecto es 'test' y se envían datos simulados, cambie a 'sensores' con el comando 'sudo nodemecu modo sensores'
-		"
-		;;
-
-	nombre)
-		funcion_configurar $@
-		;;
-	servidor)
-		funcion_configurar $@
-		;;
-	intervalo)
-		funcion_configurar $@
-		;;
-	modo)
-		funcion_configurar $@
-		;;
-	captura)
-		funcion_captura $2
-		;;
-	monitor)
-		$install_dir/monitor.sh
-	  	;;
-	cllave)
-		if  [ -z $nombre ]; then
-			echo "Debe establecer primero el nombre del dispositivo"
-		else
-			echo "Creando juego de llaves"
-			generate_private_key
-		fi
-		;;
-
-	*)
-		exit 
-		;;
-
-esac
-
-

raspberry/nodemecu.conf.ejemplo

@@ -2,24 +2,3 @@ nombre=
 servidor=
 intervalo=
 modo=test
-
-
-# AJUSTES GENERALES
-# SE RECOMIENDA NO MODIFICAR ESTAS LINEAS
-
-curl_err=/tmp/curl_err
-historical_file_size=1440
-logs_file_size=1440
-directorio_instalacion=/opt/nodemecu
-registros=$directorio_instalacion/registros
-historicos=$directorio_instalacion/historicos
-log=/var/log/nodemecu_errors.log
-registros_corruptos=$directorio_instalacion/corruptos
-envios_fallidos=$directorio_instalacion/fallidos
-contador=$directorio_instalacion/contador
-lock=$directorio_instalacion/lock
-funciones=$directorio_instalacion/funciones
-arduinos_py=$directorio_instalacion/arduinos.py
-private_key_dir=$directorio_instalacion/llaves
-private_key=$private_key_dir/$nombre.pem
-numero_serie=$directorio_instalacion/numero_serie

raspberry/registrador

@@ -1,69 +1,80 @@
 #!/bin/bash
+#set -x
 source /etc/nodemecu.conf
+source /opt/nodemecu/envs
 source $funciones 
 
-
-# Revisando stack
-
-for registro_json in $registros/*;do
-	test  "$registro_json" = "/opt/nodemecu/stack/\*"  || break
-	jsonlint-php $registro_json > /dev/null || mv -v $registro_json $registros_corruptos
-done
-
 while :;do
 	
 	# archivo a procesar
 	file=$(get_stack)
 
+	# si no hay nada que procesar reinicia el bucle
+	test -z $file && funcion_espera && continue
+
 	# si no hay servidor definido se reinicia el bucle
-	# espera el intervalo definido o 1 minuto.
-	#[ -z $servidor ] && echo "no se ha definido un servidor de entrega" && sleep ${intervalo:-1}m && continue
+	test -z $servidor && echo "No se configuró nigun servidor de entrega." && funcion_espera && continue
 
-
-	# si no hay nada en el directorio registros reinicia el bucle
-	# espera el intervalo definido o 1 minuto.
-	[ -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 no hay internet reinica el bucle
+	if ! funcion_verificar_internet; then
+		err_time=$(date +%Y-%m-%d-%H:%M:%S)
+		echo "$err_time - Parece no haber internet." | tee -a $log
+		funcion_espera
+		continue
+	fi
 
 	# si el fichero 'lock' existe (se esta creando un nuevo registro) reinicia el bucle
-	[ -f $lock ] && continue
+	test -f $lock && continue
 
+	# validación del fichero
+	if ! funcion_validador_json "$(cat $registros/$file)";then
+	       	mv $registros/$file $registros_corruptos
+		continue
+	fi
+
+	# firmado de regisro
+	firma=$(sign_file $registros/$file)
+
+	# UUID del registro a enviar
+	uuid_registro=$(jq -r '."transaction_uuid"' $registros/$file)
+
+	# envio de registro
+	transaccion=$(curl  -v -s --show-error -w "~%{http_code}" -X POST -H "X-Signature: $(sign_file $registros/$file)" -H "Content-Type: application/json" -d @$registros/$file $servidor 2> $curl_err)
+
+	# respuestas del servidor
+	respuesta_servidor="$(echo $transaccion | cut -d '~' -f 1)"
+	error_servidor="$(echo $transaccion | cut -d '~' -f 2)"
+
+	if [ ${#respuesta_servidor} -eq 36 ] && [ "$uuid_registro" == "$respuesta_servidor" ]; then
+			echo -e "$respuesta_servidor: \e[92mOK\e[0m"
+			mv $registros/$file $registros/$file.sig $historicos
+	else
+
+		err_time=$(date +%Y-%m-%d-%H:%M:%S)
+		srv_msg="$(echo $respuesta_servidor | grep -o '<body.*>.*</body>')" 
+		echo -e "$err_time - $uuid_registro: \e[91mFAIL\e[0m"
+
+		echo "$err_time - $uuid_registro - Error del servidor: $error_servidor" >> $log
+		echo "$err_time - $uuid_registro - Mensaje del servidor:" >> $log
+		echo "$srv_msg" >> $log
+		if [ -s $curl_err ];then
+			echo "$err_time - $uuid_registro - Salida de curl:" >> $log
+			cat $curl_err >> $log
+		fi
+
+		rm $curl_err
+		#funcion_espera
+	fi
+
+	#exit
+done 
+
+
+
+######
 
 	# 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
-
-	# firma de registros
-	sign_file $registros/$file
-	firma="$(cat $registros/$file.sign)"
-	
-
-	local_transaction_uuid=$(jq -r '."transaction_uuid"' $registros/$file)
-	remote_transaction=$(curl -s --connect-timeout 1,5 --show-error -w "~%{http_code}" -X POST -H "X-Signature: $firma" -H "Content-Type: application/json" -d @$registros/$file $servidor 2> $curl_err)
-	remote_response="$(echo $remote_transaction | cut -d '~' -f 1)"
-	server_error="$(echo $remote_transaction | cut -d '~' -f 2)"
-	if [ ${#remote_response} -eq 36 ];then
-
-		if [ $local_transaction_uuid == $remote_response ]; then
-			mv $registros/$file $registros/$file.sign $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
-

raspberry/test

@@ -1,13 +0,0 @@
-#!/bin/bash
-
-
-
-
-
-if timeout 1 python arduinos.py 0x05; then
-
-	echo respondio
-else
-	echo "No respondio, erro $?"
-
-fi