ufd_exporter.sh

#!/usr/bin/env bash

set -Eeo pipefail

dependencies=(awk curl date gzip jq tr)
for program in "${dependencies[@]}"; do
    command -v "$program" >/dev/null 2>&1 || {
        echo >&2 "Couldn't find dependency: $program. Aborting."
        exit 1
    }
done

# shellcheck source=/dev/null
source "$CREDENTIALS_DIRECTORY/creds"

[[ -z "${INFLUXDB_HOST}" ]] && echo >&2 "INFLUXDB_HOST is empty. Aborting" && exit 1
[[ -z "${INFLUXDB_API_TOKEN}" ]] && echo >&2 "INFLUXDB_API_TOKEN is empty. Aborting" && exit 1
[[ -z "${ORG}" ]] && echo >&2 "ORG is empty. Aborting" && exit 1
[[ -z "${BUCKET}" ]] && echo >&2 "BUCKET is empty. Aborting" && exit 1
[[ -z "${UFD_USERNAME}" ]] && echo >&2 "UFD_USERNAME is empty. Aborting" && exit 1
[[ -z "${UFD_PASSWORD}" ]] && echo >&2 "UFD_PASSWORD is empty. Aborting" && exit 1
[[ -z "${CUPS}" ]] && echo >&2 "CUPS is empty. Aborting" && exit 1

AWK=$(command -v awk)
CURL=$(command -v curl)
DATE=$(command -v date)
GZIP=$(command -v gzip)
JQ=$(command -v jq)
TR=$(command -v tr)

TODAY=$($DATE +"%d/%m/%Y")
MONTH_AGO=$($DATE +"%d/%m/%Y" --date "30 days ago")

INFLUXDB_URL="https://$INFLUXDB_HOST/api/v2/write?precision=s&org=$ORG&bucket=$BUCKET"
UFD_LOGIN_URL="https://api.ufd.es/ufd/v1.0/login"
UFD_API_URL="https://api.ufd.es/ufd/v1.0/consumptions"

ufd_token=$(
    $CURL --silent --fail --show-error \
        --compressed \
        --request POST \
        --data "{\"user\": \"$UFD_USERNAME\",\"password\": \"$UFD_PASSWORD\"}" \
        --header 'Accept-Encoding: gzip, deflate, br' \
        --header 'X-Appclientid: 1f3n1frmnqn14arndr3507lnok' \
        --header 'X-AppClient: ACUFDW' \
        --header 'X-Application: ACUFD' \
        --header 'X-Appversion: 1.0.0.0' \
        --header 'X-AppClientSecret: 102sml3ajvkdjakoh2rhgrfpvjogl4b0or5nqmcmilvt2odpu9ce' \
        --header 'X-MessageId: 1f3n1frmnqn14arndr3507lnok' \
        --header "Content-Type: application/json" \
        --header 'Content-Encoding: application/json' \
        "$UFD_LOGIN_URL" |
        $JQ --raw-output '.accessToken'
)

ufd_query="$UFD_API_URL?filter="
ufd_query+="nif::$UFD_USERNAME"
ufd_query+="%7Ccups::$CUPS%7C"
ufd_query+="startDate::$MONTH_AGO%7C"
ufd_query+="endDate::$TODAY%7C"
ufd_query+="granularity::H%7C"
ufd_query+="unit::K%7C"
ufd_query+="generator::0%7C"
ufd_query+="isDelegate::N%7C"
ufd_query+="isSelfConsumption::0%7C"
ufd_query+="measurementSystem::O"

ufd_json=$(
    $CURL --silent --fail --show-error \
        --compressed \
        --request GET \
        --header 'Accept-Encoding: gzip, deflate, br' \
        --header "Authorization: Bearer $ufd_token" \
        --header 'X-Appclientid: 1f3n1frmnqn14arndr3507lnok' \
        --header 'X-AppClient: ACUFDW' \
        --header 'X-Application: ACUFD' \
        --header 'X-Appversion: 1.0.0.0' \
        --header 'X-AppClientSecret: 102sml3ajvkdjakoh2rhgrfpvjogl4b0or5nqmcmilvt2odpu9ce' \
        --header 'X-MessageId: 1f3n1frmnqn14arndr3507lnok' \
        --header "Content-Type: application/json" \
        --header 'Content-Encoding: application/json' \
        "$ufd_query" |
        $JQ '.items'
)

price_stats=$(
    echo "$ufd_json" |
        $JQ --raw-output "
        (.[].consumptions.items[] |
        [\"${CUPS}\",
        if .consumptionValueP1  == \"\" then \"0\" else .consumptionValueP1 end,
        if .consumptionValueP2  == \"\" then \"0\" else .consumptionValueP2 end,
        if .consumptionValueP3  == \"\" then \"0\" else .consumptionValueP3 end,
        if .consumptionValueP4  == \"\" then \"0\" else .consumptionValueP4 end,
        if .consumptionValueP5  == \"\" then \"0\" else .consumptionValueP5 end,
        if .consumptionValueP6  == \"\" then \"0\" else .consumptionValueP6 end,
        ( (.consumptionDate? + ((if .hour == 24 then 0 else .hour end) | tostring)) | strptime(\"%d/%m/%Y%H\") | todate | fromdate)
        ])
        | @tsv" |
        $TR , . |
        $AWK '{printf "ufd_consumption,cups=%s p1=%s,p2=%s,p3=%s,p4=%s,p5=%s,p6=%s %s\n", $1, $2, $3, $4, $5, $6, $7, $8}'
)

echo "${price_stats}" |
    $GZIP |
    $CURL --silent --fail --show-error \
        --request POST "${INFLUXDB_URL}" \
        --header 'Content-Encoding: gzip' \
        --header "Authorization: Token $INFLUXDB_API_TOKEN" \
        --header "Content-Type: text/plain; charset=utf-8" \
        --header "Accept: application/json" \
        --data-binary @-