From 5b6ca6b5348b995eff18af641df99f4dbeaeaeac Mon Sep 17 00:00:00 2001
From: bel <bel@bel.bel>
Date: Tue, 3 Sep 2024 14:01:58 -0600
Subject: [PATCH] on hold because i destroyed db oops

---
 .../movement_detection_via_api_ffmpeg.sh      | 101 ++++++++++++------
 1 file changed, 71 insertions(+), 30 deletions(-)

diff --git a/testdata/moonfire-nvr/movement_detection_via_api_ffmpeg.sh b/testdata/moonfire-nvr/movement_detection_via_api_ffmpeg.sh
index a3c19ac..782ac7a 100644
--- a/testdata/moonfire-nvr/movement_detection_via_api_ffmpeg.sh
+++ b/testdata/moonfire-nvr/movement_detection_via_api_ffmpeg.sh
@@ -1,61 +1,94 @@
 #! /bin/bash
 
 main() {
-   local nonrecent_unix="$(($(date +%s) - 15 * 60))"
-   local nonrecent_ts="$(date -d @$nonrecent_unix -u +%Y-%m-%dT%H:%M:%SZ)"
+   local nonrecent_unix="$(($(_date +%s) - 24 * 60 * 60))" # 1d 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
-      for recording in $(
-         api /api/cameras/$uuid/$stream/recordings \
+      local streams=(main sub)
+      local recordings=($(
+         api /api/cameras/$uuid/$streams/recordings \
          | jq -c '.recordings[] | [.startId, .growing, .startTime90k]' \
          | grep -v ,true, \
          | jq -r .[0] \
          | sort -n #-r
-      ); do
-         local ts="$(date -u -d @"$(
-            api "/api/cameras/$uuid/$stream/view.mp4.txt?s=$recording&ts=true" \
+      ))
+      for recording_idx in $(seq 1 ${#recordings[@]}); do
+         local recording=${recordings[recording_idx-1]}
+         if grep "^$uuid.$recording$" /tmp/movement_detection_via_api_ffmpeg.sh.txt; then
+            continue
+         fi
+
+         local ts="$(_date -u -d @"$(
+            api "/api/cameras/$uuid/$streams/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 [[ "$ts" > "$nonrecent_ts" ]]; then
+         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/f.mp4
+         echo uuid=$uuid stream=$streams recording=$recording ts=$ts
+         api "/api/cameras/$uuid/$streams/view.mp4?s=$recording&ts=true" > /tmp/movement_detection_via_api_ffmpeg.sh.mp4
 
-         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 has_change=false
+         local cksum="$(cksum /tmp/movement_detection_via_api_ffmpeg.sh.mp4)"
+         if grep "^$cksum$" /tmp/movement_detection_via_api_ffmpeg.sh.txt; then
+            has_change=true
+         fi
 
-         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
+         if ! $has_change; then
+            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 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"
+            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
+               has_change=true
             fi
-         done
-         threshold="$(echo "$threshold + 0.01" | bc)"
+         fi
 
-         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
+         if $has_change; then
+            echo "$uuid.$recording" >> /tmp/movement_detection_via_api_ffmpeg.sh.txt
+            echo "$cksum" >> /tmp/movement_detection_via_api_ffmpeg.sh.txt
+         else
+            local next_recording=$(( ${recordings[recording_idx]} - 1 ))
+            local span="$recording"
+            if [ "$recording" != "$next_recording" ]; then
+               span="$recording-$next_recording"
+            fi
+            echo no movement in "$span"
+            for stream in ${streams[@]}; do
+               api "/api/cameras/$uuid/$stream/view.mp4" \
+                  -X DELETE \
+                  -H 'Content-Type: application/json' \
+                  -d "$(printf '{"s": "%s"}' "$span")"
+            done
          fi
       done
+      break
    done
 }
 
@@ -65,6 +98,14 @@ api() {
    curl -sS "${CAMS_URL:-https://cams.inhome.blapointe.com}/${path#/}" "$@"
 }
 
+_date() {
+   if which gdate &> /dev/null; then
+      gdate "$@"
+   else
+      date "$@"
+   fi
+}
+
 if [ "$0" == "$BASH_SOURCE" ]; then
    main "$@"
 fi