feat: async chapter-names AI generation with review & apply

- Add POST /api/admin/text-gen/chapter-names/async backend endpoint: fire-and-forget,
  returns job_id immediately (HTTP 202), runs batch generation in background goroutine,
  persists proposed titles in ai_job payload when done
- Register new route in server.go alongside existing SSE endpoint (backward compat)
- Add SvelteKit proxy at /api/admin/text-gen/chapter-names/async
- Add SvelteKit proxy for GET /api/admin/ai-jobs/[id] (job detail with payload)
- Add Review button on ai-jobs page for done chapter-names jobs; inline panel shows
  editable title table (old to new) with Apply All button that POSTs to chapter-names/apply

.gitea/workflows/release.yaml

@@ -239,6 +239,11 @@ jobs:
           name: ui-build-injected
           path: ui/build
 
+      - name: Allow build/ into Docker context (override .dockerignore)
+        run: |
+          grep -v '^build$' ui/.dockerignore > ui/.dockerignore.tmp
+          mv ui/.dockerignore.tmp ui/.dockerignore
+
       - uses: docker/setup-buildx-action@v3
 
       - name: Log in to Docker Hub

backend/internal/backend/handlers.go

@@ -904,6 +904,115 @@ func (s *Server) handleAudioStream(w http.ResponseWriter, r *http.Request) {
 	// on its next poll as soon as the MinIO object is present.
 }
 
+// handleAudioPreview handles GET /api/audio-preview/{slug}/{n}.
+//
+// CF AI voices are batch-only and can take 1-2+ minutes to generate a full
+// chapter. This endpoint generates only the FIRST chunk of text (~1 800 chars,
+// roughly 1-2 minutes of audio) so the client can start playing immediately
+// while the full audio is generated in the background by the runner.
+//
+// Fast path: if a preview object already exists in MinIO, redirects to its
+// presigned URL (no regeneration).
+//
+// Slow path: generates the first chunk via CF AI, streams the MP3 bytes to the
+// client, and simultaneously uploads to MinIO under a "_preview" key so future
+// requests hit the fast path.
+//
+// Only CF AI voices are expected here. Calling this with a Kokoro/PocketTTS
+// voice falls back to the normal audio-stream endpoint behaviour.
+//
+// Query params:
+//
+//	voice  (required — must be a cfai: voice)
+func (s *Server) handleAudioPreview(w http.ResponseWriter, r *http.Request) {
+	slug := r.PathValue("slug")
+	n, err := strconv.Atoi(r.PathValue("n"))
+	if err != nil || n < 1 {
+		jsonError(w, http.StatusBadRequest, "invalid chapter")
+		return
+	}
+
+	voice := r.URL.Query().Get("voice")
+	if voice == "" {
+		voice = s.cfg.DefaultVoice
+	}
+
+	if s.deps.CFAI == nil {
+		jsonError(w, http.StatusServiceUnavailable, "cloudflare AI TTS not configured")
+		return
+	}
+
+	// Preview key: same as normal key with a "_preview" suffix before the extension.
+	// e.g. slug/1/cfai:luna_preview.mp3
+	previewKey := s.deps.AudioStore.AudioObjectKeyExt(slug, n, voice+"_preview", "mp3")
+
+	// ── Fast path: preview already in MinIO ──────────────────────────────────
+	if s.deps.AudioStore.AudioExists(r.Context(), previewKey) {
+		presignURL, err := s.deps.PresignStore.PresignAudio(r.Context(), previewKey, 1*time.Hour)
+		if err != nil {
+			s.deps.Log.Error("handleAudioPreview: PresignAudio failed", "slug", slug, "n", n, "err", err)
+			jsonError(w, http.StatusInternalServerError, "presign failed")
+			return
+		}
+		http.Redirect(w, r, presignURL, http.StatusFound)
+		return
+	}
+
+	// ── Slow path: generate first chunk + stream + save ──────────────────────
+
+	// Read the chapter text.
+	raw, err := s.deps.BookReader.ReadChapter(r.Context(), slug, n)
+	if err != nil {
+		s.deps.Log.Error("handleAudioPreview: ReadChapter failed", "slug", slug, "n", n, "err", err)
+		jsonError(w, http.StatusNotFound, "chapter not found")
+		return
+	}
+	text := stripMarkdown(raw)
+	if text == "" {
+		jsonError(w, http.StatusUnprocessableEntity, "chapter text is empty")
+		return
+	}
+
+	// Take only the first ~1 800 characters — one CF AI chunk, roughly 1-2 min.
+	const previewChars = 1800
+	firstChunk := text
+	if len([]rune(text)) > previewChars {
+		runes := []rune(text)
+		firstChunk = string(runes[:previewChars])
+		// Walk back to last sentence boundary (. ! ?) to avoid a mid-word cut.
+		for i := previewChars - 1; i > previewChars/2; i-- {
+			r := runes[i]
+			if r == '.' || r == '!' || r == '?' || r == '\n' {
+				firstChunk = string(runes[:i+1])
+				break
+			}
+		}
+	}
+
+	// Generate the preview chunk via CF AI.
+	mp3, err := s.deps.CFAI.GenerateAudio(r.Context(), firstChunk, voice)
+	if err != nil {
+		s.deps.Log.Error("handleAudioPreview: GenerateAudio failed", "slug", slug, "n", n, "voice", voice, "err", err)
+		jsonError(w, http.StatusInternalServerError, "tts generation failed")
+		return
+	}
+
+	// Upload to MinIO in the background so the next request hits the fast path.
+	go func() {
+		if uploadErr := s.deps.AudioStore.PutAudio(
+			context.Background(), previewKey, mp3,
+		); uploadErr != nil {
+			s.deps.Log.Error("handleAudioPreview: MinIO upload failed", "key", previewKey, "err", uploadErr)
+		}
+	}()
+
+	w.Header().Set("Content-Type", "audio/mpeg")
+	w.Header().Set("Content-Length", strconv.Itoa(len(mp3)))
+	w.Header().Set("Cache-Control", "no-store")
+	w.WriteHeader(http.StatusOK)
+	_, _ = w.Write(mp3)
+}
+
 // ── Translation ────────────────────────────────────────────────────────────────
 
 // supportedTranslationLangs is the set of target locales the backend accepts.

