From 91df362af37484197da2ce7101298bbd2879ede9 Mon Sep 17 00:00:00 2001
From: bel <bel@bel.bel>
Date: Sat, 7 Sep 2024 13:42:15 -0600
Subject: [PATCH] stub

---
 .../movement_detection_via_api_ffmpeg.sh      | 122 ++++++++++++++++++
 1 file changed, 122 insertions(+)
 create mode 100644 testdata/sentryshot.d/movement_detection_via_api_ffmpeg.sh

diff --git a/testdata/sentryshot.d/movement_detection_via_api_ffmpeg.sh b/testdata/sentryshot.d/movement_detection_via_api_ffmpeg.sh
new file mode 100644
index 0000000..dba3f80
--- /dev/null
+++ b/testdata/sentryshot.d/movement_detection_via_api_ffmpeg.sh
@@ -0,0 +1,122 @@
+#! /bin/bash
+
+set -eo pipefail
+
+main() {
+   local nonrecent_unix="$(($(_date +%s) - 4 * 60 * 60))" # 4h ago
+   local nonrecent_ts="$(_date -d @$nonrecent_unix -u +%Y-%m-%dT%H:%M:%SZ)"
+
+   for uuid in $(
+      api /api/ | jq -r .cameras[].uuid
+   ); do
+      local stream=main
+      local recordings=($(
+         api /api/cameras/$uuid/$stream/recordings \
+         | jq -c '.recordings[] | [.startId, .growing, .startTime90k]' \
+         | grep -v ,true, \
+         | jq -r .[0] \
+         | sort -n #-r
+      ))
+      for recording in "${recordings[@]}"; do
+         if grep "^$uuid.$recording$" ${MOONFIRE_DIR:-/tmp}/movement_detection_via_api_ffmpeg.sh.txt; then
+            continue
+         fi
+
+         local ts="$(_date -u -d @"$(
+            api "/api/cameras/$uuid/$stream/view.mp4.txt?s=$recording&ts=true" \
+            | grep -A 1 last_modified: \
+            | head -n 2 \
+            | tail -n 1 \
+            | awk '{print $NF}' \
+            | tr -d ','
+         )" +%Y-%m-%dT%H:%M:%SZ )"
+         if [ -z "$ts" ] || [[ "$ts" > "$nonrecent_ts" ]]; then
+            echo "$ts > $nonrecent_ts, so skipping"
+            continue
+         fi
+
+         echo uuid=$uuid stream=$stream recording=$recording ts=$ts
+         api "/api/cameras/$uuid/$stream/view.mp4?s=$recording&ts=true" > /tmp/movement_detection_via_api_ffmpeg.sh.mp4
+
+         local fps=$(_ffprobe -i /tmp/movement_detection_via_api_ffmpeg.sh.mp4 2>&1 | grep -o '[0-9]*\.*[0-9]* fps' | head -n 1 | awk '{print $1}')
+         local inspection="$(_ffmpeg -i /tmp/movement_detection_via_api_ffmpeg.sh.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="$(_perl -e "print $threshold + 0.01")"
+
+         local has_change=false
+         if [ "${#flattened_scores[@]}" -lt 10 ]; then
+            has_change=true
+         else
+            local max_flattened_score=$(echo "${flattened_scores[@]:5:${#flattened_scores[@]}-10}" | tr ' ' '\n' | sort -n | tail -n 1)
+            if [[ "${max_flattened_score#*.}" > "${threshold#*.}" ]]; then
+               has_change=true
+            fi
+         fi
+
+         if $has_change; then
+            echo "$uuid.$recording" >> ${MOONFIRE_DIR:-/tmp}/movement_detection_via_api_ffmpeg.sh.txt
+         else
+            echo no movement in "$recording"
+            api "/api/cameras/$uuid/$stream/view.mp4" \
+               -X DELETE \
+               -H 'Content-Type: application/json' \
+               -d "$(printf '{"runStartId": %s}' "$recording")"
+         fi
+      done
+   done
+}
+
+api() {
+   local path="$1"
+   shift
+   curl -sS "${CAMS_URL:-http://192.168.0.86:29898}/${path#/}" "$@"
+}
+
+_date() {
+   if which gdate &> /dev/null; then
+      gdate "$@"
+   else
+      date "$@"
+   fi
+}
+
+_perl() {
+   if which perl &> /dev/null; then
+      perl "$@"
+   else
+      /var/services/homes/squeaky2x3/.nix-profile/bin/perl "$@"
+   fi
+}
+
+_ffprobe() {
+   if which ffprobe &> /dev/null; then
+      ffprobe "$@"
+   else
+      /volume1/homes/squeaky2x3/ffmpeg-local/ffprobe "$@"
+   fi
+}
+
+_ffmpeg() {
+   if which ffmpeg &> /dev/null; then
+      ffmpeg "$@"
+   else
+      /volume1/homes/squeaky2x3/ffmpeg-local/ffmpeg "$@"
+   fi
+}
+
+main "$@"