feat(auth): enhance error handling for token expiration and unauthorized access

README.md

@@ -0,0 +1,73 @@
+# k-tv
+
+Self-hosted linear TV channel orchestration. Turns a personal media library into broadcast-style channels.
+
+## Stack
+
+- **Backend** — Rust (Axum), SQLite/PostgreSQL, Jellyfin
+- **Frontend** — Next.js 16, React 19, TanStack Query, Tailwind v4, shadcn/ui
+
+---
+
+## Docker
+
+Registry: `registry.gabrielkaszewski.dev`
+
+### Build
+
+`NEXT_PUBLIC_API_URL` is baked into the frontend bundle at build time — always pass it explicitly.
+
+```bash
+# Backend
+docker build -t registry.gabrielkaszewski.dev/k-tv-backend:latest ./k-tv-backend
+
+# Frontend — NEXT_PUBLIC_API_URL required
+docker build \
+  --build-arg NEXT_PUBLIC_API_URL=https://tv-api.gabrielkaszewski.dev/api/v1 \
+  -t registry.gabrielkaszewski.dev/k-tv-frontend:latest \
+  ./k-tv-frontend
+```
+
+### Push
+
+```bash
+docker push registry.gabrielkaszewski.dev/k-tv-backend:latest
+docker push registry.gabrielkaszewski.dev/k-tv-frontend:latest
+```
+
+### Build + push (one-liner)
+
+```bash
+docker build -t registry.gabrielkaszewski.dev/k-tv-backend:latest ./k-tv-backend && \
+docker push registry.gabrielkaszewski.dev/k-tv-backend:latest && \
+docker build \
+  --build-arg NEXT_PUBLIC_API_URL=https://tv-api.gabrielkaszewski.dev/api/v1 \
+  -t registry.gabrielkaszewski.dev/k-tv-frontend:latest \
+  ./k-tv-frontend && \
+docker push registry.gabrielkaszewski.dev/k-tv-frontend:latest
+```
+
+### Deploy (on server)
+
+```bash
+docker compose -f compose.yml -f compose.traefik.yml pull
+docker compose -f compose.yml -f compose.traefik.yml up -d
+```
+
+---
+
+## Ports
+
+| Service  | Port |
+|----------|------|
+| Backend  | 3000 |
+| Frontend | 3001 |
+
+## Env vars
+
+| Var | Where | Note |
+|-----|-------|------|
+| `NEXT_PUBLIC_API_URL` | frontend build arg | Baked in at build time — must point to the public backend URL |
+| `API_URL` | frontend runtime env | Server-side only (Next.js API routes). Set in compose. |
+| `DATABASE_URL` | backend | `sqlite:///app/data/k-tv.db` or postgres DSN |
+| `SESSION_SECRET` | backend | Change in production |

k-tv-backend/api/src/routes/channels/mod.rs