backend/internal/backend/handlers_textgen.go

@@ -371,6 +371,215 @@ func parseChapterTitlesJSON(raw string) []rawChapterTitle {
 	return out
 }
 
+// handleAdminTextGenChapterNamesAsync handles POST /api/admin/text-gen/chapter-names/async.
+//
+// Fire-and-forget variant: validates inputs, creates an ai_job record, spawns a
+// background goroutine, and returns HTTP 202 with {job_id} immediately. The
+// goroutine runs all batches, stores the proposed titles in the job payload, and
+// marks the job done/failed/cancelled when finished.
+//
+// The client can poll GET /api/admin/ai-jobs/{id} for progress, then call
+// POST /api/admin/text-gen/chapter-names/apply once the job is "done".
+func (s *Server) handleAdminTextGenChapterNamesAsync(w http.ResponseWriter, r *http.Request) {
+	if s.deps.TextGen == nil {
+		jsonError(w, http.StatusServiceUnavailable, "text generation not configured (CFAI_ACCOUNT_ID/CFAI_API_TOKEN missing)")
+		return
+	}
+
+	var req textGenChapterNamesRequest
+	if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
+		jsonError(w, http.StatusBadRequest, "parse body: "+err.Error())
+		return
+	}
+	if strings.TrimSpace(req.Slug) == "" {
+		jsonError(w, http.StatusBadRequest, "slug is required")
+		return
+	}
+	if strings.TrimSpace(req.Pattern) == "" {
+		jsonError(w, http.StatusBadRequest, "pattern is required")
+		return
+	}
+
+	// Load existing chapter list (use request context — just for validation).
+	allChapters, err := s.deps.BookReader.ListChapters(r.Context(), req.Slug)
+	if err != nil {
+		jsonError(w, http.StatusInternalServerError, "list chapters: "+err.Error())
+		return
+	}
+	if len(allChapters) == 0 {
+		jsonError(w, http.StatusNotFound, fmt.Sprintf("no chapters found for slug %q", req.Slug))
+		return
+	}
+
+	// Apply chapter range filter.
+	chapters := allChapters
+	if req.FromChapter > 0 || req.ToChapter > 0 {
+		filtered := chapters[:0]
+		for _, ch := range allChapters {
+			if req.FromChapter > 0 && ch.Number < req.FromChapter {
+				continue
+			}
+			if req.ToChapter > 0 && ch.Number > req.ToChapter {
+				break
+			}
+			filtered = append(filtered, ch)
+		}
+		chapters = filtered
+	}
+	if len(chapters) == 0 {
+		jsonError(w, http.StatusBadRequest, "no chapters in the specified range")
+		return
+	}
+
+	model := cfai.TextModel(req.Model)
+	if model == "" {
+		model = cfai.DefaultTextModel
+	}
+	maxTokens := req.MaxTokens
+	if maxTokens <= 0 {
+		maxTokens = 4096
+	}
+
+	// Index existing titles for old/new diff.
+	existing := make(map[int]string, len(chapters))
+	for _, ch := range chapters {
+		existing[ch.Number] = ch.Title
+	}
+
+	batches := chunkChapters(chapters, chapterNamesBatchSize)
+	totalBatches := len(batches)
+
+	if s.deps.AIJobStore == nil {
+		jsonError(w, http.StatusServiceUnavailable, "ai job store not configured")
+		return
+	}
+
+	jobPayload := fmt.Sprintf(`{"pattern":%q}`, req.Pattern)
+	jobID, createErr := s.deps.AIJobStore.CreateAIJob(r.Context(), domain.AIJob{
+		Kind:       "chapter-names",
+		Slug:       req.Slug,
+		Status:     domain.TaskStatusPending,
+		FromItem:   req.FromChapter,
+		ToItem:     req.ToChapter,
+		ItemsTotal: len(chapters),
+		Model:      string(model),
+		Payload:    jobPayload,
+		Started:    time.Now(),
+	})
+	if createErr != nil {
+		jsonError(w, http.StatusInternalServerError, "create ai job: "+createErr.Error())
+		return
+	}
+
+	jobCtx, jobCancel := context.WithCancel(context.Background())
+	registerCancelJob(jobID, jobCancel)
+
+	s.deps.Log.Info("admin: text-gen chapter-names async started",
+		"job_id", jobID, "slug", req.Slug,
+		"chapters", len(chapters), "batches", totalBatches, "model", model)
+
+	// Mark running before returning so the UI sees it immediately.
+	_ = s.deps.AIJobStore.UpdateAIJob(r.Context(), jobID, map[string]any{
+		"status": string(domain.TaskStatusRunning),
+	})
+
+	systemPrompt := `You are a chapter title editor for a web novel platform. ` +
+		`The user provides a list of chapter numbers with their current titles, ` +
+		`and a naming pattern template. ` +
+		`Your job: produce one new title for every chapter, following the pattern exactly. ` +
+		`Pattern placeholders: {n} = the chapter number (integer), {scene} = a very short (2–5 word) scene hint derived from the existing title. ` +
+		`RULES: ` +
+		`1. Do NOT include the chapter number inside the title text — the {n} placeholder is already in the pattern. ` +
+		`2. Do NOT include any prefix like "Chapter X -" or "Chapter X:" inside the title field itself. ` +
+		`3. The "title" field in your JSON must be the fully-rendered string (e.g. if pattern is "Chapter {n}: {scene}", output "Chapter 3: The Bet"). ` +
+		`4. Respond ONLY with a raw JSON array — no prose, no markdown fences, no explanation. ` +
+		`5. Each element: {"number": <int>, "title": <string>}. ` +
+		`6. Output every chapter in the input list, in order. Do not skip any.`
+
+	// Capture all locals needed in the goroutine.
+	store := s.deps.AIJobStore
+	textGen := s.deps.TextGen
+	logger := s.deps.Log
+	capturedModel := model
+	capturedMaxTokens := maxTokens
+	capturedPattern := req.Pattern
+	capturedSlug := req.Slug
+
+	go func() {
+		defer deregisterCancelJob(jobID)
+		defer jobCancel()
+
+		var allResults []proposedChapterTitle
+		chaptersDone := 0
+
+		for i, batch := range batches {
+			if jobCtx.Err() != nil {
+				_ = store.UpdateAIJob(context.Background(), jobID, map[string]any{
+					"status":   string(domain.TaskStatusCancelled),
+					"finished": time.Now().Format(time.RFC3339),
+				})
+				return
+			}
+
+			var chapterListSB strings.Builder
+			for _, ch := range batch {
+				chapterListSB.WriteString(fmt.Sprintf("%d: %s\n", ch.Number, ch.Title))
+			}
+			userPrompt := fmt.Sprintf("Naming pattern: %s\n\nChapters:\n%s", capturedPattern, chapterListSB.String())
+
+			raw, genErr := textGen.Generate(jobCtx, cfai.TextRequest{
+				Model: capturedModel,
+				Messages: []cfai.TextMessage{
+					{Role: "system", Content: systemPrompt},
+					{Role: "user", Content: userPrompt},
+				},
+				MaxTokens: capturedMaxTokens,
+			})
+			if genErr != nil {
+				logger.Error("admin: text-gen chapter-names async batch failed",
+					"job_id", jobID, "batch", i+1, "err", genErr)
+				// Continue — skip errored batch rather than aborting.
+				continue
+			}
+
+			proposed := parseChapterTitlesJSON(raw)
+			for _, p := range proposed {
+				allResults = append(allResults, proposedChapterTitle{
+					Number:   p.Number,
+					OldTitle: existing[p.Number],
+					NewTitle: p.Title,
+				})
+			}
+			chaptersDone += len(batch)
+
+			_ = store.UpdateAIJob(context.Background(), jobID, map[string]any{
+				"items_done": chaptersDone,
+			})
+		}
+
+		// Persist results into payload so the UI can load them for review.
+		resultsJSON, _ := json.Marshal(allResults)
+		finalPayload := fmt.Sprintf(`{"pattern":%q,"slug":%q,"results":%s}`,
+			capturedPattern, capturedSlug, string(resultsJSON))
+
+		status := domain.TaskStatusDone
+		if jobCtx.Err() != nil {
+			status = domain.TaskStatusCancelled
+		}
+		_ = store.UpdateAIJob(context.Background(), jobID, map[string]any{
+			"status":     string(status),
+			"items_done": chaptersDone,
+			"finished":   time.Now().Format(time.RFC3339),
+			"payload":    finalPayload,
+		})
+		logger.Info("admin: text-gen chapter-names async done",
+			"job_id", jobID, "slug", capturedSlug,
+			"results", len(allResults), "status", string(status))
+	}()
+
+	writeJSON(w, http.StatusAccepted, map[string]any{"job_id": jobID})
+}
+
 // ── Apply chapter names ───────────────────────────────────────────────────────
 
 // applyChapterNamesRequest is the JSON body for POST /api/admin/text-gen/chapter-names/apply.

