diff --git a/testdata/moonfire-nvr/.movement_detection_via_api_ffmpeg.sh.swp b/testdata/moonfire-nvr/.movement_detection_via_api_ffmpeg.sh.swp new file mode 100644 index 0000000..5a24411 Binary files /dev/null and b/testdata/moonfire-nvr/.movement_detection_via_api_ffmpeg.sh.swp differ diff --git a/testdata/moonfire-nvr/movement_detection_to_rclone_via_ffmpeg.sh b/testdata/moonfire-nvr/movement_detection_to_rclone_via_ffmpeg.sh new file mode 100644 index 0000000..8f92666 --- /dev/null +++ b/testdata/moonfire-nvr/movement_detection_to_rclone_via_ffmpeg.sh @@ -0,0 +1,57 @@ +#! /bin/bash +disabled="false" +threshold="0.040" +vdir=/tmp/tmpfs +exec > >(tee "$vdir/backup.log") 2>&1 +if ! [ -d "$vdir" ]; then + echo $vdir does not exist >&2 + exit 1 +fi +if ps aux | \ + grep -v grep | \ + grep -E 'services.backups.rclone|local.ffprobe'; then + echo skipping colliding run >&2 + exit 0 +fi +echo ok at 1 +files=($(find $vdir -type f -name "*.m*")) +if [ "${#files[@]}" == "0" ]; then + echo no files found >&2 + exit 0 +fi +echo files=${files[@]} +includes=() +printf "reviewing"; printf " %s\n" "${files[@]}" +echo ok at 2 +for file in "${files[@]}"; do + frames="$( + nice -n 19 /var/services/homes/squeaky2x3/ffmpeg-local/ffprobe \ + -threads 1 -loglevel error -hide_banner -show_frames -of compact=p=0 \ + -f lavfi "movie=$file,select=gt(scene\\,$threshold)" 2> /dev/null \ + )" + ret=$? + if [ $ret -eq 0 ] && [ $(printf "%s\n" "$frames" | wc -l) -lt 2 ]; then + echo file has no movement $file >&2 + rm -f "$file" + elif [ $ret -ne 0 ]; then + echo failed scanning $file >&2 + files=("${files[@]/"$file"}") + else + echo file has movement $file + includes+=("$(basename "$file")") + fi +done +echo "pushing files ${includes[@]}" +if [ "${#includes[@]}" -gt 0 ]; then + if [ "$disabled" == "true" ] || \ + /volume1/homes/squeaky2x3/services/backups/rclone \ + --config /volume1/homes/squeaky2x3/services/backups/rclone.conf \ + copy \ + $vdir/ \ + blapointe-drive:/projects/cctv/ut/ \ + $(printf " --include %s" "${includes[@]}") ; then + rm -f "${files[@]}" + fi +fi +echo donezo +echo why diff --git a/testdata/moonfire-nvr/movement_detection_via_api_ffmpeg.sh b/testdata/moonfire-nvr/movement_detection_via_api_ffmpeg.sh new file mode 100644 index 0000000..8546bac --- /dev/null +++ b/testdata/moonfire-nvr/movement_detection_via_api_ffmpeg.sh @@ -0,0 +1,64 @@ +#! /bin/bash + +main() { + local one_hour_ago_unix="$(($(date +%s) - 60 * 60))" + local one_hour_ago_ts="$(date -d @$one_hour_ago_unix -u +%Y-%m-%dT%H:%M:%SZ)" + + for uuid in $( + api /api/ | jq -r .cameras[].uuid + ); do + local stream=main + for recording in $( + api /api/cameras/$uuid/$stream/recordings \ + | jq -c '.recordings[] | [.startId, .growing, .startTime90k]' \ + | grep -v ,true, \ + | jq -r .[0] \ + | sort -n #-r + ); do + api "/api/cameras/$uuid/$stream/view.mp4?s=$recording&ts=true" > /tmp/f.mp4 + + local ts="$(ffprobe /tmp/f.mp4 2>&1 | grep creation_time | tail -n 1 | awk '{print $NF}' | sed 's/\.000000Z/Z/')" + if [[ "$ts" > "$one_hour_ago_ts" ]]; then + echo "$ts > $one_hour_ago_ts, skipping" + continue + fi + + echo uuid=$uuid stream=$stream recording=$recording ts=$ts + + local fps=$(ffprobe -i /tmp/f.mp4 2>&1 | grep -o '[0-9]*\.*[0-9]* fps' | head -n 1 | awk '{print $1}') + local inspection="$(ffmpeg -i /tmp/f.mp4 -vf 'select=not(mod(n\,'${fps%.*}')),select=gte(scene\,0),metadata=print:file=-' -an -f null - 2> /dev/null | paste - -)" + local scores=($(echo "$inspection" | awk '{print $NF}' | sed 's/.*=//')) + + local flattened_scores=() + for i in $(seq 1 ${#scores[@]}); do + flattened_scores+=($(echo ${scores[@]:i-2:3} | tr ' ' '\n' | sort -n | head -n 2 | tail -n 1)) + done + + local threshold=1 + local last_n=(${flattened_scores[@]:0:7}) + for i in $(seq 1 ${#flattened_scores[@]}); do + last_n[$(( (i-1)%7 ))]=${flattened_scores[$((i-1))]} + max_of_last_n=$(echo "${last_n[@]}" | tr ' ' '\n' | sort | tail -n 1) + if [[ "$max_of_last_n" < "$threshold" ]]; then + threshold="$max_of_last_n" + fi + done + threshold="$(echo "$threshold + 0.01" | bc)" + + local max_flattened_score=$(echo "${flattened_scores[@]:5:${#flattened_scores[@]}-10}" | tr ' ' '\n' | sort -n | tail -n 1) + if ! [[ "${max_flattened_score#*.}" > "${threshold#*.}" ]]; then + echo nothing + fi + done + done +} + +api() { + local path="$1" + shift + curl -sS "${CAMS_URL:-https://cams.inhome.blapointe.com}/${path#/}" "$@" +} + +if [ "$0" == "$BASH_SOURCE" ]; then + main "$@" +fi