@@ -55,6 +55,10 @@ pub(super) fn check_access(
     match mode {
         AccessMode::Public => Ok(()),
         AccessMode::PasswordProtected => {
+            // Owner always has access to their own channel without needing the password
+            if user.map(|u| u.id) == Some(owner_id) {
+                return Ok(());
+            }
             let hash = password_hash.ok_or(ApiError::PasswordRequired)?;
             let supplied = supplied_password.unwrap_or("").trim();
             if supplied.is_empty() {

k-tv-frontend/app/(main)/guide/page.tsx

@@ -3,7 +3,7 @@
 import Link from "next/link";
 import { useQuery } from "@tanstack/react-query";
 import { Tv } from "lucide-react";
-import { api } from "@/lib/api";
+import { api, ApiRequestError } from "@/lib/api";
 import { useChannels } from "@/hooks/use-channels";
 import { useAuthContext } from "@/context/auth-context";
 import type { ChannelResponse, ScheduledSlotResponse } from "@/lib/types";
@@ -43,16 +43,17 @@ function slotLabel(slot: ScheduledSlotResponse) {
 // ---------------------------------------------------------------------------
 
 function ChannelRow({ channel }: { channel: ChannelResponse }) {
-  const { token } = useAuthContext();
+  const { token, isLoaded } = useAuthContext();
 
-  const { data: slots, isError, isPending } = useQuery({
-    queryKey: ["guide-epg", channel.id],
+  const { data: slots, isError, error, isPending, isFetching } = useQuery({
+    queryKey: ["guide-epg", channel.id, token],
     queryFn: () => {
       const now = new Date();
       const from = now.toISOString();
       const until = new Date(now.getTime() + 4 * 60 * 60 * 1000).toISOString();
       return api.schedule.getEpg(channel.id, token ?? "", from, until);
     },
+    enabled: isLoaded,
     refetchInterval: 30_000,
     retry: false,
   });
@@ -117,8 +118,10 @@ function ChannelRow({ channel }: { channel: ChannelResponse }) {
               />
             </div>
           </div>
-        ) : isPending ? (
+        ) : isPending && isFetching ? (
           <p className="text-xs italic text-zinc-600">Loading…</p>
+        ) : isError && error instanceof ApiRequestError && error.status === 401 ? (
+          <p className="text-xs italic text-zinc-600">Sign in to view this channel</p>
         ) : (
           <p className="text-xs italic text-zinc-600">
             {isError || !slots?.length

k-tv-frontend/app/globals.css

@@ -54,7 +54,7 @@
   --card-foreground: oklch(0.145 0 0);
   --popover: oklch(1 0 0);
   --popover-foreground: oklch(0.145 0 0);
-  --primary: oklch(0.205 0 0);
+  --primary: oklch(0.702 0.176 48.5);
   --primary-foreground: oklch(0.985 0 0);
   --secondary: oklch(0.97 0 0);
   --secondary-foreground: oklch(0.205 0 0);
@@ -65,7 +65,7 @@
   --destructive: oklch(0.577 0.245 27.325);
   --border: oklch(0.922 0 0);
   --input: oklch(0.922 0 0);
-  --ring: oklch(0.708 0 0);
+  --ring: oklch(0.702 0.176 48.5);
   --chart-1: oklch(0.809 0.105 251.813);
   --chart-2: oklch(0.623 0.214 259.815);
   --chart-3: oklch(0.546 0.245 262.881);
@@ -74,12 +74,12 @@
   --radius: 0.625rem;
   --sidebar: oklch(0.985 0 0);
   --sidebar-foreground: oklch(0.145 0 0);
-  --sidebar-primary: oklch(0.205 0 0);
+  --sidebar-primary: oklch(0.702 0.176 48.5);
   --sidebar-primary-foreground: oklch(0.985 0 0);
   --sidebar-accent: oklch(0.97 0 0);
   --sidebar-accent-foreground: oklch(0.205 0 0);
   --sidebar-border: oklch(0.922 0 0);
-  --sidebar-ring: oklch(0.708 0 0);
+  --sidebar-ring: oklch(0.702 0.176 48.5);
 }
 
 .dark {
@@ -89,8 +89,8 @@
   --card-foreground: oklch(0.985 0 0);
   --popover: oklch(0.205 0 0);
   --popover-foreground: oklch(0.985 0 0);
-  --primary: oklch(0.922 0 0);
-  --primary-foreground: oklch(0.205 0 0);
+  --primary: oklch(0.702 0.176 48.5);
+  --primary-foreground: oklch(0.985 0 0);
   --secondary: oklch(0.269 0 0);
   --secondary-foreground: oklch(0.985 0 0);
   --muted: oklch(0.269 0 0);
@@ -100,7 +100,7 @@
   --destructive: oklch(0.704 0.191 22.216);
   --border: oklch(1 0 0 / 10%);
   --input: oklch(1 0 0 / 15%);
-  --ring: oklch(0.556 0 0);
+  --ring: oklch(0.702 0.176 48.5);
   --chart-1: oklch(0.809 0.105 251.813);
   --chart-2: oklch(0.623 0.214 259.815);
   --chart-3: oklch(0.546 0.245 262.881);
@@ -108,12 +108,12 @@
   --chart-5: oklch(0.424 0.199 265.638);
   --sidebar: oklch(0.205 0 0);
   --sidebar-foreground: oklch(0.985 0 0);
-  --sidebar-primary: oklch(0.488 0.243 264.376);
+  --sidebar-primary: oklch(0.702 0.176 48.5);
   --sidebar-primary-foreground: oklch(0.985 0 0);
   --sidebar-accent: oklch(0.269 0 0);
   --sidebar-accent-foreground: oklch(0.985 0 0);
   --sidebar-border: oklch(1 0 0 / 10%);
-  --sidebar-ring: oklch(0.556 0 0);
+  --sidebar-ring: oklch(0.702 0.176 48.5);
 }
 
 @layer base {

k-tv-frontend/app/providers.tsx

@@ -14,19 +14,30 @@ import { Toaster } from "@/components/ui/sonner";
 import { ApiRequestError } from "@/lib/api";
 
 function QueryProvider({ children }: { children: React.ReactNode }) {
-  const { setToken } = useAuthContext();
+  const { token, setToken } = useAuthContext();
   const router = useRouter();
 
   const [queryClient] = useState(() => {
-    const on401 = (error: unknown) => {
+    return new QueryClient({
+      queryCache: new QueryCache({
+        onError: (error) => {
+          // Only redirect on 401 if the user had a token (expired session).
+          // Guests hitting 401 on restricted content should not be redirected.
+          if (error instanceof ApiRequestError && error.status === 401 && token) {
+            setToken(null);
+            router.push("/login");
+          }
+        },
+      }),
+      mutationCache: new MutationCache({
+        onError: (error) => {
+          // Mutations always require auth — redirect on 401 regardless.
           if (error instanceof ApiRequestError && error.status === 401) {
             setToken(null);
             router.push("/login");
           }
-    };
-    return new QueryClient({
-      queryCache: new QueryCache({ onError: on401 }),
-      mutationCache: new MutationCache({ onError: on401 }),
+        },
+      }),
       defaultOptions: { queries: { staleTime: 60 * 1000 } },
     });
   });