backend/internal/backend/server.go

@@ -180,6 +180,9 @@ func (s *Server) ListenAndServe(ctx context.Context) error {
 	// Streaming audio: serves from MinIO if cached, else streams live TTS
 	// while simultaneously uploading to MinIO for future requests.
 	mux.HandleFunc("GET /api/audio-stream/{slug}/{n}", s.handleAudioStream)
+	// CF AI preview: generates only the first ~1 800-char chunk so the client
+	// can start playing immediately while the full audio is generated by the runner.
+	mux.HandleFunc("GET /api/audio-preview/{slug}/{n}", s.handleAudioPreview)
 
 	// Translation task creation (backend creates task; runner executes via LibreTranslate)
 	mux.HandleFunc("POST /api/translation/{slug}/{n}", s.handleTranslationGenerate)
@@ -203,6 +206,7 @@ func (s *Server) ListenAndServe(ctx context.Context) error {
 	// Admin text generation endpoints (chapter names + book description)
 	mux.HandleFunc("GET /api/admin/text-gen/models", s.handleAdminTextGenModels)
 	mux.HandleFunc("POST /api/admin/text-gen/chapter-names", s.handleAdminTextGenChapterNames)
+	mux.HandleFunc("POST /api/admin/text-gen/chapter-names/async", s.handleAdminTextGenChapterNamesAsync)
 	mux.HandleFunc("POST /api/admin/text-gen/chapter-names/apply", s.handleAdminTextGenApplyChapterNames)
 	mux.HandleFunc("POST /api/admin/text-gen/description", s.handleAdminTextGenDescription)
 	mux.HandleFunc("POST /api/admin/text-gen/description/apply", s.handleAdminTextGenApplyDescription)

ui/src/lib/audio.svelte.ts

@@ -62,6 +62,13 @@ class AudioStore {
 	/** Pseudo-progress bar value 0–100 during generation */
 	progress = $state(0);
 
+	/**
+	 * True while playing a short CF AI preview clip (~1-2 min) and the full
+	 * audio is still being generated in the background.  Set to false once the
+	 * full audio URL has been swapped in.
+	 */
+	isPreview = $state(false);
+
 	// ── Playback state (kept in sync with the <audio> element) ─────────────
 	currentTime = $state(0);
 	duration = $state(0);

ui/src/lib/components/AudioPlayer.svelte

@@ -603,13 +603,17 @@
 				return;
 			}
 
-			// CF AI (batch-only) or already enqueued by presign: keep the traditional
-			// POST → poll → presign flow. For enqueued, we skip the POST and poll.
+			// CF AI voices: use preview/swap strategy.
+			// 1. Fetch a short ~1-2 min preview clip from the first text chunk
+			//    so playback starts immediately — no more waiting behind a spinner.
+			// 2. Meanwhile keep polling the full audio job; when it finishes,
+			//    swap the <audio> src to the full URL preserving currentTime.
 			audioStore.status = 'generating';
+			audioStore.isPreview = false;
 			startProgress();
 
-			// presignResult.enqueued=true means /api/presign/audio already POSTed on our
-			// behalf — skip the duplicate POST and go straight to polling.
+			// Kick off the full audio generation task in the background
+			// (presignResult.enqueued=true means the presign endpoint already did it).
 			if (!presignResult.enqueued) {
 				const res = await fetch(`/api/audio/${slug}/${chapter}`, {
 					method: 'POST',
@@ -618,7 +622,6 @@
 				});
 
 				if (res.status === 402) {
-					// Free daily limit reached — surface upgrade CTA
 					audioStore.status = 'idle';
 					stopProgress();
 					onProRequired?.();
@@ -628,37 +631,96 @@
 				if (!res.ok) throw new Error(`Generation failed: HTTP ${res.status}`);
 
 				if (res.status === 200) {
-					// Already cached — body is { status: 'done' }, no url needed.
+					// Already cached — fast path: presign and play directly.
 					await res.body?.cancel();
 					await finishProgress();
 					const doneUrl = await tryPresign(slug, chapter, voice);
 					if (!doneUrl.ready) throw new Error('Audio generated but presign returned 404');
+					audioStore.isPreview = false;
 					audioStore.audioUrl = doneUrl.url;
 					audioStore.status = 'ready';
 					maybeStartPrefetch();
 					return;
 				}
-				// 202: fall through to polling below.
+				// 202 accepted — fall through: start preview while runner generates
 			}
 
-			// Poll until the runner finishes generating.
-			const final = await pollAudioStatus(slug, chapter, voice);
-			if (final.status === 'failed') {
-				throw new Error(
-					`Generation failed: ${(final as { error?: string }).error ?? 'unknown error'}`
-				);
+			// Fetch the preview clip (first ~1-2 min chunk).
+			// Use an AbortController so we can cancel the background polling if the
+			// user navigates away or stops playback before the full audio is ready.
+			const previewAbort = new AbortController();
+			const qs = new URLSearchParams({ voice });
+			const previewUrl = `/api/audio-preview/${slug}/${chapter}?${qs}`;
+
+			try {
+				const previewRes = await fetch(previewUrl, { signal: previewAbort.signal });
+				if (previewRes.status === 402) {
+					audioStore.status = 'idle';
+					stopProgress();
+					onProRequired?.();
+					return;
+				}
+				if (!previewRes.ok) throw new Error(`Preview failed: HTTP ${previewRes.status}`);
+
+				// The backend responded with the MP3 bytes (or a redirect to MinIO).
+				// Build a blob URL so we can swap it out later without reloading the page.
+				const previewBlob = await previewRes.blob();
+				const previewBlobUrl = URL.createObjectURL(previewBlob);
+
+				audioStore.isPreview = true;
+				audioStore.audioUrl = previewBlobUrl;
+				audioStore.status = 'ready';
+				// Don't restore saved time here — preview is always from 0.
+				// Kick off prefetch of next chapter in the background.
+				maybeStartPrefetch();
+			} catch (previewErr: unknown) {
+				if (previewErr instanceof DOMException && previewErr.name === 'AbortError') return;
+				// Preview failed — fall through to the spinner (old behaviour).
+				// We'll wait for the full audio to finish instead.
+				audioStore.isPreview = false;
 			}
 
-			await finishProgress();
+			// Background: poll for full audio; when done, swap src preserving position.
+			try {
+				const final = await pollAudioStatus(slug, chapter, voice, 2000, previewAbort.signal);
+				if (final.status === 'failed') {
+					throw new Error(
+						`Generation failed: ${(final as { error?: string }).error ?? 'unknown error'}`
+					);
+				}
 
-			// Audio is ready in MinIO — always use a presigned URL for direct playback.
-			const doneUrl = await tryPresign(slug, chapter, voice);
-			if (!doneUrl.ready) throw new Error('Audio generated but presign returned 404');
-			audioStore.audioUrl = doneUrl.url;
-			audioStore.status = 'ready';
-			// Don't restore time for freshly generated audio — position is 0
-			// Immediately start pre-generating the next chapter in background.
-			maybeStartPrefetch();
+				await finishProgress();
+
+				const doneUrl = await tryPresign(slug, chapter, voice);
+				if (!doneUrl.ready) throw new Error('Audio generated but presign returned 404');
+
+				// Swap: save currentTime → update URL → seek to saved position.
+				const savedTime = audioStore.currentTime;
+				const blobUrlToRevoke = audioStore.audioUrl; // capture before overwrite
+				audioStore.isPreview = false;
+				audioStore.audioUrl = doneUrl.url;
+				// If we never started a preview (preview fetch failed), switch to ready now.
+				if (audioStore.status !== 'ready') audioStore.status = 'ready';
+				// The layout $effect will load the new src and auto-play from 0.
+				// We seek back to savedTime after a short delay to let the element
+				// attach the new source before accepting a seek.
+				if (savedTime > 0) {
+					setTimeout(() => {
+						audioStore.seekRequest = savedTime;
+					}, 300);
+				}
+				// Revoke the preview blob URL to free memory.
+				// (We need to wait until the new src is playing; 2 s is safe.)
+				setTimeout(() => {
+					if (blobUrlToRevoke.startsWith('blob:')) {
+						URL.revokeObjectURL(blobUrlToRevoke);
+					}
+				}, 2000);
+				maybeStartPrefetch();
+			} catch (pollErr: unknown) {
+				if (pollErr instanceof DOMException && pollErr.name === 'AbortError') return;
+				throw pollErr;
+			}
 		} catch (e) {
 			stopProgress();
 			audioStore.progress = 0;

ui/src/lib/server/cache.ts

@@ -20,7 +20,8 @@ function client(): Redis {
 		_client = new Redis(url, {
 			lazyConnect: false,
 			enableOfflineQueue: true,
-			maxRetriesPerRequest: 2
+			maxRetriesPerRequest: 1,
+			connectTimeout: 1500
 		});
 		_client.on('error', (err: Error) => {
 			console.error('[cache] Valkey error:', err.message);

ui/src/lib/server/pocketbase.ts

@@ -100,8 +100,8 @@ export interface User {
 let _token = '';
 let _tokenExp = 0;
 
-async function getToken(): Promise<string> {
-	if (_token && Date.now() < _tokenExp) return _token;
+async function getToken(forceRefresh = false): Promise<string> {
+	if (!forceRefresh && _token && Date.now() < _tokenExp) return _token;
 
 	log.debug('pocketbase', 'authenticating with admin credentials', { url: PB_URL, email: PB_EMAIL });
 
@@ -119,7 +119,9 @@ async function getToken(): Promise<string> {
 
 	const data = await res.json();
 	_token = data.token as string;
-	_tokenExp = Date.now() + 12 * 60 * 60 * 1000; // 12 hours
+	// PocketBase superuser tokens expire in ~1 hour by default.
+	// Cache for 50 minutes to stay safely within that window.
+	_tokenExp = Date.now() + 50 * 60 * 1000;
 	log.info('pocketbase', 'admin auth token refreshed', { url: PB_URL });
 	return _token;
 }
@@ -132,6 +134,18 @@ async function pbGet<T>(path: string): Promise<T> {
 		headers: { Authorization: `Bearer ${token}` }
 	});
 	if (!res.ok) {
+		// On 401/403, the token may have expired on the PocketBase side even if
+		// our local TTL hasn't fired yet. Force a refresh and retry once.
+		if (res.status === 401 || res.status === 403) {
+			const freshToken = await getToken(true);
+			const retry = await fetch(`${PB_URL}${path}`, {
+				headers: { Authorization: `Bearer ${freshToken}` }
+			});
+			if (retry.ok) return retry.json() as Promise<T>;
+			const retryBody = await retry.text().catch(() => '');
+			log.error('pocketbase', 'GET failed', { path, status: retry.status, body: retryBody });
+			throw new Error(`PocketBase GET ${path} failed: ${retry.status} — ${retryBody}`);
+		}
 		const body = await res.text().catch(() => '');
 		log.error('pocketbase', 'GET failed', { path, status: res.status, body });
 		throw new Error(`PocketBase GET ${path} failed: ${res.status} — ${body}`);

ui/src/routes/+layout.svelte

@@ -37,6 +37,10 @@
 	let activeChapterEl = $state<HTMLElement | null>(null);
 	let listeningModeOpen = $state(false);
 
+	// Build time formatted in the user's local timezone (populated on mount so
+	// SSR and CSR don't produce a mismatch — SSR renders nothing, hydration fills it in).
+	let buildTimeLocal = $state('');
+
 	function setIfActive(node: HTMLElement, isActive: boolean) {
 		if (isActive) activeChapterEl = node;
 		return {
@@ -51,6 +55,12 @@
 		}
 	});
 
+	$effect(() => {
+		if (env.PUBLIC_BUILD_TIME && env.PUBLIC_BUILD_TIME !== 'unknown') {
+			buildTimeLocal = new Date(env.PUBLIC_BUILD_TIME).toLocaleString();
+		}
+	});
+
 	// The single <audio> element that persists across navigations.
 	// AudioPlayer components in chapter pages control it via audioStore.
 	let audioEl = $state<HTMLAudioElement | null>(null);
@@ -750,10 +760,9 @@
 		</div>
 		<!-- Build version / commit SHA / build time -->
 		{#snippet buildTime()}
-			{#if env.PUBLIC_BUILD_TIME && env.PUBLIC_BUILD_TIME !== 'unknown'}
-				{@const d = new Date(env.PUBLIC_BUILD_TIME)}
+			{#if buildTimeLocal}
 				<span class="text-(--color-muted)" title="Build time">
-					· {d.toUTCString().replace(' GMT', ' UTC').replace(/:\d\d /, ' ')}
+					· {buildTimeLocal}
 				</span>
 			{/if}
 		{/snippet}
@@ -857,19 +866,16 @@
 				aria-label={audioStore.chapters.length > 0 ? m.player_toggle_chapter_list() : undefined}
 				title={audioStore.chapters.length > 0 ? m.player_chapter_list_label() : undefined}
 			>
-				{#if audioStore.chapterTitle}
-					<p class="text-xs text-(--color-text) truncate leading-tight">{audioStore.chapterTitle}</p>
-				{/if}
-				{#if audioStore.bookTitle}
-					<p class="text-xs text-(--color-muted) truncate leading-tight">{audioStore.bookTitle}</p>
-				{/if}
 				{#if audioStore.status === 'generating'}
 					<p class="text-xs text-(--color-brand) leading-tight">
 						{m.player_generating({ percent: String(Math.round(audioStore.progress)) })}
 					</p>
 				{:else if audioStore.status === 'ready'}
-					<p class="text-xs text-(--color-muted) tabular-nums leading-tight">
+					<p class="text-xs text-(--color-muted) tabular-nums leading-tight flex items-center gap-1.5">
 						{formatTime(audioStore.currentTime)} / {formatTime(audioStore.duration)}
+						{#if audioStore.isPreview}
+							<span class="px-1 py-0.5 rounded text-[10px] font-medium bg-(--color-brand)/15 text-(--color-brand) leading-none">preview</span>
+						{/if}
 					</p>
 				{:else if audioStore.status === 'loading'}
 					<p class="text-xs text-(--color-muted) leading-tight">{m.player_loading()}</p>
@@ -922,46 +928,6 @@
 					</svg>
 				</Button>
 
-				<!-- Speed control — fixed-width pill, kept as raw button -->
-				<button
-					onclick={cycleSpeed}
-					class="text-xs font-semibold text-(--color-text) hover:text-(--color-brand) transition-colors px-2 py-1 rounded bg-(--color-surface-2) hover:bg-(--color-surface-3) flex-shrink-0 tabular-nums w-12 text-center"
-					title={m.player_change_speed()}
-					aria-label={m.player_speed_label({ speed: String(audioStore.speed) })}
-				>
-					{audioStore.speed}×
-				</button>
-
-			<!-- Auto-next toggle — has absolute-positioned status dots, kept as raw button -->
-			<button
-				onclick={() => (audioStore.autoNext = !audioStore.autoNext)}
-				class={cn(
-					'relative p-1.5 rounded flex-shrink-0 transition-colors',
-					audioStore.autoNext
-						? 'text-(--color-brand) bg-(--color-brand)/15 hover:bg-(--color-brand)/25'
-						: 'text-(--color-muted) hover:text-(--color-text) hover:bg-(--color-surface-2)'
-				)}
-				title={audioStore.autoNext
-					? audioStore.nextStatus === 'prefetched'
-						? m.player_auto_next_ready({ n: String(audioStore.nextChapter) })
-						: audioStore.nextStatus === 'prefetching'
-							? m.player_auto_next_preparing({ n: String(audioStore.nextChapter) })
-							: m.player_auto_next_on()
-					: m.player_auto_next_off()}
-				aria-label={m.player_auto_next_aria({ state: audioStore.autoNext ? m.common_on() : m.common_off() })}
-				aria-pressed={audioStore.autoNext}
-			>
-				<!-- "skip to end" / auto-advance icon -->
-				<svg class="w-4 h-4" fill="currentColor" viewBox="0 0 24 24">
-					<path d="M6 18l8.5-6L6 6v12zm8.5-6L23 6v12l-8.5-6z"/>
-				</svg>
-				<!-- Prefetch status dot -->
-				{#if audioStore.autoNext && audioStore.nextStatus === 'prefetching'}
-					<span class="absolute top-0.5 right-0.5 w-1.5 h-1.5 rounded-full bg-(--color-brand) animate-pulse"></span>
-				{:else if audioStore.autoNext && audioStore.nextStatus === 'prefetched'}
-					<span class="absolute top-0.5 right-0.5 w-1.5 h-1.5 rounded-full bg-green-400"></span>
-				{/if}
-			</button>
 			{:else if audioStore.status === 'generating'}
 				<!-- Spinner during generation -->
 				<svg class="w-6 h-6 text-(--color-brand) animate-spin flex-shrink-0" fill="none" viewBox="0 0 24 24">

ui/src/routes/admin/ai-jobs/+page.svelte

@@ -77,6 +77,92 @@
 		}
 	}
 
+	// ── Review & Apply (chapter-names jobs) ──────────────────────────────────────
+
+	interface ProposedTitle {
+		number: number;
+		old_title: string;
+		new_title: string;
+	}
+
+	interface ReviewState {
+		jobId: string;
+		slug: string;
+		pattern: string;
+		titles: ProposedTitle[];
+		loading: boolean;
+		error: string;
+		applying: boolean;
+		applyError: string;
+		applyDone: boolean;
+	}
+
+	let review = $state<ReviewState | null>(null);
+
+	async function openReview(job: AIJob) {
+		review = {
+			jobId: job.id,
+			slug: job.slug,
+			pattern: '',
+			titles: [],
+			loading: true,
+			error: '',
+			applying: false,
+			applyError: '',
+			applyDone: false
+		};
+
+		try {
+			const res = await fetch(`/api/admin/ai-jobs/${job.id}`);
+			if (!res.ok) throw new Error(`HTTP ${res.status}`);
+			const data = await res.json();
+
+			let payload: { pattern?: string; slug?: string; results?: ProposedTitle[] } = {};
+			try {
+				payload = JSON.parse(data.payload ?? '{}');
+			} catch {
+				// ignore
+			}
+
+			review.pattern = payload.pattern ?? '';
+			review.titles = (payload.results ?? []).map((t: ProposedTitle) => ({ ...t }));
+			review.loading = false;
+		} catch (e) {
+			review.loading = false;
+			review.error = String(e);
+		}
+	}
+
+	function closeReview() {
+		review = null;
+	}
+
+	async function applyReview() {
+		if (!review || review.applying) return;
+		review.applying = true;
+		review.applyError = '';
+		review.applyDone = false;
+
+		const chapters = review.titles.map((t) => ({ number: t.number, title: t.new_title }));
+		try {
+			const res = await fetch('/api/admin/text-gen/chapter-names/apply', {
+				method: 'POST',
+				headers: { 'content-type': 'application/json' },
+				body: JSON.stringify({ slug: review.slug, chapters })
+			});
+			if (!res.ok) {
+				const body = await res.json().catch(() => ({}));
+				review.applyError = body.error ?? `Error ${res.status}`;
+			} else {
+				review.applyDone = true;
+			}
+		} catch {
+			review.applyError = 'Network error.';
+		} finally {
+			review.applying = false;
+		}
+	}
+
 	// ── Helpers ───────────────────────────────────────────────────────────────────
 	function statusColor(status: string) {
 		if (status === 'done') return 'text-green-400';
@@ -304,6 +390,14 @@
 											{cancellingId === job.id ? 'Cancelling…' : 'Cancel'}
 										</button>
 									{/if}
+									{#if job.kind === 'chapter-names' && job.status === 'done'}
+										<button
+											onclick={() => openReview(job)}
+											class="px-2 py-1 rounded text-xs font-medium bg-green-400/10 text-green-400 hover:bg-green-400/20 transition-colors"
+										>
+											Review
+										</button>
+									{/if}
 									{#if job.error_message}
 										<span
 											class="text-xs text-(--color-danger) max-w-[12rem] truncate"
@@ -324,3 +418,112 @@
 		</p>
 	{/if}
 </div>
+
+<!-- ── Review & Apply panel ──────────────────────────────────────────────────── -->
+{#if review}
+	<!-- Backdrop -->
+	<div
+		class="fixed inset-0 z-40 bg-black/60 backdrop-blur-sm"
+		onclick={closeReview}
+		role="presentation"
+	></div>
+
+	<!-- Panel -->
+	<div class="fixed inset-x-0 bottom-0 z-50 max-h-[85vh] overflow-hidden flex flex-col rounded-t-2xl bg-(--color-surface) border-t border-(--color-border) shadow-2xl sm:inset-auto sm:top-1/2 sm:left-1/2 sm:-translate-x-1/2 sm:-translate-y-1/2 sm:w-[min(900px,95vw)] sm:max-h-[85vh] sm:rounded-xl sm:border sm:shadow-2xl">
+		<!-- Panel header -->
+		<div class="flex items-center justify-between gap-4 px-5 py-4 border-b border-(--color-border) shrink-0">
+			<div>
+				<h2 class="text-base font-semibold text-(--color-text)">Review Chapter Names</h2>
+				<p class="text-xs text-(--color-muted) mt-0.5">
+					<span class="font-mono">{review.slug}</span>
+					{#if review.pattern}
+						· pattern: <span class="font-mono">{review.pattern}</span>
+					{/if}
+				</p>
+			</div>
+			<button
+				onclick={closeReview}
+				class="p-1.5 rounded-md text-(--color-muted) hover:text-(--color-text) hover:bg-(--color-surface-2) transition-colors"
+				aria-label="Close"
+			>
+				<svg class="w-4 h-4" fill="none" stroke="currentColor" viewBox="0 0 24 24">
+					<path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M6 18L18 6M6 6l12 12" />
+				</svg>
+			</button>
+		</div>
+
+		<!-- Body -->
+		<div class="flex-1 overflow-y-auto">
+			{#if review.loading}
+				<div class="flex items-center justify-center py-16 text-(--color-muted) text-sm">
+					Loading results…
+				</div>
+			{:else if review.error}
+				<div class="px-5 py-8 text-center">
+					<p class="text-(--color-danger) text-sm">{review.error}</p>
+				</div>
+			{:else if review.titles.length === 0}
+				<div class="px-5 py-8 text-center">
+					<p class="text-(--color-muted) text-sm">No results found in this job's payload.</p>
+				</div>
+			{:else}
+				<table class="w-full text-sm">
+					<thead class="sticky top-0 bg-(--color-surface) border-b border-(--color-border)">
+						<tr>
+							<th class="px-4 py-2.5 text-left text-xs font-semibold text-(--color-muted) uppercase tracking-wider w-16">#</th>
+							<th class="px-4 py-2.5 text-left text-xs font-semibold text-(--color-muted) uppercase tracking-wider w-1/2">Old Title</th>
+							<th class="px-4 py-2.5 text-left text-xs font-semibold text-(--color-muted) uppercase tracking-wider">New Title (editable)</th>
+						</tr>
+					</thead>
+					<tbody class="divide-y divide-(--color-border)">
+						{#each review.titles as title (title.number)}
+							<tr class="bg-(--color-surface) hover:bg-(--color-surface-2)/40 transition-colors">
+								<td class="px-4 py-2 text-xs text-(--color-muted) tabular-nums">{title.number}</td>
+								<td class="px-4 py-2 text-xs text-(--color-muted) max-w-0">
+									<span class="block truncate" title={title.old_title}>{title.old_title || '—'}</span>
+								</td>
+								<td class="px-4 py-2">
+									<input
+										type="text"
+										bind:value={title.new_title}
+										class="w-full px-2 py-1 rounded bg-(--color-surface-2) border border-(--color-border) text-xs text-(--color-text) focus:outline-none focus:ring-1 focus:ring-(--color-brand)"
+									/>
+								</td>
+							</tr>
+						{/each}
+					</tbody>
+				</table>
+			{/if}
+		</div>
+
+		<!-- Footer -->
+		{#if !review.loading && !review.error && review.titles.length > 0}
+			<div class="px-5 py-4 border-t border-(--color-border) shrink-0 flex items-center justify-between gap-4">
+				<div class="text-xs text-(--color-muted)">
+					{review.titles.length} chapters
+				</div>
+				<div class="flex items-center gap-3">
+					{#if review.applyError}
+						<p class="text-xs text-(--color-danger)">{review.applyError}</p>
+					{/if}
+					{#if review.applyDone}
+						<p class="text-xs text-green-400">Applied successfully.</p>
+					{/if}
+					<button
+						onclick={closeReview}
+						class="px-3 py-1.5 rounded-md text-sm text-(--color-muted) hover:text-(--color-text) hover:bg-(--color-surface-2) transition-colors"
+					>
+						Close
+					</button>
+					<button
+						onclick={applyReview}
+						disabled={review.applying || review.applyDone}
+						class="px-4 py-1.5 rounded-md text-sm font-medium bg-(--color-brand) text-black hover:bg-amber-300 disabled:opacity-50 transition-colors"
+					>
+						{review.applying ? 'Applying…' : review.applyDone ? 'Applied' : 'Apply All'}
+					</button>
+				</div>
+			</div>
+		{/if}
+	</div>
+{/if}

ui/src/routes/api/admin/ai-jobs/[id]/+server.ts

@@ -0,0 +1,31 @@
+/**
+ * GET /api/admin/ai-jobs/[id]
+ *
+ * Admin-only proxy to the Go backend's AI job detail endpoint.
+ * Returns the full job record including the payload field (which contains
+ * results for completed chapter-names jobs).
+ */
+
+import { json, error } from '@sveltejs/kit';
+import type { RequestHandler } from './$types';
+import { log } from '$lib/server/logger';
+import { backendFetch } from '$lib/server/scraper';
+
+export const GET: RequestHandler = async ({ params, locals }) => {
+	if (!locals.user || locals.user.role !== 'admin') {
+		throw error(403, 'Forbidden');
+	}
+
+	const { id } = params;
+
+	let res: Response;
+	try {
+		res = await backendFetch(`/api/admin/ai-jobs/${id}`, { method: 'GET' });
+	} catch (e) {
+		log.error('admin/ai-jobs/get', 'backend proxy error', { id, err: String(e) });
+		throw error(502, 'Could not reach backend');
+	}
+
+	const data = await res.json().catch(() => ({}));
+	return json(data, { status: res.status });
+};

ui/src/routes/api/admin/text-gen/chapter-names/async/+server.ts

@@ -0,0 +1,35 @@
+/**
+ * POST /api/admin/text-gen/chapter-names/async
+ *
+ * Fire-and-forget variant: forwards to the Go backend's async endpoint and
+ * returns {job_id} immediately (HTTP 202). The backend runs generation in the
+ * background; the client polls GET /api/admin/ai-jobs/{id} for progress and
+ * then reviews/applies via POST /api/admin/text-gen/chapter-names/apply.
+ */
+
+import { json, error } from '@sveltejs/kit';
+import type { RequestHandler } from './$types';
+import { log } from '$lib/server/logger';
+import { backendFetch } from '$lib/server/scraper';
+
+export const POST: RequestHandler = async ({ request, locals }) => {
+	if (!locals.user || locals.user.role !== 'admin') {
+		throw error(403, 'Forbidden');
+	}
+
+	const body = await request.text();
+	let res: Response;
+	try {
+		res = await backendFetch('/api/admin/text-gen/chapter-names/async', {
+			method: 'POST',
+			headers: { 'content-type': 'application/json' },
+			body
+		});
+	} catch (e) {
+		log.error('admin/text-gen/chapter-names/async', 'backend proxy error', { err: String(e) });
+		throw error(502, 'Could not reach backend');
+	}
+
+	const data = await res.json().catch(() => ({}));
+	return json(data, { status: res.status });
+};

ui/src/routes/api/export/[slug]/+server.ts

@@ -2,7 +2,11 @@ import { error } from '@sveltejs/kit';
 import type { RequestHandler } from './$types';
 import { backendFetch } from '$lib/server/scraper';
 
-export const GET: RequestHandler = async ({ params, url }) => {
+export const GET: RequestHandler = async ({ params, url, locals }) => {
+	if (!locals.isPro) {
+		error(403, 'EPUB download requires a Pro subscription');
+	}
+
 	const { slug } = params;
 	const from = url.searchParams.get('from');
 	const to = url.searchParams.get('to');

ui/src/routes/books/[slug]/+page.server.ts

@@ -64,8 +64,9 @@ export const load: PageServerLoad = async ({ params, locals }) => {
 				lastChapter: null,
 				userRating: 0,
 				ratingAvg: { avg: 0, count: 0 },
-				isAdmin: locals.user?.role === 'admin',
-				isLoggedIn: !!locals.user,
+		isAdmin: locals.user?.role === 'admin',
+		isPro: locals.isPro,
+		isLoggedIn: !!locals.user,
 				currentUserId: locals.user?.id ?? '',
 				scraping: true,
 				taskId: body.task_id

ui/src/routes/books/[slug]/+page.svelte

@@ -326,7 +326,7 @@
 	let chapNamesPreview = $state<{ number: number; old_title: string; new_title: string; edited: string }[]>([]);
 	let chapNamesApplying = $state(false);
 	let chapNamesResult = $state<'applied' | 'error' | ''>('');
-	let chapNamesPattern = $state('Chapter {n}: {scene}');
+	let chapNamesPattern = $state('{scene}');
 	let chapNamesBatchProgress = $state('');
 	let chapNamesBatchWarnings = $state<string[]>([]);
 
@@ -342,7 +342,7 @@
 			const res = await fetch('/api/admin/text-gen/chapter-names', {
 				method: 'POST',
 				headers: { 'Content-Type': 'application/json' },
-				body: JSON.stringify({ slug, pattern: chapNamesPattern.trim() || 'Chapter {n}: {scene}' })
+				body: JSON.stringify({ slug, pattern: chapNamesPattern.trim() || '{scene}' })
 			});
 			if (!res.ok) {
 				chapNamesResult = 'error';
@@ -835,13 +835,22 @@
 		<p class="text-sm font-medium text-(--color-text)">Download</p>
 		<p class="text-xs text-(--color-muted)">All {chapterList.length} chapters as EPUB</p>
 	</div>
-	<a
-		href="/api/export/{book.slug}"
-		download="{book.slug}.epub"
-		class="px-3 py-1.5 rounded-lg bg-(--color-surface-2) border border-(--color-border) text-sm font-medium text-(--color-muted) hover:text-(--color-text) hover:border-zinc-500 transition-colors flex-shrink-0"
-	>
-		.epub
-	</a>
+	{#if data.isPro}
+		<a
+			href="/api/export/{book.slug}"
+			download="{book.slug}.epub"
+			class="px-3 py-1.5 rounded-lg bg-(--color-surface-2) border border-(--color-border) text-sm font-medium text-(--color-muted) hover:text-(--color-text) hover:border-zinc-500 transition-colors flex-shrink-0"
+		>
+			.epub
+		</a>
+	{:else}
+		<a
+			href="/profile"
+			class="px-3 py-1.5 rounded-lg bg-(--color-brand)/15 border border-(--color-brand)/30 text-sm font-medium text-(--color-brand) hover:bg-(--color-brand)/25 transition-colors flex-shrink-0"
+		>
+			Pro
+		</a>
+	{/if}
 </div>
 {/if}
 
@@ -1135,7 +1144,7 @@
 					<input
 						type="text"
 						bind:value={chapNamesPattern}
-						placeholder="Chapter {'{n}'}: {'{scene}'}"
+						placeholder="{'{scene}'}"
 						class="w-full px-2 py-1.5 rounded bg-(--color-surface-3) border border-(--color-border) text-(--color-text) text-xs focus:outline-none focus:border-(--color-brand)"
 					/>
 					<div class="flex items-center gap-3 flex-wrap">

ui/src/routes/books/[slug]/chapters/[n]/+page.svelte

@@ -471,18 +471,28 @@
 			</button>
 			{#if audioExpanded}
 				<div class="border border-t-0 border-(--color-border) rounded-b-lg overflow-hidden">
-					<AudioPlayer
-						slug={data.book.slug}
-						chapter={data.chapter.number}
-						chapterTitle={data.chapter.title || m.reader_chapter_n({ n: String(data.chapter.number) })}
-						bookTitle={data.book.title}
-						cover={data.book.cover}
-						nextChapter={data.next}
-						chapters={data.chapters}
-						voices={data.voices}
-						playerStyle={layout.playerStyle}
-						onProRequired={() => { audioProRequired = true; }}
-					/>
+					{#if audioStore.slug === data.book.slug && audioStore.chapter === data.chapter.number && audioStore.active}
+						<!-- Mini-player is already playing this chapter — don't duplicate controls -->
+						<div class="px-4 py-3 flex items-center gap-2 text-sm text-(--color-muted)">
+							<svg class="w-4 h-4 text-(--color-brand) shrink-0" fill="currentColor" viewBox="0 0 24 24">
+								<path d="M12 3v10.55A4 4 0 1014 17V7h4V3h-6z"/>
+							</svg>
+							<span>Controls are in the player bar below.</span>
+						</div>
+					{:else}
+						<AudioPlayer
+							slug={data.book.slug}
+							chapter={data.chapter.number}
+							chapterTitle={data.chapter.title || m.reader_chapter_n({ n: String(data.chapter.number) })}
+							bookTitle={data.book.title}
+							cover={data.book.cover}
+							nextChapter={data.next}
+							chapters={data.chapters}
+							voices={data.voices}
+							playerStyle={layout.playerStyle}
+							onProRequired={() => { audioProRequired = true; }}
+						/>
+					{/if}
 				</div>
 			{/if}
 		</div>