From 8905095adbcf1d0caca1cc0cb15dd530221e3925 Mon Sep 17 00:00:00 2001
From: mkelvers <mikkelelvers@outlook.com>
Date: Sun, 10 May 2026 18:34:39 +0200
Subject: [PATCH] feat: extract watch progress persistence

---
 static/player/progress.ts | 70 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 70 insertions(+)
 create mode 100644 static/player/progress.ts

diff --git a/static/player/progress.ts b/static/player/progress.ts
new file mode 100644
index 0000000..7e1033a
--- /dev/null
+++ b/static/player/progress.ts
@@ -0,0 +1,70 @@
+import { state } from './state'
+import { displayTimeFromAbsolute } from './timeline'
+
+const buildPayload = (episode: number, seconds: number) => JSON.stringify({
+  mal_id: state.malID,
+  episode,
+  time_seconds: seconds,
+})
+
+const sendBeacon = (payload: string) => {
+  if (!navigator.sendBeacon) return false
+  navigator.sendBeacon('/api/watch-progress', new Blob([payload], { type: 'application/json' }))
+  return true
+}
+
+export const saveProgress = async (): Promise<void> => {
+  if (!state.malID || state.video.currentTime < 1) return
+  const episode = Number.parseInt(state.currentEpisode, 10)
+  if (!episode) return
+
+  const safeTime = displayTimeFromAbsolute(state.video.currentTime)
+  if (state.lastSavedProgress.episode === state.currentEpisode &&
+      Math.abs(state.lastSavedProgress.seconds - safeTime) < 5) return
+
+  const payload = buildPayload(episode, safeTime)
+  try {
+    const res = await fetch('/api/watch-progress', { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: payload })
+    if (!res.ok) return
+    state.lastSavedProgress = { episode: state.currentEpisode, seconds: safeTime }
+  } catch {}
+}
+
+const scheduleProgressSave = (): void => {
+  if (state.progressSaveTimer !== undefined) return
+  state.progressSaveTimer = window.setTimeout(() => {
+    state.progressSaveTimer = undefined
+    saveProgress()
+  }, 30000)
+}
+
+export const markEpisodeTransition = (episodeNumber: number): void => {
+  if (!state.malID || !episodeNumber) return
+  if (state.progressSaveTimer !== undefined) { window.clearTimeout(state.progressSaveTimer); state.progressSaveTimer = undefined }
+  state.transitionEpisode = episodeNumber
+  const payload = buildPayload(episodeNumber, 0)
+  if (!sendBeacon(payload)) {
+    fetch('/api/watch-progress', { method: 'POST', headers: { 'Content-Type': 'application/json' }, keepalive: true, body: payload }).catch(() => {})
+  }
+}
+
+export const setupProgress = (): void => {
+  state.video.addEventListener('timeupdate', () => {
+    scheduleProgressSave()
+  })
+
+  state.video.addEventListener('pause', () => {
+    window.clearTimeout(state.progressSaveTimer)
+    state.progressSaveTimer = undefined
+    saveProgress()
+  })
+
+  window.addEventListener('mouseup', () => { state.isScrubbing = false; saveProgress() })
+
+  window.addEventListener('beforeunload', () => {
+    if (state.transitionEpisode !== null || state.completionSent || !state.malID) return
+    const episode = Number.parseInt(state.currentEpisode, 10)
+    if (!episode) return
+    sendBeacon(buildPayload(episode, displayTimeFromAbsolute(state.video.currentTime)))
+  })
+}