Compare commits

...

10 commits

Author SHA1 Message Date
f d2f30d8fe7 si no hay archivos que enviar esperar al próximo intervalo 2022-03-03 15:13:39 -03:00
f 9fef227f5e get_stack solo trae el último archivo de la cola
las funciones hacen una sola cosa
2022-03-03 15:09:52 -03:00
f b8d45a0adf no crear los directorios si ya existen 2022-03-03 15:09:06 -03:00
f 2feee6f70b mover los archivos fallados a otro directorio
de lo contrario detienen el envío porque el stack siempre devuelve el fallado
2022-03-03 15:08:32 -03:00
f 4411d7ee0c probar la conexión sólo cuando hay un archivo para enviar 2022-03-03 15:06:00 -03:00
f 6105e5948e el id de transaccion es el mismo del archivo 2022-03-03 14:53:01 -03:00
f 623dccb301 solo el estado 200 indica que está todo bien 2022-03-03 14:49:39 -03:00
f 0b77d81c2b detener el loop si se lo pedimos amablemente 2022-03-03 14:47:52 -03:00
f f148b14b92 no declarar variables que se usan una vez 2022-03-03 14:37:09 -03:00
f a921e1fd5d usar el archivo de error configurado
además no hace falta borrarlo
2022-03-03 14:35:39 -03:00
5 changed files with 22 additions and 26 deletions

View file

@ -43,7 +43,7 @@ uuid="$(uuidgen)"
timestamp="$(date +%s)"
json="{\"transaction_uuid\":\"$uuid\",\"controller_id\":\"$name\",\"timestamp\":\"$timestamp\",\"error_code\":\"10\",\"coordinates\":{\"lat\":1,\"lng\":1},\"battery_status\":\"98\",\"sample\":\"0\",\"storage\":\"uso del almacenamiento\",\"arduinos\":[$sensores]}"
touch $install_dir/lock
file=$(date +%Y%m%d%H%M%S)-$(uuidgen)
file=$(date +%Y%m%d%H%M%S)-$uuid
for ((i=1 ; i <=3 ; i++));do
if echo $json | $json_linter >/dev/null 2>&1 ;then
echo $json > $install_dir/stack/$file && rm $install_dir/lock && echo $((counter+1)) > $install_dir/counter && break

View file

@ -1,10 +1,3 @@
get_stack () {
if [[ ! -z $1 && $1 == "wc" ]];then
ls $install_dir/stack | wc -l
else
ls $install_dir/stack | tail -1
fi
ls $install_dir/stack | tail -1
}

View file

@ -15,9 +15,10 @@ echo -e "2. Creando directorios y copiando archivos"
sudo mkdir -vp $install_dir/archives/historical
sudo mkdir -vp $install_dir/archives/logs
sudo mkdir $historical
sudo mkdir $stack
sudo mkdir $corrupt
sudo mkdir -vp $historical
sudo mkdir -vp $stack
sudo mkdir -vp $corrupt
sudo mkdir -vp $failed
echo ""
sudo cp -vr $files $install_dir
sudo cp -v $config /etc/nodemecu.conf

View file

@ -15,3 +15,4 @@ stack=$install_dir/stack
historical=$install_dir/historical
log=$install_dir/errors.log
corrupt=$install_dir/corrupt
failed=$install_dir/failed

View file

@ -13,34 +13,35 @@ for filename in $install_dir/stack/*;do
done
while :;do
[ -f $install_dir/stop ] && break
[ -f $install_dir/lock ] && continue
file=$(get_stack)
[ -z $file ] && sleep ${interval:-1}m && continue
ping -c 1 fsf.org > /dev/null 2>&1 || continue
test_url="$(curl -s -X POST -o /dev/null -w "%{http_code}" $url)"
if [ $test_url -eq 404 ];then
if [ $test_url -ne 200 ];then
echo "$(date +%Y-%m-%d-%H:%M:%S) - $url - $test_url" >> $log && sleep 300 && continue
fi
file=$(get_stack)
[ -z $file ] && continue
local_transaction_uuid=$(jq -r '."transaction_uuid"' $stack/$file)
remote_transaction=$(curl -s --connect-timeout 0.9 --show-error -w "~%{http_code}" -X POST -H "Content-Type: application/json" -d @$stack/$file $url 2> $curl_err)
file="$stack/$file"
local_transaction_uuid="$(echo "$file" | cut -d - -f 2-)"
remote_transaction=$(curl -s --connect-timeout 1 --show-error -w "~%{http_code}" -X POST -H "Content-Type: application/json" -d @$file $url 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 $stack/$file $historical
echo -e "$remote_response: \e[92mOK\e[0m"
fi
if [ "$local_transaction_uuid" = "$remote_response" ]; then
mv $file $historical
echo -e "$remote_response: \e[92mOK\e[0m"
else
mv $file $failed
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
[ -s "$curl_err" ] && curl_msg="- $(<$curl_err)"
echo $(date +%Y-%m-%d-%H:%M:%S) - $local_transaction_uuid - server status: $server_error $srv_msg $curl_msg >> $log
fi
done